Class PipelineSettings

All Implemented Interfaces:

public class PipelineSettings
extends java.lang.Object
implements JsonpSerializable
See Also:
API specification
  • Field Details

  • Method Details

    • of

      public static PipelineSettings of​(java.util.function.Function<PipelineSettings.Builder,​ObjectBuilder<PipelineSettings>> fn)
    • pipelineWorkers

      public final int pipelineWorkers()
      Required - API name: pipeline.workers
    • pipelineBatchSize

      public final int pipelineBatchSize()
      Required - API name: pipeline.batch.size
    • pipelineBatchDelay

      public final int pipelineBatchDelay()
      Required - API name: pipeline.batch.delay
    • queueType

      public final java.lang.String queueType()
      Required - API name: queue.type
    • queueMaxBytesNumber

      public final int queueMaxBytesNumber()
      Required - API name: queue.max_bytes.number
    • queueMaxBytesUnits

      public final java.lang.String queueMaxBytesUnits()
      Required - API name: queue.max_bytes.units
    • queueCheckpointWrites

      public final int queueCheckpointWrites()
      Required - API name: queue.checkpoint.writes
    • serialize

      public void serialize​( generator, JsonpMapper mapper)
      Serialize this object to JSON.
      Specified by:
      serialize in interface JsonpSerializable
    • serializeInternal

      protected void serializeInternal​( generator, JsonpMapper mapper)
    • setupPipelineSettingsDeserializer

      protected static void setupPipelineSettingsDeserializer​(ObjectDeserializer<PipelineSettings.Builder> op)