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

Class PythonSplitStream

java.lang.Object

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

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

@PublicEvolving
public class PythonSplitStream
extends PythonDataStream<SplitStream<org.python.core.PyObject>>

A thin wrapper layer over SplitStream.

The PythonSplitStream represents an operator that has been split using an OutputSelector. Named outputs can be selected using the select(java.lang.String...) function. To apply transformation on the whole output simply call the transformation on the PythonSplitStream

Field Summary

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

stream

Method Summary

Modifier and Type	Method and Description
PythonDataStream	select(String... output_names) A thin wrapper layer over SplitStream.select(java.lang.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

select

public PythonDataStream select(String... output_names)

A thin wrapper layer over SplitStream.select(java.lang.String...).

Parameters:

output_names - The output names for which the operator will receive the input.

Returns:

Returns the selected PythonDataStream