Package | Description |
---|---|
org.apache.flink.table.store.connector.source |
Class and Description |
---|
CompactorSourceBuilder
Source builder to build a Flink
StaticFileStoreSource or ContinuousFileStoreSource . |
FileStoreSourceSplit
SourceSplit of file store. |
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. |
PendingSplitsCheckpoint
A checkpoint of the current state of the containing the currently pending splits that are not yet
assigned.
|
PendingSplitsCheckpointSerializer
A
SimpleVersionedSerializer for PendingSplitsCheckpoint . |
StaticFileStoreSplitEnumerator
A
SplitEnumerator implementation for StaticFileStoreSource input. |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.