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

  • Field Summary

    Fields inherited from class org.apache.hadoop.hive.serde2.AbstractSerDe

    configErrors

  • Constructor Summary

    Constructors
    Constructor
    Description
    HiveIcebergSerDe()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    Object
    deserialize(org.apache.hadoop.io.Writable writable)
     
    org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector
    getObjectInspector()
     
    org.apache.hadoop.hive.serde2.SerDeStats
    getSerDeStats()
     
    Class<? extends org.apache.hadoop.io.Writable>
    getSerializedClass()
     
    void
    initialize(org.apache.hadoop.conf.Configuration configuration, Properties serDeProperties)
     
    org.apache.hadoop.io.Writable
    serialize(Object o, org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector objectInspector)
     

    Methods inherited from class org.apache.hadoop.hive.serde2.AbstractSerDe

    getConfigurationErrors, initialize, shouldStoreFieldsInMetastore

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • HiveIcebergSerDe

      public HiveIcebergSerDe()

  • Method Details

    • initialize

      public void initialize(@Nullable org.apache.hadoop.conf.Configuration configuration, Properties serDeProperties) throws org.apache.hadoop.hive.serde2.SerDeException
      Specified by:
      initialize in interface org.apache.hadoop.hive.serde2.Deserializer
      Specified by:
      initialize in interface org.apache.hadoop.hive.serde2.Serializer
      Specified by:
      initialize in class org.apache.hadoop.hive.serde2.AbstractSerDe
      Throws:
      org.apache.hadoop.hive.serde2.SerDeException

    • getSerializedClass

      public Class<? extends org.apache.hadoop.io.Writable> getSerializedClass()
      Specified by:
      getSerializedClass in interface org.apache.hadoop.hive.serde2.Serializer
      Specified by:
      getSerializedClass in class org.apache.hadoop.hive.serde2.AbstractSerDe

    • serialize

      public org.apache.hadoop.io.Writable serialize(Object o, org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector objectInspector)
      Specified by:
      serialize in interface org.apache.hadoop.hive.serde2.Serializer
      Specified by:
      serialize in class org.apache.hadoop.hive.serde2.AbstractSerDe

    • getSerDeStats

      public org.apache.hadoop.hive.serde2.SerDeStats getSerDeStats()
      Specified by:
      getSerDeStats in interface org.apache.hadoop.hive.serde2.Deserializer
      Specified by:
      getSerDeStats in interface org.apache.hadoop.hive.serde2.Serializer
      Specified by:
      getSerDeStats in class org.apache.hadoop.hive.serde2.AbstractSerDe

    • deserialize

      public Object deserialize(org.apache.hadoop.io.Writable writable)
      Specified by:
      deserialize in interface org.apache.hadoop.hive.serde2.Deserializer
      Specified by:
      deserialize in class org.apache.hadoop.hive.serde2.AbstractSerDe

    • getObjectInspector

      public org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector getObjectInspector()
      Specified by:
      getObjectInspector in interface org.apache.hadoop.hive.serde2.Deserializer
      Specified by:
      getObjectInspector in class org.apache.hadoop.hive.serde2.AbstractSerDe