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.

Field Summary

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

out

Constructor Summary

protected

SchemaAwareCompressionOutputStream(OutputStream out)

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

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

Constructor Detail

SchemaAwareCompressionOutputStream

protected SchemaAwareCompressionOutputStream(OutputStream out)

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