Change in asterixdb[master]: Add support for thetajoins.
Jenkins has posted comments on this change. Change subject: Add support for thetajoins. .. Patch Set 4: WARNING: THIS CHANGE CONTAINS CROSS-PRODUCT CHANGES IN: * asterixdb * hyracks-fullstack PLEASE REVIEW CAREFULLY AND LOOK FOR API CHANGES! -- To view, visit https://asterix-gerrit.ics.uci.edu/1436 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: comment Gerrit-Change-Id: Ibb9a7f3188b6aa01b0784fa5184a2fd1a00c8f4f Gerrit-PatchSet: 4 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: Wenhai Li Gerrit-Reviewer: Jenkins Gerrit-HasComments: No
Change in asterixdb[master]: Add support for thetajoins.
Jenkins has posted comments on this change. Change subject: Add support for thetajoins. .. Patch Set 4: Build Started https://asterix-jenkins.ics.uci.edu/job/asterix-gerrit-notopic/3990/ -- To view, visit https://asterix-gerrit.ics.uci.edu/1436 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: comment Gerrit-Change-Id: Ibb9a7f3188b6aa01b0784fa5184a2fd1a00c8f4f Gerrit-PatchSet: 4 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: Wenhai Li Gerrit-Reviewer: Jenkins Gerrit-HasComments: No
Change in asterixdb[master]: Add support for thetajoins.
Hello Jenkins, I'd like you to reexamine a change. Please visit https://asterix-gerrit.ics.uci.edu/1436 to look at the new patch set (#4). Change subject: Add support for thetajoins. .. Add support for thetajoins. - Add WeightedMergeOperator to join two localRgAgg and merge onto a GlobalAgg. - Add BinaryMergeOperatorDescriptor to merge binary ranges onto glboal one. - Resue the ParallelSortRule to trigger binary join based on sort-merge. - Add PriorityQueue to support sort-based join, i.e., bandjoin, thetajoin, after locally sorted both branches. Change-Id: Ibb9a7f3188b6aa01b0784fa5184a2fd1a00c8f4f --- A asterixdb/asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/ParallelStableSortPOperator.java A asterixdb/asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/WeightedMergeJoinPOperator.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/base/RuleCollections.java A asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceParallelSortRule.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/PushAggFuncIntoStandaloneAggregateRule.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SetAsterixPhysicalOperatorsRule.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SweepIllegalNonfunctionalFunctions.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/InlineAllNtsInSubplanVisitor.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/InlineLeftNtsInSubplanJoinFlatteningVisitor.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/SubplanSpecialFlatteningCheckVisitor.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/AqlPlusExpressionToPlanTranslator.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/LangExpressionToPlanTranslator.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/util/FunctionCollection.java M asterixdb/asterix-algebra/src/main/javacc/AQLPlus.jj A asterixdb/asterix-app/data/skew/zipfan1.tbl A asterixdb/asterix-app/data/skew/zipfan2.tbl A asterixdb/asterix-app/data/skew/zipfanmissing_1.tbl A asterixdb/asterix-app/data/skew/zipfanmissing_2.tbl A asterixdb/asterix-app/data/skew/zipfannull_1.tbl A asterixdb/asterix-app/data/skew/zipfannull_2.tbl A asterixdb/asterix-app/data/tpch0.001/lineitem-part1.tbl A asterixdb/asterix-app/data/tpch0.001/lineitem-part2.tbl A asterixdb/asterix-app/src/test/java/org/apache/asterix/runtime/AsterixAlgebricksHyracksIntegrationUtil.java A asterixdb/asterix-app/src/test/java/org/apache/asterix/runtime/BinaryJoinRuntimeTest.java A asterixdb/asterix-app/src/test/java/org/apache/asterix/runtime/ParallelSortRuntimeTest.java M asterixdb/asterix-app/src/test/java/org/apache/asterix/test/dataflow/TestPartitionComputerFactory.java M asterixdb/asterix-app/src/test/resources/logging.properties M asterixdb/asterix-app/src/test/resources/optimizerts/ignore.txt A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_band_join.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_group.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_join.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_join_group.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_join_nested.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_prime.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_theta_join.aql A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_band_join.plan A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_join.plan A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_join_nested.plan A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_prime.plan A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_theta_join.plan M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_float/avg_float.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_int16/avg_int16.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_int32/avg_int32.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_int64/avg_int64.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_int8/avg_int8.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queri
Change in asterixdb[master]: Add support for thetajoins.
Jenkins has posted comments on this change. Change subject: Add support for thetajoins. .. Patch Set 3: Integration-Tests+1 Integration Tests Successful https://asterix-jenkins.ics.uci.edu/job/asterix-gerrit-integration-tests/1598/ : SUCCESS -- To view, visit https://asterix-gerrit.ics.uci.edu/1436 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: comment Gerrit-Change-Id: Ibb9a7f3188b6aa01b0784fa5184a2fd1a00c8f4f Gerrit-PatchSet: 3 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: Wenhai Li Gerrit-Reviewer: Jenkins Gerrit-HasComments: No
Change in asterixdb[master]: Add support for thetajoins.
Jenkins has posted comments on this change. Change subject: Add support for thetajoins. .. Patch Set 3: BAD+1 BAD Compatibility Tests Successful https://asterix-jenkins.ics.uci.edu/job/asterixbad-compat/292/ : SUCCESS -- To view, visit https://asterix-gerrit.ics.uci.edu/1436 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: comment Gerrit-Change-Id: Ibb9a7f3188b6aa01b0784fa5184a2fd1a00c8f4f Gerrit-PatchSet: 3 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: Wenhai Li Gerrit-Reviewer: Jenkins Gerrit-HasComments: No
Change in asterixdb[master]: Add support for thetajoins.
Jenkins has posted comments on this change. Change subject: Add support for thetajoins. .. Patch Set 3: BAD Compatibility Tests Started https://asterix-jenkins.ics.uci.edu/job/asterixbad-compat/292/ -- To view, visit https://asterix-gerrit.ics.uci.edu/1436 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: comment Gerrit-Change-Id: Ibb9a7f3188b6aa01b0784fa5184a2fd1a00c8f4f Gerrit-PatchSet: 3 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: Wenhai Li Gerrit-Reviewer: Jenkins Gerrit-HasComments: No
Change in asterixdb[master]: Add support for thetajoins.
Jenkins has posted comments on this change. Change subject: Add support for thetajoins. .. Patch Set 3: Integration Tests Started https://asterix-jenkins.ics.uci.edu/job/asterix-gerrit-integration-tests/1598/ -- To view, visit https://asterix-gerrit.ics.uci.edu/1436 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: comment Gerrit-Change-Id: Ibb9a7f3188b6aa01b0784fa5184a2fd1a00c8f4f Gerrit-PatchSet: 3 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: Wenhai Li Gerrit-Reviewer: Jenkins Gerrit-HasComments: No
Change in asterixdb[master]: Add support for thetajoins.
Jenkins has posted comments on this change. Change subject: Add support for thetajoins. .. Patch Set 3: WARNING: THIS CHANGE CONTAINS CROSS-PRODUCT CHANGES IN: * asterixdb * hyracks-fullstack PLEASE REVIEW CAREFULLY AND LOOK FOR API CHANGES! -- To view, visit https://asterix-gerrit.ics.uci.edu/1436 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: comment Gerrit-Change-Id: Ibb9a7f3188b6aa01b0784fa5184a2fd1a00c8f4f Gerrit-PatchSet: 3 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: Wenhai Li Gerrit-Reviewer: Jenkins Gerrit-HasComments: No
Change in asterixdb[master]: Add support for thetajoins.
Jenkins has posted comments on this change. Change subject: Add support for thetajoins. .. Patch Set 3: Build Started https://asterix-jenkins.ics.uci.edu/job/asterix-gerrit-notopic/3932/ -- To view, visit https://asterix-gerrit.ics.uci.edu/1436 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: comment Gerrit-Change-Id: Ibb9a7f3188b6aa01b0784fa5184a2fd1a00c8f4f Gerrit-PatchSet: 3 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: Wenhai Li Gerrit-Reviewer: Jenkins Gerrit-HasComments: No
Change in asterixdb[master]: Add support for thetajoins.
Hello Jenkins, I'd like you to reexamine a change. Please visit https://asterix-gerrit.ics.uci.edu/1436 to look at the new patch set (#3). Change subject: Add support for thetajoins. .. Add support for thetajoins. - Add WeightedMergeOperator to join two localRgAgg and merge onto a GlobalAgg. - Add BinaryMergeOperatorDescriptor to merge binary ranges onto glboal one. - Resue the ParallelSortRule to trigger binary join based on sort-merge. - Add PriorityQueue to support sort-based join, i.e., bandjoin, thetajoin, after locally sorted both branches. Change-Id: Ibb9a7f3188b6aa01b0784fa5184a2fd1a00c8f4f --- A asterixdb/asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/ParallelStableSortPOperator.java A asterixdb/asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/WeightedMergeJoinPOperator.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/base/RuleCollections.java A asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceParallelSortRule.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/PushAggFuncIntoStandaloneAggregateRule.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SetAsterixPhysicalOperatorsRule.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SweepIllegalNonfunctionalFunctions.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/InlineAllNtsInSubplanVisitor.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/InlineLeftNtsInSubplanJoinFlatteningVisitor.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/SubplanSpecialFlatteningCheckVisitor.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/AqlPlusExpressionToPlanTranslator.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/LangExpressionToPlanTranslator.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/util/FunctionCollection.java M asterixdb/asterix-algebra/src/main/javacc/AQLPlus.jj A asterixdb/asterix-app/data/skew/zipfan1.tbl A asterixdb/asterix-app/data/skew/zipfan2.tbl A asterixdb/asterix-app/data/skew/zipfanmissing_1.tbl A asterixdb/asterix-app/data/skew/zipfanmissing_2.tbl A asterixdb/asterix-app/data/skew/zipfannull_1.tbl A asterixdb/asterix-app/data/skew/zipfannull_2.tbl A asterixdb/asterix-app/data/tpch0.001/lineitem-part1.tbl A asterixdb/asterix-app/data/tpch0.001/lineitem-part2.tbl A asterixdb/asterix-app/src/test/java/org/apache/asterix/runtime/AsterixAlgebricksHyracksIntegrationUtil.java A asterixdb/asterix-app/src/test/java/org/apache/asterix/runtime/ParallelSortRuntimeTest.java M asterixdb/asterix-app/src/test/java/org/apache/asterix/test/dataflow/TestPartitionComputerFactory.java M asterixdb/asterix-app/src/test/resources/logging.properties M asterixdb/asterix-app/src/test/resources/optimizerts/ignore.txt A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_band_join.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_group.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_join.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_join_group.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_join_nested.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_prime.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_theta_join.aql A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_band_join.plan A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_join.plan A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_join_nested.plan A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_prime.plan A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_theta_join.plan M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_float/avg_float.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_int16/avg_int16.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_int32/avg_int32.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_int64/avg_int64.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_int8/avg_int8.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/count_01/count_01.3.query.aql M asterixdb/asterix-app/src/test/resources/runtim
Change in asterixdb[master]: Add support for thetajoins.
Jenkins has posted comments on this change. Change subject: Add support for thetajoins. .. Patch Set 2: WARNING: THIS CHANGE CONTAINS CROSS-PRODUCT CHANGES IN: * asterixdb * hyracks-fullstack PLEASE REVIEW CAREFULLY AND LOOK FOR API CHANGES! -- To view, visit https://asterix-gerrit.ics.uci.edu/1436 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: comment Gerrit-Change-Id: Ibb9a7f3188b6aa01b0784fa5184a2fd1a00c8f4f Gerrit-PatchSet: 2 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: Wenhai Li Gerrit-Reviewer: Jenkins Gerrit-HasComments: No
Change in asterixdb[master]: Add support for thetajoins.
Jenkins has posted comments on this change. Change subject: Add support for thetajoins. .. Patch Set 2: Build Started https://asterix-jenkins.ics.uci.edu/job/asterix-gerrit-notopic/3912/ -- To view, visit https://asterix-gerrit.ics.uci.edu/1436 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: comment Gerrit-Change-Id: Ibb9a7f3188b6aa01b0784fa5184a2fd1a00c8f4f Gerrit-PatchSet: 2 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: Wenhai Li Gerrit-Reviewer: Jenkins Gerrit-HasComments: No
Change in asterixdb[master]: Add support for thetajoins.
Wenhai Li has uploaded a new patch set (#2). Change subject: Add support for thetajoins. .. Add support for thetajoins. - Add WeightedMergeOperator to join two localRgAgg and merge onto a GlobalAgg. - Reuse the ParallelSortRule to trigger binary join based on sort-merge. - Add PriorityQueue to support sort-based join, i.e., bandjoin, thetajoin, after locally sorted both branches. Change-Id: Ibb9a7f3188b6aa01b0784fa5184a2fd1a00c8f4f --- A asterixdb/asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/ParallelStableSortPOperator.java A asterixdb/asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/WeightedMergeJoinPOperator.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/base/RuleCollections.java A asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceParallelSortRule.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/PushAggFuncIntoStandaloneAggregateRule.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SetAsterixPhysicalOperatorsRule.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SweepIllegalNonfunctionalFunctions.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/InlineAllNtsInSubplanVisitor.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/InlineLeftNtsInSubplanJoinFlatteningVisitor.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/SubplanSpecialFlatteningCheckVisitor.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/AqlPlusExpressionToPlanTranslator.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/LangExpressionToPlanTranslator.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/util/FunctionCollection.java M asterixdb/asterix-algebra/src/main/javacc/AQLPlus.jj A asterixdb/asterix-app/data/skew/zipfan1.tbl A asterixdb/asterix-app/data/skew/zipfan2.tbl A asterixdb/asterix-app/data/skew/zipfanmissing_1.tbl A asterixdb/asterix-app/data/skew/zipfanmissing_2.tbl A asterixdb/asterix-app/data/skew/zipfannull_1.tbl A asterixdb/asterix-app/data/skew/zipfannull_2.tbl A asterixdb/asterix-app/data/tpch0.001/lineitem-part1.tbl A asterixdb/asterix-app/data/tpch0.001/lineitem-part2.tbl A asterixdb/asterix-app/src/test/java/org/apache/asterix/runtime/AsterixAlgebricksHyracksIntegrationUtil.java A asterixdb/asterix-app/src/test/java/org/apache/asterix/runtime/ParallelSortRuntimeTest.java M asterixdb/asterix-app/src/test/java/org/apache/asterix/test/dataflow/TestPartitionComputerFactory.java M asterixdb/asterix-app/src/test/resources/logging.properties M asterixdb/asterix-app/src/test/resources/optimizerts/ignore.txt A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_band_join.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_group.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_join.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_join_group.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_join_nested.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_prime.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_theta_join.aql A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_band_join.plan A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_join.plan A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_join_nested.plan A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_prime.plan A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_theta_join.plan M asterixdb/asterix-app/src/test/resources/runtimets/only.xml M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_float/avg_float.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_int16/avg_int16.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_int32/avg_int32.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_int64/avg_int64.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_int8/avg_int8.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/count_01/count_01.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/global-avg_01/global-avg_01.3.query.aql A asterixdb/asterix-app/src/test/resources/runtimets/
Change in asterixdb[master]: Add support for thetajoins. - Add WeightedMergeOperator to j...
Wenhai Li has uploaded a new change for review. https://asterix-gerrit.ics.uci.edu/1436 Change subject: Add support for thetajoins. - Add WeightedMergeOperator to join two localRgAgg and merge onto a GlobalAgg. - Resue the ParallelSortRule to trigger binary join based on sort-merge. - Add PriorityQueue to support sort-based join, i.e., bandjoin, thetajoin, .. Add support for thetajoins. - Add WeightedMergeOperator to join two localRgAgg and merge onto a GlobalAgg. - Resue the ParallelSortRule to trigger binary join based on sort-merge. - Add PriorityQueue to support sort-based join, i.e., bandjoin, thetajoin, after locally sorted both branches. Change-Id: Ibb9a7f3188b6aa01b0784fa5184a2fd1a00c8f4f --- A asterixdb/asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/ParallelStableSortPOperator.java A asterixdb/asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/WeightedMergeJoinPOperator.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/base/RuleCollections.java A asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceParallelSortRule.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/PushAggFuncIntoStandaloneAggregateRule.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SetAsterixPhysicalOperatorsRule.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SweepIllegalNonfunctionalFunctions.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/InlineAllNtsInSubplanVisitor.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/InlineLeftNtsInSubplanJoinFlatteningVisitor.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/SubplanSpecialFlatteningCheckVisitor.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/AqlPlusExpressionToPlanTranslator.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/LangExpressionToPlanTranslator.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/util/FunctionCollection.java M asterixdb/asterix-algebra/src/main/javacc/AQLPlus.jj A asterixdb/asterix-app/data/skew/zipfan1.tbl A asterixdb/asterix-app/data/skew/zipfan2.tbl A asterixdb/asterix-app/data/skew/zipfanmissing_1.tbl A asterixdb/asterix-app/data/skew/zipfanmissing_2.tbl A asterixdb/asterix-app/data/skew/zipfannull_1.tbl A asterixdb/asterix-app/data/skew/zipfannull_2.tbl A asterixdb/asterix-app/data/tpch0.001/lineitem-part1.tbl A asterixdb/asterix-app/data/tpch0.001/lineitem-part2.tbl A asterixdb/asterix-app/src/test/java/org/apache/asterix/runtime/AsterixAlgebricksHyracksIntegrationUtil.java A asterixdb/asterix-app/src/test/java/org/apache/asterix/runtime/ParallelSortRuntimeTest.java M asterixdb/asterix-app/src/test/java/org/apache/asterix/test/dataflow/TestPartitionComputerFactory.java M asterixdb/asterix-app/src/test/resources/logging.properties M asterixdb/asterix-app/src/test/resources/optimizerts/ignore.txt A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_band_join.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_group.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_join.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_join_group.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_join_nested.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_prime.aql A asterixdb/asterix-app/src/test/resources/optimizerts/queries/dynamic-connector/psort_theta_join.aql A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_band_join.plan A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_join.plan A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_join_nested.plan A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_prime.plan A asterixdb/asterix-app/src/test/resources/optimizerts/results/dynamic-connector/psort_theta_join.plan M asterixdb/asterix-app/src/test/resources/runtimets/only.xml M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_float/avg_float.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_int16/avg_int16.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_int32/avg_int32.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_int64/avg_int64.3.query.aql M asterixdb/asterix-app/src/test/resources/runtimets/queries/aggregate/avg_int8/avg_int8.3.qu
