DataStreamPythonFunctionOperator (Flink : 2.0-SNAPSHOT API)

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

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`addSideOutputTags(Collection<OutputTag<?>> outputTags)`	Add a collection of `OutputTag`s 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 `OutputTag`s 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.