Modifier and Type | Interface and Description |
---|---|
interface |
StateInitializationContext
This interface provides a context in which operators can initialize by registering to managed state (i.e.
|
Modifier and Type | Class and Description |
---|---|
class |
StateInitializationContextImpl
Default implementation of
StateInitializationContext . |
Modifier and Type | Method and Description |
---|---|
void |
CheckpointedFunction.initializeState(FunctionInitializationContext context)
This method is called when the parallel function instance is created during distributed
execution.
|
Modifier and Type | Method and Description |
---|---|
void |
TwoPhaseCommitSinkFunction.initializeState(FunctionInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
StreamingFileSink.initializeState(FunctionInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
StatefulSequenceSource.initializeState(FunctionInitializationContext context) |
void |
FromElementsFunction.initializeState(FunctionInitializationContext context) |
void |
MessageAcknowledgingSourceBase.initializeState(FunctionInitializationContext context) |
void |
ContinuousFileMonitoringFunction.initializeState(FunctionInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
CassandraSinkBase.initializeState(FunctionInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
ElasticsearchSinkBase.initializeState(FunctionInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
RollingSink.initializeState(FunctionInitializationContext context)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
BucketingSink.initializeState(FunctionInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
FlinkKafkaProducer.initializeState(FunctionInitializationContext context) |
void |
FlinkKafkaProducer011.initializeState(FunctionInitializationContext context) |
void |
FlinkKafkaProducerBase.initializeState(FunctionInitializationContext context) |
void |
FlinkKafkaConsumerBase.initializeState(FunctionInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
SequenceGeneratorSource.initializeState(FunctionInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
ArtificalOperatorStateMapper.initializeState(FunctionInitializationContext context) |
void |
ArtificialKeyedStateMapper.initializeState(FunctionInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
ArtificialValueStateBuilder.initialize(FunctionInitializationContext initializationContext) |
void |
ArtificialMapStateBuilder.initialize(FunctionInitializationContext initializationContext) |
void |
ArtificialListStateBuilder.initialize(FunctionInitializationContext initializationContext) |
abstract void |
ArtificialStateBuilder.initialize(FunctionInitializationContext initializationContext)
Registers the state.
|
Modifier and Type | Method and Description |
---|---|
State |
TtlStateVerifier.createState(FunctionInitializationContext context,
StateTtlConfig ttlConfig) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.