org.apache.flink.table.planner.plan.utils

Class MinibatchUtil

java.lang.Object

org.apache.flink.table.planner.plan.utils.MinibatchUtil

public class MinibatchUtil
extends Object

Utility class for mini-batch related config.

Constructor Summary

Constructors

Constructor and Description
MinibatchUtil()

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.table.runtime.operators.bundle.trigger.CoBundleTrigger<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>	createMiniBatchCoTrigger(org.apache.flink.configuration.ReadableConfig config) Creates a MiniBatch trigger depends on the config for two input.
static org.apache.flink.table.runtime.operators.bundle.trigger.CountBundleTrigger<org.apache.flink.table.data.RowData>	createMiniBatchTrigger(org.apache.flink.configuration.ReadableConfig config) Creates a MiniBatch trigger depends on the config for one input.
static boolean	isMiniBatchEnabled(org.apache.flink.configuration.ReadableConfig config) Check if MiniBatch is enabled.
static long	miniBatchSize(org.apache.flink.configuration.ReadableConfig config) Returns the mini batch size for given config and mixed mode flag, considering fallback logic.

Methods inherited from class java.lang.Object

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

Constructor Detail

MinibatchUtil

public MinibatchUtil()

Method Detail

isMiniBatchEnabled

public static boolean isMiniBatchEnabled(org.apache.flink.configuration.ReadableConfig config)

Check if MiniBatch is enabled.

Parameters:

config - config

Returns:

true if MiniBatch enabled else false.

createMiniBatchTrigger

public static org.apache.flink.table.runtime.operators.bundle.trigger.CountBundleTrigger<org.apache.flink.table.data.RowData> createMiniBatchTrigger(org.apache.flink.configuration.ReadableConfig config)

Creates a MiniBatch trigger depends on the config for one input.

Parameters:

config - config

Returns:

MiniBatch trigger

createMiniBatchCoTrigger

public static org.apache.flink.table.runtime.operators.bundle.trigger.CoBundleTrigger<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData> createMiniBatchCoTrigger(org.apache.flink.configuration.ReadableConfig config)

Creates a MiniBatch trigger depends on the config for two input.

Parameters:

config - config

Returns:

MiniBatch trigger

miniBatchSize

public static long miniBatchSize(org.apache.flink.configuration.ReadableConfig config)

Returns the mini batch size for given config and mixed mode flag, considering fallback logic.

Parameters:

config - config

Returns:

mini batch size