org.apache.hadoop.hive.ql.io

Class SchemaAwareCompressionInputStream

java.lang.Object

CompressionInputStream

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

public abstract class SchemaAwareCompressionInputStream
extends CompressionInputStream

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SchemaAwareCompressionInputStream(java.io.InputStream in)

Method Summary

Modifier and Type	Method and Description
abstract void	setColumnIndex(int columnIndex) The column being read

Methods inherited from class java.lang.Object

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

Constructor Detail

SchemaAwareCompressionInputStream

protected SchemaAwareCompressionInputStream(java.io.InputStream in)
                                     throws java.io.IOException

Throws:

java.io.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