Name | Type | Default Value | Description |
---|---|---|---|
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). |