Package | Description |
---|---|
org.apache.drill.exec.expr |
Drill expression materialization and evaluation facilities.
|
org.apache.drill.exec.expr.fn.impl | |
org.apache.drill.exec.physical.impl | |
org.apache.drill.exec.physical.impl.aggregate | |
org.apache.drill.exec.physical.impl.common | |
org.apache.drill.exec.physical.impl.partitionsender | |
org.apache.drill.exec.physical.impl.project | |
org.apache.drill.exec.physical.impl.protocol |
Defines a revised implementation of the Drill RecordBatch protocol.
|
org.apache.drill.exec.physical.impl.unorderedreceiver | |
org.apache.drill.exec.physical.impl.validate | |
org.apache.drill.exec.physical.impl.window | |
org.apache.drill.exec.physical.impl.xsort | |
org.apache.drill.exec.record | |
org.apache.drill.exec.vector.complex |
Modifier and Type | Method and Description |
---|---|
TypedFieldId |
ValueVectorReadExpression.getFieldId() |
TypedFieldId |
ValueVectorWriteExpression.getFieldId() |
TypedFieldId |
ValueVectorReadExpression.getTypedFieldId() |
Modifier and Type | Method and Description |
---|---|
List<TypedFieldId> |
ClassGenerator.getWorkspaceTypes() |
Modifier and Type | Method and Description |
---|---|
com.sun.codemodel.JVar |
ClassGenerator.declareVectorValueSetupAndMember(DirectExpression batchName,
TypedFieldId fieldId)
Creates class variable for the value vector using metadata from
fieldId
and initializes it using setup blocks. |
com.sun.codemodel.JVar |
ClassGenerator.declareVectorValueSetupAndMember(String batchName,
TypedFieldId fieldId) |
Constructor and Description |
---|
ValueVectorReadExpression(TypedFieldId tfId) |
ValueVectorReadExpression(TypedFieldId tfId,
BatchReference batchRef) |
ValueVectorWriteExpression(TypedFieldId fieldId,
LogicalExpression child) |
ValueVectorWriteExpression(TypedFieldId fieldId,
LogicalExpression child,
boolean safe) |
Modifier and Type | Method and Description |
---|---|
ValueVectorHashHelper.Hash64 |
ValueVectorHashHelper.getHash64(LogicalExpression[] hashFieldsExp,
TypedFieldId[] hashFieldIds) |
Modifier and Type | Method and Description |
---|---|
TypedFieldId |
ScanBatch.getValueVectorId(SchemaPath path) |
Modifier and Type | Method and Description |
---|---|
TypedFieldId |
SpilledRecordBatch.getValueVectorId(SchemaPath path) |
Modifier and Type | Method and Description |
---|---|
protected void |
StreamingAggBatch.outputRecordKeys(ClassGenerator<StreamingAggregator> cg,
TypedFieldId[] keyOutputIds,
LogicalExpression[] keyExprs) |
protected void |
StreamingAggBatch.outputRecordKeysPrev(ClassGenerator<StreamingAggregator> cg,
TypedFieldId[] keyOutputIds,
LogicalExpression[] keyExprs) |
void |
HashAggregator.setup(HashAggregate hashAggrConfig,
HashTableConfig htConfig,
FragmentContext context,
OperatorContext oContext,
RecordBatch incoming,
HashAggBatch outgoing,
LogicalExpression[] valueExprs,
List<TypedFieldId> valueFieldIds,
ClassGenerator<?> cg,
TypedFieldId[] keyFieldIds,
VectorContainer outContainer,
int extraRowBytes) |
void |
HashAggTemplate.setup(HashAggregate hashAggrConfig,
HashTableConfig htConfig,
FragmentContext context,
OperatorContext oContext,
RecordBatch incoming,
HashAggBatch outgoing,
LogicalExpression[] valueExprs,
List<TypedFieldId> valueFieldIds,
ClassGenerator<?> cg,
TypedFieldId[] groupByOutFieldIds,
VectorContainer outContainer,
int extraRowBytes) |
Modifier and Type | Method and Description |
---|---|
void |
HashAggregator.setup(HashAggregate hashAggrConfig,
HashTableConfig htConfig,
FragmentContext context,
OperatorContext oContext,
RecordBatch incoming,
HashAggBatch outgoing,
LogicalExpression[] valueExprs,
List<TypedFieldId> valueFieldIds,
ClassGenerator<?> cg,
TypedFieldId[] keyFieldIds,
VectorContainer outContainer,
int extraRowBytes) |
void |
HashAggTemplate.setup(HashAggregate hashAggrConfig,
HashTableConfig htConfig,
FragmentContext context,
OperatorContext oContext,
RecordBatch incoming,
HashAggBatch outgoing,
LogicalExpression[] valueExprs,
List<TypedFieldId> valueFieldIds,
ClassGenerator<?> cg,
TypedFieldId[] groupByOutFieldIds,
VectorContainer outContainer,
int extraRowBytes) |
Modifier and Type | Method and Description |
---|---|
HashTable |
ChainedHashTable.createAndSetupHashTable(TypedFieldId[] outKeyFieldIds) |
Modifier and Type | Method and Description |
---|---|
TypedFieldId |
PartitionerTemplate.OutgoingRecordBatch.getValueVectorId(SchemaPath path) |
Modifier and Type | Method and Description |
---|---|
boolean |
ProjectMemoryManager.isFixedWidth(TypedFieldId fieldId) |
Modifier and Type | Method and Description |
---|---|
TypedFieldId |
BatchAccessor.getValueVectorId(SchemaPath path) |
TypedFieldId |
OperatorRecordBatch.getValueVectorId(SchemaPath path) |
TypedFieldId |
VectorContainerAccessor.getValueVectorId(SchemaPath path) |
Modifier and Type | Method and Description |
---|---|
TypedFieldId |
UnorderedReceiverBatch.getValueVectorId(SchemaPath path) |
Modifier and Type | Method and Description |
---|---|
TypedFieldId |
IteratorValidatorBatchIterator.getValueVectorId(SchemaPath path) |
Modifier and Type | Method and Description |
---|---|
TypedFieldId |
WindowDataBatch.getValueVectorId(SchemaPath path) |
Modifier and Type | Method and Description |
---|---|
TypedFieldId |
BatchGroup.getValueVectorId(SchemaPath path) |
Modifier and Type | Method and Description |
---|---|
TypedFieldId |
VectorContainer.add(ValueVector vv) |
TypedFieldId |
TypedFieldId.Builder.build() |
TypedFieldId |
TypedFieldId.cloneWithChild(int id) |
TypedFieldId |
TypedFieldId.cloneWithRemainder(PathSegment remainder) |
TypedFieldId |
HyperVectorWrapper.getFieldIdIfMatches(int id,
SchemaPath expectedPath) |
TypedFieldId |
SimpleVectorWrapper.getFieldIdIfMatches(int id,
SchemaPath expectedPath) |
TypedFieldId |
VectorWrapper.getFieldIdIfMatches(int id,
SchemaPath expectedPath)
Traverse the object graph and determine whether the provided SchemaPath matches data within the Wrapper.
|
TypedFieldId |
RecordBatch.getValueVectorId(SchemaPath path)
Gets the value vector type and ID for the given schema path.
|
TypedFieldId |
RecordIterator.getValueVectorId(SchemaPath path) |
TypedFieldId |
SchemalessBatch.getValueVectorId(SchemaPath path) |
TypedFieldId |
SimpleRecordBatch.getValueVectorId(SchemaPath path) |
TypedFieldId |
VectorAccessible.getValueVectorId(SchemaPath path)
Get the value vector type and id for the given schema path.
|
TypedFieldId |
RecordBatchLoader.getValueVectorId(SchemaPath path) |
TypedFieldId |
AbstractRecordBatch.getValueVectorId(SchemaPath path) |
TypedFieldId |
VectorContainer.getValueVectorId(SchemaPath path) |
Modifier and Type | Method and Description |
---|---|
static String |
TypedFieldId.getPath(TypedFieldId typeFieldId,
RecordBatch recordBatch)
Generates the full path to a field from the typefield ids
|
Modifier and Type | Method and Description |
---|---|
static TypedFieldId |
FieldIdUtil.getFieldId(ValueVector vector,
int id,
SchemaPath expectedPath,
boolean hyper) |
static TypedFieldId |
FieldIdUtil.getFieldIdIfMatches(ValueVector vector,
TypedFieldId.Builder builder,
boolean addToBreadCrumb,
PathSegment seg)
Utility method to obtain
TypedFieldId , providing metadata
for specified field given by value vector used in code generation. |
static TypedFieldId |
FieldIdUtil.getFieldIdIfMatchesUnion(UnionVector unionVector,
TypedFieldId.Builder builder,
boolean addToBreadCrumb,
PathSegment seg) |
Copyright © 1970 The Apache Software Foundation. All rights reserved.