ports.batchSize

int

1024

Specifies that operator ports should publish pushed data tokens in batches of the specified size. Data will not be published to readers until a full batch is ready or end of data is reached.

ports.sizeByReaders

boolean

true

When enabled, this property allows the runtime engine to automatically resize dataflow queues as a factor of the number of readers on the queue. This property is enabled by default.

ports.spoolThreshold

int

0

Dead-lock detection within a graph can cause queue expansion. When a queue grows larger than this threshold, the queue will be routed to disk until it shrinks, thereby saving memory. The default value of zero indicates the system should determine a valid threshold based on available resources.

ports.writeahead

int

2

Specifies the number of unread batches which a port can publish before blocking. This defaults to a small size (2).