org.apache.hadoop.hive.llap.io.encoded

Class LlapRecordReaderUtils

java.lang.Object

org.apache.hadoop.hive.llap.io.encoded.LlapRecordReaderUtils

public class LlapRecordReaderUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
LlapRecordReaderUtils()

Method Summary

Modifier and Type	Method and Description
static LlapDataReader	createDefaultLlapDataReader(org.apache.orc.impl.DataReaderProperties properties)
static DiskRangeList	planIndexReading(org.apache.orc.TypeDescription fileSchema, org.apache.orc.OrcProto.StripeFooter footer, boolean ignoreNonUtf8BloomFilter, boolean[] fileIncluded, boolean[] sargColumns, org.apache.orc.OrcFile.WriterVersion version, org.apache.orc.OrcProto.Stream.Kind[] bloomFilterKinds) Plans the list of disk ranges that the given stripe needs to read the indexes.

Methods inherited from class java.lang.Object

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

Constructor Detail

LlapRecordReaderUtils

public LlapRecordReaderUtils()

Method Detail

createDefaultLlapDataReader

public static LlapDataReader createDefaultLlapDataReader(org.apache.orc.impl.DataReaderProperties properties)

planIndexReading

public static DiskRangeList planIndexReading(org.apache.orc.TypeDescription fileSchema,
                                             org.apache.orc.OrcProto.StripeFooter footer,
                                             boolean ignoreNonUtf8BloomFilter,
                                             boolean[] fileIncluded,
                                             boolean[] sargColumns,
                                             org.apache.orc.OrcFile.WriterVersion version,
                                             org.apache.orc.OrcProto.Stream.Kind[] bloomFilterKinds)

Plans the list of disk ranges that the given stripe needs to read the indexes. All of the positions are relative to the start of the stripe.

Parameters:

fileSchema - the schema for the file

footer - the stripe footer

ignoreNonUtf8BloomFilter - should the reader ignore non-utf8 encoded bloom filters

fileIncluded - the columns (indexed by file columns) that should be read

sargColumns - true for the columns (indexed by file columns) that we need bloom filters for

version - the version of the software that wrote the file

bloomFilterKinds - (output) the stream kind of the bloom filters

Returns:

a list of merged disk ranges to read