Package | Description |
---|---|
org.apache.flink.cep.operator | |
org.apache.flink.streaming.api.operators | |
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 |
KeyedCEPPatternOperator.snapshotOperatorState(long checkpointId,
long timestamp) |
StreamTaskState |
CEPPatternOperator.snapshotOperatorState(long checkpointId,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
void |
KeyedCEPPatternOperator.restoreState(StreamTaskState state,
long recoveryTimestamp) |
void |
CEPPatternOperator.restoreState(StreamTaskState state,
long recoveryTimestamp) |
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,
long recoveryTimestamp)
Restores the operator state, if this operator's execution is recovering from a checkpoint.
|
void |
AbstractUdfStreamOperator.restoreState(StreamTaskState state,
long recoveryTimestamp) |
void |
AbstractStreamOperator.restoreState(StreamTaskState state,
long recoveryTimestamp) |
Modifier and Type | Method and Description |
---|---|
StreamTaskState |
WindowOperator.snapshotOperatorState(long checkpointId,
long timestamp) |
StreamTaskState |
NonKeyedWindowOperator.snapshotOperatorState(long checkpointId,
long timestamp) |
StreamTaskState |
AbstractAlignedProcessingTimeWindowOperator.snapshotOperatorState(long checkpointId,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
void |
WindowOperator.restoreState(StreamTaskState taskState,
long recoveryTimestamp) |
void |
NonKeyedWindowOperator.restoreState(StreamTaskState taskState,
long recoveryTimestamp) |
void |
AbstractAlignedProcessingTimeWindowOperator.restoreState(StreamTaskState taskState,
long recoveryTimestamp) |
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.