Uses of Interface
org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext

Packages that use SourceFunction.SourceContext

Package	Description
<Unnamed>
org.apache.flink.sql.tests
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.functions.source.datagen
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.connectors.gcp.pubsub
org.apache.flink.streaming.connectors.kafka
org.apache.flink.streaming.connectors.kafka.internals
org.apache.flink.streaming.connectors.kafka.shuffle
org.apache.flink.streaming.connectors.kinesis
org.apache.flink.streaming.connectors.kinesis.internals
org.apache.flink.streaming.connectors.nifi
org.apache.flink.streaming.connectors.rabbitmq
org.apache.flink.streaming.connectors.wikiedits
org.apache.flink.streaming.examples.async.util
org.apache.flink.streaming.examples.statemachine.generator
org.apache.flink.streaming.examples.windowing.util
org.apache.flink.streaming.tests
org.apache.flink.streaming.util
org.apache.flink.table.examples.java.connectors
org.apache.flink.table.runtime.arrow.sources
org.apache.flink.test

Uses of SourceFunction.SourceContext in <Unnamed>

Methods in <Unnamed> with parameters of type SourceFunction.SourceContext

Modifier and Type	Method and Description
void	FileSinkProgram.Generator.run(SourceFunction.SourceContext<Tuple2<Integer,Integer>> ctx)

Uses of SourceFunction.SourceContext in org.apache.flink.sql.tests

Methods in org.apache.flink.sql.tests with parameters of type SourceFunction.SourceContext

Modifier and Type	Method and Description
void	StreamSQLTestProgram.Generator.run(SourceFunction.SourceContext<Row> ctx)

Uses of SourceFunction.SourceContext in org.apache.flink.streaming.api.functions.source

Methods in org.apache.flink.streaming.api.functions.source with parameters of type SourceFunction.SourceContext

Modifier and Type	Method and Description
void	StatefulSequenceSource.run(SourceFunction.SourceContext<Long> ctx)
void	InputFormatSourceFunction.run(SourceFunction.SourceContext<OUT> ctx)
void	SocketTextStreamFunction.run(SourceFunction.SourceContext<String> ctx)
void	SourceFunction.run(SourceFunction.SourceContext<T> ctx) Starts the source.
void	FromIteratorFunction.run(SourceFunction.SourceContext<T> ctx)
void	FromSplittableIteratorFunction.run(SourceFunction.SourceContext<T> ctx)
void	FromElementsFunction.run(SourceFunction.SourceContext<T> ctx)
void	ContinuousFileMonitoringFunction.run(SourceFunction.SourceContext<TimestampedFileInputSplit> context)
void	FileMonitoringFunction.run(SourceFunction.SourceContext<Tuple3<String,Long,Long>> ctx) Deprecated.

Uses of SourceFunction.SourceContext in org.apache.flink.streaming.api.functions.source.datagen

Methods in org.apache.flink.streaming.api.functions.source.datagen with parameters of type SourceFunction.SourceContext

Modifier and Type	Method and Description
void	DataGeneratorSource.run(SourceFunction.SourceContext<T> ctx)

Uses of SourceFunction.SourceContext in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators that return SourceFunction.SourceContext

Modifier and Type	Method and Description
static <OUT> SourceFunction.SourceContext<OUT>	StreamSourceContexts.getSourceContext(TimeCharacteristic timeCharacteristic, ProcessingTimeService processingTimeService, Object checkpointLock, Output<StreamRecord<OUT>> output, long watermarkInterval, long idleTimeout, boolean emitProgressiveWatermarks) Depending on the TimeCharacteristic, this method will return the adequate SourceFunction.SourceContext.

Uses of SourceFunction.SourceContext in org.apache.flink.streaming.connectors.gcp.pubsub

Methods in org.apache.flink.streaming.connectors.gcp.pubsub with parameters of type SourceFunction.SourceContext

Modifier and Type	Method and Description
void	PubSubSource.run(SourceFunction.SourceContext<OUT> sourceContext)

