Package | Description |
---|---|
org.apache.hadoop.hive.llap.io.decode | |
org.apache.hadoop.hive.llap.io.encoded | |
org.apache.hadoop.hive.metastore | |
org.apache.hadoop.hive.ql.io.orc |
The Optimized Row Columnar (ORC) File Format.
|
org.apache.hadoop.hive.ql.io.parquet.read | |
org.apache.hadoop.hive.ql.io.sarg | |
org.apache.hadoop.hive.ql.optimizer.ppr | |
org.apache.orc | |
org.apache.orc.impl |
Modifier and Type | Method and Description |
---|---|
ReadPipeline |
OrcColumnVectorProducer.createReadPipeline(Consumer<ColumnVectorBatch> consumer,
org.apache.hadoop.mapred.FileSplit split,
List<Integer> columnIds,
SearchArgument sarg,
String[] columnNames,
QueryFragmentCounters counters) |
ReadPipeline |
ColumnVectorProducer.createReadPipeline(Consumer<ColumnVectorBatch> consumer,
org.apache.hadoop.mapred.FileSplit split,
List<Integer> columnIds,
SearchArgument sarg,
String[] columnNames,
QueryFragmentCounters counters) |
Constructor and Description |
---|
OrcEncodedDataReader(LowLevelCache lowLevelCache,
BufferUsageManager bufferManager,
OrcMetadataCache metadataCache,
org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.mapred.FileSplit split,
List<Integer> columnIds,
SearchArgument sarg,
String[] columnNames,
OrcEncodedDataConsumer consumer,
QueryFragmentCounters counters) |
Modifier and Type | Method and Description |
---|---|
SearchArgument |
PartitionExpressionProxy.createSarg(byte[] expr)
Creates SARG from serialized representation.
|
Modifier and Type | Method and Description |
---|---|
Metastore.SplitInfos |
FileFormatProxy.applySargToMetadata(SearchArgument sarg,
ByteBuffer fileMetadata)
Applies SARG to file metadata, and produces some result for this file.
|
Modifier and Type | Method and Description |
---|---|
Metastore.SplitInfos |
OrcFileFormatProxy.applySargToMetadata(SearchArgument sarg,
ByteBuffer fileMetadata) |
static boolean[] |
OrcInputFormat.pickStripesViaTranslatedSarg(SearchArgument sarg,
OrcFile.WriterVersion writerVersion,
List<OrcProto.Type> types,
List<StripeStatistics> stripeStats,
int stripeCount) |
RecordReader |
ReaderImpl.rows(long offset,
long length,
boolean[] include,
SearchArgument sarg,
String[] columnNames) |
RecordReader |
Reader.rows(long offset,
long length,
boolean[] include,
SearchArgument sarg,
String[] neededColumns)
Create a RecordReader that will read a section of a file.
|
static void |
ExternalCache.translateSargToTableColIndexes(SearchArgument sarg,
org.apache.hadoop.conf.Configuration conf,
int rootColumn)
Modifies the SARG, replacing column names with column indexes in target table schema.
|
Modifier and Type | Method and Description |
---|---|
static org.apache.parquet.filter2.predicate.FilterPredicate |
ParquetFilterPredicateConverter.toFilterPredicate(SearchArgument sarg,
org.apache.parquet.schema.MessageType schema)
Translate the search argument to the filter predicate parquet uses.
|
Modifier and Type | Class and Description |
---|---|
class |
SearchArgumentImpl
The implementation of SearchArguments.
|
Modifier and Type | Method and Description |
---|---|
SearchArgument |
SearchArgument.Builder.build()
Build and return the SearchArgument that has been defined.
|
SearchArgument |
ConvertAstToSearchArg.buildSearchArgument()
Build the search argument from the expression.
|
static SearchArgument |
ConvertAstToSearchArg.create(byte[] kryoBytes) |
static SearchArgument |
ConvertAstToSearchArg.create(ExprNodeGenericFuncDesc expression) |
static SearchArgument |
ConvertAstToSearchArg.create(String kryo) |
static SearchArgument |
ConvertAstToSearchArg.createFromConf(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
SearchArgument |
PartitionExpressionForMetastore.createSarg(byte[] expr) |
Modifier and Type | Method and Description |
---|---|
SearchArgument |
Reader.Options.getSearchArgument() |
Modifier and Type | Method and Description |
---|---|
Reader.Options |
Reader.Options.searchArgument(SearchArgument sarg,
String[] columnNames)
Set search argument for predicate push down.
|
Constructor and Description |
---|
SargApplier(SearchArgument sarg,
String[] columnNames,
long rowIndexStride,
int includedCount,
SchemaEvolution evolution) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.