Package org.apache.flink.api.common.functions.util

Class FunctionUtils

java.lang.Object

org.apache.flink.api.common.functions.util.FunctionUtils

@Internal
public final class FunctionUtils
extends Object

Utility class that contains helper methods to work with Flink Function class.

Method Summary

Modifier and Type	Method	Description
static void	closeFunction(org.apache.flink.api.common.functions.Function function)
static RuntimeContext	getFunctionRuntimeContext(org.apache.flink.api.common.functions.Function function, RuntimeContext defaultContext)
static void	openFunction(org.apache.flink.api.common.functions.Function function, OpenContext openContext)
static void	setFunctionRuntimeContext(org.apache.flink.api.common.functions.Function function, RuntimeContext context)

Methods inherited from class java.lang.Object

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

Method Detail

openFunction

public static void openFunction(org.apache.flink.api.common.functions.Function function,
                                OpenContext openContext)
                         throws Exception

Throws:

Exception

closeFunction

public static void closeFunction(org.apache.flink.api.common.functions.Function function)
                          throws Exception

Throws:

Exception

setFunctionRuntimeContext

public static void setFunctionRuntimeContext(org.apache.flink.api.common.functions.Function function,
                                             RuntimeContext context)

getFunctionRuntimeContext

public static RuntimeContext getFunctionRuntimeContext(org.apache.flink.api.common.functions.Function function,
                                                       RuntimeContext defaultContext)