public class ThriftByteStreamTypedSerDe extends ByteStreamTypedSerDe
Modifier and Type | Field and Description |
---|---|
protected org.apache.thrift.protocol.TProtocol |
inProtocol |
protected org.apache.thrift.transport.TIOStreamTransport |
inTransport |
protected org.apache.thrift.protocol.TProtocol |
outProtocol |
protected org.apache.thrift.transport.TIOStreamTransport |
outTransport |
bis, bos
deserializeCache, objectClass, objectType
configuration, log, partitionProperties, properties, tableProperties
Constructor and Description |
---|
ThriftByteStreamTypedSerDe(Type objectType,
org.apache.thrift.protocol.TProtocolFactory inFactory,
org.apache.thrift.protocol.TProtocolFactory outFactory) |
Modifier and Type | Method and Description |
---|---|
Object |
deserialize(org.apache.hadoop.io.Writable field)
Deserialize an object out of a Writable blob.
|
protected ObjectInspectorFactory.ObjectInspectorOptions |
getObjectInspectorOptions() |
void |
initialize(org.apache.hadoop.conf.Configuration configuration,
Properties tableProperties,
Properties partitionProperties)
Initialize the SerDe.
|
getObjectInspector, getSerializedClass, serialize
getColumnComments, getColumnNames, getColumnTypes, getConfiguration, getPartitionColumnComments, getPartitionColumnNames, getPartitionColumnTypes, getSerDeStats, parseColumnComments, parseColumnNames, parseColumnNames, parseColumnTypes, parseColumnTypes, shouldStoreFieldsInMetastore, toString
protected org.apache.thrift.transport.TIOStreamTransport outTransport
protected org.apache.thrift.transport.TIOStreamTransport inTransport
protected org.apache.thrift.protocol.TProtocol outProtocol
protected org.apache.thrift.protocol.TProtocol inProtocol
public ThriftByteStreamTypedSerDe(Type objectType, org.apache.thrift.protocol.TProtocolFactory inFactory, org.apache.thrift.protocol.TProtocolFactory outFactory) throws SerDeException
SerDeException
public void initialize(org.apache.hadoop.conf.Configuration configuration, Properties tableProperties, Properties partitionProperties) throws SerDeException
AbstractSerDe
initialize
in class TypedSerDe
configuration
- Hadoop configurationtableProperties
- Table propertiespartitionProperties
- Partition properties (may be null
if
table has no partitions)SerDeException
- if SerDe fails to initializeprotected ObjectInspectorFactory.ObjectInspectorOptions getObjectInspectorOptions()
getObjectInspectorOptions
in class TypedSerDe
public Object deserialize(org.apache.hadoop.io.Writable field) throws SerDeException
Deserializer
deserialize
in interface Deserializer
deserialize
in class ByteStreamTypedSerDe
field
- The Writable object containing a serialized objectSerDeException
Copyright © 2022 The Apache Software Foundation. All rights reserved.