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 and Description
IcebergWritable(Record record, Schema schema)

Method Summary

Modifier and Type	Method and 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)

Methods inherited from class java.lang.Object

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

Constructor Detail

IcebergWritable

public IcebergWritable(Record record,
                       Schema schema)

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 interface org.apache.hadoop.io.Writable

readFields

public void readFields(java.io.DataInput dataInput)

Specified by:

readFields in interface org.apache.hadoop.io.Writable