Package | Description |
---|---|
org.apache.flink.state.api | |
org.apache.flink.state.api.runtime | |
org.apache.flink.state.api.runtime.metadata |
Class and Description |
---|
BootstrapTransformation
A
BootstrapTransformation represents a procedure of writing new operator state into a
Savepoint . |
EvictingWindowReader
This class provides entry points for reading keyed state written out using the
WindowOperator . |
ExistingSavepoint
An existing savepoint.
|
KeyedOperatorTransformation
A
KeyedOperatorTransformation represents a OneInputOperatorTransformation on
which operator state is partitioned by key using a provided KeySelector . |
NewSavepoint
A new savepoint.
|
OneInputOperatorTransformation
OneInputOperatorTransformation represents a user defined transformation applied on an
OperatorTransformation with one input. |
SavepointWriterOperatorFactory
Creates a savepoint writing operator from a savepoint path.
|
WindowedOperatorTransformation
A
WindowedOperatorTransformation represents a OneInputOperatorTransformation for
bootstrapping window state. |
WindowReader
This class provides entry points for reading keyed state written out using the
WindowOperator . |
WritableSavepoint
A
WritableSavepoint is any savepoint that can be written to from a batch context. |
Class and Description |
---|
BootstrapTransformation
A
BootstrapTransformation represents a procedure of writing new operator state into a
Savepoint . |
Class and Description |
---|
BootstrapTransformation
A
BootstrapTransformation represents a procedure of writing new operator state into a
Savepoint . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.