Package | Description |
---|---|
org.apache.flink.streaming.runtime.io |
Modifier and Type | Class and Description |
---|---|
class |
CachedBufferStorage
The
CachedBufferStorage takes the buffers and events from a data stream and adds them to
a memory queue. |
class |
EmptyBufferStorage
Always empty implementation of
BufferStorage . |
class |
LinkedBufferStorage
Implementation of
BufferStorage that links two BufferStorage together. |
Constructor and Description |
---|
CheckpointedInputGate(InputGate inputGate,
BufferStorage bufferStorage,
CheckpointBarrierHandler barrierHandler) |
CheckpointedInputGate(InputGate inputGate,
BufferStorage bufferStorage,
CheckpointBarrierHandler barrierHandler,
int channelIndexOffset)
Creates a new checkpoint stream aligner.
|
CheckpointedInputGate(InputGate inputGate,
BufferStorage bufferStorage,
String taskName,
AbstractInvokable toNotifyOnCheckpoint) |
LinkedBufferStorage(BufferStorage mainStorage,
BufferStorage linkedStorage,
long maxBufferedBytes) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.