public class PythonOutputSelector extends Object implements OutputSelector<org.python.core.PyObject>
PythonOutputSelectoris a thin wrapper layer over a Python UDF
OutputSelector. It receives an
OutputSelectoras an input and keeps it internally in a serialized form. It is then delivered, as part of the job graph, up to the TaskManager, then it is opened and becomes a sort of mediator to the Python UDF
This function is used internally by the Python thin wrapper layer over the streaming data functionality
|Constructor and Description|
|Modifier and Type||Method and Description|
Method for selecting output names for the emitted objects when using the
SingleOutputStreamOperator.split(org.apache.flink.streaming.api.collector.selector.OutputSelector<T>)method. The values will be emitted only to output names which are contained in the returned iterable.
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.