Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Drill >> mail # dev >> [5/5] git commit: DRILL-185: Extend code/clean code generator and add first aggregate functions.


Copy link to this message
-
[5/5] git commit: DRILL-185: Extend code/clean code generator and add first aggregate functions.
DRILL-185: Extend code/clean code generator and add first aggregate functions.
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/e43093d9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/e43093d9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/e43093d9

Branch: refs/heads/master
Commit: e43093d9e0df6a2c3f9f217cf8b16969f13afabb
Parents: daa42b8
Author: Jacques Nadeau <[EMAIL PROTECTED]>
Authored: Sat Aug 24 21:21:51 2013 -0700
Committer: Jacques Nadeau <[EMAIL PROTECTED]>
Committed: Tue Aug 27 16:38:28 2013 -0700

----------------------------------------------------------------------
 .../common/expression/OutputTypeDeterminer.java |   1 +
 .../expression/fn/AggregationFunctions.java     |   2 +-
 .../templates/FixedValueVectors.java            |  29 +-
 .../templates/NullableValueVectors.java         |  37 ++-
 .../templates/RepeatedValueVectors.java         |  18 +-
 .../templates/VariableLengthVectors.java        |  54 +++-
 .../drill/exec/compile/ClassTransformer.java    |  27 +-
 .../exec/compile/TemplateClassDefinition.java   |  34 +-
 .../compile/sig/DefaultGeneratorSignature.java  |  22 --
 .../exec/compile/sig/GeneratorMapping.java      |  41 ++-
 .../drill/exec/compile/sig/MappingSet.java      |  37 ++-
 .../drill/exec/compile/sig/SignatureHolder.java |  24 +-
 .../apache/drill/exec/expr/CodeGenerator.java   | 130 ++++++--
 .../drill/exec/expr/DirectExpression.java       |  50 +++
 .../apache/drill/exec/expr/DrillAggFunc.java    |  10 +
 .../apache/drill/exec/expr/DrillAggrFunc.java   |   9 -
 .../apache/drill/exec/expr/DrillBatchFunc.java  |  10 -
 .../org/apache/drill/exec/expr/DrillFunc.java   |   5 -
 .../apache/drill/exec/expr/DrillSimpleFunc.java |   8 +
 .../drill/exec/expr/EvaluationVisitor.java      |  68 ++--
 .../exec/expr/ExpressionTreeMaterializer.java   |   3 +-
 .../exec/expr/ValueVectorReadExpression.java    |  15 +-
 .../exec/expr/ValueVectorWriteExpression.java   |  13 +-
 .../drill/exec/expr/fn/DrillAggFuncHolder.java  |  63 +++-
 .../drill/exec/expr/fn/DrillFuncHolder.java     | 207 +++++++++----
 .../exec/expr/fn/DrillSimpleFuncHolder.java     | 103 +++++++
 .../drill/exec/expr/fn/FunctionConverter.java   |  23 +-
 .../drill/exec/expr/fn/FunctionHolder.java      | 153 ---------
 .../expr/fn/FunctionImplementationRegistry.java |  19 +-
 .../exec/expr/fn/agg/impl/CountFunctions.java   |  69 +++++
 .../exec/expr/fn/agg/impl/SumFunctions.java     |  69 +++++
 .../drill/exec/expr/fn/impl/Alternator.java     |   6 +-
 .../drill/exec/expr/fn/impl/ByteSubstring.java  |   4 +-
 .../drill/exec/expr/fn/impl/CharSubstring.java  |   4 +-
 .../exec/expr/fn/impl/ComparatorFunctions.java  |   6 +-
 .../exec/expr/fn/impl/ComparisonFunctions.java  |  50 +--
 .../fn/impl/ComparisonFunctionsNullable.java    |  26 +-
 .../apache/drill/exec/expr/fn/impl/Hash.java    |   4 +-
 .../drill/exec/expr/fn/impl/IsNotNull.java      |  11 +-
 .../apache/drill/exec/expr/fn/impl/IsNull.java  |  11 +-
 .../drill/exec/expr/fn/impl/MathFunctions.java  |   8 +-
 .../expr/fn/impl/SimpleRepeatedFunctions.java   |   8 +-
 .../drill/exec/expr/holders/Float8Holder.java   |  13 -
 .../exec/expr/holders/NullableFloat8Holder.java |  14 -
 .../drill/exec/physical/base/AbstractBase.java  |   3 +
 .../physical/base/AbstractPhysicalVisitor.java  |   6 +
 .../exec/physical/base/PhysicalVisitor.java     |   2 +-
 .../drill/exec/physical/config/Project.java     |   1 -
 .../physical/config/StreamingAggregate.java     |  83 +++++
 .../drill/exec/physical/impl/ImplCreator.java   |  12 +-
 .../drill/exec/physical/impl/ScanBatch.java     |  32 +-
 .../exec/physical/impl/aggregate/AggBatch.java  | 309 +++++++++++++++++++
 .../impl/aggregate/AggBatchCreator.java         |  23 ++
 .../physical/impl/aggregate/AggTemplate.java    | 288 +++++++++++++++++
 .../physical/impl/aggregate/Aggregator.java     |  26 ++
 .../physical/impl/aggregate/BatchIterator.java  |   9 +
 .../physical/impl/aggregate/InternalBatch.java  |  65 ++++
 .../physical/impl/filter/FilterEvaluator.java   |  10 -
 .../physical/impl/filter/FilterTemplate.java    |   7 +-
 .../exec/physical/impl/filter/Filterer.java     |   3 +-
 .../partitionsender/OutgoingRecordBatch.java    |  71 ++---
 .../impl/partitionsender/Partitioner.java       |   6 +-
 .../partitionsender/PartitionerEvaluator.java   |  28 --
 .../partitionsender/PartitionerTemplate.java    |   7 +-
 .../physical/impl/project/ProjectEvaluator.java |  12 -
 .../impl/project/ProjectRecordBatch.java        |  41 +--
 .../exec/physical/impl/project/Projector.java   |   6 +-
 .../impl/project/ProjectorTemplate.java         |   7 +-
 .../exec/physical/impl/sort/Comparator.java     |  11 -
 .../physical/impl/sort/ReadIndexRewriter.java   |  87 ------
 .../physical/impl/sort/RecordBatchData.java     |   2 +-
 .../exec/physical/impl/sort/SortBatch.java      |  15 +-
 .../exec/physical/impl/sort/SortSignature.java  |  20 --
 .../exec/physical/impl/sort/SortTemplate.java   |   7 +-
 .../drill/exec/physical/impl/sort/Sorter.java   |   3 +-
 .../exec/physical/impl/svremover/Copier.java    |  10 +-
 .../impl/svremover/CopierTemplate2.java         |   9 +-
 .../impl/svremover/CopierTemplate4.java         |  14 +-
 .../physical/impl/svremover/CopyEvaluator.java  |  11 -
 .../impl/svremover/RemovingRecordBatch.java     |  66 +---
 .../drill/exec/record/HyperVectorWrapper.java   |  15 +
 .../drill/exec/record/MaterializedField.java    |  10 +-
 .../drill/exec/record/SimpleVectorWrapper.java  |   8 +
 .../apache/drill/exec/record/TransferPair.java  |   1 +
 .../drill/exec/record/VectorContainer.java      |  36 ++-
 .../apache/drill/exec/record/VectorWrapper.java |   1 +
 .../exec/record/selection/SelectionVector4.java |  30 +-
 .../drill/exec/store/mock/MockRecordReader.java |   7 +-
 .../drill/exec/vector/BaseValueVector.java      |   5 +
 .../org/apache/drill/exec/vector/BitVector.jav