Package | Description |
---|---|
org.apache.flink.streaming.runtime.io |
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.
|
Constructor and Description |
---|
BarrierBuffer(InputGate inputGate,
BufferBlocker bufferBlocker)
Creates a new checkpoint stream aligner.
|
BarrierBuffer(InputGate inputGate,
BufferBlocker bufferBlocker,
long maxBufferedBytes)
Creates a new checkpoint stream aligner.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.