public interface TableScan extends Scan<TableScan,FileScanTask,CombinedScanTask>
Modifier and Type | Method and Description |
---|---|
default TableScan |
appendsAfter(long fromSnapshotId)
Deprecated.
since 1.0.0, will be removed in 2.0.0; use
Table.newIncrementalAppendScan()
instead. |
default TableScan |
appendsBetween(long fromSnapshotId,
long toSnapshotId)
Deprecated.
since 1.0.0, will be removed in 2.0.0; use
Table.newIncrementalAppendScan()
instead. |
TableScan |
asOfTime(long timestampMillis)
Create a new
TableScan from this scan's configuration that will use the most recent
snapshot as of the given time in milliseconds on the branch in the scan or main if no branch is
set. |
Snapshot |
snapshot()
Returns the
Snapshot that will be used by this scan. |
Table |
table()
Returns the
Table from which this scan loads data. |
default TableScan |
useRef(java.lang.String ref)
Create a new
TableScan from this scan's configuration that will use the given
reference. |
TableScan |
useSnapshot(long snapshotId)
Create a new
TableScan from this scan's configuration that will use the given snapshot
by ID. |
caseSensitive, filter, filter, ignoreResiduals, includeColumnStats, isCaseSensitive, metricsReporter, option, planFiles, planTasks, planWith, project, schema, select, select, splitLookback, splitOpenFileCost, targetSplitSize
TableScan useSnapshot(long snapshotId)
TableScan
from this scan's configuration that will use the given snapshot
by ID.snapshotId
- a snapshot IDjava.lang.IllegalArgumentException
- if the snapshot cannot be founddefault TableScan useRef(java.lang.String ref)
TableScan
from this scan's configuration that will use the given
reference.ref
- referencejava.lang.IllegalArgumentException
- if a reference with the given name could not be foundTableScan asOfTime(long timestampMillis)
TableScan
from this scan's configuration that will use the most recent
snapshot as of the given time in milliseconds on the branch in the scan or main if no branch is
set.timestampMillis
- a timestamp in milliseconds.java.lang.IllegalArgumentException
- if the snapshot cannot be found or time travel is attempted on
a tag@Deprecated default TableScan appendsBetween(long fromSnapshotId, long toSnapshotId)
Table.newIncrementalAppendScan()
instead.TableScan
to read appended data from fromSnapshotId
exclusive to
toSnapshotId
inclusive.fromSnapshotId
- the last snapshot id read by the user, exclusivetoSnapshotId
- read append data up to this snapshot idfromSnapshotId
exclusive and up to
toSnapshotId
inclusive@Deprecated default TableScan appendsAfter(long fromSnapshotId)
Table.newIncrementalAppendScan()
instead.TableScan
to read appended data from fromSnapshotId
exclusive to
the current snapshot inclusive.fromSnapshotId
- - the last snapshot id read by the user, exclusivefromSnapshotId
exclusive and up to
current snapshot inclusiveSnapshot snapshot()
Snapshot
that will be used by this scan.
If the snapshot was not configured using asOfTime(long)
or useSnapshot(long)
, the current table snapshot will be used.