Package org.apache.iceberg.mr.mapred
Class IcebergWritable
- java.lang.Object
-
- org.apache.iceberg.mr.mapred.IcebergWritable
-
- All Implemented Interfaces:
org.apache.hadoop.io.Writable
public class IcebergWritable extends java.lang.Object implements org.apache.hadoop.io.Writable
Wraps an Iceberg Record in a Writable which Hive can use in the SerDe.
-
-
Constructor Summary
Constructors Constructor Description IcebergWritable(Record record, Schema schema)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
readFields(java.io.DataInput dataInput)
Record
record()
Schema
schema()
void
wrapRecord(Record record)
void
wrapSchema(Schema schema)
void
write(java.io.DataOutput dataOutput)
-
-
-
Method Detail
-
wrapRecord
public void wrapRecord(Record record)
-
record
public Record record()
-
schema
public Schema schema()
-
wrapSchema
public void wrapSchema(Schema schema)
-
write
public void write(java.io.DataOutput dataOutput)
- Specified by:
write
in interfaceorg.apache.hadoop.io.Writable
-
readFields
public void readFields(java.io.DataInput dataInput)
- Specified by:
readFields
in interfaceorg.apache.hadoop.io.Writable
-
-