org.apache.paimon.flink.utils

Class RuntimeContextUtils

java.lang.Object

org.apache.paimon.flink.utils.RuntimeContextUtils

public class RuntimeContextUtils
extends Object

Utility methods about Flink runtime context to resolve compatibility issues.

Constructor Summary

Constructors

Constructor and Description
RuntimeContextUtils()

Method Summary

Modifier and Type	Method and Description
static Integer	getIndexOfThisSubtask(org.apache.flink.table.functions.FunctionContext context)
static int	getIndexOfThisSubtask(org.apache.flink.api.common.functions.RuntimeContext context)
static Integer	getNumberOfParallelSubtasks(org.apache.flink.table.functions.FunctionContext context)
static int	getNumberOfParallelSubtasks(org.apache.flink.api.common.functions.RuntimeContext context)
static boolean	preferCustomShuffle(org.apache.flink.table.connector.source.LookupTableSource.LookupContext context)

Methods inherited from class java.lang.Object

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

Constructor Detail

RuntimeContextUtils

public RuntimeContextUtils()

Method Detail

getNumberOfParallelSubtasks

public static int getNumberOfParallelSubtasks(org.apache.flink.api.common.functions.RuntimeContext context)

getIndexOfThisSubtask

public static int getIndexOfThisSubtask(org.apache.flink.api.common.functions.RuntimeContext context)

getNumberOfParallelSubtasks

@Nullable
public static Integer getNumberOfParallelSubtasks(org.apache.flink.table.functions.FunctionContext context)

getIndexOfThisSubtask

@Nullable
public static Integer getIndexOfThisSubtask(org.apache.flink.table.functions.FunctionContext context)

preferCustomShuffle

public static boolean preferCustomShuffle(org.apache.flink.table.connector.source.LookupTableSource.LookupContext context)