public class ContinuousDataFileSnapshotEnumerator extends Object implements SnapshotEnumerator
SnapshotEnumerator
for streaming read.Modifier and Type | Class and Description |
---|---|
static interface |
ContinuousDataFileSnapshotEnumerator.Factory
Factory to create
ContinuousDataFileSnapshotEnumerator . |
Constructor and Description |
---|
ContinuousDataFileSnapshotEnumerator(org.apache.flink.core.fs.Path tablePath,
DataTableScan scan,
StartingScanner startingScanner,
FollowUpScanner followUpScanner,
Long nextSnapshotId) |
Modifier and Type | Method and Description |
---|---|
static ContinuousDataFileSnapshotEnumerator |
create(DataTable table,
DataTableScan scan,
Long nextSnapshotId) |
static ContinuousDataFileSnapshotEnumerator |
createWithSnapshotStarting(DataTable table,
DataTableScan scan) |
DataTableScan.DataFilePlan |
enumerate()
The first call to this method will produce a
DataTableScan.DataFilePlan containing
the base files for the following incremental changes (or just return null if there are no
base files). |
static void |
validate(TableSchema schema) |
public ContinuousDataFileSnapshotEnumerator(org.apache.flink.core.fs.Path tablePath, DataTableScan scan, StartingScanner startingScanner, FollowUpScanner followUpScanner, @Nullable Long nextSnapshotId)
@Nullable public DataTableScan.DataFilePlan enumerate()
SnapshotEnumerator
DataTableScan.DataFilePlan
containing
the base files for the following incremental changes (or just return null if there are no
base files).
Following calls to this method will produce DataTableScan.DataFilePlan
s containing
incremental changed files. If there is currently no newer snapshots, null will be returned
instead.
enumerate
in interface SnapshotEnumerator
public static ContinuousDataFileSnapshotEnumerator createWithSnapshotStarting(DataTable table, DataTableScan scan)
public static ContinuousDataFileSnapshotEnumerator create(DataTable table, DataTableScan scan, @Nullable Long nextSnapshotId)
public static void validate(TableSchema schema)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.