Package io.deephaven.extensions.barrage.util

Interface StreamReaderOptions

All Known Implementing Classes:
BarrageSnapshotOptions, BarrageSubscriptionOptions
public interface StreamReaderOptions

  • Method Details

    • useDeephavenNulls

      boolean useDeephavenNulls()
      Returns:
      whether we encode the validity buffer to express null values or QueryConstants's NULL values.

    • columnConversionMode

      ColumnConversionMode columnConversionMode()
      Returns:
      the conversion mode to use for object columns

    • batchSize

      int batchSize()
      Returns:
      the ideal number of records to send per record batch

    • maxMessageSize

      int maxMessageSize()
      Returns:
      the maximum number of bytes that should be sent in a single message.

    • columnsAsList

      default boolean columnsAsList()
      Some Flight clients cannot handle modifications that have irregular column counts. These clients request that the server wrap all columns in a list to enable each column having a variable length.
      Returns:
      true if the columns should be wrapped in a list