Modifier and Type | Method and Description |
---|---|
void |
RowDataGenerator.snapshotState(FunctionSnapshotContext context) |
Modifier and Type | Method and Description |
---|---|
void |
FileSinkProgram.Generator.snapshotState(FunctionSnapshotContext context)
Deprecated.
|
Modifier and Type | Interface and Description |
---|---|
interface |
StateSnapshotContext
This interface provides a context in which operators that use managed (i.e. state that is managed
by state backends) or raw (i.e. the operator can write it's state streams) state can perform a
snapshot.
|
Modifier and Type | Class and Description |
---|---|
class |
StateSnapshotContextSynchronousImpl
This class is a default implementation for StateSnapshotContext.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamSQLTestProgram.Generator.snapshotState(FunctionSnapshotContext context)
Deprecated.
|
void |
StreamSQLTestProgram.KillMapper.snapshotState(FunctionSnapshotContext context) |
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)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
MessageAcknowledgingSourceBase.snapshotState(FunctionSnapshotContext context)
Deprecated.
|
void |
MultipleIdsMessageAcknowledgingSourceBase.snapshotState(FunctionSnapshotContext context)
Deprecated.
|
void |
FromElementsFunction.snapshotState(FunctionSnapshotContext context)
Deprecated.
|
void |
ContinuousFileMonitoringFunction.snapshotState(FunctionSnapshotContext context)
Deprecated.
|
void |
StatefulSequenceSource.snapshotState(FunctionSnapshotContext context)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
default void |
DataGenerator.snapshotState(FunctionSnapshotContext context)
Snapshot state for
DataGenerator . |
void |
DataGeneratorSource.snapshotState(FunctionSnapshotContext context)
Deprecated.
|
void |
SequenceGenerator.snapshotState(FunctionSnapshotContext context) |
Modifier and Type | Method and Description |
---|---|
void |
CollectSinkFunction.snapshotState(FunctionSnapshotContext context) |
Modifier and Type | Method and Description |
---|---|
void |
SequenceGeneratorSource.snapshotState(FunctionSnapshotContext context)
Deprecated.
|
void |
PeriodicStreamingJob.PeriodicSourceGenerator.snapshotState(FunctionSnapshotContext context)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
ArtificialKeyedStateMapper.snapshotState(FunctionSnapshotContext context) |
void |
ArtificalOperatorStateMapper.snapshotState(FunctionSnapshotContext context) |
Modifier and Type | Method and Description |
---|---|
void |
ArrowSourceFunction.snapshotState(FunctionSnapshotContext context)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
UpdatableTopNFunction.snapshotState(FunctionSnapshotContext context) |
void |
FastTop1Function.snapshotState(FunctionSnapshotContext context) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.