Uses of Interface
org.apache.flink.streaming.runtime.io.BufferBlocker

Packages that use BufferBlocker

Package	Description
org.apache.flink.streaming.runtime.io

Uses of BufferBlocker in org.apache.flink.streaming.runtime.io

Classes in org.apache.flink.streaming.runtime.io that implement BufferBlocker

Modifier and Type	Class and Description
class	BufferSpiller Deprecated.
class	CachedBufferBlocker The cached buffer blocker takes the buffers and events from a data stream and adds them to a memory queue.

Constructors in org.apache.flink.streaming.runtime.io with parameters of type BufferBlocker

Constructor and Description
BarrierBuffer(org.apache.flink.runtime.io.network.partition.consumer.InputGate inputGate, BufferBlocker bufferBlocker) Creates a new checkpoint stream aligner.
BarrierBuffer(org.apache.flink.runtime.io.network.partition.consumer.InputGate inputGate, BufferBlocker bufferBlocker, long maxBufferedBytes) Creates a new checkpoint stream aligner.