org.apache.hadoop.hive.ql.io.orc
Class OrcRawRecordMerger
java.lang.Object
org.apache.hadoop.hive.ql.io.orc.OrcRawRecordMerger
- All Implemented Interfaces:
- AcidInputFormat.RawReader<OrcStruct>, org.apache.hadoop.mapred.RecordReader<RecordIdentifier,OrcStruct>
public class OrcRawRecordMerger
- extends Object
- implements AcidInputFormat.RawReader<OrcStruct>
Merges a base and a list of delta files together into a single stream of
events.
next
public boolean next(RecordIdentifier recordIdentifier,
OrcStruct prev)
throws IOException
- Specified by:
next
in interface org.apache.hadoop.mapred.RecordReader<RecordIdentifier,OrcStruct>
- Throws:
IOException
createKey
public RecordIdentifier createKey()
- Specified by:
createKey
in interface org.apache.hadoop.mapred.RecordReader<RecordIdentifier,OrcStruct>
createValue
public OrcStruct createValue()
- Specified by:
createValue
in interface org.apache.hadoop.mapred.RecordReader<RecordIdentifier,OrcStruct>
getPos
public long getPos()
throws IOException
- Specified by:
getPos
in interface org.apache.hadoop.mapred.RecordReader<RecordIdentifier,OrcStruct>
- Throws:
IOException
close
public void close()
throws IOException
- Specified by:
close
in interface org.apache.hadoop.mapred.RecordReader<RecordIdentifier,OrcStruct>
- Throws:
IOException
getProgress
public float getProgress()
throws IOException
- Specified by:
getProgress
in interface org.apache.hadoop.mapred.RecordReader<RecordIdentifier,OrcStruct>
- Throws:
IOException
getObjectInspector
public ObjectInspector getObjectInspector()
- Specified by:
getObjectInspector
in interface AcidInputFormat.RawReader<OrcStruct>
getColumns
public int getColumns()
- Get the number of columns in the underlying rows.
- Returns:
- 0 if there are no base and no deltas.
Copyright © 2014 The Apache Software Foundation. All rights reserved.