Package | Description |
---|---|
org.apache.flink.python.api.streaming.data |
Modifier and Type | Method and Description |
---|---|
protected <IN> PythonSender.Serializer<IN> |
PythonSender.getSerializer(IN value) |
Modifier and Type | Method and Description |
---|---|
protected <IN> int |
PythonSender.sendBuffer(org.apache.flink.python.api.streaming.data.SingleElementPushBackIterator<IN> input,
PythonSender.Serializer<IN> serializer)
Extracts records from an iterator and writes them to the memory-mapped file.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.