Was this helpful?
Port Settings and Types
 
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).
The following code example shows how to create a base engine configuration and set specific port settings.
Setting port configuration
EngineConfig config = EngineConfig.engine().ports.batchSize(4096).ports.writeahead(4);
Last modified date: 12/09/2024