public class PythonOutputSelector extends Object implements OutputSelector<org.python.core.PyObject>
PythonOutputSelector
is a thin wrapper layer over a Python UDF OutputSelector
.
It receives an OutputSelector
as 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 OutputSelector
.
This function is used internally by the Python thin wrapper layer over the streaming data functionality
Constructor and Description |
---|
PythonOutputSelector(OutputSelector<org.python.core.PyObject> fun) |
Modifier and Type | Method and Description |
---|---|
Iterable<String> |
select(org.python.core.PyObject value)
Method for selecting output names for the emitted objects when using the
SingleOutputStreamOperator.split(org.apache.flink.streaming.api.collector.selector.OutputSelector<T>) method. |
public PythonOutputSelector(OutputSelector<org.python.core.PyObject> fun) throws IOException
IOException
public Iterable<String> select(org.python.core.PyObject value)
OutputSelector
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.select
in interface OutputSelector<org.python.core.PyObject>
value
- Output object for which the output selection should be made.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.