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 data
org.apache.flink.api.java.DataSet<T> data_set
org.apache.flink.api.common.accumulators.LongCounter c
Function f
Function f
Function f
org.apache.mrql.Parser parser
Environment client_env
String var
org.apache.hadoop.io.SequenceFile.Reader in
long start
long end
boolean more
MRContainer key
MRContainer value
MRData value
Function lambda
boolean value
byte value
char value
DataSet dataset
double value
org.apache.flink.api.java.DataSet<T> flink
float value
int value
long value
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
MRData[] tuple
byte tag
MRData value
Copyright © 2013-2016 The Apache Software Foundation. All Rights Reserved.