Modifier and Type | Interface and Description |
---|---|
interface |
IterationRuntimeContext
A specialization of the
RuntimeContext available in iterative computations of the DataSet
API. |
Modifier and Type | Method and Description |
---|---|
RuntimeContext |
RichFunction.getRuntimeContext()
Gets the context that contains information about the UDF's runtime, such as the parallelism
of the function, the subtask index of the function, or the name of the task that executes the
function.
|
RuntimeContext |
AbstractRichFunction.getRuntimeContext() |
Modifier and Type | Method and Description |
---|---|
void |
RichFunction.setRuntimeContext(RuntimeContext t)
Sets the function's runtime context.
|
void |
AbstractRichFunction.setRuntimeContext(RuntimeContext t) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRuntimeUDFContext
A standalone implementation of the
RuntimeContext , created by runtime UDF operators. |
class |
RuntimeUDFContext
A standalone implementation of the
RuntimeContext , created by runtime UDF operators. |
Modifier and Type | Method and Description |
---|---|
static RuntimeContext |
FunctionUtils.getFunctionRuntimeContext(Function function,
RuntimeContext defaultContext) |
Modifier and Type | Method and Description |
---|---|
static RuntimeContext |
FunctionUtils.getFunctionRuntimeContext(Function function,
RuntimeContext defaultContext) |
static void |
FunctionUtils.setFunctionRuntimeContext(Function function,
RuntimeContext context) |
Modifier and Type | Method and Description |
---|---|
RuntimeContext |
RichInputFormat.getRuntimeContext() |
RuntimeContext |
RichOutputFormat.getRuntimeContext() |
RuntimeContext |
ReplicatingInputFormat.getRuntimeContext() |
Modifier and Type | Method and Description |
---|---|
void |
RichInputFormat.setRuntimeContext(RuntimeContext t) |
void |
RichOutputFormat.setRuntimeContext(RuntimeContext t) |
void |
ReplicatingInputFormat.setRuntimeContext(RuntimeContext context) |
Modifier and Type | Method and Description |
---|---|
void |
GuavaFlinkConnectorRateLimiter.open(RuntimeContext runtimeContext)
Creates a rate limiter with the runtime context provided.
|
void |
FlinkConnectorRateLimiter.open(RuntimeContext runtimeContext)
A method that can be used to create and configure a ratelimiter based on the runtimeContext.
|
Modifier and Type | Method and Description |
---|---|
protected void |
GenericDataSinkBase.executeOnCollections(List<IN> inputData,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected abstract List<OUT> |
SingleInputOperator.executeOnCollections(List<IN> inputData,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected abstract List<OUT> |
DualInputOperator.executeOnCollections(List<IN1> inputData1,
List<IN2> inputData2,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<T> |
Union.executeOnCollections(List<T> inputData1,
List<T> inputData2,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<OUT> |
GenericDataSourceBase.executeOnCollections(RuntimeContext ctx,
ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
protected List<IN> |
PartitionOperatorBase.executeOnCollections(List<IN> inputData,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<IN> |
SortPartitionOperatorBase.executeOnCollections(List<IN> inputData,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<OUT> |
GroupCombineOperatorBase.executeOnCollections(List<IN> inputData,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<OUT> |
GroupReduceOperatorBase.executeOnCollections(List<IN> inputData,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<OUT> |
MapOperatorBase.executeOnCollections(List<IN> inputData,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<OUT> |
FlatMapOperatorBase.executeOnCollections(List<IN> input,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<OUT> |
MapPartitionOperatorBase.executeOnCollections(List<IN> inputData,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<OUT> |
CrossOperatorBase.executeOnCollections(List<IN1> inputData1,
List<IN2> inputData2,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<OUT> |
CoGroupRawOperatorBase.executeOnCollections(List<IN1> input1,
List<IN2> input2,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<OUT> |
CoGroupOperatorBase.executeOnCollections(List<IN1> input1,
List<IN2> input2,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<OUT> |
InnerJoinOperatorBase.executeOnCollections(List<IN1> inputData1,
List<IN2> inputData2,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<OUT> |
OuterJoinOperatorBase.executeOnCollections(List<IN1> leftInput,
List<IN2> rightInput,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<ST> |
DeltaIterationBase.executeOnCollections(List<ST> inputData1,
List<WT> inputData2,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<T> |
FilterOperatorBase.executeOnCollections(List<T> inputData,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<T> |
ReduceOperatorBase.executeOnCollections(List<T> inputData,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<T> |
BulkIterationBase.executeOnCollections(List<T> inputData,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
static DeserializationSchema.InitializationContext |
RuntimeContextInitializationContextAdapters.deserializationAdapter(RuntimeContext runtimeContext) |
static DeserializationSchema.InitializationContext |
RuntimeContextInitializationContextAdapters.deserializationAdapter(RuntimeContext runtimeContext,
java.util.function.Function<MetricGroup,MetricGroup> mapMetricGroup) |
static SerializationSchema.InitializationContext |
RuntimeContextInitializationContextAdapters.serializationAdapter(RuntimeContext runtimeContext) |
static SerializationSchema.InitializationContext |
RuntimeContextInitializationContextAdapters.serializationAdapter(RuntimeContext runtimeContext,
java.util.function.Function<MetricGroup,MetricGroup> mapMetricGroup) |
Modifier and Type | Method and Description |
---|---|
void |
WrappingFunction.setRuntimeContext(RuntimeContext t) |
Modifier and Type | Method and Description |
---|---|
void |
NFA.open(RuntimeContext cepRuntimeContext,
Configuration conf)
Initialization method for the NFA.
|
Modifier and Type | Method and Description |
---|---|
RuntimeContext |
RichIterativeCondition.getRuntimeContext() |
Modifier and Type | Method and Description |
---|---|
void |
RichCompositeIterativeCondition.setRuntimeContext(RuntimeContext t) |
void |
RichIterativeCondition.setRuntimeContext(RuntimeContext runtimeContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
XidGenerator.belongsToSubtask(Xid xid,
RuntimeContext ctx) |
Xid |
XidGenerator.generateXid(RuntimeContext runtimeContext,
long checkpointId)
Generate new
Xid . |
Modifier and Type | Method and Description |
---|---|
void |
HiveTableFileInputFormat.setRuntimeContext(RuntimeContext t) |
Modifier and Type | Method and Description |
---|---|
protected List<OUT> |
NoOpBinaryUdfOp.executeOnCollections(List<OUT> inputData1,
List<OUT> inputData2,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<OUT> |
NoOpUnaryUdfOp.executeOnCollections(List<OUT> inputData,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
protected RuntimeContext |
ChainedDriver.getUdfRuntimeContext() |
Modifier and Type | Class and Description |
---|---|
class |
DistributedRuntimeUDFContext
A standalone implementation of the
RuntimeContext , created by runtime UDF operators. |
Modifier and Type | Method and Description |
---|---|
void |
EvictingWindowReaderFunction.setRuntimeContext(RuntimeContext t) |
Modifier and Type | Class and Description |
---|---|
class |
SavepointRuntimeContext
A streaming
RuntimeContext which delegates to the underlying batch RuntimeContext
along with a specified KeyedStateStore . |
Constructor and Description |
---|
Builder(RuntimeContext ctx,
int maxParallelism) |
SavepointRuntimeContext(RuntimeContext ctx,
KeyedStateStore keyedStateStore) |
Modifier and Type | Method and Description |
---|---|
void |
RichAsyncFunction.setRuntimeContext(RuntimeContext runtimeContext) |
Modifier and Type | Method and Description |
---|---|
void |
OutputFormatSinkFunction.setRuntimeContext(RuntimeContext context)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
SequenceGenerator.open(String name,
FunctionInitializationContext context,
RuntimeContext runtimeContext) |
void |
DataGenerator.open(String name,
FunctionInitializationContext context,
RuntimeContext runtimeContext)
Open and initialize state for
DataGenerator . |
void |
RandomGenerator.open(String name,
FunctionInitializationContext context,
RuntimeContext runtimeContext) |
Modifier and Type | Method and Description |
---|---|
void |
ReduceApplyProcessWindowFunction.setRuntimeContext(RuntimeContext t) |
void |
ReduceApplyProcessAllWindowFunction.setRuntimeContext(RuntimeContext t) |
Modifier and Type | Class and Description |
---|---|
class |
StreamingRuntimeContext
Implementation of the
RuntimeContext , for streaming
operators. |
Modifier and Type | Method and Description |
---|---|
static FlinkFnApi.UserDefinedDataStreamFunction |
PythonOperatorUtils.getUserDefinedDataStreamFunctionProto(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo,
RuntimeContext runtimeContext,
Map<String,String> internalParameters,
boolean inBatchExecutionMode) |
static FlinkFnApi.UserDefinedDataStreamFunction |
PythonOperatorUtils.getUserDefinedDataStreamStatefulFunctionProto(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo,
RuntimeContext runtimeContext,
Map<String,String> internalParameters,
TypeInformation keyTypeInfo,
boolean inBatchExecutionMode) |
Modifier and Type | Method and Description |
---|---|
void |
ElasticsearchSinkFunction.process(T element,
RuntimeContext ctx,
RequestIndexer indexer)
Process the incoming element to produce multiple
ActionsRequests . |
void |
ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction.process(Tuple2<Boolean,Row> element,
RuntimeContext ctx,
RequestIndexer indexer) |
Modifier and Type | Method and Description |
---|---|
RuntimeContext |
BufferedUpsertSinkFunction.getRuntimeContext() |
Modifier and Type | Method and Description |
---|---|
void |
BufferedUpsertSinkFunction.setRuntimeContext(RuntimeContext t) |
Modifier and Type | Method and Description |
---|---|
protected KinesisDataFetcher<T> |
FlinkDynamoDBStreamsConsumer.createFetcher(List<String> streams,
SourceFunction.SourceContext<T> sourceContext,
RuntimeContext runtimeContext,
Properties configProps,
KinesisDeserializationSchema<T> deserializationSchema) |
protected KinesisDataFetcher<T> |
FlinkKinesisConsumer.createFetcher(List<String> streams,
SourceFunction.SourceContext<T> sourceContext,
RuntimeContext runtimeContext,
Properties configProps,
KinesisDeserializationSchema<T> deserializationSchema)
This method is exposed for tests that need to mock the KinesisDataFetcher in the consumer.
|
Modifier and Type | Method and Description |
---|---|
void |
JobManagerWatermarkTracker.open(RuntimeContext context) |
void |
WatermarkTracker.open(RuntimeContext context) |
Modifier and Type | Method and Description |
---|---|
NiFiDataPacket |
NiFiDataPacketBuilder.createNiFiDataPacket(T t,
RuntimeContext ctx) |
Modifier and Type | Method and Description |
---|---|
RuntimeContext |
InternalSingleValueProcessWindowFunction.getRuntimeContext() |
RuntimeContext |
InternalAggregateProcessAllWindowFunction.getRuntimeContext() |
RuntimeContext |
InternalIterableWindowFunction.getRuntimeContext() |
RuntimeContext |
InternalSingleValueAllWindowFunction.getRuntimeContext() |
RuntimeContext |
InternalSingleValueProcessAllWindowFunction.getRuntimeContext() |
RuntimeContext |
InternalAggregateProcessWindowFunction.getRuntimeContext() |
RuntimeContext |
InternalIterableAllWindowFunction.getRuntimeContext() |
RuntimeContext |
InternalSingleValueWindowFunction.getRuntimeContext() |
RuntimeContext |
InternalIterableProcessAllWindowFunction.getRuntimeContext() |
RuntimeContext |
InternalIterableProcessWindowFunction.getRuntimeContext() |
Modifier and Type | Method and Description |
---|---|
void |
DecimalDataRandomGenerator.open(String name,
FunctionInitializationContext context,
RuntimeContext runtimeContext) |
void |
RowDataGenerator.open(String name,
FunctionInitializationContext context,
RuntimeContext runtimeContext) |
void |
DataGeneratorMapper.open(String name,
FunctionInitializationContext context,
RuntimeContext runtimeContext) |
Constructor and Description |
---|
FunctionContext(RuntimeContext context)
Wraps the underlying
RuntimeContext . |
Modifier and Type | Method and Description |
---|---|
RuntimeContext |
ExecutionContext.getRuntimeContext() |
RuntimeContext |
ExecutionContextImpl.getRuntimeContext() |
Constructor and Description |
---|
ExecutionContextImpl(AbstractStreamOperator<?> operator,
RuntimeContext runtimeContext) |
Modifier and Type | Method and Description |
---|---|
RuntimeContext |
PerWindowStateDataViewStore.getRuntimeContext() |
RuntimeContext |
UnsupportedStateDataViewStore.getRuntimeContext() |
RuntimeContext |
StateDataViewStore.getRuntimeContext() |
RuntimeContext |
PerKeyStateDataViewStore.getRuntimeContext() |
Constructor and Description |
---|
PerKeyStateDataViewStore(RuntimeContext ctx) |
PerKeyStateDataViewStore(RuntimeContext ctx,
StateTtlConfig stateTtlConfig) |
PerWindowStateDataViewStore(KeyedStateBackend<?> keyedStateBackend,
TypeSerializer<?> windowSerializer,
RuntimeContext runtimeContext) |
UnsupportedStateDataViewStore(RuntimeContext runtimeContext) |
Modifier and Type | Method and Description |
---|---|
WindowBuffer |
WindowBuffer.LocalFactory.create(Object operatorOwner,
MemoryManager memoryManager,
long memorySize,
RuntimeContext runtimeContext,
Collector<RowData> collector,
java.time.ZoneId shiftTimeZone)
Creates a
WindowBuffer for local window that buffers elements in memory before
flushing. |
WindowBuffer |
RecordsWindowBuffer.LocalFactory.create(Object operatorOwner,
MemoryManager memoryManager,
long memorySize,
RuntimeContext runtimeContext,
Collector<RowData> collector,
java.time.ZoneId shiftTimeZone) |
WindowBuffer |
WindowBuffer.Factory.create(Object operatorOwner,
MemoryManager memoryManager,
long memorySize,
RuntimeContext runtimeContext,
WindowTimerService<Long> timerService,
KeyedStateBackend<RowData> stateBackend,
WindowState<Long> windowState,
boolean isEventTime,
java.time.ZoneId shiftTimeZone)
Creates a
WindowBuffer that buffers elements in memory before flushing. |
WindowBuffer |
RecordsWindowBuffer.Factory.create(Object operatorOwner,
MemoryManager memoryManager,
long memorySize,
RuntimeContext runtimeContext,
WindowTimerService<Long> timerService,
KeyedStateBackend<RowData> stateBackend,
WindowState<Long> windowState,
boolean isEventTime,
java.time.ZoneId shiftTimeZone) |
Modifier and Type | Method and Description |
---|---|
RecordsCombiner |
LocalAggCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext,
Collector<RowData> collector) |
RecordsCombiner |
AggCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext,
WindowTimerService<Long> timerService,
KeyedStateBackend<RowData> stateBackend,
WindowState<Long> windowState,
boolean isEventTime) |
RecordsCombiner |
GlobalAggCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext,
WindowTimerService<Long> timerService,
KeyedStateBackend<RowData> stateBackend,
WindowState<Long> windowState,
boolean isEventTime) |
Modifier and Type | Method and Description |
---|---|
static JoinRecordStateView |
JoinRecordStateViews.create(RuntimeContext ctx,
String stateName,
JoinInputSideSpec inputSideSpec,
InternalTypeInfo<RowData> recordType,
long retentionTime)
Creates a
JoinRecordStateView depends on JoinInputSideSpec . |
static OuterJoinRecordStateView |
OuterJoinRecordStateViews.create(RuntimeContext ctx,
String stateName,
JoinInputSideSpec inputSideSpec,
InternalTypeInfo<RowData> recordType,
long retentionTime)
Creates a
OuterJoinRecordStateView depends on JoinInputSideSpec . |
Modifier and Type | Method and Description |
---|---|
RecordsCombiner |
TopNRecordsCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext,
WindowTimerService<Long> timerService,
KeyedStateBackend<RowData> stateBackend,
WindowState<Long> windowState,
boolean isEventTime) |
Modifier and Type | Method and Description |
---|---|
RecordsCombiner |
RecordsCombiner.LocalFactory.createRecordsCombiner(RuntimeContext runtimeContext,
Collector<RowData> collector) |
RecordsCombiner |
RecordsCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext,
WindowTimerService<Long> timerService,
KeyedStateBackend<RowData> stateBackend,
WindowState<Long> windowState,
boolean isEventTime)
Creates a
RecordsCombiner that can combine buffered data into states. |
Modifier and Type | Method and Description |
---|---|
RuntimeContext |
SlicingWindowProcessor.Context.getRuntimeContext()
Returns the current
RuntimeContext . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.