org.apache.hadoop.hive.ql.io
Class SchemaAwareCompressionOutputStream

java.lang.Object
  java.io.OutputStream
      org.apache.hadoop.io.compress.CompressionOutputStream
          org.apache.hadoop.hive.ql.io.SchemaAwareCompressionOutputStream

All Implemented Interfaces:

Closeable, Flushable

public abstract class SchemaAwareCompressionOutputStream
extends org.apache.hadoop.io.compress.CompressionOutputStream

SchemaAwareCompressionOutputStream adds the ability to inform the comression stream the current column being compressed.

Method Summary

abstract void

setColumnIndex(int columnIndex) The column being output

Methods inherited from class org.apache.hadoop.io.compress.CompressionOutputStream

close, finish, flush, resetState, write

Methods inherited from class java.io.OutputStream

write, write

Methods inherited from class java.lang.Object

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

Method Detail

setColumnIndex

public abstract void setColumnIndex(int columnIndex)

The column being output

Parameters:

columnIndex - the index of the column. Use -1 for non-column data