Package | Description |
---|---|
org.apache.flink.runtime.checkpoint.channel | |
org.apache.flink.runtime.io.network.partition.consumer | |
org.apache.flink.streaming.runtime.io | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Modifier and Type | Class and Description |
---|---|
static class |
ChannelStateWriter.NoOpChannelStateWriter
No-op implementation of
ChannelStateWriter . |
class |
ChannelStateWriterImpl
ChannelStateWriter implemented using CheckpointStateOutputStreams . |
Modifier and Type | Field and Description |
---|---|
static ChannelStateWriter |
ChannelStateWriter.NO_OP |
Modifier and Type | Method and Description |
---|---|
void |
InputChannel.spillInflightBuffers(long checkpointId,
ChannelStateWriter channelStateWriter) |
void |
LocalInputChannel.spillInflightBuffers(long checkpointId,
ChannelStateWriter channelStateWriter) |
void |
RemoteInputChannel.spillInflightBuffers(long checkpointId,
ChannelStateWriter channelStateWriter) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
StreamTaskInput.prepareSnapshot(ChannelStateWriter channelStateWriter,
long checkpointId)
Prepares to spill the in-flight input buffers as checkpoint snapshot.
|
CompletableFuture<Void> |
StreamTaskNetworkInput.prepareSnapshot(ChannelStateWriter channelStateWriter,
long checkpointId) |
CompletableFuture<Void> |
StreamTwoInputProcessor.prepareSnapshot(ChannelStateWriter channelStateWriter,
long checkpointId) |
CompletableFuture<Void> |
StreamMultipleInputProcessor.prepareSnapshot(ChannelStateWriter channelStateWriter,
long checkpointId) |
CompletableFuture<Void> |
StreamTaskSourceInput.prepareSnapshot(ChannelStateWriter channelStateWriter,
long checkpointId) |
CompletableFuture<Void> |
StreamInputProcessor.prepareSnapshot(ChannelStateWriter channelStateWriter,
long checkpointId) |
CompletableFuture<Void> |
StreamOneInputProcessor.prepareSnapshot(ChannelStateWriter channelStateWriter,
long checkpointId) |
void |
CheckpointedInputGate.spillInflightBuffers(long checkpointId,
int channelIndex,
ChannelStateWriter channelStateWriter) |
Modifier and Type | Method and Description |
---|---|
ChannelStateWriter |
SubtaskCheckpointCoordinator.getChannelStateWriter() |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.