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)
static boolean	supportCompactDiffStreamingReading(Table table) Check whether streaming reading is supported based on the data changed before and after compact.

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.

supportCompactDiffStreamingReading

public static boolean supportCompactDiffStreamingReading(Table table)

Check whether streaming reading is supported based on the data changed before and after compact.