Package org.apache.ignite.table

Class DataStreamerOptions

java.lang.Object
org.apache.ignite.table.DataStreamerOptions
public class DataStreamerOptions extends Object
Data streamer options. See DataStreamerTarget for more information.

  • Field Details

  • Method Details

    • builder

      public static DataStreamerOptions.Builder builder()
      Creates a new builder.
      Returns:
      Builder.

    • pageSize

      public int pageSize()
      Gets the page size (the number of entries that will be sent to the cluster in one network call).
      Returns:
      Page size.

    • perPartitionParallelOperations

      public int perPartitionParallelOperations()
      Gets the number of parallel operations per partition (how many in-flight requests can be active for a given partition).
      Returns:
      Per node parallel operations.

    • autoFlushInterval

      public int autoFlushInterval()
      Gets the auto flush interval, in milliseconds (the period of time after which the streamer will flush the per-node buffer even if it is not full).
      Returns:
      Auto flush interval.

    • retryLimit

      public int retryLimit()
      Gets the retry limit for a page. If a page fails to be sent to the cluster, the streamer will retry it a number of times. If all retries fail, the streamer will be aborted.
      Returns:
      Retry limit.

    • sameKeyUpdateMode

      public DataStreamerSameKeyUpdateMode sameKeyUpdateMode()
      Gets the mode controlling how same-key updates within one batch are handled.

      By default (DataStreamerSameKeyUpdateMode.SQUASH), updates to the same key within a single batch are conflated and only the final state is applied — Continuous Query observes one event per affected key per batch.

      With DataStreamerSameKeyUpdateMode.PRESERVE, repeated updates to the same key are separated into duplicate-free sub-batches, so Continuous Query observes one event per update. Updates for different keys can still be part of the same implicit transaction and share the same commit timestamp.

      Returns:
      Same-key update mode.