Package | Description |
---|---|
org.apache.paimon.flink.lookup | |
org.apache.paimon.table.source | |
org.apache.paimon.table.source.snapshot |
Modifier and Type | Method and Description |
---|---|
protected BoundedChecker |
LookupDataTableScan.createBoundedChecker() |
Modifier and Type | Method and Description |
---|---|
protected BoundedChecker |
DataTableStreamScan.createBoundedChecker() |
Modifier and Type | Method and Description |
---|---|
static BoundedChecker |
BoundedChecker.neverEnd() |
static BoundedChecker |
BoundedChecker.watermark(long boundedWatermark) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.