Modifier and Type | Method and Description |
---|---|
void |
CepOperator.initializeState(StateInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
CompactorOperatorStateHandler.initializeState(StateInitializationContext context) |
void |
CompactCoordinator.initializeState(StateInitializationContext context) |
void |
CompactCoordinatorStateHandler.initializeState(StateInitializationContext context) |
void |
CompactorOperator.initializeState(StateInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionCommitter.initializeState(StateInitializationContext context) |
void |
AbstractStreamingWriter.initializeState(StateInitializationContext context) |
void |
StreamingFileWriter.initializeState(StateInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
CompactCoordinator.initializeState(StateInitializationContext context) |
void |
CompactOperator.initializeState(StateInitializationContext context) |
Modifier and Type | Class and Description |
---|---|
class |
StateInitializationContextImpl
Default implementation of
StateInitializationContext . |
Modifier and Type | Method and Description |
---|---|
void |
ContinuousFileReaderOperator.initializeState(StateInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
SourceOperator.initializeState(StateInitializationContext context) |
void |
AbstractStreamOperatorV2.initializeState(StateInitializationContext context)
Stream operators with state which can be restored need to override this hook method.
|
void |
AbstractStreamOperator.initializeState(StateInitializationContext context)
Stream operators with state which can be restored need to override this hook method.
|
void |
StreamOperatorStateHandler.CheckpointedStreamOperator.initializeState(StateInitializationContext context) |
void |
AbstractUdfStreamOperator.initializeState(StateInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
AsyncWaitOperator.initializeState(StateInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
IntervalJoinOperator.initializeState(StateInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
GenericWriteAheadSink.initializeState(StateInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
static void |
StreamingFunctionUtils.restoreFunctionState(StateInitializationContext context,
Function userFunction) |
Modifier and Type | Method and Description |
---|---|
void |
StreamSortOperator.initializeState(StateInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
SlicingWindowOperator.initializeState(StateInitializationContext context) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.