Package org.apache.spark.api.r

Class SerDe

Object

org.apache.spark.api.r.SerDe

public class SerDe
extends Object

Utility functions to serialize, deserialize objects to / from R

Constructor Summary

Constructors

Constructor	Description
SerDe()

Method Summary

Modifier and Type	Method	Description
static Object	readArray(DataInputStream dis, org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker)
static boolean	readBoolean(DataInputStream in)
static boolean[]	readBooleanArr(DataInputStream in)
static byte[]	readBytes(DataInputStream in)
static byte[][]	readBytesArr(DataInputStream in)
static Date	readDate(DataInputStream in)
static double	readDouble(DataInputStream in)
static double[]	readDoubleArr(DataInputStream in)
static int	readInt(DataInputStream in)
static int[]	readIntArr(DataInputStream in)
static Object[]	readList(DataInputStream dis, org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker)
static Map<Object,Object>	readMap(DataInputStream in, org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker)
static Object	readObject(DataInputStream dis, org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker)
static char	readObjectType(DataInputStream dis)
static String	readString(DataInputStream in)
static String[]	readStringArr(DataInputStream in)
static String	readStringBytes(DataInputStream in, int len)
static Timestamp	readTime(DataInputStream in)
static Object	readTypedObject(DataInputStream dis, char dataType, org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker)
static org.apache.spark.api.r.SerDe$	setSQLReadObject(scala.Function2<DataInputStream,Object,Object> value)
static org.apache.spark.api.r.SerDe$	setSQLWriteObject(scala.Function2<DataOutputStream,Object,Object> value)
static void	writeBoolean(DataOutputStream out, boolean value)
static void	writeBooleanArr(DataOutputStream out, boolean[] value)
static void	writeBytes(DataOutputStream out, byte[] value)
static void	writeDate(DataOutputStream out, Date value)
static void	writeDouble(DataOutputStream out, double value)
static void	writeDoubleArr(DataOutputStream out, double[] value)
static void	writeInt(DataOutputStream out, int value)
static void	writeIntArr(DataOutputStream out, int[] value)
static void	writeJObj(DataOutputStream out, Object value, org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker)
static void	writeObject(DataOutputStream dos, Object obj, org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker)
static void	writeString(DataOutputStream out, String value)
static void	writeStringArr(DataOutputStream out, String[] value)
static void	writeTime(DataOutputStream out, Time value)
static void	writeTime(DataOutputStream out, Timestamp value)
static void	writeType(DataOutputStream dos, String typeStr)

Methods inherited from class java.lang.Object

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

Constructor Details

SerDe

public SerDe()

Method Details

setSQLReadObject

public static org.apache.spark.api.r.SerDe$ setSQLReadObject(scala.Function2<DataInputStream,Object,Object> value)

setSQLWriteObject

public static org.apache.spark.api.r.SerDe$ setSQLWriteObject(scala.Function2<DataOutputStream,Object,Object> value)

readObjectType

public static char readObjectType(DataInputStream dis)

readObject

public static Object readObject(DataInputStream dis,
 org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker)

readTypedObject

public static Object readTypedObject(DataInputStream dis,
 char dataType,
 org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker)

readBytes

public static byte[] readBytes(DataInputStream in)

readInt

public static int readInt(DataInputStream in)

readDouble

public static double readDouble(DataInputStream in)

readStringBytes

public static String readStringBytes(DataInputStream in,
 int len)

readString

public static String readString(DataInputStream in)

readBoolean

public static boolean readBoolean(DataInputStream in)

readDate

public static Date readDate(DataInputStream in)

readTime

public static Timestamp readTime(DataInputStream in)

readBytesArr

public static byte[][] readBytesArr(DataInputStream in)

readIntArr

public static int[] readIntArr(DataInputStream in)

readDoubleArr

public static double[] readDoubleArr(DataInputStream in)

readBooleanArr

public static boolean[] readBooleanArr(DataInputStream in)

readStringArr

public static String[] readStringArr(DataInputStream in)

readArray

public static Object readArray(DataInputStream dis,
 org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker)

readList

public static Object[] readList(DataInputStream dis,
 org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker)

readMap

public static Map<Object,Object> readMap(DataInputStream in,
 org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker)

writeType

public static void writeType(DataOutputStream dos,
 String typeStr)

writeObject

public static void writeObject(DataOutputStream dos,
 Object obj,
 org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker)

writeInt

public static void writeInt(DataOutputStream out,
 int value)

writeDouble

public static void writeDouble(DataOutputStream out,
 double value)

writeBoolean

public static void writeBoolean(DataOutputStream out,
 boolean value)

writeDate

public static void writeDate(DataOutputStream out,
 Date value)

writeTime

public static void writeTime(DataOutputStream out,
 Time value)

writeTime

public static void writeTime(DataOutputStream out,
 Timestamp value)

writeString

public static void writeString(DataOutputStream out,
 String value)

writeBytes

public static void writeBytes(DataOutputStream out,
 byte[] value)

writeJObj

public static void writeJObj(DataOutputStream out,
 Object value,
 org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker)

writeIntArr

public static void writeIntArr(DataOutputStream out,
 int[] value)

writeDoubleArr

public static void writeDoubleArr(DataOutputStream out,
 double[] value)

writeBooleanArr

public static void writeBooleanArr(DataOutputStream out,
 boolean[] value)

writeStringArr

public static void writeStringArr(DataOutputStream out,
 String[] value)