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

java.lang.Object
  java.io.InputStream
      org.apache.hadoop.io.compress.CompressionInputStream
          org.apache.hadoop.hive.ql.io.SchemaAwareCompressionInputStream

All Implemented Interfaces:

Closeable

public abstract class SchemaAwareCompressionInputStream
extends org.apache.hadoop.io.compress.CompressionInputStream

SchemaAwareCompressionInputStream adds the ability to inform the compression stream what column is being read.

Field Summary

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

in

Constructor Summary

protected

SchemaAwareCompressionInputStream(InputStream in)

Method Summary

abstract void

setColumnIndex(int columnIndex) The column being read

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

close, read, resetState

Methods inherited from class java.io.InputStream

available, mark, markSupported, read, read, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

SchemaAwareCompressionInputStream

protected SchemaAwareCompressionInputStream(InputStream in)
                                     throws IOException

Throws:

IOException

Method Detail

setColumnIndex

public abstract void setColumnIndex(int columnIndex)

The column being read

Parameters:

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