Package | Description |
---|---|
org.apache.flink.table.store.connector.source | |
org.apache.flink.table.store.table.source.snapshot |
Class and Description |
---|
ContinuousDataFileSnapshotEnumerator.Factory
Factory to create
ContinuousDataFileSnapshotEnumerator . |
SnapshotEnumerator
Enumerate incremental changes from newly created snapshots.
|
StaticDataFileSnapshotEnumerator.Factory
Factory to create
StaticDataFileSnapshotEnumerator . |
Class and Description |
---|
ContinuousDataFileSnapshotEnumerator
SnapshotEnumerator for streaming read. |
FollowUpScanner
Helper class for the follow-up enumeration of a
SnapshotEnumerator . |
SnapshotEnumerator
Enumerate incremental changes from newly created snapshots.
|
StartingScanner
Helper class for the first enumeration of a
SnapshotEnumerator . |
StaticDataFileSnapshotEnumerator
SnapshotEnumerator for batch read. |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.