org.apache.iceberg

Interface TableScan

All Superinterfaces:

Scan<TableScan,FileScanTask,CombinedScanTask>

All Known Implementing Classes:

AllDataFilesTable.AllDataFilesTableScan, AllDeleteFilesTable.AllDeleteFilesTableScan, AllFilesTable.AllFilesTableScan, AllManifestsTable.AllManifestsTableScan, DataFilesTable.DataFilesTableScan, DataTableScan, DeleteFilesTable.DeleteFilesTableScan, FilesTable.FilesTableScan

public interface TableScan
extends Scan<TableScan,FileScanTask,CombinedScanTask>

API for configuring a table scan.

Method Summary

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.

Methods inherited from interface org.apache.iceberg.Scan

caseSensitive, filter, filter, ignoreResiduals, includeColumnStats, isCaseSensitive, option, planFiles, planTasks, planWith, project, schema, select, select, splitLookback, splitOpenFileCost, targetSplitSize

Method Detail

table

Table table()

Returns the Table from which this scan loads data.

Returns:

this scan's table

useSnapshot

TableScan useSnapshot(long snapshotId)

Create a new TableScan from this scan's configuration that will use the given snapshot by ID.

Parameters:

snapshotId - a snapshot ID

Returns:

a new scan based on this with the given snapshot ID

Throws:

java.lang.IllegalArgumentException - if the snapshot cannot be found

useRef

default TableScan useRef(java.lang.String ref)

Create a new TableScan from this scan's configuration that will use the given reference.

Parameters:

ref - reference

Returns:

a new scan based on the given reference.

Throws:

java.lang.IllegalArgumentException - if a reference with the given name could not be found

asOfTime

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.

Parameters:

timestampMillis - a timestamp in milliseconds.

Returns:

a new scan based on this with the current snapshot at the given time

Throws:

java.lang.IllegalArgumentException - if the snapshot cannot be found or time travel is attempted on a tag

appendsBetween

@Deprecated
default TableScan appendsBetween(long fromSnapshotId,
                                             long toSnapshotId)

Deprecated. since 1.0.0, will be removed in 2.0.0; use Table.newIncrementalAppendScan() instead.

Create a new TableScan to read appended data from fromSnapshotId exclusive to toSnapshotId inclusive.

Parameters:

fromSnapshotId - the last snapshot id read by the user, exclusive

toSnapshotId - read append data up to this snapshot id

Returns:

a table scan which can read append data from fromSnapshotId exclusive and up to toSnapshotId inclusive

appendsAfter

@Deprecated
default TableScan appendsAfter(long fromSnapshotId)

Deprecated. since 1.0.0, will be removed in 2.0.0; use Table.newIncrementalAppendScan() instead.

Create a new TableScan to read appended data from fromSnapshotId exclusive to the current snapshot inclusive.

Parameters:

fromSnapshotId - - the last snapshot id read by the user, exclusive

Returns:

a table scan which can read append data from fromSnapshotId exclusive and up to current snapshot inclusive

snapshot

Snapshot snapshot()

Returns the 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.

Returns:

the Snapshot this scan will use