Package org.apache.spark.api.r
Class SerDe
Object
org.apache.spark.api.r.SerDe
Utility functions to serialize, deserialize objects to / from R
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic Object
readArray
(DataInputStream dis, org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker) static boolean
static boolean[]
static byte[]
static byte[][]
static Date
static double
static double[]
static int
static int[]
static Object[]
readList
(DataInputStream dis, org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker) readMap
(DataInputStream in, org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker) static Object
readObject
(DataInputStream dis, org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker) static char
static String
static String[]
static String
readStringBytes
(DataInputStream in, int len) static Timestamp
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)
-
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
-
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
-
readInt
-
readDouble
-
readStringBytes
-
readString
-
readBoolean
-
readDate
-
readTime
-
readBytesArr
-
readIntArr
-
readDoubleArr
-
readBooleanArr
-
readStringArr
-
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
-
writeObject
public static void writeObject(DataOutputStream dos, Object obj, org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker) -
writeInt
-
writeDouble
-
writeBoolean
-
writeDate
-
writeTime
-
writeTime
-
writeString
-
writeBytes
-
writeJObj
public static void writeJObj(DataOutputStream out, Object value, org.apache.spark.api.r.JVMObjectTracker jvmObjectTracker) -
writeIntArr
-
writeDoubleArr
-
writeBooleanArr
-
writeStringArr
-