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 |
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 |
FlinkKafkaProducer011.initializeState(FunctionInitializationContext context) |
void |
FlinkKafkaProducerBase.initializeState(FunctionInitializationContext context) |
void |
FlinkKafkaConsumerBase.initializeState(FunctionInitializationContext context) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.