org.apache.flink.table.planner.plan.abilities.source

类 WatermarkPushDownSpec

java.lang.Object

org.apache.flink.table.planner.plan.abilities.source.SourceAbilitySpecBase

org.apache.flink.table.planner.plan.abilities.source.WatermarkPushDownSpec

所有已实现的接口:

SourceAbilitySpec

public final class WatermarkPushDownSpec
extends SourceAbilitySpecBase

A sub-class of SourceAbilitySpec that can not only serialize/deserialize the watermark to/from JSON, but also can push the watermark into a SupportsWatermarkPushDown.

字段概要

字段

限定符和类型	字段和说明
static String	FIELD_NAME_IDLE_TIMEOUT_MILLIS
static String	FIELD_NAME_WATERMARK_EXPR

从类继承的字段 org.apache.flink.table.planner.plan.abilities.source.SourceAbilitySpecBase

FIELD_NAME_PRODUCED_TYPE

构造器概要

构造器

构造器和说明
WatermarkPushDownSpec(org.apache.calcite.rex.RexNode watermarkExpr, long idleTimeoutMillis, org.apache.flink.table.types.logical.RowType producedType)

方法概要

限定符和类型	方法和说明
void	apply(org.apache.flink.table.connector.source.DynamicTableSource tableSource, SourceAbilityContext context) Apply the ability to the given DynamicTableSource.
boolean	equals(Object o)
String	getDigests(SourceAbilityContext context) Additional digests to generate when this spec is applied to the source.
int	hashCode()

从类继承的方法 org.apache.flink.table.planner.plan.abilities.source.SourceAbilitySpecBase

getProducedType

从类继承的方法 java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

字段详细资料

FIELD_NAME_WATERMARK_EXPR

public static final String FIELD_NAME_WATERMARK_EXPR

另请参阅:

常量字段值

FIELD_NAME_IDLE_TIMEOUT_MILLIS

public static final String FIELD_NAME_IDLE_TIMEOUT_MILLIS

另请参阅:

常量字段值

构造器详细资料

WatermarkPushDownSpec

public WatermarkPushDownSpec(org.apache.calcite.rex.RexNode watermarkExpr,
                             long idleTimeoutMillis,
                             org.apache.flink.table.types.logical.RowType producedType)

方法详细资料

apply

public void apply(org.apache.flink.table.connector.source.DynamicTableSource tableSource,
                  SourceAbilityContext context)

从接口复制的说明: SourceAbilitySpec

Apply the ability to the given DynamicTableSource.

getDigests

public String getDigests(SourceAbilityContext context)

从接口复制的说明: SourceAbilitySpec

Additional digests to generate when this spec is applied to the source.

参数:

context - The context about the source.

equals

public boolean equals(Object o)

覆盖:

equals 在类中 SourceAbilitySpecBase

hashCode

public int hashCode()

覆盖:

hashCode 在类中 SourceAbilitySpecBase