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.internals

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.

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,?>	FlinkKafkaConsumer010.createFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, StreamingRuntimeContext runtimeContext, OffsetCommitMode offsetCommitMode, MetricGroup consumerMetricGroup, boolean useMetrics)
protected AbstractFetcher<T,?>	FlinkKafkaConsumer09.createFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, StreamingRuntimeContext runtimeContext, OffsetCommitMode offsetCommitMode, MetricGroup consumerMetricGroup, boolean useMetrics)
protected AbstractFetcher<T,?>	FlinkKafkaConsumer08.createFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, StreamingRuntimeContext runtimeContext, OffsetCommitMode offsetCommitMode, MetricGroup consumerMetricGroup, boolean useMetrics)
protected abstract AbstractFetcher<T,?>	FlinkKafkaConsumerBase.createFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> subscribedPartitionsToStartOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, 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.internals

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

Constructor and Description

Kafka08Fetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> seedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, StreamingRuntimeContext runtimeContext, KeyedDeserializationSchema<T> deserializer, Properties kafkaProperties, long autoCommitInterval, MetricGroup consumerMetricGroup, boolean useMetrics)