org.apache.paimon.table

Class KnownSplitsTable

java.lang.Object

org.apache.paimon.table.KnownSplitsTable

All Implemented Interfaces:

Serializable, InnerTable, ReadonlyTable, Table

public class KnownSplitsTable
extends Object
implements ReadonlyTable

A table to hold some known data splits. For now, it is only used by internal for Spark engine.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
Table	copy(Map<String,String> dynamicOptions) Copy this table with adding dynamic options.
static KnownSplitsTable	create(InnerTable origin, DataSplit[] splits)
String	name() A name to identify this table.
InnerTableRead	newRead()
InnerTableScan	newScan()
Map<String,String>	options() Options of this table.
List<String>	partitionKeys() Partition keys of this table.
List<String>	primaryKeys() Primary keys of this table.
RowType	rowType() Returns the row type of this table.
DataSplit[]	splits()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.paimon.table.ReadonlyTable

comment, createBranch, createBranch, createTag, createTag, createTag, createTag, deleteBranch, deleteTag, fastForward, indexManifestFileReader, latestSnapshotId, manifestFileReader, manifestListReader, newBatchWriteBuilder, newCommit, newExpireChangelog, newExpireSnapshots, newStreamScan, newStreamWriteBuilder, newWrite, newWriteSelector, renameTag, replaceTag, rollbackTo, rollbackTo, snapshot, statistics

Methods inherited from interface org.apache.paimon.table.InnerTable

newReadBuilder

Methods inherited from interface org.apache.paimon.table.Table

deleteBranches, deleteTags, fullName

Method Detail

create

public static KnownSplitsTable create(InnerTable origin,
                                      DataSplit[] splits)

splits

public DataSplit[] splits()

name

public String name()

Description copied from interface: Table

A name to identify this table.

Specified by:

name in interface Table

rowType

public RowType rowType()

Description copied from interface: Table

Returns the row type of this table.

Specified by:

rowType in interface Table

primaryKeys

public List<String> primaryKeys()

Description copied from interface: Table

Primary keys of this table.

Specified by:

primaryKeys in interface Table

partitionKeys

public List<String> partitionKeys()

Description copied from interface: Table

Partition keys of this table.

Specified by:

partitionKeys in interface ReadonlyTable

Specified by:

partitionKeys in interface Table

options

public Map<String,String> options()

Description copied from interface: Table

Options of this table.

Specified by:

options in interface ReadonlyTable

Specified by:

options in interface Table

newRead

public InnerTableRead newRead()

Specified by:

newRead in interface InnerTable

newScan

public InnerTableScan newScan()

Specified by:

newScan in interface InnerTable

copy

public Table copy(Map<String,String> dynamicOptions)

Description copied from interface: Table

Copy this table with adding dynamic options.

Specified by:

copy in interface Table