Uses of Class
org.apache.flink.streaming.api.operators.StreamingRuntimeContext

Packages that use StreamingRuntimeContext

Package	Description
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.connectors.kafka
org.apache.flink.streaming.connectors.kafka.shuffle

Uses of StreamingRuntimeContext in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators that return StreamingRuntimeContext

Modifier and Type	Method and Description
StreamingRuntimeContext	AbstractStreamOperator.getRuntimeContext() Returns a context that allows the operator to query information about the execution and also to interact with systems such as broadcast variables and managed state.
StreamingRuntimeContext	AbstractStreamOperatorV2.getRuntimeContext() Returns a context that allows the operator to query information about the execution and also to interact with systems such as broadcast variables and managed state.

Uses of StreamingRuntimeContext in org.apache.flink.streaming.connectors.kafka

Methods in org.apache.flink.streaming.connectors.kafka with parameters of type StreamingRuntimeContext

Modifier and Type	Method and Description
protected AbstractFetcher<T,?>	FlinkKafkaConsumer.createFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<WatermarkStrategy<T>> watermarkStrategy, StreamingRuntimeContext runtimeContext, OffsetCommitMode offsetCommitMode, MetricGroup consumerMetricGroup, boolean useMetrics)
protected abstract AbstractFetcher<T,?>	FlinkKafkaConsumerBase.createFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> subscribedPartitionsToStartOffsets, SerializedValue<WatermarkStrategy<T>> watermarkStrategy, StreamingRuntimeContext runtimeContext, OffsetCommitMode offsetCommitMode, MetricGroup kafkaMetricGroup, boolean useMetrics) Creates the fetcher that connect to the Kafka brokers, pulls data, deserialized the data, and emits it into the data streams.

Uses of StreamingRuntimeContext in org.apache.flink.streaming.connectors.kafka.shuffle

Methods in org.apache.flink.streaming.connectors.kafka.shuffle with parameters of type StreamingRuntimeContext

Modifier and Type	Method and Description
protected AbstractFetcher<T,?>	FlinkKafkaShuffleConsumer.createFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<WatermarkStrategy<T>> watermarkStrategy, StreamingRuntimeContext runtimeContext, OffsetCommitMode offsetCommitMode, MetricGroup consumerMetricGroup, boolean useMetrics)