org.apache.flink.streaming.api.operators.python

Interface DataStreamPythonFunctionOperator<OUT>

All Superinterfaces:

ResultTypeQueryable<OUT>

All Known Implementing Classes:

AbstractEmbeddedDataStreamPythonFunctionOperator, AbstractExternalDataStreamPythonFunctionOperator, AbstractExternalOneInputPythonFunctionOperator, AbstractExternalTwoInputPythonFunctionOperator, AbstractOneInputEmbeddedPythonFunctionOperator, AbstractTwoInputEmbeddedPythonFunctionOperator, DelegateOperatorTransformation.DelegateOperator, EmbeddedPythonBatchCoBroadcastProcessOperator, EmbeddedPythonBatchKeyedCoBroadcastProcessOperator, EmbeddedPythonCoProcessOperator, EmbeddedPythonKeyedCoProcessOperator, EmbeddedPythonKeyedProcessOperator, EmbeddedPythonProcessOperator, EmbeddedPythonWindowOperator, ExternalPythonBatchCoBroadcastProcessOperator, ExternalPythonBatchKeyedCoBroadcastProcessOperator, ExternalPythonCoProcessOperator, ExternalPythonKeyedCoProcessOperator, ExternalPythonKeyedProcessOperator, ExternalPythonProcessOperator

@Internal
public interface DataStreamPythonFunctionOperator<OUT>
extends ResultTypeQueryable<OUT>

Interface for Python DataStream operators.

Method Summary

Modifier and Type	Method and Description
void	addSideOutputTags(Collection<OutputTag<?>> outputTags) Add a collection of OutputTags to the operator.
<T> DataStreamPythonFunctionOperator<T>	copy(DataStreamPythonFunctionInfo pythonFunctionInfo, TypeInformation<T> outputTypeInfo) Make a copy of the DataStreamPythonFunctionOperator with the given pythonFunctionInfo and outputTypeInfo.
DataStreamPythonFunctionInfo	getPythonFunctionInfo() Returns the underlying DataStreamPythonFunctionInfo.
Collection<OutputTag<?>>	getSideOutputTags() Gets the OutputTags belongs to the operator.
void	setNumPartitions(int numPartitions) Sets the number of partitions.

Methods inherited from interface org.apache.flink.api.java.typeutils.ResultTypeQueryable

getProducedType

Method Detail

setNumPartitions

void setNumPartitions(int numPartitions)

Sets the number of partitions. This is used for partitionCustom which takes the number of partitions to partition into as input.

getPythonFunctionInfo

DataStreamPythonFunctionInfo getPythonFunctionInfo()

Returns the underlying DataStreamPythonFunctionInfo.

addSideOutputTags

void addSideOutputTags(Collection<OutputTag<?>> outputTags)

Add a collection of OutputTags to the operator.

getSideOutputTags

Collection<OutputTag<?>> getSideOutputTags()

Gets the OutputTags belongs to the operator.

copy

<T> DataStreamPythonFunctionOperator<T> copy(DataStreamPythonFunctionInfo pythonFunctionInfo,
                                             TypeInformation<T> outputTypeInfo)

Make a copy of the DataStreamPythonFunctionOperator with the given pythonFunctionInfo and outputTypeInfo. This is used for chaining optimization which may need to update the underlying pythonFunctionInfo and outputTypeInfo with the other fields not changed.