public class StreamUtils extends Object
Constructor and Description |
---|
StreamUtils() |
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 SettableUncompressedStream |
createSettableUncompressedStream(String streamName,
org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch.ColumnStreamData streamBuffer)
Create SettableUncompressedStream from stream buffer.
|
public static SettableUncompressedStream createSettableUncompressedStream(String streamName, org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch.ColumnStreamData streamBuffer) throws IOException
streamName
- - stream namestreamBuffer
- - stream bufferIOException
public static org.apache.hadoop.hive.common.DiskRangeInfo createDiskRangeInfo(org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch.ColumnStreamData streamBuffer)
streamBuffer
- - stream bufferCopyright © 2017 The Apache Software Foundation. All rights reserved.