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.
|
Class and Description |
---|
FileMonitoringFunction.WatchType
Deprecated.
|
FileProcessingMode
The mode in which the
ContinuousFileMonitoringFunction operates. |
SourceFunction
Base interface for all stream data sources in Flink.
|
Class and Description |
---|
FileMonitoringFunction.WatchType
Deprecated.
|
FileProcessingMode
The mode in which the
ContinuousFileMonitoringFunction operates. |
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.
|
TimestampedFileInputSplit
An extended
FileInputSplit that also includes information about:
The modification time of the file this split belongs to.
When checkpointing, the state of the split at the moment of the checkpoint.
This class is used by the ContinuousFileMonitoringFunction and the
ContinuousFileReaderOperator to perform continuous file processing. |
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.
|
Class and Description |
---|
SourceFunction.SourceContext
Interface that source functions use to emit elements, and possibly watermarks.
|
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.
|
Class and Description |
---|
SourceFunction.SourceContext
Interface that source functions use to emit elements, and possibly watermarks.
|
Class and Description |
---|
SourceFunction.SourceContext
Interface that source functions use to emit elements, and possibly watermarks.
|
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.
|
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.
|
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.
|
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.
|
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.
|
Class and Description |
---|
SourceFunction
Base interface for all stream data sources in Flink.
|
Class and Description |
---|
ParallelSourceFunction
A stream data source that is executed in parallel.
|
SourceFunction
Base interface for all stream data sources in Flink.
|
SourceFunction.SourceContext
Interface that source functions use to emit elements, and possibly watermarks.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.