Modifier and Type | Method and Description |
---|---|
boolean[] |
RecordReaderImpl.SargApplier.pickRowGroups(org.apache.orc.StripeInformation stripe,
org.apache.orc.OrcProto.RowIndex[] indexes,
org.apache.orc.OrcProto.Stream.Kind[] bloomFilterKinds,
List<org.apache.orc.OrcProto.ColumnEncoding> encodings,
org.apache.orc.OrcProto.BloomFilterIndex[] bloomFilterIndices,
boolean returnNone,
long rowBaseInStripe,
FileIndexResult fileIndexResult)
Pick the row groups that we need to load from the current stripe.
|
Constructor and Description |
---|
RecordReaderImpl(org.apache.orc.impl.ReaderImpl fileReader,
org.apache.orc.Reader.Options options,
FileIndexResult fileIndexResult) |
Modifier and Type | Field and Description |
---|---|
static FileIndexResult |
FileIndexResult.REMAIN |
static FileIndexResult |
FileIndexResult.SKIP |
Modifier and Type | Method and Description |
---|---|
default FileIndexResult |
FileIndexResult.and(FileIndexResult fileIndexResult) |
default FileIndexResult |
FileIndexResult.or(FileIndexResult fileIndexResult) |
Modifier and Type | Method and Description |
---|---|
FileIndexResult |
FileIndexReader.visitAnd(List<FileIndexResult> children) |
FileIndexResult |
FileIndexReader.visitOr(List<FileIndexResult> children) |
Modifier and Type | Class and Description |
---|---|
class |
BitmapIndexResult
bitmap file index result.
|
Modifier and Type | Method and Description |
---|---|
FileIndexResult |
BitmapIndexResult.and(FileIndexResult fileIndexResult) |
FileIndexResult |
BitmapIndexResult.or(FileIndexResult fileIndexResult) |
Modifier and Type | Method and Description |
---|---|
FileIndexResult |
BitmapIndexResult.and(FileIndexResult fileIndexResult) |
FileIndexResult |
BitmapIndexResult.or(FileIndexResult fileIndexResult) |
Modifier and Type | Method and Description |
---|---|
FileIndexResult |
EmptyFileIndexReader.visitContains(FieldRef fieldRef,
Object literal) |
FileIndexResult |
EmptyFileIndexReader.visitEndsWith(FieldRef fieldRef,
Object literal) |
FileIndexResult |
EmptyFileIndexReader.visitEqual(FieldRef fieldRef,
Object literal) |
FileIndexResult |
EmptyFileIndexReader.visitGreaterOrEqual(FieldRef fieldRef,
Object literal) |
FileIndexResult |
EmptyFileIndexReader.visitGreaterThan(FieldRef fieldRef,
Object literal) |
FileIndexResult |
EmptyFileIndexReader.visitIn(FieldRef fieldRef,
List<Object> literals) |
FileIndexResult |
EmptyFileIndexReader.visitIsNotNull(FieldRef fieldRef) |
FileIndexResult |
EmptyFileIndexReader.visitLessOrEqual(FieldRef fieldRef,
Object literal) |
FileIndexResult |
EmptyFileIndexReader.visitLessThan(FieldRef fieldRef,
Object literal) |
FileIndexResult |
EmptyFileIndexReader.visitStartsWith(FieldRef fieldRef,
Object literal) |
Modifier and Type | Method and Description |
---|---|
FileIndexResult |
FormatReaderContext.fileIndex() |
FileIndexResult |
FormatReaderFactory.Context.fileIndex() |
Constructor and Description |
---|
FormatReaderContext(FileIO fileIO,
Path file,
long fileSize,
FileIndexResult fileIndexResult) |
Modifier and Type | Method and Description |
---|---|
static org.apache.orc.Reader |
OrcReaderFactory.createReader(org.apache.hadoop.conf.Configuration conf,
FileIO fileIO,
Path path,
FileIndexResult fileIndexResult) |
Modifier and Type | Method and Description |
---|---|
static ParquetFileReader |
ParquetUtil.getParquetReader(FileIO fileIO,
Path path,
FileIndexResult fileIndexResult)
Generate
ParquetFileReader instance to read the Parquet files at the given path. |
Modifier and Type | Method and Description |
---|---|
static FileIndexResult |
FileIndexEvaluator.evaluate(FileIO fileIO,
TableSchema dataSchema,
List<Predicate> dataFilter,
DataFilePathFactory dataFilePathFactory,
DataFileMeta file) |
Constructor and Description |
---|
ParquetFileReader(org.apache.parquet.io.InputFile file,
org.apache.parquet.ParquetReadOptions options,
FileIndexResult fileIndexResult) |
Modifier and Type | Method and Description |
---|---|
static RowRanges |
ColumnIndexFilter.calculateRowRanges(org.apache.parquet.filter2.compat.FilterCompat.Filter filter,
org.apache.parquet.internal.filter2.columnindex.ColumnIndexStore columnIndexStore,
Set<org.apache.parquet.hadoop.metadata.ColumnPath> paths,
long rowCount,
long rowIndexOffset,
FileIndexResult fileIndexResult)
Calculates the row ranges containing the indexes of the rows might match the specified
filter.
|
static RowRanges |
RowRanges.create(long rowCount,
long rowIndexOffset,
PrimitiveIterator.OfInt pageIndexes,
org.apache.parquet.internal.column.columnindex.OffsetIndex offsetIndex,
FileIndexResult fileIndexResult)
Support using
FileIndexResult to filter the row ranges. |
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.