Package org.apache.iceberg.mr.hive
Class HiveIcebergSerDe
- java.lang.Object
-
- org.apache.hadoop.hive.serde2.AbstractSerDe
-
- org.apache.iceberg.mr.hive.HiveIcebergSerDe
-
- All Implemented Interfaces:
org.apache.hadoop.hive.serde2.Deserializer
,org.apache.hadoop.hive.serde2.Serializer
public class HiveIcebergSerDe extends org.apache.hadoop.hive.serde2.AbstractSerDe
-
-
Constructor Summary
Constructors Constructor Description HiveIcebergSerDe()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Object
deserialize(org.apache.hadoop.io.Writable writable)
org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector
getObjectInspector()
org.apache.hadoop.hive.serde2.SerDeStats
getSerDeStats()
java.lang.Class<? extends org.apache.hadoop.io.Writable>
getSerializedClass()
void
initialize(org.apache.hadoop.conf.Configuration configuration, java.util.Properties serDeProperties)
org.apache.hadoop.io.Writable
serialize(java.lang.Object o, org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector objectInspector)
-
-
-
Method Detail
-
initialize
public void initialize(@Nullable org.apache.hadoop.conf.Configuration configuration, java.util.Properties serDeProperties) throws org.apache.hadoop.hive.serde2.SerDeException
- Specified by:
initialize
in interfaceorg.apache.hadoop.hive.serde2.Deserializer
- Specified by:
initialize
in interfaceorg.apache.hadoop.hive.serde2.Serializer
- Specified by:
initialize
in classorg.apache.hadoop.hive.serde2.AbstractSerDe
- Throws:
org.apache.hadoop.hive.serde2.SerDeException
-
getSerializedClass
public java.lang.Class<? extends org.apache.hadoop.io.Writable> getSerializedClass()
- Specified by:
getSerializedClass
in interfaceorg.apache.hadoop.hive.serde2.Serializer
- Specified by:
getSerializedClass
in classorg.apache.hadoop.hive.serde2.AbstractSerDe
-
serialize
public org.apache.hadoop.io.Writable serialize(java.lang.Object o, org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector objectInspector)
- Specified by:
serialize
in interfaceorg.apache.hadoop.hive.serde2.Serializer
- Specified by:
serialize
in classorg.apache.hadoop.hive.serde2.AbstractSerDe
-
getSerDeStats
public org.apache.hadoop.hive.serde2.SerDeStats getSerDeStats()
- Specified by:
getSerDeStats
in interfaceorg.apache.hadoop.hive.serde2.Deserializer
- Specified by:
getSerDeStats
in interfaceorg.apache.hadoop.hive.serde2.Serializer
- Specified by:
getSerDeStats
in classorg.apache.hadoop.hive.serde2.AbstractSerDe
-
deserialize
public java.lang.Object deserialize(org.apache.hadoop.io.Writable writable)
- Specified by:
deserialize
in interfaceorg.apache.hadoop.hive.serde2.Deserializer
- Specified by:
deserialize
in classorg.apache.hadoop.hive.serde2.AbstractSerDe
-
getObjectInspector
public org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector getObjectInspector()
- Specified by:
getObjectInspector
in interfaceorg.apache.hadoop.hive.serde2.Deserializer
- Specified by:
getObjectInspector
in classorg.apache.hadoop.hive.serde2.AbstractSerDe
-
-