org.apache.flink.streaming.api.utils

Class PythonOperatorUtils

java.lang.Object

org.apache.flink.streaming.api.utils.PythonOperatorUtils

@Internal
public class PythonOperatorUtils
extends Object

Utilities used by Python operators.

Constructor Summary

Constructors

Constructor and Description
PythonOperatorUtils()

Method Summary

Modifier and Type	Method and Description
static <K> boolean	inBatchExecutionMode(org.apache.flink.runtime.state.KeyedStateBackend<K> stateBackend)
static <K> void	setCurrentKeyForStreaming(org.apache.flink.runtime.state.KeyedStateBackend<K> stateBackend, K currentKey) Set the current key for streaming operator.

Methods inherited from class java.lang.Object

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

Constructor Detail

PythonOperatorUtils

public PythonOperatorUtils()

Method Detail

setCurrentKeyForStreaming

public static <K> void setCurrentKeyForStreaming(org.apache.flink.runtime.state.KeyedStateBackend<K> stateBackend,
                                                 K currentKey)

Set the current key for streaming operator.

inBatchExecutionMode

public static <K> boolean inBatchExecutionMode(org.apache.flink.runtime.state.KeyedStateBackend<K> stateBackend)