Ctrl+K
Logo image Logo image

Site Navigation

  • API Reference
  • Examples

Site Navigation

  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
  • PyFlink DataStream
    • StreamExecutionEnvironment
    • DataStream
    • Functions
    • State
    • Timer
    • Window
    • Checkpoint
    • Side Outputs
    • Connectors
    • Formats
  • PyFlink Common

pyflink.datastream.data_stream.DataStream.set_buffer_timeout#

DataStream.set_buffer_timeout(timeout_millis: int) → pyflink.datastream.data_stream.DataStream[source]#

Sets the buffering timeout for data produced by this operation. The timeout defines how long data may linger ina partially full buffer before being sent over the network.

Lower timeouts lead to lower tail latencies, but may affect throughput. Timeouts of 1 ms still sustain high throughput, even for jobs with high parallelism.

A value of ‘-1’ means that the default buffer timeout should be used. A value of ‘0’ indicates that no buffering should happen, and all records/events should be immediately sent through the network, without additional buffering.

Parameters

timeout_millis – The maximum time between two output flushes.

Returns

The operator with buffer timeout set.

previous

pyflink.datastream.data_stream.DataStream.force_non_parallel

next

pyflink.datastream.data_stream.DataStream.start_new_chain

Show Source

Created using Sphinx 4.5.0.