org.apache.paimon.table.source.snapshot

Interface BoundedChecker

public interface BoundedChecker

Checker to check whether the bounded stream is end.

Method Summary

Modifier and Type	Method and Description
static BoundedChecker	neverEnd()
boolean	shouldEndInput(Snapshot snapshot)
static BoundedChecker	watermark(long boundedWatermark)

Method Detail

shouldEndInput

boolean shouldEndInput(Snapshot snapshot)

neverEnd

static BoundedChecker neverEnd()

watermark

static BoundedChecker watermark(long boundedWatermark)