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

类 SourceWatermarkSpec

java.lang.Object

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

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

所有已实现的接口:

SourceAbilitySpec

public final class SourceWatermarkSpec
extends SourceAbilitySpecBase

A sub-class of SourceAbilitySpec that can not only serialize/deserialize the boolean flag whether a source watermark should be used to/from JSON, but can also apply it to SupportsSourceWatermark.

字段概要

字段

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

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

FIELD_NAME_PRODUCED_TYPE

构造器概要

构造器

构造器和说明
SourceWatermarkSpec(boolean sourceWatermarkEnabled, 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_SOURCE_WATERMARK_ENABLED

public static final String FIELD_NAME_SOURCE_WATERMARK_ENABLED

另请参阅:

常量字段值

构造器详细资料

SourceWatermarkSpec

public SourceWatermarkSpec(boolean sourceWatermarkEnabled,
                           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