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 |
ReplicatingInputFormat.getRuntimeContext() |
RuntimeContext |
RichOutputFormat.getRuntimeContext() |
RuntimeContext |
RichInputFormat.getRuntimeContext() |
Modifier and Type | Method and Description |
---|---|
void |
ReplicatingInputFormat.setRuntimeContext(RuntimeContext context) |
void |
RichOutputFormat.setRuntimeContext(RuntimeContext t) |
void |
RichInputFormat.setRuntimeContext(RuntimeContext t) |
Modifier and Type | Method and Description |
---|---|
void |
FlinkConnectorRateLimiter.open(RuntimeContext runtimeContext)
A method that can be used to create and configure a ratelimiter based on the runtimeContext.
|
void |
GuavaFlinkConnectorRateLimiter.open(RuntimeContext runtimeContext)
Creates a rate limiter with the runtime context provided.
|
Modifier and Type | Method and Description |
---|---|
protected abstract List<OUT> |
SingleInputOperator.executeOnCollections(List<IN> inputData,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected void |
GenericDataSinkBase.executeOnCollections(List<IN> inputData,
RuntimeContext ctx,
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<OUT> |
GroupReduceOperatorBase.executeOnCollections(List<IN> inputData,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<IN> |
PartitionOperatorBase.executeOnCollections(List<IN> inputData,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<OUT> |
MapPartitionOperatorBase.executeOnCollections(List<IN> inputData,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<OUT> |
MapOperatorBase.executeOnCollections(List<IN> inputData,
RuntimeContext ctx,
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> |
FlatMapOperatorBase.executeOnCollections(List<IN> input,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<OUT> |
InnerJoinOperatorBase.executeOnCollections(List<IN1> inputData1,
List<IN2> inputData2,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<OUT> |
CoGroupRawOperatorBase.executeOnCollections(List<IN1> input1,
List<IN2> input2,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<OUT> |
OuterJoinOperatorBase.executeOnCollections(List<IN1> leftInput,
List<IN2> rightInput,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<OUT> |
CoGroupOperatorBase.executeOnCollections(List<IN1> input1,
List<IN2> input2,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<OUT> |
CrossOperatorBase.executeOnCollections(List<IN1> inputData1,
List<IN2> inputData2,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<ST> |
DeltaIterationBase.executeOnCollections(List<ST> inputData1,
List<WT> inputData2,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<T> |
BulkIterationBase.executeOnCollections(List<T> inputData,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<T> |
ReduceOperatorBase.executeOnCollections(List<T> inputData,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<T> |
FilterOperatorBase.executeOnCollections(List<T> inputData,
RuntimeContext ctx,
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 |
---|---|
void |
HiveTableFileInputFormat.setRuntimeContext(RuntimeContext t) |
Modifier and Type | Method and Description |
---|---|
List<Row> |
ModelSource.getModelRows(RuntimeContext runtimeContext)
Get the rows that containing the model.
|
List<Row> |
BroadcastVariableModelSource.getModelRows(RuntimeContext runtimeContext) |
List<Row> |
RowsModelSource.getModelRows(RuntimeContext runtimeContext) |
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 |
RandomGenerator.open(String name,
FunctionInitializationContext context,
RuntimeContext runtimeContext) |
void |
DataGenerator.open(String name,
FunctionInitializationContext context,
RuntimeContext runtimeContext)
Open and initialize state for
DataGenerator . |
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) |
static FlinkFnApi.UserDefinedDataStreamFunction |
PythonOperatorUtils.getUserDefinedDataStreamStatefulFunctionProto(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo,
RuntimeContext runtimeContext,
Map<String,String> internalParameters,
TypeInformation keyTypeInfo) |
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 |
---|---|
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.
|
protected KinesisDataFetcher<T> |
FlinkDynamoDBStreamsConsumer.createFetcher(List<String> streams,
SourceFunction.SourceContext<T> sourceContext,
RuntimeContext runtimeContext,
Properties configProps,
KinesisDeserializationSchema<T> deserializationSchema) |
Modifier and Type | Method and Description |
---|---|
void |
WatermarkTracker.open(RuntimeContext context) |
void |
JobManagerWatermarkTracker.open(RuntimeContext context) |
Modifier and Type | Method and Description |
---|---|
NiFiDataPacket |
NiFiDataPacketBuilder.createNiFiDataPacket(T t,
RuntimeContext ctx) |
Modifier and Type | Method and Description |
---|---|
RuntimeContext |
InternalSingleValueProcessAllWindowFunction.getRuntimeContext() |
RuntimeContext |
InternalAggregateProcessAllWindowFunction.getRuntimeContext() |
RuntimeContext |
InternalSingleValueWindowFunction.getRuntimeContext() |
RuntimeContext |
InternalIterableProcessWindowFunction.getRuntimeContext() |
RuntimeContext |
InternalSingleValueAllWindowFunction.getRuntimeContext() |
RuntimeContext |
InternalIterableWindowFunction.getRuntimeContext() |
RuntimeContext |
InternalSingleValueProcessWindowFunction.getRuntimeContext() |
RuntimeContext |
InternalIterableProcessAllWindowFunction.getRuntimeContext() |
RuntimeContext |
InternalIterableAllWindowFunction.getRuntimeContext() |
RuntimeContext |
InternalAggregateProcessWindowFunction.getRuntimeContext() |
Modifier and Type | Method and Description |
---|---|
void |
RowDataGenerator.open(String name,
FunctionInitializationContext context,
RuntimeContext runtimeContext) |
void |
DataGeneratorMapper.open(String name,
FunctionInitializationContext context,
RuntimeContext runtimeContext) |
void |
DecimalDataRandomGenerator.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 |
StateDataViewStore.getRuntimeContext() |
RuntimeContext |
PerKeyStateDataViewStore.getRuntimeContext() |
RuntimeContext |
PerWindowStateDataViewStore.getRuntimeContext() |
Constructor and Description |
---|
PerKeyStateDataViewStore(RuntimeContext ctx) |
PerKeyStateDataViewStore(RuntimeContext ctx,
StateTtlConfig stateTtlConfig) |
PerWindowStateDataViewStore(KeyedStateBackend<?> keyedStateBackend,
TypeSerializer<?> windowSerializer,
RuntimeContext runtimeContext) |
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 . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.