Package | Description |
---|---|
org.apache.flink.streaming.python.api.datastream | |
org.apache.flink.streaming.python.api.environment |
Modifier and Type | Class and Description |
---|---|
class |
PythonIterativeStream
A thin wrapper layer over
IterativeStream . |
class |
PythonKeyedStream
A thin wrapper layer over
KeyedStream . |
class |
PythonSingleOutputStreamOperator
A thin wrapper layer over
SingleOutputStreamOperator |
class |
PythonSplitStream
A thin wrapper layer over
SplitStream . |
Modifier and Type | Method and Description |
---|---|
PythonDataStream |
PythonIterativeStream.close_with(PythonDataStream<? extends DataStream<org.python.core.PyObject>> feedback_stream)
A thin wrapper layer over
IterativeStream.closeWith(org.apache.flink.streaming.api.datastream.DataStream) |
PythonDataStream<SingleOutputStreamOperator<org.python.core.PyObject>> |
PythonDataStream.flat_map(FlatMapFunction<org.python.core.PyObject,Object> flat_mapper)
A thin wrapper layer over
DataStream.flatMap(FlatMapFunction) . |
PythonDataStream<SingleOutputStreamOperator<org.python.core.PyObject>> |
PythonDataStream.map(MapFunction<org.python.core.PyObject,org.python.core.PyObject> mapper)
A thin wrapper layer over
DataStream.map(MapFunction) . |
PythonDataStream |
PythonSplitStream.select(String... output_names)
A thin wrapper layer over
SplitStream.select(java.lang.String...) . |
PythonDataStream |
PythonDataStream.union(PythonDataStream... streams)
A thin wrapper layer over
DataStream.union(DataStream[]) . |
Modifier and Type | Method and Description |
---|---|
PythonDataStream |
PythonIterativeStream.close_with(PythonDataStream<? extends DataStream<org.python.core.PyObject>> feedback_stream)
A thin wrapper layer over
IterativeStream.closeWith(org.apache.flink.streaming.api.datastream.DataStream) |
PythonDataStream |
PythonDataStream.union(PythonDataStream... streams)
A thin wrapper layer over
DataStream.union(DataStream[]) . |
Modifier and Type | Method and Description |
---|---|
PythonDataStream |
PythonStreamExecutionEnvironment.add_java_source(SourceFunction<Object> src)
Add a java source to the streaming topology.
|
PythonDataStream |
PythonStreamExecutionEnvironment.create_python_source(SourceFunction<Object> src) |
PythonDataStream |
PythonStreamExecutionEnvironment.from_collection(Collection<Object> collection)
A thin wrapper layer over
StreamExecutionEnvironment.fromCollection(java.util.Collection) |
PythonDataStream |
PythonStreamExecutionEnvironment.from_collection(Iterator<Object> iter)
Creates a python data stream from the given iterator.
|
PythonDataStream |
PythonStreamExecutionEnvironment.from_elements(org.python.core.PyObject... elements)
A thin wrapper layer over
StreamExecutionEnvironment.fromElements(java.lang.Object[]) . |
PythonDataStream |
PythonStreamExecutionEnvironment.generate_sequence(long from,
long to)
A thin wrapper layer over
StreamExecutionEnvironment.generateSequence(long, long) . |
PythonDataStream |
PythonStreamExecutionEnvironment.read_text_file(String path)
A thin wrapper layer over
StreamExecutionEnvironment.readTextFile(java.lang.String) . |
PythonDataStream |
PythonStreamExecutionEnvironment.socket_text_stream(String host,
int port)
A thin wrapper layer over
StreamExecutionEnvironment.socketTextStream(java.lang.String, int) . |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.