Skip to main content

batched input

Consumes data from a child input and applies a batching policy to the stream.

# Common config fields, showing default values
input:
  label: ""
  batched:
    child: "" # No default (required)
    policy:
      count: 0
      byte_size: 0
      period: ""
      check: ""

Batching at the input level is sometimes useful for processing across micro-batches, and can also sometimes be a useful performance trick. However, most inputs are fine without it so unless you have a specific plan for batching this component is not worth using.

Fields​

child​

The child input.

Type: input

policy​

Allows you to configure a batching policy.

Type: object

policy.count​

A number of messages at which the batch should be flushed. If 0 disables count based batching.

Type: int
Default: 0

policy.byte_size​

An amount of bytes at which the batch should be flushed. If 0 disables size based batching.

Type: int
Default: 0

policy.period​

A period in which an incomplete batch should be flushed regardless of its size.

Type: string
Default: ""

policy.check​

A Bloblang query that should return a boolean value indicating whether a message should end a batch.

Type: string
Default: ""

policy.processors​

A list of processors to apply to a batch as it is flushed. This allows you to aggregate and archive the batch however you see fit. Please note that all resulting messages are flushed as a single batch, therefore splitting the batch into smaller batches using these processors is a no-op.

Type: array of processor