IN
- input typepublic class PythonSingleInputSender<IN> extends PythonSender
PythonSender
for operations with one input stream.PythonSender.Serializer<T>
TYPE_ARRAY, TYPE_KEY_VALUE, TYPE_VALUE_VALUE
Modifier | Constructor and Description |
---|---|
protected |
PythonSingleInputSender(Configuration config) |
Modifier and Type | Method and Description |
---|---|
int |
sendBuffer(org.apache.flink.python.api.streaming.data.SingleElementPushBackIterator<IN> input)
Extracts records from an iterator and writes them to the memory-mapped file.
|
close, getSerializer, open, sendBuffer
protected PythonSingleInputSender(Configuration config)
public int sendBuffer(org.apache.flink.python.api.streaming.data.SingleElementPushBackIterator<IN> input) throws IOException
input
- iterator containing recordsIOException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.