private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObjectNoData() throws ObjectStreamException
ObjectStreamException
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
String name
MRData value
Environment next
MRData value
Function lambda
boolean value
byte value
char value
DataSet dataset
double value
float value
int value
long value
org.apache.spark.api.java.JavaRDD<T> rdd
short value
String value
int var_num
private void readObject(ObjectInputStream arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream arg0) throws IOException
IOException
private void readObjectNoData() throws ObjectStreamException
ObjectStreamException
org.apache.spark.api.java.JavaRDD<T> rdd
String host
int port
org.apache.mrql.Parser parser
org.apache.spark.streaming.api.java.JavaStreamingContext stream_context
MRData[] tuple
byte tag
MRData value
Copyright © 2013-2016 The Apache Software Foundation. All Rights Reserved.