Uses of Package
org.apache.flink.streaming.api.functions.source

Packages that use org.apache.flink.streaming.api.functions.source

Package	Description
org.apache.flink.storm.wrappers
org.apache.flink.streaming.api.environment
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.scala
org.apache.flink.streaming.connectors.kafka
org.apache.flink.streaming.connectors.kafka.internals
org.apache.flink.streaming.connectors.nifi
org.apache.flink.streaming.connectors.rabbitmq
org.apache.flink.streaming.connectors.twitter
org.apache.flink.streaming.connectors.wikiedits
org.apache.flink.streaming.examples.join
org.apache.flink.streaming.examples.ml
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.

Classes in org.apache.flink.streaming.api.functions.source used by org.apache.flink.storm.wrappers

Class and Description
ParallelSourceFunction A stream data source that is executed in parallel.
RichParallelSourceFunction Base class for implementing a parallel data source.
SourceFunction Base interface for all stream data sources in Flink.
SourceFunction.SourceContext Interface that source functions use to emit elements, and possibly watermarks.

Classes in org.apache.flink.streaming.api.functions.source used by org.apache.flink.streaming.api.environment

Class and Description
FileMonitoringFunction.WatchType
SourceFunction Base interface for all stream data sources in Flink.

Classes in org.apache.flink.streaming.api.functions.source used by org.apache.flink.streaming.api.functions.source

Class and Description
FileMonitoringFunction.WatchType
MessageAcknowledgingSourceBase Abstract base class for data sources that receive elements from a message queue and acknowledge them back by IDs.
ParallelSourceFunction A stream data source that is executed in parallel.
RichParallelSourceFunction Base class for implementing a parallel data source.
RichSourceFunction Base class for implementing a parallel data source that has access to context information (via AbstractRichFunction.getRuntimeContext()) and additional life-cycle methods (AbstractRichFunction.open(org.apache.flink.configuration.Configuration) and AbstractRichFunction.close().
SourceFunction Base interface for all stream data sources in Flink.
SourceFunction.SourceContext Interface that source functions use to emit elements, and possibly watermarks.

Classes in org.apache.flink.streaming.api.functions.source used by org.apache.flink.streaming.api.operators

Class and Description
SourceFunction Base interface for all stream data sources in Flink.
SourceFunction.SourceContext Interface that source functions use to emit elements, and possibly watermarks.

Classes in org.apache.flink.streaming.api.functions.source used by org.apache.flink.streaming.api.scala

Class and Description
SourceFunction.SourceContext Interface that source functions use to emit elements, and possibly watermarks.

Classes in org.apache.flink.streaming.api.functions.source used by org.apache.flink.streaming.connectors.kafka

Class and Description
ParallelSourceFunction A stream data source that is executed in parallel.
RichParallelSourceFunction Base class for implementing a parallel data source.
SourceFunction Base interface for all stream data sources in Flink.
SourceFunction.SourceContext Interface that source functions use to emit elements, and possibly watermarks.

Classes in org.apache.flink.streaming.api.functions.source used by org.apache.flink.streaming.connectors.kafka.internals

Class and Description
SourceFunction.SourceContext Interface that source functions use to emit elements, and possibly watermarks.

Classes in org.apache.flink.streaming.api.functions.source used by org.apache.flink.streaming.connectors.nifi

Class and Description
ParallelSourceFunction A stream data source that is executed in parallel.
RichParallelSourceFunction Base class for implementing a parallel data source.
SourceFunction Base interface for all stream data sources in Flink.
SourceFunction.SourceContext Interface that source functions use to emit elements, and possibly watermarks.

Classes in org.apache.flink.streaming.api.functions.source used by org.apache.flink.streaming.connectors.rabbitmq

Class and Description
MessageAcknowledgingSourceBase Abstract base class for data sources that receive elements from a message queue and acknowledge them back by IDs.
MultipleIdsMessageAcknowledgingSourceBase Abstract base class for data sources that receive elements from a message queue and acknowledge them back by IDs.
RichSourceFunction Base class for implementing a parallel data source that has access to context information (via AbstractRichFunction.getRuntimeContext()) and additional life-cycle methods (AbstractRichFunction.open(org.apache.flink.configuration.Configuration) and AbstractRichFunction.close().
SourceFunction Base interface for all stream data sources in Flink.
SourceFunction.SourceContext Interface that source functions use to emit elements, and possibly watermarks.

Classes in org.apache.flink.streaming.api.functions.source used by org.apache.flink.streaming.connectors.twitter

Class and Description
RichSourceFunction Base class for implementing a parallel data source that has access to context information (via AbstractRichFunction.getRuntimeContext()) and additional life-cycle methods (AbstractRichFunction.open(org.apache.flink.configuration.Configuration) and AbstractRichFunction.close().
SourceFunction Base interface for all stream data sources in Flink.
SourceFunction.SourceContext Interface that source functions use to emit elements, and possibly watermarks.

Classes in org.apache.flink.streaming.api.functions.source used by org.apache.flink.streaming.connectors.wikiedits

Class and Description
RichSourceFunction Base class for implementing a parallel data source that has access to context information (via AbstractRichFunction.getRuntimeContext()) and additional life-cycle methods (AbstractRichFunction.open(org.apache.flink.configuration.Configuration) and AbstractRichFunction.close().
SourceFunction Base interface for all stream data sources in Flink.
SourceFunction.SourceContext Interface that source functions use to emit elements, and possibly watermarks.

Classes in org.apache.flink.streaming.api.functions.source used by org.apache.flink.streaming.examples.join

Class and Description
RichSourceFunction Base class for implementing a parallel data source that has access to context information (via AbstractRichFunction.getRuntimeContext()) and additional life-cycle methods (AbstractRichFunction.open(org.apache.flink.configuration.Configuration) and AbstractRichFunction.close().
SourceFunction Base interface for all stream data sources in Flink.
SourceFunction.SourceContext Interface that source functions use to emit elements, and possibly watermarks.

Classes in org.apache.flink.streaming.api.functions.source used by org.apache.flink.streaming.examples.ml

Class and Description
SourceFunction Base interface for all stream data sources in Flink.
SourceFunction.SourceContext Interface that source functions use to emit elements, and possibly watermarks.

Classes in org.apache.flink.streaming.api.functions.source used by org.apache.flink.streaming.runtime.tasks

Class and Description
SourceFunction Base interface for all stream data sources in Flink.