org.apache.hadoop.hive.ql.io
Class RCFile.ValueBuffer

java.lang.Object
  org.apache.hadoop.hive.ql.io.RCFile.ValueBuffer

All Implemented Interfaces:

Comparable, org.apache.hadoop.io.Writable, org.apache.hadoop.io.WritableComparable

Enclosing class:

RCFile

public static class RCFile.ValueBuffer
extends Object
implements org.apache.hadoop.io.WritableComparable

ValueBuffer is the value of each record in RCFile. Its on-disk layout is as below:

• Compressed or plain data of [column_1_row_1_value, column_1_row_2_value,....]
• Compressed or plain data of [column_2_row_1_value, column_2_row_2_value,....]

Constructor Summary

RCFile.ValueBuffer()

RCFile.ValueBuffer(RCFile.KeyBuffer keyBuffer)

RCFile.ValueBuffer(RCFile.KeyBuffer keyBuffer, boolean[] skippedColIDs)

RCFile.ValueBuffer(RCFile.KeyBuffer currentKey, int columnNumber, boolean[] skippedCols, org.apache.hadoop.io.compress.CompressionCodec codec)

RCFile.ValueBuffer(RCFile.KeyBuffer currentKey, int columnNumber, boolean[] skippedCols, org.apache.hadoop.io.compress.CompressionCodec codec, boolean lazyDecompress)

Method Summary

void	clearColumnBuffer()
void	close()
int	compareTo(Object arg0)
void	readFields(DataInput in)
void	setColumnValueBuffer(NonSyncDataOutputBuffer valBuffer, int addIndex)
void	write(DataOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

RCFile.ValueBuffer

public RCFile.ValueBuffer()
                   throws IOException

Throws:

IOException

RCFile.ValueBuffer

public RCFile.ValueBuffer(RCFile.KeyBuffer keyBuffer)
                   throws IOException

Throws:

IOException

RCFile.ValueBuffer

public RCFile.ValueBuffer(RCFile.KeyBuffer keyBuffer,
                          boolean[] skippedColIDs)
                   throws IOException

Throws:

IOException

RCFile.ValueBuffer

public RCFile.ValueBuffer(RCFile.KeyBuffer currentKey,
                          int columnNumber,
                          boolean[] skippedCols,
                          org.apache.hadoop.io.compress.CompressionCodec codec)
                   throws IOException

Throws:

IOException

RCFile.ValueBuffer

public RCFile.ValueBuffer(RCFile.KeyBuffer currentKey,
                          int columnNumber,
                          boolean[] skippedCols,
                          org.apache.hadoop.io.compress.CompressionCodec codec,
                          boolean lazyDecompress)
                   throws IOException

Throws:

IOException

Method Detail

setColumnValueBuffer

public void setColumnValueBuffer(NonSyncDataOutputBuffer valBuffer,
                                 int addIndex)

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

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

Throws:

IOException

write

public void write(DataOutput out)
           throws IOException

Specified by:

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

Throws:

IOException

clearColumnBuffer

public void clearColumnBuffer()
                       throws IOException

Throws:

IOException

close

public void close()

compareTo

public int compareTo(Object arg0)

Specified by:

compareTo in interface Comparable