Class and Description |
---|
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.
|
TimestampedInputSplit
An extended
InputSplit that also includes information about:
The modification time of the file this split belongs to. |
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 |
---|
FileMonitoringFunction.WatchType
Deprecated.
The watch type of the
FileMonitoringFunction . |
FileProcessingMode
The mode in which the
ContinuousFileMonitoringFunction operates. |
SourceFunction
Base interface for all stream data sources in Flink.
|
Class and Description |
---|
FileMonitoringFunction.WatchType
Deprecated.
The watch type of the
FileMonitoringFunction . |
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
A
FileInputSplit with TimestampedInputSplit . |
TimestampedInputSplit
An extended
InputSplit that also includes information about:
The modification time of the file this split belongs to. |
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 |
---|
InputFormatSourceFunction
A
SourceFunction that reads data using an InputFormat . |
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 |
---|
ParallelSourceFunction
A stream data source that is executed in parallel.
|
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 |
---|
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 |
---|
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 |
---|
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 |
---|
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
Base interface for all stream data sources in Flink.
|
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
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 |
---|
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 |
---|
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 |
---|
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 |
---|
FromIteratorFunction
A
SourceFunction that reads elements from an Iterator and emits them. |
SourceFunction
Base interface for all stream data sources in Flink.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.