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 int	getIndexOfThisSubtask(org.apache.flink.api.common.functions.RuntimeContext context)
static int	getNumberOfParallelSubtasks(org.apache.flink.api.common.functions.RuntimeContext 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)