pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.set_buffer_timeout

StreamExecutionEnvironment.set_buffer_timeout(timeout_millis: int) → StreamExecutionEnvironment

Sets the maximum time frequency (milliseconds) for the flushing of the output buffers. By default the output buffers flush frequently to provide low latency and to aid smooth developer experience. Setting the parameter can result in three logical modes:

• A positive integer triggers flushing periodically by that integer

• 0 triggers flushing after every record thus minimizing latency

• -1 triggers flushing only when the output buffer is full thus maximizing throughput

Parameters:

timeout_millis – The maximum time between two output flushes.

Returns:

This object.