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

类 LimitPushDownSpec

java.lang.Object

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

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

所有已实现的接口:

SourceAbilitySpec

public final class LimitPushDownSpec
extends SourceAbilitySpecBase

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

字段概要

字段

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

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

FIELD_NAME_PRODUCED_TYPE

构造器概要

构造器

构造器和说明
LimitPushDownSpec(long limit)

方法概要

限定符和类型	方法和说明
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_LIMIT

public static final String FIELD_NAME_LIMIT

另请参阅:

常量字段值

构造器详细资料

LimitPushDownSpec

public LimitPushDownSpec(long limit)

方法详细资料

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