org.apache.flink.python.api.streaming.plan

Class PythonPlanReceiver

java.lang.Object

org.apache.flink.python.api.streaming.plan.PythonPlanReceiver

public class PythonPlanReceiver
extends Object

Instances of this class can be used to receive data from the plan process.

Constructor Summary

Constructors

Constructor and Description
PythonPlanReceiver(InputStream input)

Method Summary

Modifier and Type	Method and Description
Object	getRecord()
Object	getRecord(boolean normalized)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PythonPlanReceiver

public PythonPlanReceiver(InputStream input)

Method Detail

getRecord

public Object getRecord()
                 throws IOException

Throws:

IOException

getRecord

public Object getRecord(boolean normalized)
                 throws IOException

Throws:

IOException