org.apache.paimon.table.source

Interface StreamTableScan

All Superinterfaces:

Restorable<Long>, TableScan

All Known Subinterfaces:

StreamDataTableScan

All Known Implementing Classes:

DataTableStreamScan, LookupDataTableScan

@Public
public interface StreamTableScan
extends TableScan, Restorable<Long>

TableScan for streaming, supports checkpoint() and restore(java.lang.Long).

NOTE: checkpoint() will return the next snapshot id.

Since:

0.4.0

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.table.source.TableScan

TableScan.Plan

Method Summary

Modifier and Type	Method and Description
Long	checkpoint() Checkpoint to return next snapshot id.
void	notifyCheckpointComplete(Long nextSnapshot) Notifies the checkpoint complete with next snapshot id.
void	restore(Long nextSnapshotId) Restore from checkpoint next snapshot id.
Long	watermark() Current watermark for consumed snapshot.

Methods inherited from interface org.apache.paimon.table.source.TableScan

listPartitionEntries, listPartitions, plan

Method Detail

watermark

@Nullable
Long watermark()

Current watermark for consumed snapshot.

restore

void restore(@Nullable
             Long nextSnapshotId)

Restore from checkpoint next snapshot id.

Specified by:

restore in interface Restorable<Long>

checkpoint

@Nullable
Long checkpoint()

Checkpoint to return next snapshot id.

Specified by:

checkpoint in interface Restorable<Long>

notifyCheckpointComplete

void notifyCheckpointComplete(@Nullable
                              Long nextSnapshot)

Notifies the checkpoint complete with next snapshot id.