Interface | Description |
---|---|
SavepointWriterOperatorFactory |
Creates a savepoint writing operator from a savepoint path.
|
Class | Description |
---|---|
BootstrapTransformation<T> | Deprecated
Use
StateBootstrapTransformation instead. |
EvictingWindowReader<W extends Window> | Deprecated |
EvictingWindowSavepointReader<W extends Window> |
This class provides entry points for reading keyed state written out using the
WindowOperator . |
ExistingSavepoint | Deprecated
For creating a new savepoint, use
SavepointWriter and the data stream api
under batch execution. |
KeyedOperatorTransformation<K,T> | Deprecated |
KeyedStateTransformation<K,T> |
A
KeyedStateTransformation represents a OneInputStateTransformation on which
operator state is partitioned by key using a provided KeySelector . |
NewSavepoint | Deprecated
For creating a new savepoint, use
SavepointWriter and the data stream api
under batch execution. |
OneInputOperatorTransformation<T> | Deprecated
Use
OneInputStateTransformation instead. |
OneInputStateTransformation<T> |
OneInputStateTransformation represents a user defined transformation applied on an OperatorTransformation with one input. |
OperatorIdentifier |
Identifies an operator, either based on a
uid or uidHash . |
OperatorTransformation |
This class provides the entry point for building
StateBootstrapTransformation s, which
represents procedures to bootstrap new operator states with a given DataStream . |
Savepoint | Deprecated
For creating a new savepoint, use
SavepointWriter and the data stream api
under batch execution. |
SavepointReader |
The entry point for reading state from a Flink savepoint.
|
SavepointWriter |
A
SavepointWriter can create new savepoints from bounded data streams. |
StateBootstrapTransformation<T> |
A
StateBootstrapTransformation represents a procedure of writing new operator state into
a Savepoint . |
WindowedOperatorTransformation<T,K,W extends Window> |
A
WindowedOperatorTransformation represents a OneInputOperatorTransformation for
bootstrapping window state. |
WindowedStateTransformation<T,K,W extends Window> |
A
WindowedStateTransformation represents a OneInputStateTransformation for
bootstrapping window state. |
WindowReader<W extends Window> | Deprecated |
WindowSavepointReader<W extends Window> |
This class provides entry points for reading keyed state written out using the
WindowOperator . |
WritableSavepoint<F extends WritableSavepoint> | Deprecated |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.