Uses of Class
org.apache.flink.table.planner.plan.abilities.source.WatermarkPushDownSpec

Packages that use WatermarkPushDownSpec

Package	Description
org.apache.flink.table.planner.plan.abilities.source
org.apache.flink.table.planner.plan.reuse

Uses of WatermarkPushDownSpec in org.apache.flink.table.planner.plan.abilities.source

Methods in org.apache.flink.table.planner.plan.abilities.source that return WatermarkPushDownSpec

Modifier and Type	Method and Description
WatermarkPushDownSpec	WatermarkPushDownSpec.copy(org.apache.calcite.rex.RexNode watermarkExpr, org.apache.flink.table.types.logical.RowType producedType)

Uses of WatermarkPushDownSpec in org.apache.flink.table.planner.plan.reuse

Methods in org.apache.flink.table.planner.plan.reuse that return types with arguments of type WatermarkPushDownSpec

Modifier and Type	Method and Description
static Optional<WatermarkPushDownSpec>	ScanReuserUtils.getAdjustedWatermarkSpec(TableSourceTable table, org.apache.flink.table.types.logical.RowType oldSourceType, org.apache.flink.table.types.logical.RowType newSourceType) Watermark push down must be after projection push down, so we need to adjust its index.