[
https://issues.apache.org/jira/browse/HIVE-4381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Phabricator updated HIVE-4381:
------------------------------
Attachment: HIVE-4381.D10449.1.patch
rusanu requested code review of "HIVE-4381 [jira] Implement vectorized
aggregation expressions".
Reviewers: JIRA
Vectorized agregate initial implementation. Works for COUNT, SUM, MAX, MIN,
AVG, VARIANCE (pop/samp) and STD (pop/samp). GROUP BY does not work, nor
COUNT(*).
Vectorized implementation for sum, min, max, average and count.
TEST PLAN
Added TestVectorGroupByOperator
REVISION DETAIL
https://reviews.facebook.net/D10449
AFFECTED FILES
.arcconfig
.checkstyle
build.xml
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorFileSinkOperator.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorFilterOperator.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorGroupByOperator.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorMapOperator.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorSelectOperator.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorVectorizerOperator.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorizationContext.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorizedRowBatch.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorizedSerde.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/BinaryExpression.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/ColAndCol.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/ColOrCol.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/ColumnExpression.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/FilterExprAndExpr.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/FilterExprOrExpr.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/FilterNotExpr.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/FilterStringColLikeStringScalar.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/IdentityExpression.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/IsNotNull.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/IsNull.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/NotCol.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/SelectColumnIsFalse.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/SelectColumnIsNotNull.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/SelectColumnIsNull.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/SelectColumnIsTrue.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/StringExpr.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/StringLength.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/StringLower.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/StringUnaryUDF.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/StringUpper.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/VectorAggregateExpression.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFAvgDouble.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFAvgLong.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFCountDouble.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFCountLong.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMaxDouble.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMaxLong.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMinDouble.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMinLong.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdPopDouble.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdPopLong.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdSampDouble.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdSampLong.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFSumDouble.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFSumLong.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarPopDouble.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarPopLong.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarSampDouble.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarSampLong.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/templates/CodeGen.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/templates/VectorUDAFAvg.txt
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/templates/VectorUDAFCount.txt
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/templates/VectorUDAFMinMax.txt
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/templates/VectorUDAFSum.txt
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/templates/VectorUDAFVar.txt
ql/src/java/org/apache/hadoop/hive/ql/udf/IUDFUnaryString.java
ql/src/test/org/apache/hadoop/hive/ql/exec/vector/TestVectorGroupByOperator.java
ql/src/test/org/apache/hadoop/hive/ql/exec/vector/util/FakeCaptureOutputDesc.java
ql/src/test/org/apache/hadoop/hive/ql/exec/vector/util/FakeCaptureOutputOperator.java
ql/src/test/org/apache/hadoop/hive/ql/exec/vector/util/FakeVectorDataSourceOperator.java
ql/src/test/org/apache/hadoop/hive/ql/exec/vector/util/FakeVectorDataSourceOperatorDesc.java
ql/src/test/org/apache/hadoop/hive/ql/exec/vector/util/FakeVectorRowBatchBase.java
ql/src/test/org/apache/hadoop/hive/ql/exec/vector/util/FakeVectorRowBatchFromConcat.java
ql/src/test/org/apache/hadoop/hive/ql/exec/vector/util/FakeVectorRowBatchFromIterables.java
ql/src/test/org/apache/hadoop/hive/ql/exec/vector/util/FakeVectorRowBatchFromRepeats.java
MANAGE HERALD RULES
https://reviews.facebook.net/herald/view/differential/
WHY DID I GET THIS EMAIL?
https://reviews.facebook.net/herald/transcript/24993/
To: JIRA, rusanu
> Implement vectorized aggregation expressions
> --------------------------------------------
>
> Key: HIVE-4381
> URL: https://issues.apache.org/jira/browse/HIVE-4381
> Project: Hive
> Issue Type: Sub-task
> Reporter: Jitendra Nath Pandey
> Assignee: Remus Rusanu
> Attachments: HIVE-4381.D10449.1.patch
>
>
> Vectorized implementation for sum, min, max, average and count.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
