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, org.apache.hadoop.fs.Seekable

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.

Method Summary

abstract void

setColumnIndex(int columnIndex) The column being read

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

close, getPos, read, resetState, seek, seekToNewSource

Methods inherited from class java.io.InputStream

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

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 read

Parameters:

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