org.apache.hadoop.hive.ql.io.orc

Class InStream

java.lang.Object

java.io.InputStream

org.apache.hadoop.hive.ql.io.orc.InStream

All Implemented Interfaces:

Closeable, AutoCloseable

public abstract class InStream
extends InputStream

Field Summary

Fields

Modifier and Type	Field and Description
protected long	length
protected String	name

Constructor Summary

Constructors

Constructor and Description
InStream(String name, long length)

Method Summary

Methods

Modifier and Type	Method and Description
static InStream	create(String streamName, ByteBuffer[] buffers, long[] offsets, long length, CompressionCodec codec, int bufferSize) Deprecated.
static InStream	create(String name, List<DiskRange> input, long length, CompressionCodec codec, int bufferSize) Create an input stream from a list of disk ranges with data.
long	getStreamLength()
String	getStreamName()
abstract void	seek(PositionProvider index)

Methods inherited from class java.io.InputStream

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

Methods inherited from class java.lang.Object

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

Field Detail

name

protected final String name

length

protected final long length

Constructor Detail

InStream

public InStream(String name,
        long length)

Method Detail

getStreamName

public String getStreamName()

getStreamLength

public long getStreamLength()

seek

public abstract void seek(PositionProvider index)
                   throws IOException

Throws:

IOException

create

@Deprecated
public static InStream create(String streamName,
                         ByteBuffer[] buffers,
                         long[] offsets,
                         long length,
                         CompressionCodec codec,
                         int bufferSize)
                       throws IOException

Deprecated.

Create an input stream from a list of buffers.

Parameters:

streamName - the name of the stream

buffers - the list of ranges of bytes for the stream

offsets - a list of offsets (the same length as input) that must contain the first offset of the each set of bytes in input

length - the length in bytes of the stream

codec - the compression codec

bufferSize - the compression buffer size

Returns:

an input stream

Throws:

IOException

create

public static InStream create(String name,
              List<DiskRange> input,
              long length,
              CompressionCodec codec,
              int bufferSize)
                       throws IOException

Create an input stream from a list of disk ranges with data.

Parameters:

name - the name of the stream

input - the list of ranges of bytes for the stream; from disk or cache

length - the length in bytes of the stream

codec - the compression codec

bufferSize - the compression buffer size

Returns:

an input stream

Throws:

IOException