Modifier and Type | Method and Description |
---|---|
void |
DecimalDataRandomGenerator.open(String name,
FunctionInitializationContext context,
RuntimeContext runtimeContext) |
void |
DataGeneratorMapper.open(String name,
FunctionInitializationContext context,
RuntimeContext runtimeContext) |
void |
RowDataGenerator.open(String name,
FunctionInitializationContext context,
RuntimeContext runtimeContext) |
Modifier and Type | Method and Description |
---|---|
void |
FileSinkProgram.Generator.initializeState(FunctionInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
HBaseSinkFunction.initializeState(FunctionInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
GenericJdbcSinkFunction.initializeState(FunctionInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
JdbcXaSinkFunction.initializeState(FunctionInitializationContext context) |
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 |
StreamSQLTestProgram.Generator.initializeState(FunctionInitializationContext context) |
void |
StreamSQLTestProgram.KillMapper.initializeState(FunctionInitializationContext context) |
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)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
StatefulSequenceSource.initializeState(FunctionInitializationContext context) |
void |
ContinuousFileMonitoringFunction.initializeState(FunctionInitializationContext context) |
void |
MessageAcknowledgingSourceBase.initializeState(FunctionInitializationContext context) |
void |
FromElementsFunction.initializeState(FunctionInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
DataGeneratorSource.initializeState(FunctionInitializationContext context) |
void |
DataGenerator.open(String name,
FunctionInitializationContext context,
RuntimeContext runtimeContext)
Open and initialize state for
DataGenerator . |
void |
RandomGenerator.open(String name,
FunctionInitializationContext context,
RuntimeContext runtimeContext) |
void |
SequenceGenerator.open(String name,
FunctionInitializationContext context,
RuntimeContext runtimeContext) |
Modifier and Type | Method and Description |
---|---|
void |
CollectSinkFunction.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 |
PubSubSink.initializeState(FunctionInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
FlinkKafkaProducer.initializeState(FunctionInitializationContext context)
Deprecated.
|
void |
FlinkKafkaConsumerBase.initializeState(FunctionInitializationContext context) |
void |
FlinkKafkaProducerBase.initializeState(FunctionInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
FlinkKinesisProducer.initializeState(FunctionInitializationContext context)
Deprecated.
|
void |
FlinkKinesisConsumer.initializeState(FunctionInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
SimpleSource.initializeState(FunctionInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
SequenceGeneratorSource.initializeState(FunctionInitializationContext context) |
void |
PeriodicStreamingJob.PeriodicSourceGenerator.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 |
ArtificialListStateBuilder.initialize(FunctionInitializationContext initializationContext) |
abstract void |
ArtificialStateBuilder.initialize(FunctionInitializationContext initializationContext)
Registers the state.
|
void |
ArtificialMapStateBuilder.initialize(FunctionInitializationContext initializationContext) |
void |
ArtificialValueStateBuilder.initialize(FunctionInitializationContext initializationContext) |
Modifier and Type | Method and Description |
---|---|
State |
TtlStateVerifier.createState(FunctionInitializationContext context,
StateTtlConfig ttlConfig) |
Modifier and Type | Method and Description |
---|---|
void |
ArrowSourceFunction.initializeState(FunctionInitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
UpdatableTopNFunction.initializeState(FunctionInitializationContext context) |
void |
FastTop1Function.initializeState(FunctionInitializationContext context) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.