Uses of SourceFunction.SourceContext in org.apache.flink.streaming.connectors.kafka

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

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) Deprecated.
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.
void	FlinkKafkaConsumerBase.run(SourceFunction.SourceContext<T> sourceContext)

Uses of SourceFunction.SourceContext in org.apache.flink.streaming.connectors.kafka.internals

Fields in org.apache.flink.streaming.connectors.kafka.internals declared as SourceFunction.SourceContext

Modifier and Type	Field and Description
protected SourceFunction.SourceContext<T>	AbstractFetcher.sourceContext The source context to emit records and watermarks to.

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

Constructor and Description
AbstractFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> seedPartitionsWithInitialOffsets, SerializedValue<WatermarkStrategy<T>> watermarkStrategy, ProcessingTimeService processingTimeProvider, long autoWatermarkInterval, ClassLoader userCodeClassLoader, MetricGroup consumerMetricGroup, boolean useMetrics)
KafkaFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<WatermarkStrategy<T>> watermarkStrategy, ProcessingTimeService processingTimeProvider, long autoWatermarkInterval, ClassLoader userCodeClassLoader, String taskNameWithSubtasks, KafkaDeserializationSchema<T> deserializer, Properties kafkaProperties, long pollTimeout, MetricGroup subtaskMetricGroup, MetricGroup consumerMetricGroup, boolean useMetrics)
KafkaShuffleFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<WatermarkStrategy<T>> watermarkStrategy, ProcessingTimeService processingTimeProvider, long autoWatermarkInterval, ClassLoader userCodeClassLoader, String taskNameWithSubtasks, KafkaDeserializationSchema<T> deserializer, Properties kafkaProperties, long pollTimeout, MetricGroup subtaskMetricGroup, MetricGroup consumerMetricGroup, boolean useMetrics, TypeSerializer<T> typeSerializer, int producerParallelism)
SourceContextWatermarkOutputAdapter(SourceFunction.SourceContext<T> sourceContext)

Uses of SourceFunction.SourceContext in org.apache.flink.streaming.connectors.kafka.shuffle

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

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)

Uses of SourceFunction.SourceContext in org.apache.flink.streaming.connectors.kinesis

Methods in org.apache.flink.streaming.connectors.kinesis with parameters of type SourceFunction.SourceContext

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.
void	FlinkKinesisConsumer.run(SourceFunction.SourceContext<T> sourceContext)

Uses of SourceFunction.SourceContext in org.apache.flink.streaming.connectors.kinesis.internals

Constructors in org.apache.flink.streaming.connectors.kinesis.internals with parameters of type SourceFunction.SourceContext

Constructor and Description
DynamoDBStreamsDataFetcher(List<String> streams, SourceFunction.SourceContext<T> sourceContext, RuntimeContext runtimeContext, Properties configProps, KinesisDeserializationSchema<T> deserializationSchema, KinesisShardAssigner shardAssigner) Constructor.
KinesisDataFetcher(List<String> streams, SourceFunction.SourceContext<T> sourceContext, Object checkpointLock, RuntimeContext runtimeContext, Properties configProps, KinesisDeserializationSchema<T> deserializationSchema, KinesisShardAssigner shardAssigner, AssignerWithPeriodicWatermarks<T> periodicWatermarkAssigner, WatermarkTracker watermarkTracker, AtomicReference<Throwable> error, List<KinesisStreamShardState> subscribedShardsState, HashMap<String,String> subscribedStreamsToLastDiscoveredShardIds, KinesisDataFetcher.FlinkKinesisProxyFactory kinesisProxyFactory, KinesisDataFetcher.FlinkKinesisProxyV2Factory kinesisProxyV2Factory)
KinesisDataFetcher(List<String> streams, SourceFunction.SourceContext<T> sourceContext, RuntimeContext runtimeContext, Properties configProps, KinesisDeserializationSchema<T> deserializationSchema, KinesisShardAssigner shardAssigner, AssignerWithPeriodicWatermarks<T> periodicWatermarkAssigner, WatermarkTracker watermarkTracker) Creates a Kinesis Data Fetcher.

