public class PythonPlanStreamer extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
protected PythonPlanReceiver |
receiver |
protected PythonPlanSender |
sender |
Constructor and Description |
---|
PythonPlanStreamer() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Object |
getRecord() |
Object |
getRecord(boolean normalize) |
void |
open(String tmpPath,
String args) |
void |
sendRecord(Object record) |
protected PythonPlanSender sender
protected PythonPlanReceiver receiver
public Object getRecord() throws IOException
IOException
public Object getRecord(boolean normalize) throws IOException
IOException
public void sendRecord(Object record) throws IOException
IOException
public void open(String tmpPath, String args) throws IOException
IOException
public void close()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.