io.druid.data.input.thrift

Class ThriftDeserialization

java.lang.Object

io.druid.data.input.thrift.ThriftDeserialization

public class ThriftDeserialization
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static ThreadLocal<org.apache.thrift.TSerializer>	SERIALIZER_SIMPLE_JSON

Constructor Summary

Constructors

Constructor and Description
ThriftDeserialization()

Method Summary

Modifier and Type	Method and Description
static byte[]	decodeB64IfNeeded(byte[] src)
static <T extends org.apache.thrift.TBase> T	detectAndDeserialize(byte[] bytes, T thriftObj) Deserializes byte-array into thrift object.

Methods inherited from class java.lang.Object

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

Field Detail

SERIALIZER_SIMPLE_JSON

public static final ThreadLocal<org.apache.thrift.TSerializer> SERIALIZER_SIMPLE_JSON

Constructor Detail

ThriftDeserialization

public ThriftDeserialization()

Method Detail

decodeB64IfNeeded

public static byte[] decodeB64IfNeeded(byte[] src)

detectAndDeserialize

public static <T extends org.apache.thrift.TBase> T detectAndDeserialize(byte[] bytes,
                                                                         T thriftObj)
                                                                  throws org.apache.thrift.TException

Deserializes byte-array into thrift object.

Supporting binary, compact and json protocols, and the byte array could be or not be encoded by Base64.

Parameters:

bytes - the byte-array to deserialize

thriftObj - the output thrift object

Returns:

the output thrift object, or null if error occurs

Throws:

org.apache.thrift.TException