You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by pr...@apache.org on 2016/10/17 19:55:39 UTC
[49/50] [abbrv] asterixdb git commit: merge master
merge master
Project: http://git-wip-us.apache.org/repos/asf/asterixdb/repo
Commit: http://git-wip-us.apache.org/repos/asf/asterixdb/commit/9baab026
Tree: http://git-wip-us.apache.org/repos/asf/asterixdb/tree/9baab026
Diff: http://git-wip-us.apache.org/repos/asf/asterixdb/diff/9baab026
Branch: refs/heads/ecarm002/interval_join_merge
Commit: 9baab026f330a790be49f1dffeb77ae1dd3fc0ef
Parents: b4a3fd5 4819ea4
Author: Preston Carman <pr...@apache.org>
Authored: Mon Oct 17 12:18:06 2016 -0700
Committer: Preston Carman <pr...@apache.org>
Committed: Mon Oct 17 12:18:06 2016 -0700
----------------------------------------------------------------------
.../active/message/ActiveManagerMessage.java | 2 +-
.../active/message/ActivePartitionMessage.java | 2 +-
asterixdb/asterix-algebra/pom.xml | 4 +
.../optimizer/rules/LoadRecordFieldsRule.java | 46 +-
.../rules/PushLimitIntoOrderByRule.java | 16 +-
.../SweepIllegalNonfunctionalFunctions.java | 11 +-
.../subplan/InlineAllNtsInSubplanVisitor.java | 11 +-
...neLeftNtsInSubplanJoinFlatteningVisitor.java | 7 +-
.../SubplanSpecialFlatteningCheckVisitor.java | 10 +-
.../translator/AbstractLangTranslator.java | 9 +-
.../translator/util/FunctionCollection.java | 12 +
.../asterix-app/data/tpcds/call_center.csv | 5 +
.../asterix-app/data/tpcds/catalog_page.csv | 5 +
.../asterix-app/data/tpcds/catalog_returns.csv | 32 +-
.../asterix-app/data/tpcds/catalog_sales.csv | 38 +-
asterixdb/asterix-app/data/tpcds/customer.csv | 20 +-
.../asterix-app/data/tpcds/customer_address.csv | 20 +-
.../data/tpcds/customer_demographics.csv | 6 +
asterixdb/asterix-app/data/tpcds/date_dim.csv | 27 +-
.../data/tpcds/household_demographics.csv | 7 +
.../asterix-app/data/tpcds/income_band.csv | 5 +
asterixdb/asterix-app/data/tpcds/inventory.csv | 15 +
asterixdb/asterix-app/data/tpcds/item.csv | 19 +-
asterixdb/asterix-app/data/tpcds/promotion.csv | 10 +
asterixdb/asterix-app/data/tpcds/reason.csv | 10 +
asterixdb/asterix-app/data/tpcds/ship_mode.csv | 5 +
asterixdb/asterix-app/data/tpcds/store.csv | 5 +
.../asterix-app/data/tpcds/store_returns.csv | 17 +
.../asterix-app/data/tpcds/store_sales.csv | 48 +-
asterixdb/asterix-app/data/tpcds/time_dim.csv | 8 +
asterixdb/asterix-app/data/tpcds/warehouse.csv | 5 +
asterixdb/asterix-app/data/tpcds/web_page.csv | 10 +
.../asterix-app/data/tpcds/web_returns.csv | 13 +
asterixdb/asterix-app/data/tpcds/web_sales.csv | 16 +
asterixdb/asterix-app/data/tpcds/web_site.csv | 5 +
asterixdb/asterix-app/pom.xml | 14 +
.../interval_overlapping.3.adm | 35 -
.../interval_overlapping.4.adm | 35 -
.../common/AsterixHyracksIntegrationUtil.java | 2 +-
.../asterix/api/http/servlet/APIServlet.java | 12 +-
.../api/http/servlet/QueryServiceServlet.java | 19 +-
.../app/nc/AsterixNCAppRuntimeContext.java | 24 +-
.../asterix/app/translator/QueryTranslator.java | 6 +-
.../bootstrap/CCApplicationEntryPoint.java | 17 +-
.../bootstrap/ClusterLifecycleListener.java | 14 +-
.../bootstrap/NCApplicationEntryPoint.java | 17 +-
.../resources/asterix-build-configuration.xml | 5 +-
...ataset_with_default_dataverse_type.1.ddl.aql | 25 +
...aset_with_default_dataverse_type.2.query.aql | 23 +
...ataset_with_default_dataverse_type.3.ddl.aql | 20 +
.../dataset_with_default_dataverse_type.2.adm | 1 +
.../src/test/resources/metadata/testsuite.xml | 5 +
.../queries/multi-indexes/skip-one-index.aql | 49 +
.../queries/multi-indexes/skip-two-index.aql | 53 ++
.../queries/query-ASTERIXDB-1671.sqlpp | 40 +
.../results/multi-indexes/skip-one-index.plan | 26 +
.../results/multi-indexes/skip-two-index.plan | 15 +
.../results/query-ASTERIXDB-1671.plan | 17 +
.../polygon-from-open-list_issue1627.1.ddl.aql | 34 +
...olygon-from-open-list_issue1627.2.update.aql | 30 +
...polygon-from-open-list_issue1627.3.query.aql | 28 +
.../feed-with-external-function.4.sleep.aql | 19 -
.../feed-with-external-function.5.pollquery.aql | 33 +
.../feed-with-external-function.5.query.aql | 32 -
.../query-ASTERIXDB-1671-2.1.ddl.sqlpp | 47 +
.../query-ASTERIXDB-1671-2.2.update.sqlpp | 24 +
.../query-ASTERIXDB-1671-2.3.query.sqlpp | 27 +
.../query-ASTERIXDB-1671.1.ddl.sqlpp | 47 +
.../query-ASTERIXDB-1671.2.update.sqlpp | 24 +
.../query-ASTERIXDB-1671.3.query.sqlpp | 27 +
.../query-ASTERIXDB-1689.1.query.sqlpp | 22 +
.../everysat_04/everysat_04.3.query.sqlpp | 2 +-
.../query-ASTERIXDB-1674.1.ddl.sqlpp | 38 +
.../query-ASTERIXDB-1674.2.update.sqlpp | 24 +
.../query-ASTERIXDB-1674.3.query.sqlpp | 39 +
.../somesat_06/somesat_06.3.query.sqlpp | 2 +-
.../query-ASTERIXDB-1674.1.ddl.sqlpp | 38 +
.../query-ASTERIXDB-1674.2.update.sqlpp | 24 +
.../query-ASTERIXDB-1674.3.query.sqlpp | 38 +
.../queries_sqlpp/tpcds/q03/q03.1.ddl.sqlpp | 115 +++
.../queries_sqlpp/tpcds/q03/q03.2.update.sqlpp | 27 +
.../queries_sqlpp/tpcds/q03/q03.3.query.sqlpp | 40 +
.../queries_sqlpp/tpcds/q07/q07.1.ddl.sqlpp | 155 ++++
.../queries_sqlpp/tpcds/q07/q07.2.update.sqlpp | 31 +
.../queries_sqlpp/tpcds/q07/q07.3.query.sqlpp | 40 +
.../queries_sqlpp/tpcds/q15/q15.1.ddl.sqlpp | 140 +++
.../queries_sqlpp/tpcds/q15/q15.2.update.sqlpp | 29 +
.../queries_sqlpp/tpcds/q15/q15.3.query.sqlpp | 40 +
.../queries_sqlpp/tpcds/q19/q19.1.ddl.sqlpp | 193 ++++
.../queries_sqlpp/tpcds/q19/q19.2.update.sqlpp | 33 +
.../queries_sqlpp/tpcds/q19/q19.3.query.sqlpp | 44 +
.../queries_sqlpp/tpcds/q21/q21.1.ddl.sqlpp | 116 +++
.../queries_sqlpp/tpcds/q21/q21.2.update.sqlpp | 29 +
.../queries_sqlpp/tpcds/q21/q21.3.query.sqlpp | 53 ++
.../queries_sqlpp/tpcds/q24a/q24a.1.ddl.sqlpp | 185 ++++
.../tpcds/q24a/q24a.2.update.sqlpp | 33 +
.../queries_sqlpp/tpcds/q24a/q24a.3.query.sqlpp | 70 ++
.../queries_sqlpp/tpcds/q24b/q24b.1.ddl.sqlpp | 185 ++++
.../tpcds/q24b/q24b.2.update.sqlpp | 33 +
.../queries_sqlpp/tpcds/q24b/q24b.3.query.sqlpp | 70 ++
.../queries_sqlpp/tpcds/q25/q25.1.ddl.sqlpp | 215 +++++
.../queries_sqlpp/tpcds/q25/q25.2.update.sqlpp | 33 +
.../queries_sqlpp/tpcds/q25/q25.3.query.sqlpp | 69 ++
.../queries_sqlpp/tpcds/q26/q26.1.ddl.sqlpp | 164 ++++
.../queries_sqlpp/tpcds/q26/q26.2.update.sqlpp | 31 +
.../queries_sqlpp/tpcds/q26/q26.3.query.sqlpp | 40 +
.../queries_sqlpp/tpcds/q29/q29.1.ddl.sqlpp | 215 +++++
.../queries_sqlpp/tpcds/q29/q29.2.update.sqlpp | 33 +
.../queries_sqlpp/tpcds/q29/q29.3.query.sqlpp | 66 ++
.../queries_sqlpp/tpcds/q30/q30.1.ddl.sqlpp | 131 +++
.../queries_sqlpp/tpcds/q30/q30.2.update.sqlpp | 29 +
.../queries_sqlpp/tpcds/q30/q30.3.query.sqlpp | 50 +
.../queries_sqlpp/tpcds/q31/q31.1.ddl.sqlpp | 146 +++
.../queries_sqlpp/tpcds/q31/q31.2.update.sqlpp | 29 +
.../queries_sqlpp/tpcds/q31/q31.3.query.sqlpp | 71 ++
.../queries_sqlpp/tpcds/q34/q34.1.ddl.sqlpp | 156 ++++
.../queries_sqlpp/tpcds/q34/q34.2.update.sqlpp | 31 +
.../queries_sqlpp/tpcds/q34/q34.3.query.sqlpp | 55 ++
.../queries_sqlpp/tpcds/q37/q37.1.ddl.sqlpp | 135 +++
.../queries_sqlpp/tpcds/q37/q37.2.update.sqlpp | 29 +
.../queries_sqlpp/tpcds/q37/q37.3.query.sqlpp | 36 +
.../queries_sqlpp/tpcds/q41/q41.1.ddl.sqlpp | 52 ++
.../queries_sqlpp/tpcds/q41/q41.2.update.sqlpp | 23 +
.../queries_sqlpp/tpcds/q41/q41.3.query.sqlpp | 71 ++
.../queries_sqlpp/tpcds/q42/q42.1.ddl.sqlpp | 115 +++
.../queries_sqlpp/tpcds/q42/q42.2.update.sqlpp | 27 +
.../queries_sqlpp/tpcds/q42/q42.3.query.sqlpp | 41 +
.../queries_sqlpp/tpcds/q43/q43.1.ddl.sqlpp | 122 +++
.../queries_sqlpp/tpcds/q43/q43.2.update.sqlpp | 27 +
.../queries_sqlpp/tpcds/q43/q43.3.query.sqlpp | 38 +
.../queries_sqlpp/tpcds/q45/q45.1.ddl.sqlpp | 169 ++++
.../queries_sqlpp/tpcds/q45/q45.2.update.sqlpp | 31 +
.../queries_sqlpp/tpcds/q45/q45.3.query.sqlpp | 38 +
.../queries_sqlpp/tpcds/q46/q46.1.ddl.sqlpp | 176 ++++
.../queries_sqlpp/tpcds/q46/q46.2.update.sqlpp | 33 +
.../queries_sqlpp/tpcds/q46/q46.3.query.sqlpp | 54 ++
.../queries_sqlpp/tpcds/q50/q50.1.ddl.sqlpp | 148 +++
.../queries_sqlpp/tpcds/q50/q50.2.update.sqlpp | 29 +
.../queries_sqlpp/tpcds/q50/q50.3.query.sqlpp | 78 ++
.../queries_sqlpp/tpcds/q52/q52.1.ddl.sqlpp | 115 +++
.../queries_sqlpp/tpcds/q52/q52.2.update.sqlpp | 27 +
.../queries_sqlpp/tpcds/q52/q52.3.query.sqlpp | 41 +
.../queries_sqlpp/tpcds/q55/q55.1.ddl.sqlpp | 115 +++
.../queries_sqlpp/tpcds/q55/q55.2.update.sqlpp | 27 +
.../queries_sqlpp/tpcds/q55/q55.3.query.sqlpp | 33 +
.../queries_sqlpp/tpcds/q59/q59.1.ddl.sqlpp | 122 +++
.../queries_sqlpp/tpcds/q59/q59.2.update.sqlpp | 27 +
.../queries_sqlpp/tpcds/q59/q59.3.query.sqlpp | 63 ++
.../queries_sqlpp/tpcds/q62/q62.1.ddl.sqlpp | 162 ++++
.../queries_sqlpp/tpcds/q62/q62.2.update.sqlpp | 31 +
.../queries_sqlpp/tpcds/q62/q62.3.query.sqlpp | 54 ++
.../queries_sqlpp/tpcds/q68/q68.1.ddl.sqlpp | 175 ++++
.../queries_sqlpp/tpcds/q68/q68.2.update.sqlpp | 33 +
.../queries_sqlpp/tpcds/q68/q68.3.query.sqlpp | 61 ++
.../queries_sqlpp/tpcds/q73/q73.1.ddl.sqlpp | 156 ++++
.../queries_sqlpp/tpcds/q73/q73.2.update.sqlpp | 31 +
.../queries_sqlpp/tpcds/q73/q73.3.query.sqlpp | 48 +
.../queries_sqlpp/tpcds/q79/q79.1.ddl.sqlpp | 156 ++++
.../queries_sqlpp/tpcds/q79/q79.2.update.sqlpp | 31 +
.../queries_sqlpp/tpcds/q79/q79.3.query.sqlpp | 42 +
.../queries_sqlpp/tpcds/q81/q81.1.ddl.sqlpp | 134 +++
.../queries_sqlpp/tpcds/q81/q81.2.update.sqlpp | 29 +
.../queries_sqlpp/tpcds/q81/q81.3.query.sqlpp | 50 +
.../queries_sqlpp/tpcds/q82/q82.1.ddl.sqlpp | 125 +++
.../queries_sqlpp/tpcds/q82/q82.2.update.sqlpp | 29 +
.../queries_sqlpp/tpcds/q82/q82.3.query.sqlpp | 36 +
.../queries_sqlpp/tpcds/q88/q88.1.ddl.sqlpp | 113 +++
.../queries_sqlpp/tpcds/q88/q88.2.update.sqlpp | 29 +
.../queries_sqlpp/tpcds/q88/q88.3.query.sqlpp | 103 +++
.../queries_sqlpp/tpcds/q91/q91.1.ddl.sqlpp | 195 ++++
.../queries_sqlpp/tpcds/q91/q91.2.update.sqlpp | 35 +
.../queries_sqlpp/tpcds/q91/q91.3.query.sqlpp | 50 +
.../queries_sqlpp/tpcds/q94/q94.1.ddl.sqlpp | 179 ++++
.../queries_sqlpp/tpcds/q94/q94.2.update.sqlpp | 31 +
.../queries_sqlpp/tpcds/q94/q94.3.query.sqlpp | 51 ++
.../queries_sqlpp/tpcds/q95/q95.1.ddl.sqlpp | 179 ++++
.../queries_sqlpp/tpcds/q95/q95.2.update.sqlpp | 31 +
.../queries_sqlpp/tpcds/q95/q95.3.query.sqlpp | 58 ++
.../queries_sqlpp/tpcds/q96/q96.1.ddl.sqlpp | 113 +++
.../queries_sqlpp/tpcds/q96/q96.2.update.sqlpp | 29 +
.../queries_sqlpp/tpcds/q96/q96.3.query.sqlpp | 38 +
.../queries_sqlpp/tpcds/q98/q98.1.ddl.sqlpp | 115 +++
.../queries_sqlpp/tpcds/q98/q98.2.update.sqlpp | 27 +
.../queries_sqlpp/tpcds/q98/q98.3.query.sqlpp | 75 ++
.../types/isarray/isarray.1.query.sqlpp | 30 +
.../types/isboolean/isboolean.1.query.sqlpp | 30 +
.../types/isnumber/isnumber.1.query.sqlpp | 31 +
.../types/isobject/isobject.1.query.sqlpp | 30 +
.../types/isstring/isstring.1.query.sqlpp | 30 +
.../api/cluster_state_1/cluster_state_1.1.adm | 39 +-
.../polygon-from-open-list_issue1627.1.adm | 1 +
.../query-ASTERIXDB-1671.1.adm | 0
.../query-ASTERIXDB-1689.1.adm | 1 +
.../query-ASTERIXDB-1674.1.adm | 1 +
.../query-ASTERIXDB-1674.1.adm | 2 +
.../runtimets/results/tpcds/q03/q03.1.adm | 1 +
.../runtimets/results/tpcds/q07/q07.1.adm | 1 +
.../runtimets/results/tpcds/q15/q15.1.adm | 1 +
.../runtimets/results/tpcds/q19/q19.1.adm | 1 +
.../runtimets/results/tpcds/q21/q21.1.adm | 1 +
.../runtimets/results/tpcds/q24a/q24a.1.adm | 1 +
.../runtimets/results/tpcds/q24b/q24b.1.adm | 1 +
.../runtimets/results/tpcds/q25/q25.1.adm | 1 +
.../runtimets/results/tpcds/q26/q26.1.adm | 1 +
.../runtimets/results/tpcds/q29/q29.1.adm | 1 +
.../runtimets/results/tpcds/q30/q30.1.adm | 1 +
.../runtimets/results/tpcds/q31/q31.1.adm | 1 +
.../runtimets/results/tpcds/q34/q34.1.adm | 1 +
.../runtimets/results/tpcds/q37/q37.1.adm | 1 +
.../runtimets/results/tpcds/q41/q41.1.adm | 1 +
.../runtimets/results/tpcds/q42/q42.1.adm | 2 +
.../runtimets/results/tpcds/q43/q43.1.adm | 2 +
.../runtimets/results/tpcds/q45/q45.1.adm | 1 +
.../runtimets/results/tpcds/q46/q46.1.adm | 1 +
.../runtimets/results/tpcds/q50/q50.1.adm | 3 +
.../runtimets/results/tpcds/q52/q52.1.adm | 3 +
.../runtimets/results/tpcds/q55/q55.1.adm | 1 +
.../runtimets/results/tpcds/q59/q59.1.adm | 2 +
.../runtimets/results/tpcds/q62/q62.1.adm | 2 +
.../runtimets/results/tpcds/q68/q68.1.adm | 1 +
.../runtimets/results/tpcds/q73/q73.1.adm | 1 +
.../runtimets/results/tpcds/q79/q79.1.adm | 2 +
.../runtimets/results/tpcds/q81/q81.1.adm | 1 +
.../runtimets/results/tpcds/q82/q82.1.adm | 1 +
.../runtimets/results/tpcds/q88/q88.1.adm | 1 +
.../runtimets/results/tpcds/q91/q91.1.adm | 1 +
.../runtimets/results/tpcds/q94/q94.1.adm | 1 +
.../runtimets/results/tpcds/q95/q95.1.adm | 1 +
.../runtimets/results/tpcds/q96/q96.1.adm | 1 +
.../runtimets/results/tpcds/q98/q98.1.adm | 1 +
.../query-ASTERIXDB-1580.1.adm | 2 +-
.../query-ASTERIXDB-1581-2.1.adm | 2 +-
.../query-ASTERIXDB-1581-4.1.adm | 2 +-
.../query-ASTERIXDB-1581-6.1.adm | 2 +-
.../query-ASTERIXDB-1581-correlated.1.adm | 2 +-
.../query-ASTERIXDB-1591.1.adm | 2 +-
.../query-ASTERIXDB-1596.1.adm | 38 +-
.../query-ASTERIXDB-1602.1.adm | 2 +-
.../results/types/isarray/isarray.1.adm | 1 +
.../results/types/isboolean/isboolean.1.adm | 1 +
.../results/types/isnumber/isnumber.1.adm | 1 +
.../results/types/isobject/isobject.1.adm | 1 +
.../results/types/isstring/isstring.1.adm | 1 +
.../src/test/resources/runtimets/testsuite.xml | 5 +
.../resources/runtimets/testsuite_sqlpp.xml | 225 +++++
asterixdb/asterix-client-helper/pom.xml | 2 -
.../org/apache/asterix/clienthelper/Args.java | 2 +-
.../clienthelper/commands/RemoteCommand.java | 8 +
.../commands/WaitForClusterCommand.java | 10 +-
.../common/api/IClusterManagementWork.java | 1 +
.../common/cluster/ClusterPartition.java | 9 +-
.../config/AsterixMetadataProperties.java | 35 +
.../common/config/AsterixProperties.java | 2 +-
.../config/AsterixPropertiesAccessor.java | 55 +-
.../messaging/api/IApplicationMessage.java | 2 +-
.../common/metadata/IMetadataBootstrap.java | 29 +
.../apache/asterix/common/utils/JSONUtil.java | 11 +-
.../apache/asterix/common/utils/PrintUtil.java | 48 +
.../apache/asterix/test/aql/TestExecutor.java | 41 +
asterixdb/asterix-doc/pom.xml | 4 +-
.../src/main/markdown/builtins/0_toc.md | 3 +-
.../src/main/markdown/builtins/11_others.md | 249 -----
.../src/main/markdown/builtins/11_type.md | 263 ++++++
.../src/main/markdown/builtins/12_misc.md | 185 ++++
.../src/main/markdown/builtins/7_temporal.md | 3 -
.../src/main/markdown/sqlpp/1_intro.md | 8 +-
.../src/main/markdown/sqlpp/2_expr.md | 47 +-
.../src/main/markdown/sqlpp/3_query.md | 13 +-
.../src/main/markdown/sqlpp/5_ddl.md | 16 +-
.../main/markdown/sqlpp/appendix_1_keywords.md | 24 +-
.../src/site/markdown/aql/datamodel.md | 398 --------
.../src/site/markdown/aql/primer-sql-like.md | 907 -------------------
.../asterix-doc/src/site/markdown/aql/primer.md | 749 +++++++--------
.../asterix-doc/src/site/markdown/datamodel.md | 398 ++++++++
.../src/site/markdown/feeds/tutorial.md | 27 +-
.../src/site/markdown/sqlpp/primer-sqlpp.md | 3 -
asterixdb/asterix-doc/src/site/site.xml | 3 +-
.../docker/asterix-configuration.xml | 13 +-
.../configs/asterix-configuration.xml | 14 +-
asterixdb/asterix-external-data/pom.xml | 16 +
.../external/util/ExternalDataConstants.java | 4 +
.../asterix/external/util/TwitterUtil.java | 38 +-
asterixdb/asterix-installer/pom.xml | 7 +
.../resources/conf/asterix-configuration.xml | 13 +-
.../installer/test/AsterixRestartIT.java | 102 +++
.../integrationts/asterix-configuration.xml | 13 +-
.../resources/integrationts/restart/828.h1w.adm | 100 ++
.../issue-1636/issue-1636.01.ddl.aql | 81 ++
.../issue-1636/issue-1636.02.ddl.aql | 27 +
.../issue-1636/issue-1636.03.script.aql | 1 +
.../issue-1636/issue-1636.04.ddl.aql | 35 +
.../issue-1636/issue-1636.05.mgx.aql | 2 +
.../issue-1636/issue-1636.06.mgx.aql | 2 +
.../issue-1636/issue-1636.07.script.aql | 1 +
.../issue-1636/issue-1636.08.ddl.aql | 27 +
.../issue-1636/issue-1636.09.sleep.aql | 25 +
.../issue-1636/issue-1636.10.script.aql | 1 +
.../issue-1636/issue-1636.11.script.aql | 1 +
.../scripts/feed-restart/issue-1636/cat.sh | 18 +
.../scripts/feed-restart/issue-1636/grep_log.sh | 20 +
.../feed-restart/issue-1636/kill_cc_and_nc.sh | 18 +
.../scripts/feed-restart/issue-1636/touch.sh | 21 +
.../integrationts/restart/testsuite.xml | 28 +
.../resources/integrationts/restart/tweets.json | 39 +
.../lang/common/parser/ScopeChecker.java | 13 +-
.../lang/common/util/CommonFunctionMapUtil.java | 14 +
.../asterix-lang-sqlpp/src/main/javacc/SQLPP.jj | 7 +-
.../asterix/metadata/GarbageCollector.java | 37 +-
.../asterix/metadata/MetadataManager.java | 152 ++--
.../metadata/api/IAsterixStateProxy.java | 5 +-
.../asterix/metadata/api/IMetadataManager.java | 55 +-
.../metadata/bootstrap/AsterixStateProxy.java | 20 +-
.../apache/asterix/builders/RecordBuilder.java | 8 -
.../serde/ARecordSerializerDeserializer.java | 89 +-
.../om/functions/AsterixBuiltinFunctions.java | 22 +-
.../pointables/ARecordVisitablePointable.java | 39 +-
.../om/pointables/PointableAllocator.java | 18 +-
.../om/pointables/cast/ACastVisitor.java | 4 +-
.../asterix/om/pointables/cast/AListCaster.java | 4 +-
.../om/pointables/cast/ARecordCaster.java | 15 +-
.../impl/BooleanOrMissingTypeComputer.java | 44 +
.../om/typecomputer/TypeComputerTest.java | 1 +
.../functions/CreatePolygonDescriptor.java | 5 +-
.../evaluators/functions/IsArrayDescriptor.java | 68 ++
.../functions/IsBooleanDescriptor.java | 68 ++
.../functions/IsNumberDescriptor.java | 73 ++
.../functions/IsObjectDescriptor.java | 68 ++
.../functions/IsStringDescriptor.java | 68 ++
.../message/CompleteFailbackRequestMessage.java | 2 +-
.../CompleteFailbackResponseMessage.java | 2 +-
...PreparePartitionsFailbackRequestMessage.java | 2 +-
...reparePartitionsFailbackResponseMessage.java | 2 +-
.../runtime/message/ReplicaEventMessage.java | 2 +-
.../message/ReportMaxResourceIdMessage.java | 2 +-
.../ReportMaxResourceIdRequestMessage.java | 2 +-
.../message/ResourceIdRequestMessage.java | 2 +-
.../TakeoverMetadataNodeRequestMessage.java | 2 +-
.../TakeoverMetadataNodeResponseMessage.java | 2 +-
.../TakeoverPartitionsRequestMessage.java | 2 +-
.../TakeoverPartitionsResponseMessage.java | 2 +-
.../runtime/util/AsterixAppContextInfo.java | 25 +-
.../runtime/util/ClusterStateManager.java | 39 +-
asterixdb/asterix-server/pom.xml | 7 +
.../src/main/samples/local/conf/cc.conf | 2 +-
.../server/test/NCServiceExecutionIT.java | 2 +-
.../test/resources/NCServiceExecutionIT/cc.conf | 2 +-
asterixdb/asterix-yarn/pom.xml | 7 +
.../resources/base-asterix-configuration.xml | 13 +-
.../configs/base-asterix-configuration.xml | 13 +-
asterixdb/pom.xml | 9 +-
.../algebricks/algebricks-compiler/pom.xml | 19 +-
.../algebricks/algebricks-core/pom.xml | 30 +-
.../core/algebra/base/LogicalOperatorTag.java | 2 +-
.../core/algebra/base/PhysicalOperatorTag.java | 4 +-
.../logical/AbstractReplicateOperator.java | 103 +++
.../logical/PartitioningSplitOperator.java | 119 ---
.../operators/logical/ReplicateOperator.java | 70 +-
.../operators/logical/SplitOperator.java | 65 ++
.../visitors/CardinalityInferenceVisitor.java | 6 +-
.../visitors/FDsAndEquivClassesVisitor.java | 3 +-
.../visitors/IsomorphismOperatorVisitor.java | 19 +-
.../IsomorphismVariableMappingVisitor.java | 9 +-
...OperatorDeepCopyWithNewVariablesVisitor.java | 18 +-
.../visitors/LogicalPropertiesVisitor.java | 6 +
.../visitors/OperatorDeepCopyVisitor.java | 15 +-
.../visitors/PrimaryKeyVariablesVisitor.java | 7 +-
.../visitors/ProducedVariableVisitor.java | 14 +-
.../logical/visitors/SchemaVariableVisitor.java | 16 +-
.../visitors/SubstituteVariableVisitor.java | 11 +-
.../logical/visitors/UsedVariableVisitor.java | 19 +-
.../physical/AbstractReplicatePOperator.java | 68 ++
.../operators/physical/ReplicatePOperator.java | 47 +-
.../operators/physical/SplitPOperator.java | 68 ++
.../LogicalOperatorPrettyPrintVisitor.java | 21 +-
.../visitors/ILogicalOperatorVisitor.java | 8 +-
.../algebricks/algebricks-data/pom.xml | 10 +
.../algebricks-examples/piglet-example/pom.xml | 45 +
.../algebricks/algebricks-rewriter/pom.xml | 15 +
.../rules/RemoveRedundantVariablesRule.java | 19 +-
.../RemoveUnusedAssignAndAggregateRule.java | 2 +-
...placeNtsWithSubplanInputOperatorVisitor.java | 7 +-
.../algebricks/algebricks-runtime/pom.xml | 20 +-
.../PartitioningSplitOperatorDescriptor.java | 217 -----
.../operators/std/SplitOperatorDescriptor.java | 188 ++++
.../data/simple/int-string-part1-split-0.tbl | 4 +
.../data/simple/int-string-part1-split-1.tbl | 3 +
.../data/simple/int-string-part1.tbl | 7 +
.../algebricks/algebricks-tests/pom.xml | 48 +-
.../tests/pushruntime/PushRuntimeTest.java | 73 +-
hyracks-fullstack/hyracks/hyracks-api/pom.xml | 24 +-
.../application/IClusterLifecycleListener.java | 11 +-
.../SuperActivityOperatorNodePushable.java | 40 +-
.../hyracks/hyracks-client/pom.xml | 7 +-
.../hyracks-control/hyracks-control-cc/pom.xml | 62 +-
.../org/apache/hyracks/control/cc/CCDriver.java | 2 +-
.../cc/application/CCApplicationContext.java | 2 +-
.../control/cc/work/RemoveDeadNodesWork.java | 11 +-
.../hyracks-control-common/pom.xml | 27 +-
.../control/common/controllers/CCConfig.java | 46 +-
.../control/common/controllers/IniUtils.java | 8 +-
.../control/common/controllers/NCConfig.java | 4 +-
.../control/common/work/SynchronizableWork.java | 14 +-
.../hyracks-control/hyracks-control-nc/pom.xml | 25 +
.../org/apache/hyracks/control/nc/Task.java | 24 +-
.../hyracks-control/hyracks-nc-service/pom.xml | 87 +-
.../hyracks-data/hyracks-data-std/pom.xml | 5 +
.../hyracks/hyracks-dataflow-std/pom.xml | 20 +
.../AbstractReplicateOperatorDescriptor.java | 233 +++++
.../std/misc/ReplicateOperatorDescriptor.java | 36 +
.../std/misc/SplitOperatorDescriptor.java | 231 -----
.../std/sort/HybridTopKSortRunGenerator.java | 3 +
.../btree-example/btreeclient/pom.xml | 34 +-
.../btree-example/btreehelper/pom.xml | 14 +-
.../btree-example/btreeserver/pom.xml | 22 -
.../hyracks-integration-tests/pom.xml | 70 +-
.../tests/integration/JobFailureTest.java | 11 +-
.../integration/ReplicateOperatorTest.java | 115 +++
.../tests/integration/SplitOperatorTest.java | 116 ---
...onOnCreatePushRuntimeOperatorDescriptor.java | 11 +-
.../hyracks-shutdown-test/pom.xml | 29 +-
.../text-example/textclient/pom.xml | 23 +-
.../text-example/texthelper/pom.xml | 8 +-
.../text-example/textserver/pom.xml | 39 +-
.../tpch-example/tpchclient/pom.xml | 15 +
.../tpch-example/tpchserver/pom.xml | 27 -
.../hyracks-hdfs/hyracks-hdfs-1.x/pom.xml | 23 +-
.../hyracks/hdfs/MiniDFSClusterFactory.java | 35 -
.../hyracks/hdfs/MiniDFSClusterFactory.java | 35 +
.../hyracks-hdfs/hyracks-hdfs-2.x/pom.xml | 49 +-
.../hyracks/hdfs/MiniDFSClusterFactory.java | 38 -
.../hyracks/hdfs/MiniDFSClusterFactory.java | 38 +
.../hyracks-hdfs/hyracks-hdfs-core/pom.xml | 160 +++-
hyracks-fullstack/hyracks/hyracks-net/pom.xml | 2 +-
.../hyracks/hyracks-server/pom.xml | 49 +-
.../apache/hyracks/server/test/NCServiceIT.java | 2 +-
.../hyracks-storage-am-bloomfilter/pom.xml | 17 +-
.../hyracks/hyracks-storage-am-btree/pom.xml | 22 +
.../hyracks/hyracks-storage-am-common/pom.xml | 5 +
.../hyracks-storage-am-lsm-btree/pom.xml | 31 +-
.../hyracks-storage-am-lsm-common/pom.xml | 26 +-
.../pom.xml | 39 +-
.../hyracks-storage-am-lsm-rtree/pom.xml | 41 +-
.../hyracks/hyracks-storage-am-rtree/pom.xml | 26 +-
.../hyracks/hyracks-storage-common/pom.xml | 7 +-
.../hyracks/hyracks-test-support/pom.xml | 40 +-
.../hyracks-storage-am-bloomfilter-test/pom.xml | 28 +-
.../hyracks-storage-am-btree-test/pom.xml | 32 +-
.../hyracks-storage-am-lsm-btree-test/pom.xml | 43 +-
.../hyracks-storage-am-lsm-common-test/pom.xml | 28 +-
.../pom.xml | 45 +-
.../hyracks-storage-am-lsm-rtree-test/pom.xml | 48 +-
.../hyracks-storage-am-rtree-test/pom.xml | 33 +-
.../hyracks-storage-common-test/pom.xml | 12 +-
hyracks-fullstack/pom.xml | 28 +-
454 files changed, 15274 insertions(+), 4032 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SweepIllegalNonfunctionalFunctions.java
----------------------------------------------------------------------
diff --cc asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SweepIllegalNonfunctionalFunctions.java
index c7d21f8,4a79387..72c47c3
--- a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SweepIllegalNonfunctionalFunctions.java
+++ b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SweepIllegalNonfunctionalFunctions.java
@@@ -49,10 -50,7 +50,8 @@@ import org.apache.hyracks.algebricks.co
import org.apache.hyracks.algebricks.core.algebra.operators.logical.NestedTupleSourceOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator.IOrder;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.LeftOuterUnnestOperator;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.PartitioningSplitOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ProjectOperator;
+import org.apache.hyracks.algebricks.core.algebra.operators.logical.RangeForwardOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ReplicateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.RunningAggregateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ScriptOperator;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/InlineAllNtsInSubplanVisitor.java
----------------------------------------------------------------------
diff --cc asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/InlineAllNtsInSubplanVisitor.java
index 6597006,874cc7c..ead78b7
--- a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/InlineAllNtsInSubplanVisitor.java
+++ b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/InlineAllNtsInSubplanVisitor.java
@@@ -67,9 -67,8 +67,9 @@@ import org.apache.hyracks.algebricks.co
import org.apache.hyracks.algebricks.core.algebra.operators.logical.MaterializeOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.NestedTupleSourceOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.PartitioningSplitOperator;
+ import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator.IOrder;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ProjectOperator;
+import org.apache.hyracks.algebricks.core.algebra.operators.logical.RangeForwardOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ReplicateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.RunningAggregateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ScriptOperator;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/InlineLeftNtsInSubplanJoinFlatteningVisitor.java
----------------------------------------------------------------------
diff --cc asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/InlineLeftNtsInSubplanJoinFlatteningVisitor.java
index d5f8fe9,eeb2c2a..ccdb41d
--- a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/InlineLeftNtsInSubplanJoinFlatteningVisitor.java
+++ b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/InlineLeftNtsInSubplanJoinFlatteningVisitor.java
@@@ -53,9 -53,7 +53,8 @@@ import org.apache.hyracks.algebricks.co
import org.apache.hyracks.algebricks.core.algebra.operators.logical.NestedTupleSourceOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator.IOrder;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.PartitioningSplitOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ProjectOperator;
+import org.apache.hyracks.algebricks.core.algebra.operators.logical.RangeForwardOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ReplicateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.RunningAggregateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ScriptOperator;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/SubplanSpecialFlatteningCheckVisitor.java
----------------------------------------------------------------------
diff --cc asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/SubplanSpecialFlatteningCheckVisitor.java
index e5c67cc,ccf0aeb..75a42a5
--- a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/SubplanSpecialFlatteningCheckVisitor.java
+++ b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/subplan/SubplanSpecialFlatteningCheckVisitor.java
@@@ -37,10 -38,7 +38,8 @@@ import org.apache.hyracks.algebricks.co
import org.apache.hyracks.algebricks.core.algebra.operators.logical.MaterializeOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.NestedTupleSourceOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.LeftOuterUnnestOperator;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.PartitioningSplitOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ProjectOperator;
+import org.apache.hyracks.algebricks.core.algebra.operators.logical.RangeForwardOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ReplicateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.RunningAggregateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ScriptOperator;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/util/FunctionCollection.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/asterixdb/asterix-app/src/test/resources/runtimets/testsuite.xml
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/functions/AsterixBuiltinFunctions.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalOperatorTag.java
----------------------------------------------------------------------
diff --cc hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalOperatorTag.java
index 07c35a3,cc7a75f..c7f9aa1
--- a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalOperatorTag.java
+++ b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalOperatorTag.java
@@@ -38,9 -38,7 +38,8 @@@ public enum LogicalOperatorTag
MATERIALIZE,
NESTEDTUPLESOURCE,
ORDER,
- PARTITIONINGSPLIT,
PROJECT,
+ RANGE_FORWARD,
REPLICATE,
RUNNINGAGGREGATE,
SCRIPT,
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/PhysicalOperatorTag.java
----------------------------------------------------------------------
diff --cc hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/PhysicalOperatorTag.java
index 25a47ee,1d20e08..949f6c8
--- a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/PhysicalOperatorTag.java
+++ b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/PhysicalOperatorTag.java
@@@ -52,9 -50,9 +51,10 @@@ public enum PhysicalOperatorTag
PRE_SORTED_DISTINCT_BY,
RANDOM_PARTITION_EXCHANGE,
RANDOM_MERGE_EXCHANGE,
+ RANGE_FORWARD,
RANGE_PARTITION_EXCHANGE,
RANGE_PARTITION_MERGE_EXCHANGE,
+ REPLICATE,
RTREE_SEARCH,
RUNNING_AGGREGATE,
SINGLE_PARTITION_INVERTED_INDEX_SEARCH,
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/CardinalityInferenceVisitor.java
----------------------------------------------------------------------
diff --cc hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/CardinalityInferenceVisitor.java
index d7e8864,d278078..1ab0606
--- a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/CardinalityInferenceVisitor.java
+++ b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/CardinalityInferenceVisitor.java
@@@ -48,9 -48,7 +48,8 @@@ import org.apache.hyracks.algebricks.co
import org.apache.hyracks.algebricks.core.algebra.operators.logical.MaterializeOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.NestedTupleSourceOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.PartitioningSplitOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ProjectOperator;
+import org.apache.hyracks.algebricks.core.algebra.operators.logical.RangeForwardOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ReplicateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.RunningAggregateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ScriptOperator;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/FDsAndEquivClassesVisitor.java
----------------------------------------------------------------------
diff --cc hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/FDsAndEquivClassesVisitor.java
index af875f2,b259869..2bb43c9
--- a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/FDsAndEquivClassesVisitor.java
+++ b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/FDsAndEquivClassesVisitor.java
@@@ -67,9 -66,7 +66,8 @@@ import org.apache.hyracks.algebricks.co
import org.apache.hyracks.algebricks.core.algebra.operators.logical.MaterializeOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.NestedTupleSourceOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.PartitioningSplitOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ProjectOperator;
+import org.apache.hyracks.algebricks.core.algebra.operators.logical.RangeForwardOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ReplicateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.RunningAggregateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ScriptOperator;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/IsomorphismOperatorVisitor.java
----------------------------------------------------------------------
diff --cc hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/IsomorphismOperatorVisitor.java
index 737b246,7f34e8b..7c114c8
--- a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/IsomorphismOperatorVisitor.java
+++ b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/IsomorphismOperatorVisitor.java
@@@ -55,9 -55,7 +55,8 @@@ import org.apache.hyracks.algebricks.co
import org.apache.hyracks.algebricks.core.algebra.operators.logical.NestedTupleSourceOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator.IOrder;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.PartitioningSplitOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ProjectOperator;
+import org.apache.hyracks.algebricks.core.algebra.operators.logical.RangeForwardOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ReplicateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.RunningAggregateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ScriptOperator;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/IsomorphismVariableMappingVisitor.java
----------------------------------------------------------------------
diff --cc hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/IsomorphismVariableMappingVisitor.java
index 87e4f71,58b31f8..7f099cb
--- a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/IsomorphismVariableMappingVisitor.java
+++ b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/IsomorphismVariableMappingVisitor.java
@@@ -57,9 -57,7 +57,8 @@@ import org.apache.hyracks.algebricks.co
import org.apache.hyracks.algebricks.core.algebra.operators.logical.MaterializeOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.NestedTupleSourceOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.PartitioningSplitOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ProjectOperator;
+import org.apache.hyracks.algebricks.core.algebra.operators.logical.RangeForwardOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ReplicateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.RunningAggregateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ScriptOperator;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/LogicalOperatorDeepCopyWithNewVariablesVisitor.java
----------------------------------------------------------------------
diff --cc hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/LogicalOperatorDeepCopyWithNewVariablesVisitor.java
index 26f8637,f4b3195..d68f8d7
--- a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/LogicalOperatorDeepCopyWithNewVariablesVisitor.java
+++ b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/LogicalOperatorDeepCopyWithNewVariablesVisitor.java
@@@ -52,9 -52,8 +52,9 @@@ import org.apache.hyracks.algebricks.co
import org.apache.hyracks.algebricks.core.algebra.operators.logical.MaterializeOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.NestedTupleSourceOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.PartitioningSplitOperator;
+ import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator.IOrder;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ProjectOperator;
+import org.apache.hyracks.algebricks.core.algebra.operators.logical.RangeForwardOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ReplicateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.RunningAggregateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ScriptOperator;
@@@ -411,14 -402,12 +403,20 @@@ public class LogicalOperatorDeepCopyWit
}
@Override
+ public ILogicalOperator visitRangeForwardOperator(RangeForwardOperator op, ILogicalOperator arg)
+ throws AlgebricksException {
+ // TODO fix deep copy of range map
+ RangeForwardOperator opCopy = new RangeForwardOperator(op.getRangeId(), op.getRangeMap());
+ deepCopyInputsAnnotationsAndExecutionMode(op, arg, opCopy);
+ return opCopy;
+ }
+
+ public ILogicalOperator visitSplitOperator(SplitOperator op, ILogicalOperator arg) throws AlgebricksException {
+ SplitOperator opCopy = new SplitOperator(op.getOutputArity(), op.getBranchingExpression());
+ deepCopyInputsAnnotationsAndExecutionMode(op, arg, opCopy);
+ return opCopy;
+ }
+
@Override
public ILogicalOperator visitMaterializeOperator(MaterializeOperator op, ILogicalOperator arg)
throws AlgebricksException {
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/LogicalPropertiesVisitor.java
----------------------------------------------------------------------
diff --cc hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/LogicalPropertiesVisitor.java
index 58b2cd7,7e92869..f7113c0
--- a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/LogicalPropertiesVisitor.java
+++ b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/LogicalPropertiesVisitor.java
@@@ -194,12 -186,11 +195,17 @@@ public class LogicalPropertiesVisitor i
}
@Override
+ public Void visitRangeForwardOperator(RangeForwardOperator op, IOptimizationContext arg) throws AlgebricksException {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public Void visitSplitOperator(SplitOperator op, IOptimizationContext arg) throws AlgebricksException {
+ return null;
+ }
+
+ @Override
public Void visitMaterializeOperator(MaterializeOperator op, IOptimizationContext arg) throws AlgebricksException {
// TODO Auto-generated method stub
return null;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/OperatorDeepCopyVisitor.java
----------------------------------------------------------------------
diff --cc hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/OperatorDeepCopyVisitor.java
index 067a4bc,442899f..578dab0
--- a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/OperatorDeepCopyVisitor.java
+++ b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/OperatorDeepCopyVisitor.java
@@@ -53,9 -52,8 +53,9 @@@ import org.apache.hyracks.algebricks.co
import org.apache.hyracks.algebricks.core.algebra.operators.logical.MaterializeOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.NestedTupleSourceOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.PartitioningSplitOperator;
+ import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator.IOrder;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ProjectOperator;
+import org.apache.hyracks.algebricks.core.algebra.operators.logical.RangeForwardOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ReplicateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.RunningAggregateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ScriptOperator;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/PrimaryKeyVariablesVisitor.java
----------------------------------------------------------------------
diff --cc hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/PrimaryKeyVariablesVisitor.java
index f3d2990,9f1acea..ec74b4e
--- a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/PrimaryKeyVariablesVisitor.java
+++ b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/PrimaryKeyVariablesVisitor.java
@@@ -49,9 -49,7 +49,8 @@@ import org.apache.hyracks.algebricks.co
import org.apache.hyracks.algebricks.core.algebra.operators.logical.MaterializeOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.NestedTupleSourceOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.PartitioningSplitOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ProjectOperator;
+import org.apache.hyracks.algebricks.core.algebra.operators.logical.RangeForwardOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ReplicateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.RunningAggregateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ScriptOperator;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/ProducedVariableVisitor.java
----------------------------------------------------------------------
diff --cc hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/ProducedVariableVisitor.java
index 1a2c754,3645aff..a5adfa4
--- a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/ProducedVariableVisitor.java
+++ b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/ProducedVariableVisitor.java
@@@ -52,10 -53,7 +53,8 @@@ import org.apache.hyracks.algebricks.co
import org.apache.hyracks.algebricks.core.algebra.operators.logical.MaterializeOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.NestedTupleSourceOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.LeftOuterUnnestOperator;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.PartitioningSplitOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ProjectOperator;
+import org.apache.hyracks.algebricks.core.algebra.operators.logical.RangeForwardOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ReplicateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.RunningAggregateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ScriptOperator;
@@@ -256,11 -250,11 +251,16 @@@ public class ProducedVariableVisitor im
}
@Override
+ public Void visitRangeForwardOperator(RangeForwardOperator op, Void arg) throws AlgebricksException {
+ return null;
+ }
+
+ @Override
+ public Void visitSplitOperator(SplitOperator op, Void arg) throws AlgebricksException {
+ return null;
+ }
+
+ @Override
public Void visitMaterializeOperator(MaterializeOperator op, Void arg) throws AlgebricksException {
return null;
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/SchemaVariableVisitor.java
----------------------------------------------------------------------
diff --cc hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/SchemaVariableVisitor.java
index 93d878c,a746cf2..e1343d3
--- a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/SchemaVariableVisitor.java
+++ b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/SchemaVariableVisitor.java
@@@ -50,10 -51,7 +51,8 @@@ import org.apache.hyracks.algebricks.co
import org.apache.hyracks.algebricks.core.algebra.operators.logical.MaterializeOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.NestedTupleSourceOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.LeftOuterUnnestOperator;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.PartitioningSplitOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ProjectOperator;
+import org.apache.hyracks.algebricks.core.algebra.operators.logical.RangeForwardOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ReplicateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.RunningAggregateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ScriptOperator;
@@@ -289,12 -282,12 +283,18 @@@ public class SchemaVariableVisitor impl
}
@Override
+ public Void visitRangeForwardOperator(RangeForwardOperator op, Void arg) throws AlgebricksException {
+ standardLayout(op);
+ return null;
+ }
+
+ @Override
+ public Void visitSplitOperator(SplitOperator op, Void arg) throws AlgebricksException {
+ standardLayout(op);
+ return null;
+ }
+
+ @Override
public Void visitMaterializeOperator(MaterializeOperator op, Void arg) throws AlgebricksException {
standardLayout(op);
return null;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/SubstituteVariableVisitor.java
----------------------------------------------------------------------
diff --cc hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/SubstituteVariableVisitor.java
index 3623221,7345928..5d6a7b3
--- a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/SubstituteVariableVisitor.java
+++ b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/SubstituteVariableVisitor.java
@@@ -51,10 -52,7 +52,8 @@@ import org.apache.hyracks.algebricks.co
import org.apache.hyracks.algebricks.core.algebra.operators.logical.NestedTupleSourceOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator.IOrder;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.LeftOuterUnnestOperator;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.PartitioningSplitOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ProjectOperator;
+import org.apache.hyracks.algebricks.core.algebra.operators.logical.RangeForwardOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ReplicateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.RunningAggregateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ScriptOperator;
@@@ -415,12 -404,13 +415,19 @@@ public class SubstituteVariableVisito
}
@Override
+ public Void visitSplitOperator(SplitOperator op, Pair<LogicalVariable, LogicalVariable> arg)
+ throws AlgebricksException {
+ op.substituteVar(arg.first, arg.second);
+ return null;
+ }
+
+ @Override
+ public Void visitRangeForwardOperator(RangeForwardOperator op, Pair<LogicalVariable, LogicalVariable> arg)
+ throws AlgebricksException {
+ return null;
+ }
+
+ @Override
public Void visitMaterializeOperator(MaterializeOperator op, Pair<LogicalVariable, LogicalVariable> arg)
throws AlgebricksException {
return null;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/UsedVariableVisitor.java
----------------------------------------------------------------------
diff --cc hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/UsedVariableVisitor.java
index c0ca32e,3daa00f..e6a8032
--- a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/UsedVariableVisitor.java
+++ b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/visitors/UsedVariableVisitor.java
@@@ -52,9 -52,7 +52,8 @@@ import org.apache.hyracks.algebricks.co
import org.apache.hyracks.algebricks.core.algebra.operators.logical.NestedTupleSourceOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator.IOrder;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.PartitioningSplitOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ProjectOperator;
+import org.apache.hyracks.algebricks.core.algebra.operators.logical.RangeForwardOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ReplicateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.RunningAggregateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ScriptOperator;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/prettyprint/LogicalOperatorPrettyPrintVisitor.java
----------------------------------------------------------------------
diff --cc hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/prettyprint/LogicalOperatorPrettyPrintVisitor.java
index eb1780c,d3dd166..566f954
--- a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/prettyprint/LogicalOperatorPrettyPrintVisitor.java
+++ b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/prettyprint/LogicalOperatorPrettyPrintVisitor.java
@@@ -49,9 -50,7 +50,8 @@@ import org.apache.hyracks.algebricks.co
import org.apache.hyracks.algebricks.core.algebra.operators.logical.MaterializeOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.NestedTupleSourceOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.PartitioningSplitOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ProjectOperator;
+import org.apache.hyracks.algebricks.core.algebra.operators.logical.RangeForwardOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ReplicateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.RunningAggregateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ScriptOperator;
@@@ -364,8 -354,9 +355,16 @@@ public class LogicalOperatorPrettyPrint
}
@Override
+ public Void visitRangeForwardOperator(RangeForwardOperator op, Integer indent) throws AlgebricksException {
+ addIndent(indent).append("range forward ");
++ addIndent(indent).append("split " + branchingExpression.getValue().accept(exprVisitor, indent));
++ return null;
++ }
++
++ @Override
+ public Void visitSplitOperator(SplitOperator op, Integer indent) throws AlgebricksException {
+ Mutable<ILogicalExpression> branchingExpression = op.getBranchingExpression();
+ addIndent(indent).append("split " + branchingExpression.getValue().accept(exprVisitor, indent));
return null;
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/visitors/ILogicalOperatorVisitor.java
----------------------------------------------------------------------
diff --cc hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/visitors/ILogicalOperatorVisitor.java
index 0548ab3,f5ff8b4..85332ca
--- a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/visitors/ILogicalOperatorVisitor.java
+++ b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/visitors/ILogicalOperatorVisitor.java
@@@ -38,10 -39,7 +39,8 @@@ import org.apache.hyracks.algebricks.co
import org.apache.hyracks.algebricks.core.algebra.operators.logical.MaterializeOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.NestedTupleSourceOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.LeftOuterUnnestOperator;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.PartitioningSplitOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ProjectOperator;
+import org.apache.hyracks.algebricks.core.algebra.operators.logical.RangeForwardOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ReplicateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.RunningAggregateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ScriptOperator;
@@@ -83,12 -82,10 +83,12 @@@ public interface ILogicalOperatorVisito
public R visitProjectOperator(ProjectOperator op, T arg) throws AlgebricksException;
- public R visitPartitioningSplitOperator(PartitioningSplitOperator op, T arg) throws AlgebricksException;
-
public R visitReplicateOperator(ReplicateOperator op, T arg) throws AlgebricksException;
+ public R visitRangeForwardOperator(RangeForwardOperator op, T arg) throws AlgebricksException;
+
+ public R visitSplitOperator(SplitOperator op, T arg) throws AlgebricksException;
+
public R visitMaterializeOperator(MaterializeOperator op, T arg) throws AlgebricksException;
public R visitScriptOperator(ScriptOperator op, T arg) throws AlgebricksException;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/algebricks/algebricks-data/pom.xml
----------------------------------------------------------------------
diff --cc hyracks-fullstack/algebricks/algebricks-data/pom.xml
index 8502577,d95810a..b35694b
--- a/hyracks-fullstack/algebricks/algebricks-data/pom.xml
+++ b/hyracks-fullstack/algebricks/algebricks-data/pom.xml
@@@ -54,8 -54,13 +54,18 @@@
</dependency>
<dependency>
<groupId>org.apache.hyracks</groupId>
+ <artifactId>hyracks-util</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.hyracks</groupId>
+ <artifactId>hyracks-dataflow-common</artifactId>
+ <version>0.2.18-SNAPSHOT</version>
+ </dependency>
++ <dependency>
++ <groupId>org.apache.hyracks</groupId>
+ <artifactId>hyracks-api</artifactId>
+ <version>${project.version}</version>
+ </dependency>
</dependencies>
</project>
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/ReplaceNtsWithSubplanInputOperatorVisitor.java
----------------------------------------------------------------------
diff --cc hyracks-fullstack/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/ReplaceNtsWithSubplanInputOperatorVisitor.java
index ce86332,c5d7291..29e96f6
--- a/hyracks-fullstack/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/ReplaceNtsWithSubplanInputOperatorVisitor.java
+++ b/hyracks-fullstack/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/ReplaceNtsWithSubplanInputOperatorVisitor.java
@@@ -48,9 -48,7 +48,8 @@@ import org.apache.hyracks.algebricks.co
import org.apache.hyracks.algebricks.core.algebra.operators.logical.MaterializeOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.NestedTupleSourceOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.OrderOperator;
- import org.apache.hyracks.algebricks.core.algebra.operators.logical.PartitioningSplitOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ProjectOperator;
+import org.apache.hyracks.algebricks.core.algebra.operators.logical.RangeForwardOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ReplicateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.RunningAggregateOperator;
import org.apache.hyracks.algebricks.core.algebra.operators.logical.ScriptOperator;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/hyracks/hyracks-dataflow-std/pom.xml
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/9baab026/hyracks-fullstack/hyracks/hyracks-examples/hyracks-integration-tests/pom.xml
----------------------------------------------------------------------
diff --cc hyracks-fullstack/hyracks/hyracks-examples/hyracks-integration-tests/pom.xml
index 0eeddce,1a5d4ab..3692cd5
--- a/hyracks-fullstack/hyracks/hyracks-examples/hyracks-integration-tests/pom.xml
+++ b/hyracks-fullstack/hyracks/hyracks-examples/hyracks-integration-tests/pom.xml
@@@ -113,15 -91,8 +91,13 @@@
</dependency>
<dependency>
<groupId>org.apache.hyracks</groupId>
+ <artifactId>hyracks-dataflow-common</artifactId>
+ <version>0.2.18-SNAPSHOT</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.hyracks</groupId>
<artifactId>hyracks-client</artifactId>
<version>${project.version}</version>
- <type>jar</type>
- <scope>compile</scope>
</dependency>
<dependency>
<groupId>com.e-movimento.tinytools</groupId>