org.apache.paimon.flink.utils

Class TableScanUtils

java.lang.Object

org.apache.paimon.flink.utils.TableScanUtils

public class TableScanUtils
extends Object

Utility methods for TableScan, such as validating.

Constructor Summary

Constructors

Constructor and Description
TableScanUtils()

Method Summary

Modifier and Type	Method and Description
static Optional<Long>	getSnapshotId(FileStoreSourceSplit split) Get snapshot id from FileStoreSourceSplit.
static void	streamingReadingValidate(Table table)

Methods inherited from class java.lang.Object

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

Constructor Detail

TableScanUtils

public TableScanUtils()

Method Detail

streamingReadingValidate

public static void streamingReadingValidate(Table table)

getSnapshotId

public static Optional<Long> getSnapshotId(FileStoreSourceSplit split)

Get snapshot id from FileStoreSourceSplit.