public class WatermarkPushDownSpec extends SourceAbilitySpecBase
SourceAbilitySpec
that can not only serialize/deserialize the watermark
to/from JSON, but also can push the watermark into a SupportsWatermarkPushDown
.Modifier and Type | Class and Description |
---|---|
static class |
WatermarkPushDownSpec.DefaultWatermarkGeneratorSupplier
Wrapper of the
GeneratedWatermarkGenerator that is used to create WatermarkGenerator . |
Modifier and Type | Field and Description |
---|---|
static String |
FIELD_NAME_IDLE_TIMEOUT_MILLIS |
static String |
FIELD_NAME_WATERMARK_EXPR |
FIELD_NAME_PRODUCED_TYPE
Constructor and Description |
---|
WatermarkPushDownSpec(org.apache.calcite.rex.RexNode watermarkExpr,
long idleTimeoutMillis,
RowType producedType) |
Modifier and Type | Method and Description |
---|---|
void |
apply(DynamicTableSource tableSource,
SourceAbilityContext context)
Apply the ability to the given
DynamicTableSource . |
getProducedType
public static final String FIELD_NAME_WATERMARK_EXPR
public static final String FIELD_NAME_IDLE_TIMEOUT_MILLIS
public WatermarkPushDownSpec(org.apache.calcite.rex.RexNode watermarkExpr, long idleTimeoutMillis, RowType producedType)
public void apply(DynamicTableSource tableSource, SourceAbilityContext context)
SourceAbilitySpec
DynamicTableSource
.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.