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, AutoCloseable, 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.

Field Summary

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

in, maxAvailableData

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SchemaAwareCompressionInputStream(InputStream in)

Method Summary

Modifier and Type	Method and Description
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

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