public class SerDe
extends java.lang.Object
Constructor and Description |
---|
SerDe() |
Modifier and Type | Method and Description |
---|---|
static java.lang.Object |
readArray(java.io.DataInputStream dis) |
static boolean |
readBoolean(java.io.DataInputStream in) |
static boolean[] |
readBooleanArr(java.io.DataInputStream in) |
static byte[] |
readBytes(java.io.DataInputStream in) |
static byte[][] |
readBytesArr(java.io.DataInputStream in) |
static java.sql.Date |
readDate(java.io.DataInputStream in) |
static double |
readDouble(java.io.DataInputStream in) |
static double[] |
readDoubleArr(java.io.DataInputStream in) |
static int |
readInt(java.io.DataInputStream in) |
static int[] |
readIntArr(java.io.DataInputStream in) |
static java.lang.Object[] |
readList(java.io.DataInputStream dis) |
static java.util.Map<java.lang.Object,java.lang.Object> |
readMap(java.io.DataInputStream in) |
static java.lang.Object |
readObject(java.io.DataInputStream dis) |
static char |
readObjectType(java.io.DataInputStream dis) |
static java.lang.String |
readString(java.io.DataInputStream in) |
static java.lang.String[] |
readStringArr(java.io.DataInputStream in) |
static java.lang.String |
readStringBytes(java.io.DataInputStream in,
int len) |
static java.sql.Timestamp |
readTime(java.io.DataInputStream in) |
static java.lang.Object |
readTypedObject(java.io.DataInputStream dis,
char dataType) |
static void |
registerSqlSerDe(scala.Tuple2<scala.Function2<java.io.DataInputStream,java.lang.Object,java.lang.Object>,scala.Function2<java.io.DataOutputStream,java.lang.Object,java.lang.Object>> sqlSerDe) |
static scala.Tuple2<scala.Function2<java.io.DataInputStream,java.lang.Object,java.lang.Object>,scala.Function2<java.io.DataOutputStream,java.lang.Object,java.lang.Object>> |
sqlSerDe() |
static void |
writeBoolean(java.io.DataOutputStream out,
boolean value) |
static void |
writeBooleanArr(java.io.DataOutputStream out,
boolean[] value) |
static void |
writeBytes(java.io.DataOutputStream out,
byte[] value) |
static void |
writeDate(java.io.DataOutputStream out,
java.sql.Date value) |
static void |
writeDouble(java.io.DataOutputStream out,
double value) |
static void |
writeDoubleArr(java.io.DataOutputStream out,
double[] value) |
static void |
writeInt(java.io.DataOutputStream out,
int value) |
static void |
writeIntArr(java.io.DataOutputStream out,
int[] value) |
static void |
writeJObj(java.io.DataOutputStream out,
java.lang.Object value) |
static void |
writeObject(java.io.DataOutputStream dos,
java.lang.Object obj) |
static void |
writeString(java.io.DataOutputStream out,
java.lang.String value) |
static void |
writeStringArr(java.io.DataOutputStream out,
java.lang.String[] value) |
static void |
writeTime(java.io.DataOutputStream out,
java.sql.Time value) |
static void |
writeTime(java.io.DataOutputStream out,
java.sql.Timestamp value) |
static void |
writeType(java.io.DataOutputStream dos,
java.lang.String typeStr) |
public static scala.Tuple2<scala.Function2<java.io.DataInputStream,java.lang.Object,java.lang.Object>,scala.Function2<java.io.DataOutputStream,java.lang.Object,java.lang.Object>> sqlSerDe()
public static void registerSqlSerDe(scala.Tuple2<scala.Function2<java.io.DataInputStream,java.lang.Object,java.lang.Object>,scala.Function2<java.io.DataOutputStream,java.lang.Object,java.lang.Object>> sqlSerDe)
public static char readObjectType(java.io.DataInputStream dis)
public static java.lang.Object readObject(java.io.DataInputStream dis)
public static java.lang.Object readTypedObject(java.io.DataInputStream dis, char dataType)
public static byte[] readBytes(java.io.DataInputStream in)
public static int readInt(java.io.DataInputStream in)
public static double readDouble(java.io.DataInputStream in)
public static java.lang.String readStringBytes(java.io.DataInputStream in, int len)
public static java.lang.String readString(java.io.DataInputStream in)
public static boolean readBoolean(java.io.DataInputStream in)
public static java.sql.Date readDate(java.io.DataInputStream in)
public static java.sql.Timestamp readTime(java.io.DataInputStream in)
public static byte[][] readBytesArr(java.io.DataInputStream in)
public static int[] readIntArr(java.io.DataInputStream in)
public static double[] readDoubleArr(java.io.DataInputStream in)
public static boolean[] readBooleanArr(java.io.DataInputStream in)
public static java.lang.String[] readStringArr(java.io.DataInputStream in)
public static java.lang.Object readArray(java.io.DataInputStream dis)
public static java.lang.Object[] readList(java.io.DataInputStream dis)
public static java.util.Map<java.lang.Object,java.lang.Object> readMap(java.io.DataInputStream in)
public static void writeType(java.io.DataOutputStream dos, java.lang.String typeStr)
public static void writeObject(java.io.DataOutputStream dos, java.lang.Object obj)
public static void writeInt(java.io.DataOutputStream out, int value)
public static void writeDouble(java.io.DataOutputStream out, double value)
public static void writeBoolean(java.io.DataOutputStream out, boolean value)
public static void writeDate(java.io.DataOutputStream out, java.sql.Date value)
public static void writeTime(java.io.DataOutputStream out, java.sql.Time value)
public static void writeTime(java.io.DataOutputStream out, java.sql.Timestamp value)
public static void writeString(java.io.DataOutputStream out, java.lang.String value)
public static void writeBytes(java.io.DataOutputStream out, byte[] value)
public static void writeJObj(java.io.DataOutputStream out, java.lang.Object value)
public static void writeIntArr(java.io.DataOutputStream out, int[] value)
public static void writeDoubleArr(java.io.DataOutputStream out, double[] value)
public static void writeBooleanArr(java.io.DataOutputStream out, boolean[] value)
public static void writeStringArr(java.io.DataOutputStream out, java.lang.String[] value)