Package org.apache.orc.impl

Class InStream.CompressedStream

java.lang.Object

java.io.InputStream

org.apache.orc.impl.InStream

org.apache.orc.impl.InStream.CompressedStream

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

InStream

public static class InStream.CompressedStream
extends InStream

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.orc.impl.InStream

InStream.CompressedStream, InStream.EncryptedStream, InStream.StreamOptions, InStream.UncompressedStream

Field Summary

Fields

Modifier and Type	Field	Description
protected ByteBuffer	compressed
protected long	currentCompressedStart
protected org.apache.hadoop.hive.common.io.DiskRangeList	currentRange

Fields inherited from class org.apache.orc.impl.InStream

bytes, length, name, offset, position, PROTOBUF_MESSAGE_MAX_LIMIT

Constructor Summary

Constructors

Constructor	Description
CompressedStream(Object name, long offset, long length, InStream.StreamOptions options)	Create the stream without resetting the input stream.
CompressedStream(Object name, org.apache.hadoop.hive.common.io.DiskRangeList input, long offset, long length, InStream.StreamOptions options)	Create the stream and initialize the input for the stream.

Method Summary

Modifier and Type	Method	Description
int	available()
void	changeIv(Consumer<byte[]> modifier)
void	close()
int	read()
int	read(byte[] data, int offset, int length)
void	seek(PositionProvider index)
protected void	setCurrent(org.apache.hadoop.hive.common.io.DiskRangeList newRange, boolean isJump)	Set the current range
String	toString()

Methods inherited from class org.apache.orc.impl.InStream

create, create, createCodedInputStream, options, reset, reset

Methods inherited from class java.io.InputStream

mark, markSupported, nullInputStream, read, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo

Methods inherited from class java.lang.Object

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

Field Details

compressed

protected ByteBuffer compressed

currentRange

protected org.apache.hadoop.hive.common.io.DiskRangeList currentRange

currentCompressedStart

protected long currentCompressedStart

Constructor Details

CompressedStream

public CompressedStream(Object name,
 long offset,
 long length,
 InStream.StreamOptions options)

Create the stream without resetting the input stream. This is used in subclasses so they can finish initializing before reset is called.

Parameters:

name - the name of the stream

length - the total number of bytes in the stream

options - the options used to read the stream

CompressedStream

public CompressedStream(Object name,
 org.apache.hadoop.hive.common.io.DiskRangeList input,
 long offset,
 long length,
 InStream.StreamOptions options)

Create the stream and initialize the input for the stream.

Parameters:

name - the name of the stream

input - the input data

length - the total length of the stream

options - the options to read the data with

Method Details

setCurrent

protected void setCurrent(org.apache.hadoop.hive.common.io.DiskRangeList newRange,
 boolean isJump)

Description copied from class: InStream

Set the current range

Specified by:

setCurrent in class InStream

Parameters:

newRange - the block that is current

isJump - if this was a seek instead of a natural read

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException

read

public int read(byte[] data,
 int offset,
 int length)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

available

public int available()
              throws IOException

Overrides:

available in class InputStream

Throws:

IOException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in class InStream

changeIv

public void changeIv(Consumer<byte[]> modifier)

Specified by:

changeIv in class InStream

seek

public void seek(PositionProvider index)
          throws IOException

Specified by:

seek in class InStream

Throws:

IOException

toString

public String toString()

Overrides:

toString in class InStream