org.apache.flink.table.planner.plan.trait

类 MiniBatchInterval

java.lang.Object

org.apache.flink.table.planner.plan.trait.MiniBatchInterval

public class MiniBatchInterval
extends Object

The pojo class that describes the mini-batch interval and mini-batch mode.

字段概要

字段

限定符和类型	字段和说明
static String	FIELD_NAME_INTERVAL
static String	FIELD_NAME_MODE
static MiniBatchInterval	NO_MINIBATCH specific for cases when there exists nodes require watermark but mini-batch interval of watermark is disabled by force, e.g. existing window aggregate.
static MiniBatchInterval	NONE default none value.

构造器概要

构造器

构造器和说明
MiniBatchInterval(long interval, MiniBatchMode mode)

方法概要

限定符和类型	方法和说明
boolean	equals(Object o)
long	getInterval()
MiniBatchMode	getMode()
int	hashCode()
String	toString()

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

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

字段详细资料

FIELD_NAME_INTERVAL

public static final String FIELD_NAME_INTERVAL

另请参阅:

常量字段值

FIELD_NAME_MODE

public static final String FIELD_NAME_MODE

另请参阅:

常量字段值

NONE

public static final MiniBatchInterval NONE

default none value.

NO_MINIBATCH

public static final MiniBatchInterval NO_MINIBATCH

specific for cases when there exists nodes require watermark but mini-batch interval of watermark is disabled by force, e.g. existing window aggregate.

The difference between NONE AND NO_MINIBATCH is when merging with other miniBatchInterval, NONE case yields other miniBatchInterval, while NO_MINIBATCH case yields NO_MINIBATCH.

构造器详细资料

MiniBatchInterval

public MiniBatchInterval(long interval,
                         MiniBatchMode mode)

方法详细资料

getInterval

public long getInterval()

equals

public boolean equals(Object o)

覆盖:

equals 在类中 Object

hashCode

public int hashCode()

覆盖:

hashCode 在类中 Object

getMode

public MiniBatchMode getMode()

toString

public String toString()

覆盖:

toString 在类中 Object