Package | Description |
---|---|
org.apache.flink.cep.operator | |
org.apache.flink.streaming.api.functions.source | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.runtime.operators |
This package contains the operators that perform the stream transformations.
|
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations
on data streams.
|
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Modifier and Type | Method and Description |
---|---|
StreamTaskState |
AbstractKeyedCEPPatternOperator.snapshotOperatorState(long checkpointId,
long timestamp) |
StreamTaskState |
AbstractCEPPatternOperator.snapshotOperatorState(long checkpointId,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractKeyedCEPPatternOperator.restoreState(StreamTaskState state) |
void |
AbstractCEPPatternOperator.restoreState(StreamTaskState state) |
Modifier and Type | Method and Description |
---|---|
StreamTaskState |
ContinuousFileReaderOperator.snapshotOperatorState(long checkpointId,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
void |
ContinuousFileReaderOperator.restoreState(StreamTaskState state) |
Modifier and Type | Method and Description |
---|---|
StreamTaskState |
StreamOperator.snapshotOperatorState(long checkpointId,
long timestamp)
Called to draw a state snapshot from the operator.
|
StreamTaskState |
AbstractUdfStreamOperator.snapshotOperatorState(long checkpointId,
long timestamp) |
StreamTaskState |
AbstractStreamOperator.snapshotOperatorState(long checkpointId,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
void |
StreamOperator.restoreState(StreamTaskState state)
Restores the operator state, if this operator's execution is recovering from a checkpoint.
|
void |
AbstractUdfStreamOperator.restoreState(StreamTaskState state) |
void |
AbstractStreamOperator.restoreState(StreamTaskState state) |
Modifier and Type | Method and Description |
---|---|
StreamTaskState |
GenericWriteAheadSink.snapshotOperatorState(long checkpointId,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
void |
GenericWriteAheadSink.restoreState(StreamTaskState state) |
Modifier and Type | Method and Description |
---|---|
StreamTaskState |
WindowOperator.snapshotOperatorState(long checkpointId,
long timestamp) |
StreamTaskState |
AbstractAlignedProcessingTimeWindowOperator.snapshotOperatorState(long checkpointId,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
void |
WindowOperator.restoreState(StreamTaskState taskState) |
void |
AbstractAlignedProcessingTimeWindowOperator.restoreState(StreamTaskState taskState) |
Modifier and Type | Method and Description |
---|---|
StreamTaskState[] |
StreamTaskStateList.getState(ClassLoader userCodeClassLoader) |
Constructor and Description |
---|
StreamTaskStateList(StreamTaskState[] states) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.