public enum PythonOperatorUtils extends Enum<PythonOperatorUtils>
Modifier and Type | Method and Description |
---|---|
static boolean |
endOfLastFlatMap(int length,
byte[] rawData) |
static FlinkFnApi.UserDefinedAggregateFunction |
getUserDefinedAggregateFunctionProto(PythonAggregateFunctionInfo pythonFunctionInfo,
DataViewUtils.DataViewSpec[] dataViewSpecs) |
static FlinkFnApi.UserDefinedDataStreamFunction |
getUserDefinedDataStreamFunctionProto(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo,
RuntimeContext runtimeContext,
Map<String,String> internalParameters,
boolean inBatchExecutionMode) |
static FlinkFnApi.UserDefinedDataStreamFunction |
getUserDefinedDataStreamStatefulFunctionProto(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo,
RuntimeContext runtimeContext,
Map<String,String> internalParameters,
TypeInformation keyTypeInfo,
boolean inBatchExecutionMode) |
static FlinkFnApi.UserDefinedFunction |
getUserDefinedFunctionProto(PythonFunctionInfo pythonFunctionInfo) |
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.
|
static PythonOperatorUtils |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static PythonOperatorUtils[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static PythonOperatorUtils[] values()
for (PythonOperatorUtils c : PythonOperatorUtils.values()) System.out.println(c);
public static PythonOperatorUtils valueOf(String name)
name
- the name of the enum constant to be returned.IllegalArgumentException
- if this enum type has no constant with the specified nameNullPointerException
- if the argument is nullpublic static FlinkFnApi.UserDefinedFunction getUserDefinedFunctionProto(PythonFunctionInfo pythonFunctionInfo)
public static FlinkFnApi.UserDefinedAggregateFunction getUserDefinedAggregateFunctionProto(PythonAggregateFunctionInfo pythonFunctionInfo, DataViewUtils.DataViewSpec[] dataViewSpecs)
public static FlinkFnApi.UserDefinedDataStreamFunction getUserDefinedDataStreamFunctionProto(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo, RuntimeContext runtimeContext, Map<String,String> internalParameters, boolean inBatchExecutionMode)
public static FlinkFnApi.UserDefinedDataStreamFunction getUserDefinedDataStreamStatefulFunctionProto(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo, RuntimeContext runtimeContext, Map<String,String> internalParameters, TypeInformation keyTypeInfo, boolean inBatchExecutionMode)
public static boolean endOfLastFlatMap(int length, byte[] rawData)
public static <K> void setCurrentKeyForStreaming(KeyedStateBackend<K> stateBackend, K currentKey)
public static <K,N> void setCurrentKeyForTimerService(InternalTimerService<N> internalTimerService, K currentKey) throws Exception
Exception
public static <K> boolean inBatchExecutionMode(KeyedStateBackend<K> stateBackend)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.