Modifier and Type | Interface and Description |
---|---|
interface |
StateSnapshotContext
This interface provides a context in which operators that use managed (i.e.
|
Modifier and Type | Class and Description |
---|---|
class |
StateSnapshotContextSynchronousImpl
This class is a default implementation for StateSnapshotContext.
|
Modifier and Type | Method and Description |
---|---|
void |
CheckpointedFunction.snapshotState(FunctionSnapshotContext context)
This method is called when a snapshot for a checkpoint is requested.
|
Modifier and Type | Method and Description |
---|---|
void |
TwoPhaseCommitSinkFunction.snapshotState(FunctionSnapshotContext context) |
Modifier and Type | Method and Description |
---|---|
void |
StreamingFileSink.snapshotState(FunctionSnapshotContext context) |
Modifier and Type | Method and Description |
---|---|
void |
MultipleIdsMessageAcknowledgingSourceBase.snapshotState(FunctionSnapshotContext context) |
void |
StatefulSequenceSource.snapshotState(FunctionSnapshotContext context) |
void |
FromElementsFunction.snapshotState(FunctionSnapshotContext context) |
void |
MessageAcknowledgingSourceBase.snapshotState(FunctionSnapshotContext context) |
void |
ContinuousFileMonitoringFunction.snapshotState(FunctionSnapshotContext context) |
Modifier and Type | Method and Description |
---|---|
void |
CassandraSinkBase.snapshotState(FunctionSnapshotContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
ElasticsearchSinkBase.snapshotState(FunctionSnapshotContext context) |
Modifier and Type | Method and Description |
---|---|
void |
RollingSink.snapshotState(FunctionSnapshotContext context)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
BucketingSink.snapshotState(FunctionSnapshotContext context) |
Modifier and Type | Method and Description |
---|---|
void |
FlinkKafkaProducer011.snapshotState(FunctionSnapshotContext context) |
void |
FlinkKafkaProducerBase.snapshotState(FunctionSnapshotContext ctx) |
void |
FlinkKafkaConsumerBase.snapshotState(FunctionSnapshotContext context) |
Modifier and Type | Method and Description |
---|---|
void |
SequenceGeneratorSource.snapshotState(FunctionSnapshotContext context) |
Modifier and Type | Method and Description |
---|---|
void |
ArtificalOperatorStateMapper.snapshotState(FunctionSnapshotContext context) |
void |
ArtificialKeyedStateMapper.snapshotState(FunctionSnapshotContext context) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.