streamable

Streaming producer mixin: declares batch_size and flush_ms for producers reading from continuous sources.

Properties

Name	Type	Description	Required
batch_size	integer	Maximum number of records yielded per downstream batch. Default: 1000 Minimum: 1
flush_ms	integer, null	If set, flush a partial batch after this many ms of inactivity. null or omitted = wait until batch_size or end-of-stream. Default: 1000 Minimum: 1

Example

batch_size: 1000
flush_ms: 1000