Uses of SourceFunction.SourceContext in org.apache.flink.streaming.connectors.nifi

Methods in org.apache.flink.streaming.connectors.nifi with parameters of type SourceFunction.SourceContext

Modifier and Type	Method and Description
void	NiFiSource.run(SourceFunction.SourceContext<NiFiDataPacket> ctx) Deprecated.

Uses of SourceFunction.SourceContext in org.apache.flink.streaming.connectors.rabbitmq

Methods in org.apache.flink.streaming.connectors.rabbitmq with parameters of type SourceFunction.SourceContext

Modifier and Type	Method and Description
void	RMQSource.run(SourceFunction.SourceContext<OUT> ctx)

Uses of SourceFunction.SourceContext in org.apache.flink.streaming.connectors.wikiedits

Methods in org.apache.flink.streaming.connectors.wikiedits with parameters of type SourceFunction.SourceContext

Modifier and Type	Method and Description
void	WikipediaEditsSource.run(SourceFunction.SourceContext<WikipediaEditEvent> ctx)

Uses of SourceFunction.SourceContext in org.apache.flink.streaming.examples.async.util

Methods in org.apache.flink.streaming.examples.async.util with parameters of type SourceFunction.SourceContext

Modifier and Type	Method and Description
void	SimpleSource.run(SourceFunction.SourceContext<Integer> ctx)

Uses of SourceFunction.SourceContext in org.apache.flink.streaming.examples.statemachine.generator

Methods in org.apache.flink.streaming.examples.statemachine.generator with parameters of type SourceFunction.SourceContext

Modifier and Type	Method and Description
void	EventsGeneratorSource.run(SourceFunction.SourceContext<Event> sourceContext)

Uses of SourceFunction.SourceContext in org.apache.flink.streaming.examples.windowing.util

Methods in org.apache.flink.streaming.examples.windowing.util with parameters of type SourceFunction.SourceContext

Modifier and Type	Method and Description
void	CarSource.run(SourceFunction.SourceContext<Tuple4<Integer,Integer,Double,Long>> ctx)

Uses of SourceFunction.SourceContext in org.apache.flink.streaming.tests

Methods in org.apache.flink.streaming.tests with parameters of type SourceFunction.SourceContext

Modifier and Type	Method and Description
void	SequenceGeneratorSource.run(SourceFunction.SourceContext<Event> ctx)
void	PeriodicStreamingJob.PeriodicSourceGenerator.run(SourceFunction.SourceContext<Tuple> ctx)

Uses of SourceFunction.SourceContext in org.apache.flink.streaming.util

Methods in org.apache.flink.streaming.util with parameters of type SourceFunction.SourceContext

Modifier and Type	Method and Description
void	FiniteTestSource.run(SourceFunction.SourceContext<T> ctx)

Uses of SourceFunction.SourceContext in org.apache.flink.table.examples.java.connectors

Methods in org.apache.flink.table.examples.java.connectors with parameters of type SourceFunction.SourceContext

Modifier and Type	Method and Description
void	SocketSourceFunction.run(SourceFunction.SourceContext<RowData> ctx)

Uses of SourceFunction.SourceContext in org.apache.flink.table.runtime.arrow.sources

Methods in org.apache.flink.table.runtime.arrow.sources with parameters of type SourceFunction.SourceContext

Modifier and Type	Method and Description
void	ArrowSourceFunction.run(SourceFunction.SourceContext<RowData> ctx)

Uses of SourceFunction.SourceContext in org.apache.flink.test

Methods in org.apache.flink.test with parameters of type SourceFunction.SourceContext

Modifier and Type	Method and Description
void	StatefulStreamingJob.MySource.run(SourceFunction.SourceContext<Integer> ctx)