org.apache.flink.streaming.python.api.datastream

Class PythonSingleOutputStreamOperator

java.lang.Object

org.apache.flink.streaming.python.api.datastream.PythonDataStream<SingleOutputStreamOperator<org.python.core.PyObject>>

org.apache.flink.streaming.python.api.datastream.PythonSingleOutputStreamOperator

Direct Known Subclasses:

PythonIterativeStream

@Public
public class PythonSingleOutputStreamOperator
extends PythonDataStream<SingleOutputStreamOperator<org.python.core.PyObject>>

A thin wrapper layer over SingleOutputStreamOperator

PythonSingleOutputStreamOperator represents a user defined transformation applied on a PythonDataStream with one predefined output type.

Field Summary

Fields inherited from class org.apache.flink.streaming.python.api.datastream.PythonDataStream

stream

Method Summary

Modifier and Type	Method and Description
PythonSingleOutputStreamOperator	name(String name) A thin wrapper layer over SingleOutputStreamOperator.name(String) .

Methods inherited from class org.apache.flink.streaming.python.api.datastream.PythonDataStream

add_sink, filter, flat_map, iterate, iterate, key_by, map, output, split, union, write_as_text, write_as_text, write_to_socket

Methods inherited from class java.lang.Object

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

Method Detail

name

public PythonSingleOutputStreamOperator name(String name)

A thin wrapper layer over SingleOutputStreamOperator.name(String) .

Parameters:

name - operator name

Returns:

The named operator.