Return-Path: X-Original-To: apmail-asterixdb-commits-archive@minotaur.apache.org Delivered-To: apmail-asterixdb-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id DB98B17BED for ; Fri, 24 Apr 2015 18:47:03 +0000 (UTC) Received: (qmail 26539 invoked by uid 500); 24 Apr 2015 18:47:03 -0000 Delivered-To: apmail-asterixdb-commits-archive@asterixdb.apache.org Received: (qmail 26507 invoked by uid 500); 24 Apr 2015 18:47:03 -0000 Mailing-List: contact commits-help@asterixdb.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@asterixdb.incubator.apache.org Delivered-To: mailing list commits@asterixdb.incubator.apache.org Received: (qmail 26498 invoked by uid 99); 24 Apr 2015 18:47:03 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 24 Apr 2015 18:47:03 +0000 X-ASF-Spam-Status: No, hits=0.0 required=5.0 tests=SPF_PASS,WEIRD_PORT X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of root@apache.org designates 54.191.145.13 as permitted sender) Received: from [54.191.145.13] (HELO mx1-us-west.apache.org) (54.191.145.13) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 24 Apr 2015 18:46:54 +0000 Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-us-west.apache.org (ASF Mail Server at mx1-us-west.apache.org) with SMTP id 0F59325FFB for ; Fri, 24 Apr 2015 18:45:30 +0000 (UTC) Received: (qmail 19059 invoked by uid 99); 24 Apr 2015 18:45:29 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 24 Apr 2015 18:45:29 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id DE155E17DC; Fri, 24 Apr 2015 18:45:29 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: imaxon@apache.org To: commits@asterixdb.incubator.apache.org Date: Fri, 24 Apr 2015 18:46:18 -0000 Message-Id: In-Reply-To: <0a743a5c99b842bf8de294f7df7a3d2b@git.apache.org> References: <0a743a5c99b842bf8de294f7df7a3d2b@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [51/85] [abbrv] [partial] incubator-asterixdb-hyracks git commit: Move Pregelix and Hivesterix codebase to new repositories: 1. Move Pregelix codebase to https://github.com/pregelix/pregelix; 2. Move Hivesterix codebase to https://code.google.com/p/hives X-Virus-Checked: Checked by ClamAV on apache.org Move Pregelix and Hivesterix codebase to new repositories: 1. Move Pregelix codebase to https://github.com/pregelix/pregelix; 2. Move Hivesterix codebase to https://code.google.com/p/hivesterix . Change-Id: Iede698fcb92a0ad0a7a4918ea69b54886fd64fc7 Reviewed-on: http://fulliautomatix.ics.uci.edu:8443/155 Tested-by: Jenkins Reviewed-by: Ian Maxon Project: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/commit/ffc967fd Tree: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/tree/ffc967fd Diff: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/diff/ffc967fd Branch: refs/heads/master Commit: ffc967fdb5aef9e71132a7b5ce0813714c757e3e Parents: 15a7d14 Author: buyingyi Authored: Tue Oct 28 14:50:32 2014 -0700 Committer: Ian Maxon Committed: Tue Nov 4 13:04:53 2014 -0800 ---------------------------------------------------------------------- hivesterix/.gitignore | 1 - hivesterix/HyracksCodeFormatProfile.xml | 293 - hivesterix/build.sh | 12 - hivesterix/hivesterix-common/pom.xml | 92 - .../ics/hivesterix/common/config/ConfUtil.java | 200 - .../logical/expression/ExpressionConstant.java | 38 - .../expression/ExpressionTranslator.java | 228 - .../HiveAlgebricksBuiltInFunctionMap.java | 96 - .../expression/HiveExpressionTypeComputer.java | 193 - .../logical/expression/HiveFunctionInfo.java | 49 - .../HiveMergeAggregationExpressionFactory.java | 87 - .../expression/HiveNullableTypeComputer.java | 29 - .../HivePartialAggregationTypeComputer.java | 116 - .../expression/HivesterixConstantValue.java | 69 - .../test/java/edu/uci/ics/hyracks/AppTest.java | 52 - .../hivesterix-dist/conf/cluster.properties | 51 - .../hivesterix-dist/conf/configuration.xsl | 24 - .../hivesterix-dist/conf/debugnc.properties | 26 - .../hivesterix-dist/conf/hive-default.xml | 772 -- .../hivesterix-dist/conf/hive-log4j.properties | 72 - hivesterix/hivesterix-dist/conf/master | 1 - hivesterix/hivesterix-dist/conf/slaves | 1 - hivesterix/hivesterix-dist/pom.xml | 265 - .../hivesterix-dist/resource/asterix/destroy.sh | 16 - .../resource/asterix/hivedeploy.hcli | 2 - .../resource/asterix/hivedestroy.hcli | 2 - .../resource/asterix/startall.sh | 30 - .../hivesterix-dist/resource/asterix/startcc.sh | 24 - .../hivesterix-dist/resource/asterix/startnc.sh | 35 - .../hivesterix-dist/resource/asterix/stopall.sh | 25 - .../hivesterix-dist/resource/asterix/stopcc.sh | 20 - .../hivesterix-dist/resource/asterix/stopnc.sh | 38 - .../resource/asterix_dbg/destroy.sh | 16 - .../resource/asterix_dbg/hivedeploy.hcli | 2 - .../resource/asterix_dbg/hivedestroy.hcli | 2 - .../resource/asterix_dbg/startall.sh | 31 - .../resource/asterix_dbg/startcc.sh | 22 - .../resource/asterix_dbg/startnc.sh | 28 - .../resource/asterix_dbg/stopall.sh | 25 - .../resource/asterix_dbg/stopcc.sh | 20 - .../resource/asterix_dbg/stopnc.sh | 38 - .../hivesterix-dist/resource/bin/ext/cli.sh | 42 - .../hivesterix-dist/resource/bin/ext/help.sh | 50 - .../resource/bin/ext/hiveserver.sh | 49 - .../hivesterix-dist/resource/bin/ext/hwi.sh | 64 - .../hivesterix-dist/resource/bin/ext/jar.sh | 61 - .../hivesterix-dist/resource/bin/ext/lineage.sh | 52 - .../resource/bin/ext/metastore.sh | 49 - .../resource/bin/ext/rcfilecat.sh | 41 - .../resource/bin/ext/util/execHiveCmd.sh | 46 - hivesterix/hivesterix-dist/resource/bin/hive | 213 - .../hivesterix-dist/resource/bin/hive-config.sh | 82 - .../resource/bin/init-hive-dfs.sh | 121 - .../hivesterix-dist/resource/deploy/balance.jar | Bin 32237 -> 0 bytes .../hivesterix-dist/resource/deploy/deploy.sh | 30 - .../hivesterix-dist/resource/deploy/jar.sh | 15 - .../resource/hivesterix/execute.sh | 27 - .../hivesterix-dist/resource/hivesterix/loop.sh | 18 - .../hivesterix-dist/resource/hivesterix/perf.sh | 42 - .../hivesterix/perflog/tpch100/result.log | 1 - .../hivesterix/perflog/tpch_sample/result.log | 1 - .../resource/hivesterix/startcluster.sh | 23 - .../resource/hivesterix/stress.sh | 19 - .../hivesterix/tpch100/q10_returned_item.hive | 33 - .../hivesterix/tpch100/q11_important_stock.hive | 46 - .../hivesterix/tpch100/q12_shipping.hive | 39 - .../tpch100/q13_customer_distribution.hive | 26 - .../tpch100/q14_promotion_effect.hive | 24 - .../hivesterix/tpch100/q15_top_supplier.hive | 41 - .../q16_parts_supplier_relationship.hive | 52 - .../q17_small_quantity_order_revenue.hive | 38 - .../tpch100/q18_large_volume_customer.hive | 39 - .../tpch100/q19_discounted_revenue.hive | 46 - .../tpch100/q1_pricing_summary_report.hive | 19 - .../tpch100/q20_potential_part_promotion.hive | 76 - .../q21_suppliers_who_kept_orders_waiting.hive | 73 - .../tpch100/q22_global_sales_opportunity.hive | 70 - .../tpch100/q2_minimum_cost_supplier.hive | 56 - .../tpch100/q3_shipping_priority.hive | 27 - .../hivesterix/tpch100/q4_order_priority.hive | 30 - .../tpch100/q5_local_supplier_volume.hive | 39 - .../tpch100/q6_forecast_revenue_change.hive | 20 - .../hivesterix/tpch100/q7_volume_shipping.hive | 67 - .../tpch100/q8_national_market_share.hive | 55 - .../tpch100/q9_product_type_profit.hive | 46 - .../tpch_sample/q1_pricing_summary_report.hive | 19 - .../tpch_sample/q3_shipping_priority.hive | 27 - .../tpch_sample/q5_local_supplier_volume.hive | 39 - .../tpch_sample/q9_product_type_profit.hive | 47 - .../resource/tpch/q10_returned_item.hive | 37 - .../resource/tpch/q11_important_stock.hive | 47 - .../resource/tpch/q12_shipping.hive | 42 - .../tpch/q13_customer_distribution.hive | 27 - .../resource/tpch/q14_promotion_effect.hive | 28 - .../resource/tpch/q15_top_supplier.hive | 45 - .../tpch/q16_parts_supplier_relationship.hive | 53 - .../tpch/q17_small_quantity_order_revenue.hive | 38 - .../tpch/q18_large_volume_customer.hive | 43 - .../resource/tpch/q19_discounted_revenue.hive | 49 - .../tpch/q1_pricing_summary_report.hive | 21 - .../tpch/q20_potential_part_promotion.hive | 77 - .../q21_suppliers_who_kept_orders_waiting.hive | 74 - .../tpch/q22_global_sales_opportunity.hive | 70 - .../hivesterix-dist/resource/tpch/q2_copy.hive | 46 - .../resource/tpch/q2_minimum_cost_supplier.hive | 56 - .../resource/tpch/q3_shipping_priority.hive | 30 - .../resource/tpch/q4_order_priority.hive | 30 - .../resource/tpch/q5_local_supplier_volume.hive | 42 - .../tpch/q6_forecast_revenue_change.hive | 21 - .../resource/tpch/q7_volume_shipping.hive | 71 - .../resource/tpch/q8_national_market_share.hive | 56 - .../resource/tpch/q9_product_type_profit.hive | 51 - .../resource/tpch100/q10_returned_item.hive | 36 - .../resource/tpch100/q11_important_stock.hive | 46 - .../resource/tpch100/q12_shipping.hive | 42 - .../tpch100/q13_customer_distribution.hive | 26 - .../resource/tpch100/q14_promotion_effect.hive | 27 - .../resource/tpch100/q15_top_supplier.hive | 44 - .../q16_parts_supplier_relationship.hive | 52 - .../q17_small_quantity_order_revenue.hive | 38 - .../tpch100/q18_large_volume_customer.hive | 42 - .../tpch100/q19_discounted_revenue.hive | 49 - .../tpch100/q1_pricing_summary_report.hive | 21 - .../tpch100/q20_potential_part_promotion.hive | 76 - .../q21_suppliers_who_kept_orders_waiting.hive | 74 - .../tpch100/q22_global_sales_opportunity.hive | 69 - .../tpch100/q2_minimum_cost_supplier.hive | 55 - .../resource/tpch100/q3_shipping_priority.hive | 30 - .../resource/tpch100/q4_order_priority.hive | 30 - .../tpch100/q5_local_supplier_volume.hive | 41 - .../tpch100/q6_forecast_revenue_change.hive | 20 - .../resource/tpch100/q7_volume_shipping.hive | 70 - .../tpch100/q8_national_market_share.hive | 55 - .../tpch100/q9_product_type_profit.hive | 50 - .../src/main/assembly/binary-assembly.xml | 45 - .../runtime/exec/HyracksExecutionEngine.java | 627 -- .../runtime/exec/IExecutionEngine.java | 39 - .../java/org/apache/hadoop/hive/ql/Driver.java | 1557 --- .../hive/ql/udf/generic/GenericUDAFAverage.java | 247 - .../ql/udf/generic/GenericUDAFCorrelation.java | 406 - .../hive/ql/udf/generic/GenericUDAFCount.java | 185 - .../ql/udf/generic/GenericUDAFCovariance.java | 355 - .../hive/ql/udf/generic/GenericUDAFSum.java | 286 - .../ql/udf/generic/GenericUDAFVariance.java | 319 - .../LazyObjectInspectorFactory.java | 137 - .../hive/serde2/typeinfo/TypeInfoFactory.java | 145 - .../src/main/resources/conf/cluster.properties | 50 - .../src/main/resources/conf/configuration.xsl | 24 - .../src/main/resources/conf/debugnc.properties | 26 - .../main/resources/conf/hive-log4j.properties | 72 - .../src/main/resources/conf/hive-site.xml | 5189 --------- .../src/main/resources/conf/master | 1 - .../src/main/resources/conf/slaves | 1 - .../main/resources/conf/topology-template.xml | 21 - .../src/main/resources/scripts/copylog.sh | 7 - .../src/main/resources/scripts/dumpAll.sh | 12 - .../src/main/resources/scripts/dumptrace.sh | 15 - .../src/main/resources/scripts/ext/cli.sh | 42 - .../src/main/resources/scripts/ext/help.sh | 50 - .../main/resources/scripts/ext/hiveserver.sh | 49 - .../src/main/resources/scripts/ext/hwi.sh | 64 - .../src/main/resources/scripts/ext/jar.sh | 61 - .../src/main/resources/scripts/ext/lineage.sh | 52 - .../src/main/resources/scripts/ext/metastore.sh | 49 - .../src/main/resources/scripts/ext/rcfilecat.sh | 41 - .../resources/scripts/ext/util/execHiveCmd.sh | 46 - .../src/main/resources/scripts/getip.sh | 62 - .../src/main/resources/scripts/hive | 206 - .../src/main/resources/scripts/hive-config.sh | 82 - .../src/main/resources/scripts/hivesterixcc | 122 - .../src/main/resources/scripts/hivesterixnc | 117 - .../src/main/resources/scripts/init-hive-dfs.sh | 121 - .../src/main/resources/scripts/startAllNCs.sh | 38 - .../src/main/resources/scripts/startCluster.sh | 35 - .../src/main/resources/scripts/startDebugNc.sh | 82 - .../src/main/resources/scripts/startcc.sh | 65 - .../src/main/resources/scripts/startnc.sh | 81 - .../src/main/resources/scripts/stopAllNCs.sh | 38 - .../src/main/resources/scripts/stopCluster.sh | 35 - .../src/main/resources/scripts/stopcc.sh | 53 - .../src/main/resources/scripts/stopnc.sh | 59 - .../uci/ics/hivesterix/perf/PerfTestCase.java | 156 - .../uci/ics/hivesterix/perf/PerfTestSuite.java | 88 - .../perf/PerfTestSuiteCaseGenerator.java | 113 - .../hivesterix/perf/PerfTestSuiteGenerator.java | 88 - .../perf/base/AbstractPerfTestCase.java | 63 - .../perf/base/AbstractPerfTestSuiteClass.java | 215 - .../test/base/AbstractHivesterixTestCase.java | 63 - .../test/base/AbstractTestSuiteClass.java | 242 - .../hivesterix/test/datagen/RecordBalance.java | 89 - .../hivesterix/test/legacy/LegacyTestCase.java | 156 - .../test/optimizer/OptimizerTestCase.java | 74 - .../optimizer/OptimizerTestSuitGenerator.java | 89 - .../test/optimizer/OptimizerTestSuite.java | 71 - .../OptimizerTestSuiteCaseGenerator.java | 64 - .../RuntimeFunctionTestCase.java | 161 - .../RuntimeFunctionTestSuite.java | 88 - .../RuntimeFunctionTestSuiteCaseGenerator.java | 113 - .../RuntimeFunctionTestSuiteGenerator.java | 88 - .../ics/hivesterix/test/serde/SerDeTest.java | 231 - .../src/test/resources/log4j.properties | 108 - .../src/test/resources/logging.properties | 79 - .../optimizerts/hive/conf/hive-default.xml | 807 -- .../src/test/resources/optimizerts/ignore.txt | 0 .../optimizerts/queries/h11_share_scan.hive | 10 - .../optimizerts/queries/h12_select_struct.hive | 6 - .../optimizerts/queries/q10_returned_item.hive | 34 - .../queries/q11_important_stock.hive | 47 - .../optimizerts/queries/q12_shipping.hive | 40 - .../queries/q13_customer_distribution.hive | 27 - .../queries/q14_promotion_effect.hive | 25 - .../optimizerts/queries/q15_top_supplier.hive | 43 - .../q16_parts_supplier_relationship.hive | 53 - .../q17_small_quantity_order_revenue.hive | 38 - .../queries/q18_large_volume_customer.hive | 41 - .../queries/q19_discounted_revenue.hive | 47 - .../queries/q1_pricing_summary_report.hive | 19 - .../queries/q20_potential_part_promotion.hive | 77 - .../q21_suppliers_who_kept_orders_waiting.hive | 74 - .../queries/q22_global_sales_opportunity.hive | 70 - .../queries/q2_minimum_cost_supplier.hive | 56 - .../queries/q3_shipping_priority.hive | 26 - .../optimizerts/queries/q4_order_priority.hive | 29 - .../queries/q5_local_supplier_volume.hive | 41 - .../queries/q6_forecast_revenue_change.hive | 21 - .../optimizerts/queries/q7_volume_shipping.hive | 69 - .../queries/q8_national_market_share.hive | 56 - .../queries/q9_product_type_profit.hive | 49 - .../queries/u10_nestedloop_join.hive | 21 - .../optimizerts/queries/u1_group_by.hive | 12 - .../optimizerts/queries/u2_select-project.hive | 7 - .../resources/optimizerts/queries/u3_union.hive | 7 - .../resources/optimizerts/queries/u4_join.hive | 14 - .../optimizerts/queries/u5_lateral_view.hive | 7 - .../resources/optimizerts/queries/u6_limit.hive | 8 - .../optimizerts/queries/u7_multi_join.hive | 12 - .../optimizerts/queries/u8_non_mapred.hive | 7 - .../optimizerts/queries/u9_order_by.hive | 7 - .../optimizerts/results/h11_share_scan.plan | 34 - .../optimizerts/results/h12_select_struct.plan | 10 - .../optimizerts/results/q10_returned_item.plan | 102 - .../results/q11_important_stock.plan | 126 - .../optimizerts/results/q12_shipping.plan | 54 - .../results/q13_customer_distribution.plan | 71 - .../results/q14_promotion_effect.plan | 54 - .../optimizerts/results/q15_top_supplier.plan | 110 - .../q16_parts_supplier_relationship.plan | 98 - .../q17_small_quantity_order_revenue.plan | 104 - .../results/q18_large_volume_customer.plan | 126 - .../results/q19_discounted_revenue.plan | 46 - .../results/q1_pricing_summary_report.plan | 38 - .../results/q20_potential_part_promotion.plan | 178 - .../q21_suppliers_who_kept_orders_waiting.plan | 216 - .../results/q22_global_sales_opportunity.plan | 132 - .../results/q2_minimum_cost_supplier.plan | 152 - .../results/q3_shipping_priority.plan | 70 - .../optimizerts/results/q4_order_priority.plan | 78 - .../results/q5_local_supplier_volume.plan | 126 - .../results/q6_forecast_revenue_change.plan | 34 - .../optimizerts/results/q7_volume_shipping.plan | 232 - .../results/q8_national_market_share.plan | 186 - .../results/q9_product_type_profit.plan | 120 - .../results/u10_nestedloop_join.plan | 38 - .../optimizerts/results/u1_group_by.plan | 36 - .../optimizerts/results/u2_select-project.plan | 16 - .../resources/optimizerts/results/u3_union.plan | 50 - .../resources/optimizerts/results/u4_join.plan | 36 - .../optimizerts/results/u5_lateral_view.plan | 14 - .../resources/optimizerts/results/u6_limit.plan | 26 - .../optimizerts/results/u7_multi_join.plan | 50 - .../optimizerts/results/u8_non_mapred.plan | 0 .../optimizerts/results/u9_order_by.plan | 18 - .../resources/runtimefunctionts/conf/cluster | 3 - .../runtimefunctionts/data/customer.tbl | 150 - .../data/large_card_join_src.tbl | 1030 -- .../data/large_card_join_src_small.tbl | 1 - .../runtimefunctionts/data/lineitem.tbl | 6005 ---------- .../resources/runtimefunctionts/data/nation.tbl | 25 - .../resources/runtimefunctionts/data/orders.tbl | 1500 --- .../resources/runtimefunctionts/data/part.tbl | 200 - .../runtimefunctionts/data/partsupp.tbl | 800 -- .../resources/runtimefunctionts/data/region.tbl | 5 - .../runtimefunctionts/data/supplier.tbl | 10 - .../runtimefunctionts/hadoop/conf/core-site.xml | 32 - .../hadoop/conf/core-site.xml.bak | 18 - .../runtimefunctionts/hadoop/conf/hdfs-site.xml | 32 - .../hadoop/conf/hdfs-site.xml.bak | 18 - .../hadoop/conf/mapred-site.xml | 39 - .../hadoop/conf/mapred-site.xml.bak | 25 - .../hive/conf/hive-default.xml | 865 -- .../runtimefunctionts/hive/conf/topology.xml | 21 - .../test/resources/runtimefunctionts/ignore.txt | 1 - .../runtimefunctionts/logging.properties | 78 - .../queries/q10_returned_item.hive | 34 - .../queries/q11_important_stock.hive | 47 - .../runtimefunctionts/queries/q12_shipping.hive | 39 - .../queries/q13_customer_distribution.hive | 27 - .../queries/q14_promotion_effect.hive | 25 - .../queries/q15_top_supplier.hive | 43 - .../q16_parts_supplier_relationship.hive | 53 - .../q17_small_quantity_order_revenue.hive | 37 - .../queries/q18_large_volume_customer.hive | 40 - .../queries/q19_discounted_revenue.hive | 46 - .../queries/q1_pricing_summary_report.hive | 19 - .../queries/q20_potential_part_promotion.hive | 71 - .../q21_suppliers_who_kept_orders_waiting.hive | 71 - .../queries/q22_global_sales_opportunity.hive | 60 - .../queries/q2_minimum_cost_supplier.hive | 56 - .../queries/q3_shipping_priority.hive | 26 - .../queries/q4_order_priority.hive | 29 - .../queries/q5_local_supplier_volume.hive | 41 - .../queries/q6_forecast_revenue_change.hive | 21 - .../queries/q7_volume_shipping.hive | 68 - .../queries/q8_national_market_share.hive | 56 - .../queries/q9_product_type_profit.hive | 47 - .../runtimefunctionts/queries/u10_join.hive | 15 - .../queries/u10_nestedloop_join.hive | 21 - .../runtimefunctionts/queries/u1_gby.hive | 11 - .../queries/u2_gby_external.hive | 19 - .../runtimefunctionts/queries/u3_union.hive | 11 - .../queries/u4_gby_distinct.hive | 19 - .../queries/u5_gby_global.hive | 16 - .../queries/u6_large_card_join.hive | 23 - .../runtimefunctionts/queries/u8_order_by.hive | 8 - .../results/q10_returned_item.result | 20 - .../results/q11_important_stock.result | 200 - .../results/q12_shipping.result | 2 - .../results/q13_customer_distribution.result | 27 - .../results/q14_promotion_effect.result | 1 - .../results/q15_top_supplier.result | 1 - .../q16_parts_supplier_relationship.result | 34 - .../q17_small_quantity_order_revenue.result | 1 - .../results/q18_large_volume_customer.result | 100 - .../results/q19_discounted_revenue.result | 1 - .../results/q1_pricing_summary_report.result | 4 - .../results/q20_potential_part_promotion.result | 10 - ...q21_suppliers_who_kept_orders_waiting.result | 10 - .../results/q22_global_sales_opportunity.result | 23 - .../results/q2_minimum_cost_supplier.result | 11 - .../results/q3_shipping_priority.result | 10 - .../results/q4_order_priority.result | 5 - .../results/q5_local_supplier_volume.result | 8 - .../results/q6_forecast_revenue_change.result | 1 - .../results/q7_volume_shipping.result | 37 - .../results/q8_national_market_share.result | 2 - .../results/q9_product_type_profit.result | 60 - .../runtimefunctionts/results/u10_join.result | 1500 --- .../results/u10_nestedloop_join.result | 300 - .../runtimefunctionts/results/u1_gby.result | 5 - .../results/u2_gby_external.result | 10 - .../runtimefunctionts/results/u3_union.result | 9 - .../results/u4_gby_distinct.result | 10 - .../results/u5_gby_global.result | 1 - .../results/u6_large_card_join.result | 512 - .../results/u8_order_by.result | 25 - hivesterix/hivesterix-optimizer/pom.xml | 59 - .../rulecollections/HiveRuleCollections.java | 129 - .../rules/InsertProjectBeforeWriteRule.java | 93 - .../rules/IntroduceEarlyProjectRule.java | 87 - .../optimizer/rules/LocalGroupByRule.java | 80 - .../rules/RemoveRedundantSelectRule.java | 58 - hivesterix/hivesterix-runtime/pom.xml | 214 - .../evaluator/AbstractExpressionEvaluator.java | 184 - .../evaluator/AggregationFunctionEvaluator.java | 239 - ...ggregatuibFunctionSerializableEvaluator.java | 263 - .../runtime/evaluator/BufferSerDeUtil.java | 81 - .../evaluator/ColumnExpressionEvaluator.java | 31 - .../evaluator/ConstantExpressionEvaluator.java | 30 - .../evaluator/FieldExpressionEvaluator.java | 31 - .../evaluator/FunctionExpressionEvaluator.java | 31 - .../evaluator/NullExpressionEvaluator.java | 30 - .../runtime/evaluator/SerializableBuffer.java | 30 - .../evaluator/UDTFFunctionEvaluator.java | 158 - .../HiveByteBinaryAscComparatorFactory.java | 48 - .../HiveByteBinaryDescComparatorFactory.java | 47 - .../HiveDoubleBinaryAscComparatorFactory.java | 49 - .../HiveDoubleBinaryDescComparatorFactory.java | 49 - .../HiveFloatBinaryAscComparatorFactory.java | 49 - .../HiveFloatBinaryDescComparatorFactory.java | 49 - .../HiveIntegerBinaryAscComparatorFactory.java | 54 - .../HiveIntegerBinaryDescComparatorFactory.java | 52 - .../HiveLongBinaryAscComparatorFactory.java | 52 - .../HiveLongBinaryDescComparatorFactory.java | 52 - .../HiveShortBinaryAscComparatorFactory.java | 49 - .../HiveShortBinaryDescComparatorFactory.java | 49 - .../HiveStringBinaryAscComparatorFactory.java | 54 - .../HiveStringBinaryDescComparatorFactory.java | 53 - .../evaluator/AggregationFunctionFactory.java | 394 - .../AggregationFunctionSerializableFactory.java | 393 - .../ColumnExpressionEvaluatorFactory.java | 55 - .../ConstantExpressionEvaluatorFactory.java | 55 - .../FieldExpressionEvaluatorFactory.java | 54 - .../HiveExpressionRuntimeProvider.java | 181 - .../NullExpressionEvaluatorFactory.java | 55 - ...calarFunctionExpressionEvaluatorFactory.java | 83 - .../evaluator/UnnestingFunctionFactory.java | 54 - .../HiveDoubleBinaryHashFunctionFactory.java | 43 - .../HiveIntegerBinaryHashFunctionFactory.java | 47 - .../HiveLongBinaryHashFunctionFactory.java | 44 - .../HiveRawBinaryHashFunctionFactory.java | 45 - .../HiveStingBinaryHashFunctionFactory.java | 55 - ...veDoubleAscNormalizedKeyComputerFactory.java | 38 - ...eDoubleDescNormalizedKeyComputerFactory.java | 38 - ...eIntegerAscNormalizedKeyComputerFactory.java | 43 - ...IntegerDescNormalizedKeyComputerFactory.java | 43 - ...HiveLongAscNormalizedKeyComputerFactory.java | 77 - ...iveLongDescNormalizedKeyComputerFactory.java | 39 - ...veStringAscNormalizedKeyComputerFactory.java | 54 - ...eStringDescNormalizedKeyComputerFactory.java | 51 - .../nullwriter/HiveNullWriterFactory.java | 42 - .../inspector/HiveBinaryBooleanInspector.java | 33 - .../HiveBinaryBooleanInspectorFactory.java | 34 - .../inspector/HiveBinaryIntegerInspector.java | 36 - .../HiveBinaryIntegerInspectorFactory.java | 34 - .../HiveConnectorPolicyAssignmentPolicy.java | 82 - .../hivesterix/runtime/jobgen/HiveDataSink.java | 46 - .../runtime/jobgen/HiveDataSource.java | 61 - .../HiveDataSourcePartitioningProvider.java | 37 - .../hivesterix/runtime/jobgen/HiveDomain.java | 31 - .../runtime/jobgen/HiveMetaDataProvider.java | 162 - .../runtime/jobgen/HiveOperatorSchema.java | 98 - .../jobgen/HiveScanRuntimeGenerator.java | 131 - .../jobgen/HiveWriteRuntimeGenerator.java | 51 - .../ics/hivesterix/runtime/jobgen/Schema.java | 53 - .../operator/filescan/HiveKeyValueParser.java | 223 - .../filescan/HiveKeyValueParserFactory.java | 53 - .../filewrite/HiveFileWritePushRuntime.java | 187 - .../filewrite/HivePushRuntimeFactory.java | 119 - .../HiveBinaryComparatorFactoryProvider.java | 89 - .../HiveBinaryHashFunctionFactoryProvider.java | 49 - .../HiveBinaryHashFunctionFamilyProvider.java | 34 - ...iveNormalizedKeyComputerFactoryProvider.java | 65 - .../provider/HivePrinterFactoryProvider.java | 30 - .../HiveSerializerDeserializerProvider.java | 35 - .../runtime/provider/HiveTypeTraitProvider.java | 47 - hivesterix/hivesterix-serde/pom.xml | 73 - .../ics/hivesterix/serde/lazy/ByteArrayRef.java | 55 - .../ics/hivesterix/serde/lazy/LazyArray.java | 243 - .../ics/hivesterix/serde/lazy/LazyBoolean.java | 74 - .../uci/ics/hivesterix/serde/lazy/LazyByte.java | 68 - .../ics/hivesterix/serde/lazy/LazyColumnar.java | 221 - .../ics/hivesterix/serde/lazy/LazyDouble.java | 64 - .../ics/hivesterix/serde/lazy/LazyFactory.java | 108 - .../ics/hivesterix/serde/lazy/LazyFloat.java | 65 - .../ics/hivesterix/serde/lazy/LazyInteger.java | 77 - .../uci/ics/hivesterix/serde/lazy/LazyLong.java | 77 - .../uci/ics/hivesterix/serde/lazy/LazyMap.java | 341 - .../hivesterix/serde/lazy/LazyNonPrimitive.java | 91 - .../ics/hivesterix/serde/lazy/LazyObject.java | 91 - .../hivesterix/serde/lazy/LazyPrimitive.java | 83 - .../ics/hivesterix/serde/lazy/LazySerDe.java | 480 - .../ics/hivesterix/serde/lazy/LazyShort.java | 68 - .../ics/hivesterix/serde/lazy/LazyString.java | 73 - .../ics/hivesterix/serde/lazy/LazyStruct.java | 248 - .../ics/hivesterix/serde/lazy/LazyUtils.java | 517 - .../LazyColumnarObjectInspector.java | 91 - .../LazyListObjectInspector.java | 76 - .../objectinspector/LazyMapObjectInspector.java | 75 - .../LazyObjectInspectorFactory.java | 96 - .../LazyStructObjectInspector.java | 79 - .../AbstractPrimitiveLazyObjectInspector.java | 62 - .../primitive/LazyBooleanObjectInspector.java | 64 - .../primitive/LazyByteObjectInspector.java | 64 - .../primitive/LazyDoubleObjectInspector.java | 64 - .../primitive/LazyFloatObjectInspector.java | 64 - .../primitive/LazyIntObjectInspector.java | 64 - .../primitive/LazyLongObjectInspector.java | 64 - .../LazyPrimitiveObjectInspectorFactory.java | 106 - .../primitive/LazyShortObjectInspector.java | 64 - .../primitive/LazyStringObjectInspector.java | 78 - .../primitive/LazyVoidObjectInspector.java | 57 - .../PrimitiveObjectInspectorFactory.java | 90 - .../hivesterix/serde/parser/IHiveParser.java | 30 - .../serde/parser/TextToBinaryTupleParser.java | 188 - hivesterix/hivesterix-translator/pom.xml | 66 - .../logical/plan/HiveAlgebricksTranslator.java | 820 -- .../plan/HiveLogicalPlanAndMetaData.java | 49 - .../logical/plan/HiveOperatorAnnotations.java | 22 - .../logical/plan/visitor/ExtractVisitor.java | 40 - .../logical/plan/visitor/FilterVisitor.java | 55 - .../logical/plan/visitor/GroupByVisitor.java | 278 - .../logical/plan/visitor/JoinVisitor.java | 431 - .../plan/visitor/LateralViewJoinVisitor.java | 156 - .../logical/plan/visitor/LimitVisitor.java | 55 - .../logical/plan/visitor/MapJoinVisitor.java | 185 - .../logical/plan/visitor/ProjectVisitor.java | 70 - .../logical/plan/visitor/SortVisitor.java | 127 - .../plan/visitor/TableScanWriteVisitor.java | 148 - .../logical/plan/visitor/UnionVisitor.java | 76 - .../plan/visitor/base/DefaultVisitor.java | 159 - .../logical/plan/visitor/base/Translator.java | 192 - .../logical/plan/visitor/base/Visitor.java | 99 - hivesterix/pom.xml | 149 - pregelix/HyracksCodeFormatProfile.xml | 293 - pregelix/build.sh | 12 - pregelix/pom.xml | 113 - pregelix/pregelix-api/pom.xml | 83 - .../edu/uci/ics/pregelix/api/graph/Edge.java | 157 - .../pregelix/api/graph/GlobalAggregator.java | 79 - .../ics/pregelix/api/graph/MessageCombiner.java | 154 - .../edu/uci/ics/pregelix/api/graph/MsgList.java | 81 - .../api/graph/NormalizedKeyComputer.java | 37 - .../edu/uci/ics/pregelix/api/graph/Vertex.java | 763 -- .../ics/pregelix/api/graph/VertexContext.java | 71 - .../ics/pregelix/api/graph/VertexDelegate.java | 187 - .../pregelix/api/graph/VertexPartitioner.java | 36 - .../ics/pregelix/api/io/BasicGenInputSplit.java | 84 - .../edu/uci/ics/pregelix/api/io/Pointable.java | 28 - .../edu/uci/ics/pregelix/api/io/Sizable.java | 23 - .../ics/pregelix/api/io/VertexInputFormat.java | 73 - .../ics/pregelix/api/io/VertexOutputFormat.java | 80 - .../uci/ics/pregelix/api/io/VertexReader.java | 89 - .../uci/ics/pregelix/api/io/VertexWriter.java | 68 - .../ics/pregelix/api/io/WritableSizable.java | 24 - .../generated/GeneratedVertexInputFormat.java | 49 - .../api/io/generated/GeneratedVertexReader.java | 80 - .../io/internal/InternalVertexInputFormat.java | 84 - .../io/internal/InternalVertexOutputFormat.java | 111 - .../api/io/text/TextVertexInputFormat.java | 125 - .../api/io/text/TextVertexOutputFormat.java | 116 - .../ics/pregelix/api/job/ICheckpointHook.java | 24 - .../api/job/IIterationCompleteReporterHook.java | 34 - .../uci/ics/pregelix/api/job/PregelixJob.java | 394 - .../pregelix/api/util/ArrayListWritable.java | 215 - .../edu/uci/ics/pregelix/api/util/BspUtils.java | 955 -- .../api/util/ConservativeCheckpointHook.java | 35 - .../api/util/DefaultCheckpointHook.java | 31 - .../DefaultIterationCompleteReporterHook.java | 37 - .../api/util/DefaultMessageCombiner.java | 119 - .../api/util/DefaultVertexPartitioner.java | 35 - .../ics/pregelix/api/util/FrameTupleUtils.java | 92 - .../api/util/GlobalEdgeCountAggregator.java | 57 - .../api/util/GlobalVertexCountAggregator.java | 57 - .../api/util/HadoopCountersAggregator.java | 85 - .../util/HadoopCountersGlobalAggregateHook.java | 54 - .../ics/pregelix/api/util/JobStateUtils.java | 65 - .../ics/pregelix/api/util/ReflectionUtils.java | 163 - .../api/util/ResetableByteArrayInputStream.java | 55 - .../util/ResetableByteArrayOutputStream.java | 47 - .../uci/ics/pregelix/api/util/SerDeUtils.java | 43 - pregelix/pregelix-benchmark/pom.xml | 70 - .../benchmark/io/TextCCInputFormat.java | 72 - .../benchmark/io/TextCCOutputFormat.java | 42 - .../benchmark/io/TextPRInputFormat.java | 71 - .../benchmark/io/TextPROutputFormat.java | 43 - .../benchmark/io/TextSPInputFormat.java | 72 - .../vertex/ConnectedComponentsVertex.java | 97 - .../benchmark/vertex/PageRankVertex.java | 68 - .../benchmark/vertex/ShortestPathsVertex.java | 81 - .../data/tpch0.001/customer-part1.tbl | 75 - .../data/tpch0.001/customer-part2.tbl | 75 - .../pregelix-core/data/tpch0.001/customer.tbl | 150 - .../pregelix-core/data/tpch0.001/lineitem.tbl | 6005 ---------- .../pregelix-core/data/tpch0.001/nation.tbl | 25 - .../data/tpch0.001/orders-part1.tbl | 750 -- .../data/tpch0.001/orders-part2.tbl | 750 -- .../pregelix-core/data/tpch0.001/orders.tbl | 1500 --- pregelix/pregelix-core/data/tpch0.001/part.tbl | 200 - .../pregelix-core/data/tpch0.001/partsupp.tbl | 800 -- .../pregelix-core/data/tpch0.001/region.tbl | 5 - .../pregelix-core/data/tpch0.001/supplier.tbl | 10 - pregelix/pregelix-core/data/tpch0.001/tpch.ddl | 70 - .../pregelix-core/data/webmap/webmap_link.txt | 20 - pregelix/pregelix-core/pom.xml | 348 - .../src/main/assembly/binary-assembly.xml | 33 - .../edu/uci/ics/pregelix/core/base/IDriver.java | 39 - .../edu/uci/ics/pregelix/core/base/IJobGen.java | 35 - .../uci/ics/pregelix/core/data/TypeTraits.java | 46 - .../uci/ics/pregelix/core/driver/Driver.java | 502 - .../hadoop/config/ConfigurationFactory.java | 68 - .../ics/pregelix/core/hadoop/data/Message.java | 79 - .../pregelix/core/hadoop/data/MessageList.java | 29 - .../uci/ics/pregelix/core/jobgen/JobGen.java | 1036 -- .../ics/pregelix/core/jobgen/JobGenFactory.java | 39 - .../pregelix/core/jobgen/JobGenInnerJoin.java | 664 -- .../pregelix/core/jobgen/JobGenOuterJoin.java | 416 - .../ics/pregelix/core/jobgen/JobGenUtil.java | 95 - .../jobgen/clusterconfig/ClusterConfig.java | 279 - .../core/optimizer/DynamicOptimizer.java | 122 - .../ics/pregelix/core/optimizer/IOptimizer.java | 31 - .../pregelix/core/optimizer/NoOpOptimizer.java | 49 - .../touchpoint/RawBinaryComparatorFactory.java | 49 - .../RawNormalizedKeyComputerFactory.java | 47 - ...ritableComparingBinaryComparatorFactory.java | 46 - .../WritableRecordDescriptorFactory.java | 47 - .../pregelix/core/util/BufferSerDeUtils.java | 81 - .../ics/pregelix/core/util/DataBalancer.java | 82 - .../ics/pregelix/core/util/DataGenerator.java | 227 - .../ics/pregelix/core/util/DataflowUtils.java | 132 - .../pregelix/core/util/ExceptionUtilities.java | 95 - .../util/PregelixHyracksIntegrationUtil.java | 133 - .../uci/ics/pregelix/core/util/Utilities.java | 84 - .../src/main/resources/conf/cluster.properties | 50 - .../src/main/resources/conf/debugnc.properties | 26 - .../src/main/resources/conf/master | 1 - .../src/main/resources/conf/slaves | 1 - .../src/main/resources/conf/stores.properties | 16 - .../main/resources/conf/topology-template.xml | 21 - .../src/main/resources/scripts/getip.sh | 57 - .../src/main/resources/scripts/startAllNCs.sh | 38 - .../src/main/resources/scripts/startCluster.sh | 35 - .../src/main/resources/scripts/startDebugNc.sh | 82 - .../src/main/resources/scripts/startcc.sh | 65 - .../src/main/resources/scripts/startnc.sh | 80 - .../src/main/resources/scripts/stopAllNCs.sh | 38 - .../src/main/resources/scripts/stopCluster.sh | 35 - .../src/main/resources/scripts/stopcc.sh | 53 - .../src/main/resources/scripts/stopnc.sh | 59 - .../uci/ics/pregelix/core/join/JoinTest.java | 603 - .../core/join/JoinTestNullWriterFactory.java | 40 - .../uci/ics/pregelix/core/util/TestUtils.java | 92 - .../test/resources/cluster/cluster.properties | 51 - .../src/test/resources/cluster/data.properties | 15 - .../test/resources/hadoop/conf/core-site.xml | 32 - .../test/resources/hadoop/conf/hdfs-site.xml | 32 - .../test/resources/hadoop/conf/log4j.properties | 108 - .../test/resources/hadoop/conf/mapred-site.xml | 39 - .../resources/hyracks-deployment.properties | 16 - .../src/test/resources/log4j.properties | 108 - .../src/test/resources/logging.properties | 80 - .../src/test/resources/topology.xml | 21 - pregelix/pregelix-dataflow-std-base/pom.xml | 92 - .../dataflow/std/base/IAggregateFunction.java | 33 - .../std/base/IAggregateFunctionFactory.java | 27 - .../pregelix/dataflow/std/base/IFunction.java | 30 - .../dataflow/std/base/IFunctionFactory.java | 23 - .../std/base/IRecordDescriptorFactory.java | 27 - .../dataflow/std/base/IRuntimeHook.java | 24 - .../dataflow/std/base/IRuntimeHookFactory.java | 23 - .../base/ISerializableAggregateFunction.java | 30 - .../ISerializableAggregateFunctionFactory.java | 26 - .../base/ISerializerDeserializerFactory.java | 27 - .../dataflow/std/base/IUpdateFunction.java | 35 - .../std/base/IUpdateFunctionFactory.java | 23 - pregelix/pregelix-dataflow-std/pom.xml | 153 - .../std/FunctionCallOperatorDescriptor.java | 114 - ...oopJoinFunctionUpdateOperatorDescriptor.java | 177 - ...pJoinFunctionUpdateOperatorNodePushable.java | 265 - .../IndexNestedLoopJoinOperatorDescriptor.java | 123 - ...IndexNestedLoopJoinOperatorNodePushable.java | 208 - ...rJoinFunctionUpdateOperatorNodePushable.java | 332 - ...dLoopRightOuterJoinOperatorNodePushable.java | 283 - ...UnionFunctionUpdateOperatorNodePushable.java | 279 - ...xNestedLoopSetUnionOperatorNodePushable.java | 270 - .../dataflow/std/ProjectOperatorDescriptor.java | 105 - .../std/RuntimeHookOperatorDescriptor.java | 70 - .../TreeIndexBulkReLoadOperatorDescriptor.java | 63 - ...TreeIndexBulkReLoadOperatorNodePushable.java | 110 - ...eSearchFunctionUpdateOperatorDescriptor.java | 92 - ...earchFunctionUpdateOperatorNodePushable.java | 261 - .../std/collectors/SortMergeFrameReader.java | 78 - ...NPartitioningMergingConnectorDescriptor.java | 72 - .../group/ClusteredGroupOperatorDescriptor.java | 50 - .../ClusteredGroupOperatorNodePushable.java | 79 - .../std/group/ClusteredGroupWriter.java | 144 - .../std/group/IAggregatorDescriptor.java | 105 - .../IClusteredAggregatorDescriptorFactory.java | 35 - .../std/sort/ExternalSortRunGenerator.java | 114 - .../std/sort/ExternalSortRunMerger.java | 159 - .../std/sort/FastSortOperatorDescriptor.java | 188 - .../dataflow/std/sort/FrameSorterQuickSort.java | 250 - .../dataflow/std/sort/IFrameSorter.java | 37 - .../dataflow/std/sort/IRunGenerator.java | 32 - .../dataflow/std/sort/RawBinaryComparator.java | 35 - .../std/sort/RawNormalizedKeyComputer.java | 52 - .../std/sort/ReferencedPriorityQueue.java | 146 - .../std/sort/RunMergingFrameReader.java | 178 - .../dataflow/std/util/CopyUpdateUtil.java | 60 - .../dataflow/std/util/FunctionProxy.java | 156 - .../dataflow/std/util/ReferenceEntry.java | 93 - .../std/util/ResetableByteArrayInputStream.java | 55 - .../util/ResetableByteArrayOutputStream.java | 58 - .../std/util/SearchKeyTupleReference.java | 55 - .../pregelix/dataflow/std/util/StorageType.java | 21 - .../dataflow/std/util/TupleDeserializer.java | 171 - .../dataflow/std/util/UpdateBuffer.java | 135 - .../std/util/UpdateBufferTupleAccessor.java | 81 - pregelix/pregelix-dataflow/pom.xml | 139 - .../dataflow/ClearStateOperatorDescriptor.java | 85 - .../ConnectorPolicyAssignmentPolicy.java | 57 - .../dataflow/CountTupleOperatorDescriptor.java | 71 - .../dataflow/EmptySinkOperatorDescriptor.java | 62 - .../EmptyTupleSourceOperatorDescriptor.java | 62 - .../FinalAggregateOperatorDescriptor.java | 145 - .../HDFSFileWriteOperatorDescriptor.java | 195 - .../dataflow/KeyValueParserFactory.java | 79 - .../dataflow/KeyValueWriterFactory.java | 106 - .../MaterializingReadOperatorDescriptor.java | 99 - .../MaterializingWriteOperatorDescriptor.java | 109 - ...CombinerConnectorPolicyAssignmentPolicy.java | 38 - ...erminationStateWriterOperatorDescriptor.java | 79 - .../VertexFileScanOperatorDescriptor.java | 212 - .../VertexFileWriteOperatorDescriptor.java | 197 - .../dataflow/VertexWriteOperatorDescriptor.java | 105 - .../dataflow/base/IConfigurationFactory.java | 30 - .../context/NoBudgetIndexLifecycleManager.java | 194 - .../pregelix/dataflow/context/PJobContext.java | 130 - .../context/PreDelayPageCleanerPolicy.java | 46 - .../dataflow/context/RuntimeContext.java | 221 - .../ics/pregelix/dataflow/context/TaskID.java | 55 - .../dataflow/context/TaskIterationID.java | 51 - .../dataflow/state/MaterializerTaskState.java | 54 - .../pregelix/dataflow/util/IterationUtils.java | 240 - pregelix/pregelix-dist/pom.xml | 72 - .../src/main/assembly/binary-assembly.xml | 50 - .../src/main/resources/conf/cluster.properties | 59 - .../src/main/resources/conf/debugnc.properties | 26 - .../src/main/resources/conf/master | 1 - .../src/main/resources/conf/slaves | 1 - .../src/main/resources/conf/stores.properties | 16 - .../main/resources/conf/topology-template.xml | 21 - .../src/main/resources/scripts/copylog.sh | 7 - .../src/main/resources/scripts/dumpAll.sh | 12 - .../src/main/resources/scripts/dumptrace.sh | 15 - .../src/main/resources/scripts/getip.sh | 57 - .../src/main/resources/scripts/pregelix | 111 - .../src/main/resources/scripts/pregelix.bat | 124 - .../src/main/resources/scripts/pregelixcc | 114 - .../src/main/resources/scripts/pregelixnc | 115 - .../src/main/resources/scripts/startAllNCs.sh | 38 - .../src/main/resources/scripts/startCluster.sh | 35 - .../src/main/resources/scripts/startDebugNc.sh | 82 - .../src/main/resources/scripts/startcc.sh | 98 - .../src/main/resources/scripts/startnc.sh | 102 - .../src/main/resources/scripts/stopAllNCs.sh | 38 - .../src/main/resources/scripts/stopCluster.sh | 35 - .../src/main/resources/scripts/stopcc.sh | 53 - .../src/main/resources/scripts/stopnc.sh | 59 - .../pregelix-example/data/clique/clique.txt | 7 - .../pregelix-example/data/clique2/clique.txt | 6 - .../pregelix-example/data/clique3/clique.txt | 20 - pregelix/pregelix-example/data/skew/data.txt | 23 - .../data/update/webmap_link.txt | 10000 ----------------- .../data/webmap/webmap_link.txt | 20 - .../data/webmapcomplex/webmap_link.txt | 23 - pregelix/pregelix-example/pom.xml | 120 - .../src/main/assembly/binary-assembly.xml | 33 - .../example/ConnectedComponentsVertex.java | 199 - .../example/EarlyTerminationVertex.java | 106 - .../pregelix/example/GraphMutationVertex.java | 117 - .../example/GraphSampleUndirectedVertex.java | 229 - .../ics/pregelix/example/GraphSampleVertex.java | 252 - .../example/MessageOverflowFixedsizeVertex.java | 113 - .../pregelix/example/MessageOverflowVertex.java | 125 - .../ics/pregelix/example/PageRankVertex.java | 246 - .../pregelix/example/ReachabilityVertex.java | 274 - .../pregelix/example/ShortestPathsVertex.java | 162 - .../uci/ics/pregelix/example/client/Client.java | 158 - .../data/VLongNormalizedKeyComputer.java | 70 - .../TextConnectedComponentsInputFormat.java | 119 - .../TextGraphSampleVertexInputFormat.java | 115 - .../inputformat/TextPageRankInputFormat.java | 114 - .../TextReachibilityVertexInputFormat.java | 113 - .../TextShortestPathsInputFormat.java | 116 - .../pregelix/example/io/BooleanWritable.java | 36 - .../ics/pregelix/example/io/ByteWritable.java | 35 - .../ics/pregelix/example/io/BytesWritable.java | 37 - .../ics/pregelix/example/io/DoubleWritable.java | 83 - .../ics/pregelix/example/io/FloatWritable.java | 34 - .../ics/pregelix/example/io/IntWritable.java | 35 - .../ics/pregelix/example/io/LongWritable.java | 35 - .../ics/pregelix/example/io/NullWritable.java | 89 - .../ics/pregelix/example/io/VIntWritable.java | 89 - .../ics/pregelix/example/io/VLongWritable.java | 187 - .../maximalclique/AdjacencyListWritable.java | 107 - .../example/maximalclique/CliquesWritable.java | 159 - .../maximalclique/MaximalCliqueAggregator.java | 79 - .../maximalclique/MaximalCliqueVertex.java | 354 - .../TextMaximalCliqueInputFormat.java | 113 - .../TextTriangleCountingInputFormat.java | 111 - .../TriangleCountingAggregator.java | 55 - .../TriangleCountingVertex.java | 169 - ...untingWithAggregateHadoopCountersVertex.java | 77 - .../pregelix/example/utils/CommonSource.java | 85 - .../pregelix/example/utils/DuplicateGraph.java | 87 - .../ics/pregelix/example/utils/FilterCount.java | 69 - .../ics/pregelix/example/utils/FindLargest.java | 91 - .../example/utils/GraphPreProcessor.java | 67 - .../ics/pregelix/example/utils/SerDeUtils.java | 87 - .../example/utils/VertexAggregator.java | 92 - .../pregelix/example/utils/VertexSorter.java | 76 - .../FailureInjectionIterationCompleteHook.java | 38 - .../FailureRecoveryConnectedComponentsTest.java | 74 - .../example/FailureRecoveryInnerJoinTest.java | 74 - .../pregelix/example/FailureRecoveryTest.java | 72 - .../FailureRecoveryWithoutCheckpointTest.java | 70 - .../uci/ics/pregelix/example/FailureVertex.java | 36 - .../ics/pregelix/example/FailureVertexTest.java | 70 - .../pregelix/example/GraphSampleVertexTest.java | 93 - .../pregelix/example/JobConcatenationTest.java | 86 - .../MultiJobConnectedComponentsTest.java | 107 - .../pregelix/example/MultiJobPageRankTest.java | 102 - .../example/OverflowAggregatorTest.java | 79 - .../edu/uci/ics/pregelix/example/SkewTest.java | 72 - .../uci/ics/pregelix/example/UpdateVertex.java | 106 - .../example/UpdateVertexInputFormat.java | 112 - .../example/UpdateVertexOutputFormat.java | 54 - .../ics/pregelix/example/UpdateVertexTest.java | 66 - .../example/aggregator/OverflowAggregator.java | 75 - .../pregelix/example/dataload/DataLoadTest.java | 183 - .../pregelix/example/jobgen/JobGenerator.java | 422 - .../pregelix/example/jobrun/RunJobTestCase.java | 121 - .../example/jobrun/RunJobTestSuite.java | 221 - .../example/lib/io/SizeEstimationTest.java | 176 - .../uci/ics/pregelix/example/util/Record.java | 104 - .../ics/pregelix/example/util/TestCluster.java | 150 - .../ics/pregelix/example/util/TestUtils.java | 97 - .../test/resources/cluster/cluster.properties | 54 - .../test/resources/cluster/stores.properties | 15 - .../expected/ConnectedComponentsReal/part-0 | 5 - .../expected/ConnectedComponentsReal/part-1 | 5 - .../expected/ConnectedComponentsReal/part-2 | 5 - .../expected/ConnectedComponentsReal/part-3 | 5 - .../ConnectedComponentsRealComplex/part-0 | 5 - .../ConnectedComponentsRealComplex/part-1 | 7 - .../ConnectedComponentsRealComplex/part-2 | 5 - .../ConnectedComponentsRealComplex/part-3 | 6 - .../ConnectedComponentsRealComplex2/part-0 | 10 - .../ConnectedComponentsRealComplex2/part-1 | 13 - .../resources/expected/EarlyTermination/part-0 | 5 - .../resources/expected/EarlyTermination/part-1 | 5 - .../resources/expected/EarlyTermination/part-2 | 5 - .../resources/expected/EarlyTermination/part-3 | 5 - .../resources/expected/GraphMutation/part-0 | 6 - .../resources/expected/GraphMutation/part-1 | 4 - .../resources/expected/GraphMutation/part-2 | 0 .../resources/expected/GraphMutation/part-3 | 3 - .../resources/expected/MaximalClique/part-0 | 1 - .../resources/expected/MaximalClique/part-1 | 2 - .../resources/expected/MaximalClique/part-2 | 2 - .../resources/expected/MaximalClique/part-3 | 2 - .../resources/expected/MaximalClique2/part-0 | 1 - .../resources/expected/MaximalClique2/part-1 | 2 - .../resources/expected/MaximalClique2/part-2 | 2 - .../resources/expected/MaximalClique2/part-3 | 1 - .../resources/expected/MaximalClique3/part-0 | 5 - .../resources/expected/MaximalClique3/part-1 | 5 - .../resources/expected/MaximalClique3/part-2 | 5 - .../resources/expected/MaximalClique3/part-3 | 5 - .../resources/expected/MessageOverflow/part-0 | 5 - .../resources/expected/MessageOverflow/part-1 | 5 - .../resources/expected/MessageOverflow/part-2 | 5 - .../resources/expected/MessageOverflow/part-3 | 5 - .../expected/MessageOverflowFixedsize/part-0 | 5 - .../expected/MessageOverflowFixedsize/part-1 | 5 - .../expected/MessageOverflowFixedsize/part-2 | 5 - .../expected/MessageOverflowFixedsize/part-3 | 5 - .../expected/MessageOverflowLSM/part-0 | 5 - .../expected/MessageOverflowLSM/part-1 | 5 - .../expected/MessageOverflowLSM/part-2 | 5 - .../expected/MessageOverflowLSM/part-3 | 5 - .../src/test/resources/expected/PageRank/part-0 | 10 - .../src/test/resources/expected/PageRank/part-1 | 10 - .../src/test/resources/expected/PageRank/part-2 | 10 - .../src/test/resources/expected/PageRank/part-3 | 10 - .../test/resources/expected/PageRankReal/part-0 | 5 - .../test/resources/expected/PageRankReal/part-1 | 5 - .../test/resources/expected/PageRankReal/part-2 | 5 - .../test/resources/expected/PageRankReal/part-3 | 5 - .../resources/expected/PageRankReal2/part-0 | 10 - .../resources/expected/PageRankReal2/part-1 | 10 - .../expected/PageRankRealComplex/part-0 | 5 - .../expected/PageRankRealComplex/part-1 | 7 - .../expected/PageRankRealComplex/part-2 | 5 - .../expected/PageRankRealComplex/part-3 | 6 - .../expected/PageRankRealDynamic/part-0 | 5 - .../expected/PageRankRealDynamic/part-1 | 5 - .../expected/PageRankRealDynamic/part-2 | 5 - .../expected/PageRankRealDynamic/part-3 | 5 - .../expected/PageRankRealNoCombiner/part-0 | 5 - .../expected/PageRankRealNoCombiner/part-1 | 5 - .../expected/PageRankRealNoCombiner/part-2 | 5 - .../expected/PageRankRealNoCombiner/part-3 | 5 - .../expected/ReachibilityRealComplex/part-0 | 5 - .../expected/ReachibilityRealComplex/part-1 | 7 - .../expected/ReachibilityRealComplex/part-2 | 5 - .../expected/ReachibilityRealComplex/part-3 | 6 - .../part-0 | 5 - .../part-1 | 7 - .../part-2 | 5 - .../part-3 | 6 - .../resources/expected/ShortestPaths/part-0 | 10 - .../resources/expected/ShortestPaths/part-1 | 10 - .../resources/expected/ShortestPaths/part-2 | 10 - .../resources/expected/ShortestPaths/part-3 | 10 - .../resources/expected/ShortestPathsReal/part-0 | 5 - .../resources/expected/ShortestPathsReal/part-1 | 5 - .../resources/expected/ShortestPathsReal/part-2 | 5 - .../resources/expected/ShortestPathsReal/part-3 | 5 - .../expected/TriangleCounting/.part-0.crc | Bin 12 -> 0 bytes .../expected/TriangleCounting/.part-1.crc | Bin 12 -> 0 bytes .../expected/TriangleCounting/.part-2.crc | Bin 12 -> 0 bytes .../expected/TriangleCounting/.part-3.crc | Bin 12 -> 0 bytes .../resources/expected/TriangleCounting/part-0 | 1 - .../resources/expected/TriangleCounting/part-1 | 2 - .../resources/expected/TriangleCounting/part-2 | 2 - .../resources/expected/TriangleCounting/part-3 | 2 - .../src/test/resources/expected/skew/part-0 | 6 - .../src/test/resources/expected/skew/part-1 | 6 - .../src/test/resources/expected/skew/part-2 | 5 - .../src/test/resources/expected/skew/part-3 | 6 - .../test/resources/hadoop/conf/core-site.xml | 32 - .../test/resources/hadoop/conf/hdfs-site.xml | 32 - .../test/resources/hadoop/conf/log4j.properties | 108 - .../test/resources/hadoop/conf/mapred-site.xml | 39 - .../src/test/resources/ignore.txt | 0 .../resources/jobs/ConnectedComponentsReal.xml | 144 - .../jobs/ConnectedComponentsRealComplex.xml | 145 - .../test/resources/jobs/EarlyTermination.xml | 142 - .../src/test/resources/jobs/GraphMutation.xml | 142 - .../src/test/resources/jobs/MaximalClique.xml | 144 - .../src/test/resources/jobs/MaximalClique2.xml | 144 - .../src/test/resources/jobs/MaximalClique3.xml | 145 - .../src/test/resources/jobs/MessageOverflow.xml | 144 - .../resources/jobs/MessageOverflowFixedsize.xml | 142 - .../test/resources/jobs/MessageOverflowLSM.xml | 145 - .../src/test/resources/jobs/PageRank.xml | 144 - .../src/test/resources/jobs/PageRankReal.xml | 148 - .../test/resources/jobs/PageRankRealComplex.xml | 147 - .../test/resources/jobs/PageRankRealDynamic.xml | 144 - .../resources/jobs/PageRankRealNoCombiner.xml | 145 - .../resources/jobs/ReachibilityRealComplex.xml | 147 - .../ReachibilityRealComplexNoConnectivity.xml | 145 - .../src/test/resources/jobs/ShortestPaths.xml | 145 - .../test/resources/jobs/ShortestPathsReal.xml | 146 - .../test/resources/jobs/TriangleCounting.xml | 143 - .../src/test/resources/log4j.properties | 108 - .../src/test/resources/logging.properties | 80 - .../src/test/resources/only.txt | 0 .../src/test/resources/topology.xml | 21 - pregelix/pregelix-runtime/pom.xml | 162 - .../agg/AccumulatingAggregatorFactory.java | 239 - .../runtime/agg/AggregationFunction.java | 172 - .../runtime/agg/AggregationFunctionFactory.java | 46 - .../agg/SerializableAggregateFunction.java | 230 - .../SerializableAggregationFunctionFactory.java | 40 - ...SerializableAggregatorDescriptorFactory.java | 103 - .../IndexLifeCycleManagerProvider.java | 36 - .../bootstrap/NCApplicationEntryPoint.java | 43 - .../bootstrap/StorageManagerInterface.java | 52 - .../bootstrap/VirtualBufferCacheProvider.java | 41 - .../function/ComputeUpdateFunctionFactory.java | 319 - .../ExtractLiveVertexIdFunctionFactory.java | 95 - .../function/NoOpUpdateFunctionFactory.java | 69 - .../StartComputeUpdateFunctionFactory.java | 309 - .../runtime/touchpoint/DatatypeHelper.java | 114 - .../MergePartitionComputerFactory.java | 38 - .../touchpoint/MsgListNullWriterFactory.java | 45 - .../PostSuperStepRuntimeHookFactory.java | 43 - .../PreSuperStepRuntimeHookFactory.java | 49 - .../touchpoint/RecoveryRuntimeHookFactory.java | 57 - .../runtime/touchpoint/RuntimeHookFactory.java | 62 - .../VertexIdNormalizedKeyComputerFactory.java | 51 - .../touchpoint/VertexIdNullWriterFactory.java | 47 - .../VertexIdPartitionComputerFactory.java | 58 - .../VertexPartitionComputerFactory.java | 73 - ...bleDescComparingBinaryComparatorFactory.java | 42 - .../WritableSerializerDeserializerFactory.java | 36 - 958 files changed, 113418 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/ffc967fd/hivesterix/.gitignore ---------------------------------------------------------------------- diff --git a/hivesterix/.gitignore b/hivesterix/.gitignore deleted file mode 100644 index 0d0a286..0000000 --- a/hivesterix/.gitignore +++ /dev/null @@ -1 +0,0 @@ -optest http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/ffc967fd/hivesterix/HyracksCodeFormatProfile.xml ---------------------------------------------------------------------- diff --git a/hivesterix/HyracksCodeFormatProfile.xml b/hivesterix/HyracksCodeFormatProfile.xml deleted file mode 100755 index 2ebb633..0000000 --- a/hivesterix/HyracksCodeFormatProfile.xml +++ /dev/null @@ -1,293 +0,0 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -