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(KeyedStateBackend<K> stateBackend)
static <K> void	setCurrentKeyForStreaming(KeyedStateBackend<K> stateBackend, K currentKey) Set the current key for streaming operator.
static <K,N> void	setCurrentKeyForTimerService(InternalTimerService<N> internalTimerService, K currentKey) Set the current key for the timer service.

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(KeyedStateBackend<K> stateBackend,
                                                 K currentKey)

Set the current key for streaming operator.

setCurrentKeyForTimerService

public static <K,N> void setCurrentKeyForTimerService(InternalTimerService<N> internalTimerService,
                                                      K currentKey)
                                               throws Exception

Set the current key for the timer service.

Throws:

Exception

inBatchExecutionMode

public static <K> boolean inBatchExecutionMode(KeyedStateBackend<K> stateBackend)