Class and Description |
---|
Boundedness
The boundedness of a stream.
|
ReaderInfo
A container class hosting the information of a
SourceReader . |
ReaderOutput
The interface provided by the Flink runtime to the
SourceReader to emit records, and
optionally watermarks, to downstream operators for message processing. |
SourceEvent
An base class for the events passed between the SourceReaders and Enumerators.
|
SourceOutput
The
SourceOutput is the gateway for a SourceReader ) to emit the produced records
and watermarks. |
SourceReader
The interface for a source reader which is responsible for reading the records from the source
splits assigned by
SplitEnumerator . |
SourceReaderContext
The class that expose some context from runtime to the
SourceReader . |
SourceSplit
An interface for all the Split types to extend.
|
SplitEnumerator
A interface of a split enumerator responsible for the followings: 1.
|
SplitEnumeratorContext
A context class for the
SplitEnumerator . |
SplitsAssignment
A class containing the splits assignment to the source readers.
|
Class and Description |
---|
Boundedness
The boundedness of a stream.
|
Source
The interface for Source.
|
SourceReader
The interface for a source reader which is responsible for reading the records from the source
splits assigned by
SplitEnumerator . |
SourceReaderContext
The class that expose some context from runtime to the
SourceReader . |
SourceSplit
An interface for all the Split types to extend.
|
SplitEnumerator
A interface of a split enumerator responsible for the followings: 1.
|
SplitEnumeratorContext
A context class for the
SplitEnumerator . |
Class and Description |
---|
ReaderOutput
The interface provided by the Flink runtime to the
SourceReader to emit records, and
optionally watermarks, to downstream operators for message processing. |
SourceReader
The interface for a source reader which is responsible for reading the records from the source
splits assigned by
SplitEnumerator . |
SourceReaderContext
The class that expose some context from runtime to the
SourceReader . |
SourceSplit
An interface for all the Split types to extend.
|
SplitEnumerator
A interface of a split enumerator responsible for the followings: 1.
|
SplitEnumeratorContext
A context class for the
SplitEnumerator . |
Class and Description |
---|
Boundedness
The boundedness of a stream.
|
ReaderOutput
The interface provided by the Flink runtime to the
SourceReader to emit records, and
optionally watermarks, to downstream operators for message processing. |
Source
The interface for Source.
|
SourceEvent
An base class for the events passed between the SourceReaders and Enumerators.
|
SourceReader
The interface for a source reader which is responsible for reading the records from the source
splits assigned by
SplitEnumerator . |
SourceReaderContext
The class that expose some context from runtime to the
SourceReader . |
SourceSplit
An interface for all the Split types to extend.
|
SplitEnumerator
A interface of a split enumerator responsible for the followings: 1.
|
SplitEnumeratorContext
A context class for the
SplitEnumerator . |
Class and Description |
---|
ReaderOutput
The interface provided by the Flink runtime to the
SourceReader to emit records, and
optionally watermarks, to downstream operators for message processing. |
SourceEvent
An base class for the events passed between the SourceReaders and Enumerators.
|
SourceOutput
The
SourceOutput is the gateway for a SourceReader ) to emit the produced records
and watermarks. |
SourceReader
The interface for a source reader which is responsible for reading the records from the source
splits assigned by
SplitEnumerator . |
SourceReaderContext
The class that expose some context from runtime to the
SourceReader . |
SourceSplit
An interface for all the Split types to extend.
|
Class and Description |
---|
SourceSplit
An interface for all the Split types to extend.
|
Class and Description |
---|
SourceSplit
An interface for all the Split types to extend.
|
Class and Description |
---|
SourceSplit
An interface for all the Split types to extend.
|
Class and Description |
---|
Boundedness
The boundedness of a stream.
|
Source
The interface for Source.
|
SourceReader
The interface for a source reader which is responsible for reading the records from the source
splits assigned by
SplitEnumerator . |
SourceReaderContext
The class that expose some context from runtime to the
SourceReader . |
SourceSplit
An interface for all the Split types to extend.
|
SplitEnumerator
A interface of a split enumerator responsible for the followings: 1.
|
SplitEnumeratorContext
A context class for the
SplitEnumerator . |
Class and Description |
---|
SourceEvent
An base class for the events passed between the SourceReaders and Enumerators.
|
SourceReader
The interface for a source reader which is responsible for reading the records from the source
splits assigned by
SplitEnumerator . |
SourceReaderContext
The class that expose some context from runtime to the
SourceReader . |
SplitEnumerator
A interface of a split enumerator responsible for the followings: 1.
|
SplitEnumeratorContext
A context class for the
SplitEnumerator . |
Class and Description |
---|
Boundedness
The boundedness of a stream.
|
Source
The interface for Source.
|
SourceReader
The interface for a source reader which is responsible for reading the records from the source
splits assigned by
SplitEnumerator . |
SourceReaderContext
The class that expose some context from runtime to the
SourceReader . |
SplitEnumerator
A interface of a split enumerator responsible for the followings: 1.
|
SplitEnumeratorContext
A context class for the
SplitEnumerator . |
Class and Description |
---|
Boundedness
The boundedness of a stream.
|
SplitEnumerator
A interface of a split enumerator responsible for the followings: 1.
|
SplitEnumeratorContext
A context class for the
SplitEnumerator . |
Class and Description |
---|
SourceOutput
The
SourceOutput is the gateway for a SourceReader ) to emit the produced records
and watermarks. |
SourceReader
The interface for a source reader which is responsible for reading the records from the source
splits assigned by
SplitEnumerator . |
SourceReaderContext
The class that expose some context from runtime to the
SourceReader . |
Class and Description |
---|
SourceSplit
An interface for all the Split types to extend.
|
Class and Description |
---|
Boundedness
The boundedness of a stream.
|
Source
The interface for Source.
|
SourceReader
The interface for a source reader which is responsible for reading the records from the source
splits assigned by
SplitEnumerator . |
SourceReaderContext
The class that expose some context from runtime to the
SourceReader . |
SplitEnumerator
A interface of a split enumerator responsible for the followings: 1.
|
SplitEnumeratorContext
A context class for the
SplitEnumerator . |
Class and Description |
---|
SplitEnumerator
A interface of a split enumerator responsible for the followings: 1.
|
SplitEnumeratorContext
A context class for the
SplitEnumerator . |
Class and Description |
---|
SplitEnumeratorContext
A context class for the
SplitEnumerator . |
SplitsAssignment
A class containing the splits assignment to the source readers.
|
Class and Description |
---|
SourceReader
The interface for a source reader which is responsible for reading the records from the source
splits assigned by
SplitEnumerator . |
SourceReaderContext
The class that expose some context from runtime to the
SourceReader . |
Class and Description |
---|
SourceReaderContext
The class that expose some context from runtime to the
SourceReader . |
Class and Description |
---|
SourceOutput
The
SourceOutput is the gateway for a SourceReader ) to emit the produced records
and watermarks. |
Class and Description |
---|
ReaderOutput
The interface provided by the Flink runtime to the
SourceReader to emit records, and
optionally watermarks, to downstream operators for message processing. |
SourceReader
The interface for a source reader which is responsible for reading the records from the source
splits assigned by
SplitEnumerator . |
SourceReaderContext
The class that expose some context from runtime to the
SourceReader . |
Class and Description |
---|
SourceSplit
An interface for all the Split types to extend.
|
Class and Description |
---|
Boundedness
The boundedness of a stream.
|
ReaderInfo
A container class hosting the information of a
SourceReader . |
ReaderOutput
The interface provided by the Flink runtime to the
SourceReader to emit records, and
optionally watermarks, to downstream operators for message processing. |
SourceEvent
An base class for the events passed between the SourceReaders and Enumerators.
|
SourceOutput
The
SourceOutput is the gateway for a SourceReader ) to emit the produced records
and watermarks. |
SourceReader
The interface for a source reader which is responsible for reading the records from the source
splits assigned by
SplitEnumerator . |
SourceReaderContext
The class that expose some context from runtime to the
SourceReader . |
SourceSplit
An interface for all the Split types to extend.
|
SplitEnumeratorContext
A context class for the
SplitEnumerator . |
SplitsAssignment
A class containing the splits assignment to the source readers.
|
Class and Description |
---|
Source
The interface for Source.
|
SourceEvent
An base class for the events passed between the SourceReaders and Enumerators.
|
SplitEnumerator
A interface of a split enumerator responsible for the followings: 1.
|
SplitEnumeratorContext
A context class for the
SplitEnumerator . |
Class and Description |
---|
SourceSplit
An interface for all the Split types to extend.
|
Class and Description |
---|
Boundedness
The boundedness of a stream.
|
Source
The interface for Source.
|
Class and Description |
---|
ReaderInfo
A container class hosting the information of a
SourceReader . |
Source
The interface for Source.
|
SourceEvent
An base class for the events passed between the SourceReaders and Enumerators.
|
SourceSplit
An interface for all the Split types to extend.
|
SplitEnumeratorContext
A context class for the
SplitEnumerator . |
SplitsAssignment
A class containing the splits assignment to the source readers.
|
Class and Description |
---|
SourceEvent
An base class for the events passed between the SourceReaders and Enumerators.
|
Class and Description |
---|
Boundedness
The boundedness of a stream.
|
Source
The interface for Source.
|
Class and Description |
---|
Source
The interface for Source.
|
Class and Description |
---|
Boundedness
The boundedness of a stream.
|
Source
The interface for Source.
|
SourceReader
The interface for a source reader which is responsible for reading the records from the source
splits assigned by
SplitEnumerator . |
SourceReaderContext
The class that expose some context from runtime to the
SourceReader . |
SourceSplit
An interface for all the Split types to extend.
|
Class and Description |
---|
ReaderOutput
The interface provided by the Flink runtime to the
SourceReader to emit records, and
optionally watermarks, to downstream operators for message processing. |
SourceOutput
The
SourceOutput is the gateway for a SourceReader ) to emit the produced records
and watermarks. |
Class and Description |
---|
Boundedness
The boundedness of a stream.
|
Source
The interface for Source.
|
SourceSplit
An interface for all the Split types to extend.
|
Class and Description |
---|
SourceSplit
An interface for all the Split types to extend.
|
Class and Description |
---|
Source
The interface for Source.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.