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

Class PythonPlanStreamer

java.lang.Object

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

public class PythonPlanStreamer
extends Object

Generic class to exchange data during the plan phase.

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG
protected PythonPlanReceiver	receiver
protected PythonPlanSender	sender

Constructor Summary

Constructors

Constructor and Description
PythonPlanStreamer(Configuration config)

Method Summary

Modifier and Type	Method and Description
void	close()
void	finishPlanMode()
Object	getRecord()
Object	getRecord(boolean normalize)
void	open(String tmpPath, String args)
boolean	preparePlanMode()
void	sendRecord(Object record)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

sender

protected PythonPlanSender sender

receiver

protected PythonPlanReceiver receiver

Constructor Detail

PythonPlanStreamer

public PythonPlanStreamer(Configuration config)

Method Detail

getRecord

public Object getRecord()
                 throws IOException

Throws:

IOException

getRecord

public Object getRecord(boolean normalize)
                 throws IOException

Throws:

IOException

sendRecord

public void sendRecord(Object record)
                throws IOException

Throws:

IOException

open

public void open(String tmpPath,
                 String args)
          throws IOException

Throws:

IOException

preparePlanMode

public boolean preparePlanMode()
                        throws IOException

Throws:

IOException

finishPlanMode

public void finishPlanMode()

close

public void close()