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

Class StreamUtils

java.lang.Object

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

public class StreamUtils
extends Object

Stream utility.

Constructor Summary

Constructors

Constructor and Description
StreamUtils()

Method Summary

Modifier and Type	Method and Description
static org.apache.hadoop.hive.common.DiskRangeInfo	createDiskRangeInfo(org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch.ColumnStreamData streamBuffer) Converts stream buffers to disk ranges.
static org.apache.orc.impl.SettableUncompressedStream	createSettableUncompressedStream(String streamName, org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch.ColumnStreamData streamBuffer) Create SettableUncompressedStream from stream buffer.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamUtils

public StreamUtils()

Method Detail

createSettableUncompressedStream

public static org.apache.orc.impl.SettableUncompressedStream createSettableUncompressedStream(String streamName,
                                                                                              org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch.ColumnStreamData streamBuffer)
                                                                                       throws IOException

Create SettableUncompressedStream from stream buffer.

Parameters:

streamName - - stream name

streamBuffer - - stream buffer

Returns:

- SettableUncompressedStream

Throws:

IOException

createDiskRangeInfo

public static org.apache.hadoop.hive.common.DiskRangeInfo createDiskRangeInfo(org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch.ColumnStreamData streamBuffer)

Converts stream buffers to disk ranges.

Parameters:

streamBuffer - - stream buffer

Returns:

- total length of disk ranges