Class | Description |
---|---|
CompactorSourceBuilder |
Source builder to build a Flink
StaticFileStoreSource or ContinuousFileStoreSource . |
ContinuousFileSplitEnumerator |
A continuously monitoring enumerator.
|
ContinuousFileStoreSource |
Unbounded
FlinkSource for reading records. |
FileStoreSourceReader |
A
SourceReader that read records from FileStoreSourceSplit . |
FileStoreSourceSplit |
SourceSplit of file store. |
FileStoreSourceSplitGenerator |
The
FileStoreSplitGenerator 's task is to plan all files to be read and to split them into
a set of FileStoreSourceSplit . |
FileStoreSourceSplitReader |
The
SplitReader implementation for the file store source. |
FileStoreSourceSplitSerializer |
A
SimpleVersionedSerializer for FileStoreSourceSplit . |
FileStoreSourceSplitState |
State of the reader, essentially a mutable version of the
FileStoreSourceSplit . |
FlinkSource |
A Flink
Source for table store. |
FlinkSourceBuilder |
Source builder to build a Flink
StaticFileStoreSource or ContinuousFileStoreSource . |
FlinkTableSource |
A Flink
ScanTableSource for table store. |
LogHybridSourceFactory |
Log
HybridSource.SourceFactory from StaticFileStoreSplitEnumerator . |
PendingSplitsCheckpoint |
A checkpoint of the current state of the containing the currently pending splits that are not yet
assigned.
|
PendingSplitsCheckpointSerializer |
A
SimpleVersionedSerializer for PendingSplitsCheckpoint . |
SimpleSystemSource |
A
FlinkSource for system table. |
StaticFileStoreSource |
Bounded
FlinkSource for reading records. |
StaticFileStoreSplitEnumerator |
A
SplitEnumerator implementation for StaticFileStoreSource input. |
SystemTableSource |
A
FlinkTableSource for system table. |
TableStoreSource |
Table source to create
StaticFileStoreSource or ContinuousFileStoreSource under
batch mode or change-tracking is disabled. |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.