asterixdb-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ima...@apache.org
Subject [36/50] [abbrv] incubator-asterixdb git commit: Merge branch 'master' into hyracks-merge2
Date Thu, 07 Apr 2016 15:00:11 GMT
Merge branch 'master' into hyracks-merge2


Project: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/commit/8516517e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/tree/8516517e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/diff/8516517e

Branch: refs/heads/master
Commit: 8516517e1f678407ef8a6bea56c85314ed43c100
Parents: e1c203e 877407a
Author: Ian Maxon <imaxon@apache.org>
Authored: Wed Apr 6 18:56:39 2016 -0700
Committer: Ian Maxon <imaxon@apache.org>
Committed: Wed Apr 6 18:56:39 2016 -0700

----------------------------------------------------------------------
 .../classad-parser-new.1.ddl.aql                |  31 ++
 .../classad-parser-new.2.lib.aql                |  19 +
 .../classad-parser-new.3.ddl.aql                |  27 +
 .../classad-parser-new.4.query.aql              |  23 +
 .../classad-parser-new.5.lib.aql                |  19 +
 .../classad-parser-old.1.ddl.aql                |  31 ++
 .../classad-parser-old.2.lib.aql                |  19 +
 .../classad-parser-old.3.ddl.aql                |  25 +
 .../classad-parser-old.4.query.aql              |  23 +
 .../classad-parser-old.5.lib.aql                |  19 +
 .../invalid-format/invalid-format.1.ddl.aql     |  34 ++
 .../invalid-format/invalid-format.2.query.aql   |  27 +
 .../feeds/twitter-feed/twitter-feed.1.ddl.aql   |  54 ++
 .../twitter-feed/twitter-feed.2.update.aql      |  25 +
 .../file-not-found/file-not-found.1.ddl.aql     |  29 +
 .../file-not-found/file-not-found.2.update.aql  |  30 +
 .../temp_primary_plus_ngram_flush.1.ddl.aql     |  67 +++
 .../temp_primary_plus_ngram_flush.2.update.aql  |  46 ++
 .../temp_primary_plus_ngram_flush.3.query.aql   |  29 +
 .../global-aggregate/q01/q01.1.ddl.sqlpp        |  51 ++
 .../global-aggregate/q01/q01.2.update.sqlpp     |  30 +
 .../global-aggregate/q01/q01.3.query.sqlpp      |  23 +
 .../global-aggregate/q02/q02.1.ddl.sqlpp        |  51 ++
 .../global-aggregate/q02/q02.2.update.sqlpp     |  30 +
 .../global-aggregate/q02/q02.3.query.sqlpp      |  23 +
 .../global-aggregate/q03/q03.1.ddl.sqlpp        |  51 ++
 .../global-aggregate/q03/q03.2.update.sqlpp     |  30 +
 .../global-aggregate/q03/q03.3.query.sqlpp      |  23 +
 .../global-aggregate/q04/q04.1.ddl.sqlpp        |  51 ++
 .../global-aggregate/q04/q04.2.update.sqlpp     |  30 +
 .../global-aggregate/q04/q04.3.query.sqlpp      |  23 +
 .../q05_error/q05_error.1.ddl.sqlpp             |  51 ++
 .../q05_error/q05_error.2.update.sqlpp          |  30 +
 .../q05_error/q05_error.3.query.sqlpp           |  23 +
 .../q06_error/q06_error.1.ddl.sqlpp             |  51 ++
 .../q06_error/q06_error.2.update.sqlpp          |  30 +
 .../q06_error/q06_error.3.query.sqlpp           |  23 +
 .../q07_error/q07_error.1.ddl.sqlpp             |  51 ++
 .../q07_error/q07_error.2.update.sqlpp          |  30 +
 .../q07_error/q07_error.3.query.sqlpp           |  26 +
 .../global-aggregate/q08/q08.1.ddl.sqlpp        |  51 ++
 .../global-aggregate/q08/q08.2.update.sqlpp     |  30 +
 .../global-aggregate/q08/q08.3.query.sqlpp      |  24 +
 .../q06_forecast_revenue_change.4.query.sqlpp   |  27 +
 .../classad-parser-new/classad-parser-new.1.adm | 100 ++++
 .../classad-parser-old/classad-parser-old.1.adm |   5 +
 .../results/global-aggregate/q01/q01.1.adm      |   1 +
 .../results/global-aggregate/q02/q02.1.adm      |   1 +
 .../results/global-aggregate/q08/q08.1.adm      |  10 +
 .../temp_primary_plus_ngram_flush.3.adm         |   1 +
 .../q06_forecast_revenue_change.2.adm           |   1 +
 .../q06_forecast_revenue_change.4.ast           |  73 +++
 .../api/IStreamNotificationHandler.java         |  28 +
 .../reader/IndexingStreamRecordReader.java      | 101 ++++
 .../reader/stream/StreamRecordReader.java       |  98 ++++
 .../stream/StreamRecordReaderFactory.java       |  72 +++
 .../provider/StreamRecordReaderProvider.java    |  81 +++
 .../resources/classad-with-temporals.classads   | 134 +++++
 .../results/classad-with-temporals.adm          |   1 +
 .../dataset-with-meta-record.1.script.aql       |   1 +
 .../dataset-with-meta-record.2.ddl.aql          |  58 ++
 .../dataset-with-meta-record.3.update.aql       |  27 +
 .../dataset-with-meta-record.4.script.aql       |   1 +
 .../dataset-with-meta-record.5.query.aql        |  29 +
 .../dataset-with-meta-record.6.script.aql       |   1 +
 .../dataset-with-meta-record.5.adm              |   1 +
 .../create_and_start.sh                         |   1 +
 .../dataset-with-meta-record/stop_and_delete.sh |   3 +
 .../dataset-with-meta-record/stop_and_start.sh  |   2 +
 .../visitor/InlineColumnAliasVisitor.java       | 450 +++++++++++++++
 .../SqlppBuiltinFunctionRewriteVisitor.java     |  46 ++
 .../SqlppGlobalAggregationSugarVisitor.java     |  67 +++
 .../visitor/SqlppGroupBySugarVisitor.java       | 123 +++++
 .../rewrites/visitor/SqlppGroupByVisitor.java   | 168 ++++++
 .../visitor/SqlppInlineUdfsVisitor.java         | 237 ++++++++
 .../visitor/VariableCheckAndRewriteVisitor.java | 102 ++++
 .../lang/sqlpp/util/FunctionMapUtil.java        | 150 +++++
 .../visitor/CheckSql92AggregateVisitor.java     | 265 +++++++++
 .../lang/sqlpp/visitor/DeepCopyVisitor.java     | 415 ++++++++++++++
 .../lang/sqlpp/visitor/FreeVariableVisitor.java | 471 ++++++++++++++++
 .../AbstractSqlppExpressionScopingVisitor.java  | 284 ++++++++++
 .../AbstractSqlppSimpleExpressionVisitor.java   | 347 ++++++++++++
 .../LangExpressionToPlanTranslator.java         | 112 ++--
 .../common/AsterixHyracksIntegrationUtil.java   |  25 +-
 .../asterix/app/external/FeedOperations.java    |  34 +-
 .../apache/asterix/file/DatasetOperations.java  |  10 +-
 .../asterix/file/DataverseOperations.java       |   2 +-
 .../asterix/messaging/NCMessageBroker.java      |  19 +-
 .../asterix/test/runtime/ExecutionTest.java     |   9 +-
 .../asterix/test/runtime/ExecutionTestUtil.java |   8 +-
 .../test/runtime/SqlppExecutionTest.java        |   8 +-
 .../asterix/test/sqlpp/ParserTestExecutor.java  |   1 +
 .../queries_sqlpp/count-tweets.sqlpp            |   2 +-
 .../queries_sqlpp/denorm-cust-order.sqlpp       |   4 +-
 .../queries_sqlpp/distinct_aggregate.sqlpp      |   4 +-
 .../optimizerts/queries_sqlpp/fj-phase1.sqlpp   |   2 +-
 .../queries_sqlpp/fj-phase2-with-hints.sqlpp    |   2 +-
 .../inlined_q18_large_volume_customer.sqlpp     |   4 +-
 .../queries_sqlpp/nest_aggregate.sqlpp          |   2 +-
 .../queries_sqlpp/orders-aggreg.sqlpp           |   6 +-
 .../q01_pricing_summary_report_nt.sqlpp         |  16 +-
 .../queries_sqlpp/q03_shipping_priority.sqlpp   |   2 +-
 .../q05_local_supplier_volume.sqlpp             |   2 +-
 .../optimizerts/queries_sqlpp/q2.sqlpp          |   4 +-
 .../queries_sqlpp/query-issue562.sqlpp          |   6 +-
 .../queries_sqlpp/query-issue601.sqlpp          |   2 +-
 .../queries_sqlpp/query-issue697.sqlpp          |   2 +-
 .../queries_sqlpp/query-issue785.sqlpp          |   2 +-
 .../queries_sqlpp/query-issue810-2.sqlpp        |   2 +-
 .../queries_sqlpp/query-issue810.sqlpp          |   2 +-
 .../queries_sqlpp/query-issue827-2.sqlpp        |  16 +-
 .../split-materialization-above-join.sqlpp      |   4 +-
 .../queries_sqlpp/split-materialization.sqlpp   |   4 +-
 .../rc-format/rc-format.1.ddl.aql               |   7 +-
 .../classad-parser/classad-parser.1.ddl.aql     |  31 --
 .../classad-parser/classad-parser.2.lib.aql     |  19 -
 .../classad-parser/classad-parser.3.ddl.aql     |  27 -
 .../classad-parser/classad-parser.4.query.aql   |  23 -
 .../classad-parser/classad-parser.5.lib.aql     |  19 -
 .../classad-parser2/classad-parser2.1.ddl.aql   |  31 --
 .../classad-parser2/classad-parser2.2.lib.aql   |  19 -
 .../classad-parser2/classad-parser2.3.ddl.aql   |  25 -
 .../classad-parser2/classad-parser2.4.query.aql |  23 -
 .../classad-parser2/classad-parser2.5.lib.aql   |  19 -
 .../hdfs/large-record/large-record.1.ddl.aql    |   2 +-
 .../agg_null/agg_null.3.query.sqlpp             |   2 +-
 .../agg_null_rec/agg_null_rec.3.query.sqlpp     |  10 +-
 .../agg_null_rec_1/agg_null_rec_1.3.query.sqlpp |  10 +-
 .../agg_number/agg_number.3.query.sqlpp         |   2 +-
 .../agg_number_rec/agg_number_rec.3.query.sqlpp |  10 +-
 .../avg_double/avg_double.3.query.sqlpp         |   2 +-
 .../avg_double_null.3.query.sqlpp               |   2 +-
 .../avg_empty_01/avg_empty_01.1.ddl.sqlpp       |   2 +-
 .../avg_empty_01/avg_empty_01.2.update.sqlpp    |   2 +-
 .../avg_empty_01/avg_empty_01.3.query.sqlpp     |   4 +-
 .../avg_empty_02/avg_empty_02.1.ddl.sqlpp       |   2 +-
 .../avg_empty_02/avg_empty_02.2.update.sqlpp    |   2 +-
 .../avg_empty_02/avg_empty_02.3.query.sqlpp     |   4 +-
 .../avg_float/avg_float.3.query.sqlpp           |   2 +-
 .../avg_float_null/avg_float_nu.3.query.sqlpp   |   2 +-
 .../avg_int16/avg_int16.3.query.sqlpp           |   2 +-
 .../avg_int16_null/avg_int16_null.3.query.sqlpp |   2 +-
 .../avg_int32/avg_int32.3.query.sqlpp           |   2 +-
 .../avg_int32_null/avg_int32_null.3.query.sqlpp |   2 +-
 .../avg_int64/avg_int64.3.query.sqlpp           |   2 +-
 .../avg_int64_null/avg_int64_null.3.query.sqlpp |   2 +-
 .../avg_int8/avg_int8.3.query.sqlpp             |   2 +-
 .../avg_int8_null/avg_int8_null.3.query.sqlpp   |   2 +-
 .../avg_mixed/avg_mixed.1.ddl.sqlpp             |   2 +-
 .../avg_mixed/avg_mixed.3.query.sqlpp           |   4 +-
 .../count_01/count_01.3.query.sqlpp             |   2 +-
 .../count_empty_01/count_empty_01.1.ddl.sqlpp   |   2 +-
 .../count_empty_01.2.update.sqlpp               |   2 +-
 .../count_empty_01/count_empty_01.3.query.sqlpp |   4 +-
 .../count_empty_02/count_empty_02.1.ddl.sqlpp   |   2 +-
 .../count_empty_02.2.update.sqlpp               |   2 +-
 .../count_empty_02/count_empty_02.3.query.sqlpp |   4 +-
 .../count_null/count_null.3.query.sqlpp         |   2 +-
 .../issue395/issue395.3.query.sqlpp             |   2 +-
 .../issue412_0/issue412_0.3.query.sqlpp         |   2 +-
 .../issue412_1/issue412_1.3.query.sqlpp         |   2 +-
 .../issue425_min_hetero_list.3.query.sqlpp      |   2 +-
 .../issue425_min_hetero_list_1.3.query.sqlpp    |   2 +-
 .../issue425_sum_hetero_list.3.query.sqlpp      |   2 +-
 .../issue425_sum_hetero_list_1.3.query.sqlpp    |   2 +-
 .../issue531_string_min_max.1.ddl.sqlpp         |   4 +-
 .../issue531_string_min_max.2.update.sqlpp      |   4 +-
 .../issue531_string_min_max.3.query.sqlpp       |   8 +-
 .../max_empty_01/max_empty_01.1.ddl.sqlpp       |   2 +-
 .../max_empty_01/max_empty_01.2.update.sqlpp    |   2 +-
 .../max_empty_01/max_empty_01.3.query.sqlpp     |   4 +-
 .../max_empty_02/max_empty_02.1.ddl.sqlpp       |   2 +-
 .../max_empty_02/max_empty_02.2.update.sqlpp    |   2 +-
 .../max_empty_02/max_empty_02.3.query.sqlpp     |   4 +-
 .../min_empty_01/min_empty_01.1.ddl.sqlpp       |   2 +-
 .../min_empty_01/min_empty_01.2.update.sqlpp    |   2 +-
 .../min_empty_01/min_empty_01.3.query.sqlpp     |   4 +-
 .../min_empty_02/min_empty_02.1.ddl.sqlpp       |   2 +-
 .../min_empty_02/min_empty_02.2.update.sqlpp    |   2 +-
 .../min_empty_02/min_empty_02.3.query.sqlpp     |   4 +-
 .../min_mixed/min_mixed.1.ddl.sqlpp             |   2 +-
 .../min_mixed/min_mixed.3.query.sqlpp           |   4 +-
 .../query-issue400/query-issue400.3.query.sqlpp |   2 +-
 .../scalar_avg/scalar_avg.1.ddl.sqlpp           |   2 +-
 .../scalar_avg/scalar_avg.2.update.sqlpp        |   2 +-
 .../scalar_avg/scalar_avg.3.query.sqlpp         |  14 +-
 .../scalar_avg_empty.1.ddl.sqlpp                |   2 +-
 .../scalar_avg_empty.2.update.sqlpp             |   2 +-
 .../scalar_avg_empty.3.query.sqlpp              |   4 +-
 .../scalar_avg_null/scalar_avg_null.1.ddl.sqlpp |   2 +-
 .../scalar_avg_null.2.update.sqlpp              |   2 +-
 .../scalar_avg_null.3.query.sqlpp               |  14 +-
 .../scalar_count/scalar_count.1.ddl.sqlpp       |   2 +-
 .../scalar_count/scalar_count.2.update.sqlpp    |   2 +-
 .../scalar_count/scalar_count.3.query.sqlpp     |  16 +-
 .../scalar_count_empty.1.ddl.sqlpp              |   2 +-
 .../scalar_count_empty.2.update.sqlpp           |   2 +-
 .../scalar_count_empty.3.query.sqlpp            |   4 +-
 .../scalar_count_null.1.ddl.sqlpp               |   2 +-
 .../scalar_count_null.2.update.sqlpp            |   2 +-
 .../scalar_count_null.3.query.sqlpp             |  16 +-
 .../scalar_max/scalar_max.1.ddl.sqlpp           |   2 +-
 .../scalar_max/scalar_max.2.update.sqlpp        |   2 +-
 .../scalar_max/scalar_max.3.query.sqlpp         |  18 +-
 .../scalar_max_empty.1.ddl.sqlpp                |   2 +-
 .../scalar_max_empty.2.update.sqlpp             |   2 +-
 .../scalar_max_empty.3.query.sqlpp              |   4 +-
 .../scalar_max_null/scalar_max_null.1.ddl.sqlpp |   2 +-
 .../scalar_max_null.2.update.sqlpp              |   2 +-
 .../scalar_max_null.3.query.sqlpp               |  18 +-
 .../scalar_min/scalar_min.1.ddl.sqlpp           |   2 +-
 .../scalar_min/scalar_min.2.update.sqlpp        |   2 +-
 .../scalar_min/scalar_min.3.query.sqlpp         |  18 +-
 .../scalar_min_empty.1.ddl.sqlpp                |   2 +-
 .../scalar_min_empty.2.update.sqlpp             |   2 +-
 .../scalar_min_empty.3.query.sqlpp              |   4 +-
 .../scalar_min_null/scalar_min_null.1.ddl.sqlpp |   2 +-
 .../scalar_min_null.2.update.sqlpp              |   2 +-
 .../scalar_min_null.3.query.sqlpp               |  18 +-
 .../scalar_sum/scalar_sum.1.ddl.sqlpp           |   2 +-
 .../scalar_sum/scalar_sum.2.update.sqlpp        |   2 +-
 .../scalar_sum/scalar_sum.3.query.sqlpp         |  14 +-
 .../scalar_sum_empty.1.ddl.sqlpp                |   2 +-
 .../scalar_sum_empty.2.update.sqlpp             |   2 +-
 .../scalar_sum_empty.3.query.sqlpp              |   4 +-
 .../scalar_sum_null/scalar_sum_null.1.ddl.sqlpp |   2 +-
 .../scalar_sum_null.2.update.sqlpp              |   2 +-
 .../scalar_sum_null.3.query.sqlpp               |  14 +-
 .../sum_double/sum_double.3.query.sqlpp         |   2 +-
 .../sum_double_null.3.query.sqlpp               |   2 +-
 .../sum_empty_01/sum_empty_01.1.ddl.sqlpp       |   2 +-
 .../sum_empty_01/sum_empty_01.2.update.sqlpp    |   2 +-
 .../sum_empty_01/sum_empty_01.3.query.sqlpp     |   4 +-
 .../sum_empty_02/sum_empty_02.1.ddl.sqlpp       |   2 +-
 .../sum_empty_02/sum_empty_02.2.update.sqlpp    |   2 +-
 .../sum_empty_02/sum_empty_02.3.query.sqlpp     |   4 +-
 .../sum_float/sum_float.3.query.sqlpp           |   2 +-
 .../sum_float_null/sum_float_null.3.query.sqlpp |   2 +-
 .../sum_int16/sum_int16.3.query.sqlpp           |   2 +-
 .../sum_int16_null/sum_int16_null.3.query.sqlpp |   2 +-
 .../sum_int32/sum_int32.3.query.sqlpp           |   2 +-
 .../sum_int32_null/sum_int32_null.3.query.sqlpp |   2 +-
 .../sum_int64/sum_int64.3.query.sqlpp           |   2 +-
 .../sum_int64_null/sum_int64_null.3.query.sqlpp |   2 +-
 .../sum_int8/sum_int8.3.query.sqlpp             |   2 +-
 .../sum_int8_null/sum_int8_null.3.query.sqlpp   |   2 +-
 .../sum_mixed/sum_mixed.1.ddl.sqlpp             |   2 +-
 .../sum_mixed/sum_mixed.3.query.sqlpp           |   4 +-
 .../sum_null-with-pred.1.ddl.sqlpp              |   4 +-
 .../sum_null-with-pred.2.update.sqlpp           |   4 +-
 .../sum_null-with-pred.3.query.sqlpp            |   6 +-
 .../sum_numeric_null.1.ddl.sqlpp                |   2 +-
 .../sum_numeric_null.2.update.sqlpp             |   2 +-
 .../sum_numeric_null.3.query.sqlpp              |   4 +-
 .../aggregate/agg_null/agg_null.3.query.sqlpp   |   2 +-
 .../agg_null_rec/agg_null_rec.3.query.sqlpp     |  10 +-
 .../agg_null_rec_1/agg_null_rec_1.3.query.sqlpp |  10 +-
 .../agg_number/agg_number.3.query.sqlpp         |   2 +-
 .../agg_number_rec/agg_number_rec.3.query.sqlpp |  10 +-
 .../avg_double/avg_double.3.query.sqlpp         |   2 +-
 .../avg_double_null.3.query.sqlpp               |   2 +-
 .../avg_empty_01/avg_empty_01.3.query.sqlpp     |   2 +-
 .../avg_empty_02/avg_empty_02.3.query.sqlpp     |   2 +-
 .../aggregate/avg_float/avg_float.3.query.sqlpp |   2 +-
 .../avg_float_null/avg_float_nu.3.query.sqlpp   |   2 +-
 .../aggregate/avg_int16/avg_int16.3.query.sqlpp |   2 +-
 .../avg_int16_null/avg_int16_null.3.query.sqlpp |   2 +-
 .../aggregate/avg_int32/avg_int32.3.query.sqlpp |   2 +-
 .../avg_int32_null/avg_int32_null.3.query.sqlpp |   2 +-
 .../aggregate/avg_int64/avg_int64.3.query.sqlpp |   2 +-
 .../avg_int64_null/avg_int64_null.3.query.sqlpp |   2 +-
 .../aggregate/avg_int8/avg_int8.3.query.sqlpp   |   2 +-
 .../avg_int8_null/avg_int8_null.3.query.sqlpp   |   2 +-
 .../aggregate/avg_mixed/avg_mixed.3.query.sqlpp |   2 +-
 .../aggregate/count_01/count_01.3.query.sqlpp   |   2 +-
 .../count_empty_01/count_empty_01.3.query.sqlpp |   2 +-
 .../count_empty_02/count_empty_02.3.query.sqlpp |   2 +-
 .../count_null/count_null.3.query.sqlpp         |   2 +-
 .../aggregate/issue395/issue395.3.query.sqlpp   |   2 +-
 .../issue412_0/issue412_0.3.query.sqlpp         |   2 +-
 .../issue412_1/issue412_1.3.query.sqlpp         |   2 +-
 .../issue425_min_hetero_list.3.query.sqlpp      |   2 +-
 .../issue425_min_hetero_list_1.3.query.sqlpp    |   2 +-
 .../issue425_sum_hetero_list.3.query.sqlpp      |   2 +-
 .../issue425_sum_hetero_list_1.3.query.sqlpp    |   2 +-
 .../issue531_string_min_max.3.query.sqlpp       |   4 +-
 .../max_empty_01/max_empty_01.3.query.sqlpp     |   2 +-
 .../max_empty_02/max_empty_02.3.query.sqlpp     |   2 +-
 .../min_empty_01/min_empty_01.3.query.sqlpp     |   2 +-
 .../min_empty_02/min_empty_02.3.query.sqlpp     |   2 +-
 .../aggregate/min_mixed/min_mixed.3.query.sqlpp |   2 +-
 .../query-issue400/query-issue400.3.query.sqlpp |   2 +-
 .../scalar_avg/scalar_avg.3.query.sqlpp         |  12 +-
 .../scalar_avg_empty.3.query.sqlpp              |   2 +-
 .../scalar_avg_null.3.query.sqlpp               |  12 +-
 .../scalar_count/scalar_count.3.query.sqlpp     |  14 +-
 .../scalar_count_empty.3.query.sqlpp            |   2 +-
 .../scalar_count_null.3.query.sqlpp             |  14 +-
 .../scalar_max/scalar_max.3.query.sqlpp         |  16 +-
 .../scalar_max_empty.3.query.sqlpp              |   2 +-
 .../scalar_max_null.3.query.sqlpp               |  16 +-
 .../scalar_min/scalar_min.3.query.sqlpp         |  16 +-
 .../scalar_min_empty.3.query.sqlpp              |   2 +-
 .../scalar_min_null.3.query.sqlpp               |  16 +-
 .../scalar_sum/scalar_sum.3.query.sqlpp         |  12 +-
 .../scalar_sum_empty.3.query.sqlpp              |   2 +-
 .../scalar_sum_null.3.query.sqlpp               |  12 +-
 .../sum_double/sum_double.3.query.sqlpp         |   2 +-
 .../sum_double_null.3.query.sqlpp               |   2 +-
 .../sum_empty_01/sum_empty_01.3.query.sqlpp     |   2 +-
 .../sum_empty_02/sum_empty_02.3.query.sqlpp     |   2 +-
 .../aggregate/sum_float/sum_float.3.query.sqlpp |   2 +-
 .../sum_float_null/sum_float_null.3.query.sqlpp |   2 +-
 .../aggregate/sum_int16/sum_int16.3.query.sqlpp |   2 +-
 .../sum_int16_null/sum_int16_null.3.query.sqlpp |   2 +-
 .../aggregate/sum_int32/sum_int32.3.query.sqlpp |   2 +-
 .../sum_int32_null/sum_int32_null.3.query.sqlpp |   2 +-
 .../aggregate/sum_int64/sum_int64.3.query.sqlpp |   2 +-
 .../sum_int64_null/sum_int64_null.3.query.sqlpp |   2 +-
 .../aggregate/sum_int8/sum_int8.3.query.sqlpp   |   2 +-
 .../sum_int8_null/sum_int8_null.3.query.sqlpp   |   2 +-
 .../aggregate/sum_mixed/sum_mixed.3.query.sqlpp |   2 +-
 .../sum_null-with-pred.1.ddl.sqlpp              |   2 +-
 .../sum_null-with-pred.2.update.sqlpp           |   2 +-
 .../sum_null-with-pred.3.query.sqlpp            |   4 +-
 .../sum_numeric_null.1.ddl.sqlpp                |   2 +-
 .../sum_numeric_null.2.update.sqlpp             |   2 +-
 .../sum_numeric_null.3.query.sqlpp              |   4 +-
 .../cross-dv03/cross-dv03.3.query.sqlpp         |   2 +-
 .../custord/freq-clerk/freq-clerk.3.query.sqlpp |   2 +-
 .../custord/join_q_06/join_q_06.3.query.sqlpp   |   2 +-
 .../custord/join_q_07/join_q_07.3.query.sqlpp   |   2 +-
 .../queries_sqlpp/dapd/q2/q2.3.query.sqlpp      |   4 +-
 .../query-issue382/query-issue382.3.query.sqlpp |   2 +-
 .../rc-format/rc-format.1.ddl.sqlpp             |   8 +-
 ...pricing_summary_report_failure.3.query.sqlpp |  16 +-
 .../feeds/feeds_05/feeds_05.3.query.sqlpp       |   2 +-
 .../feeds/feeds_07/feeds_07.3.query.sqlpp       |   2 +-
 .../feeds/feeds_08/feeds_08.3.query.sqlpp       |   2 +-
 .../feeds/feeds_09/feeds_09.3.query.sqlpp       |   2 +-
 .../feeds/feeds_10/feeds_10.3.query.sqlpp       |   2 +-
 .../flwor/grpby01/grpby01.3.query.sqlpp         |   2 +-
 .../flwor/grpby02/grpby02.3.query.sqlpp         |   2 +-
 .../fuzzyjoin/dblp-1_1/dblp-1_1.3.query.sqlpp   |   2 +-
 .../dblp-2_5.3/dblp-2_5.3.3.query.sqlpp         |   2 +-
 .../group-by/core-01/core-01.3.query.sqlpp      |   2 +-
 .../group-by/core-02/core-02.3.query.sqlpp      |   2 +-
 .../group-by/core-03/core-02.3.query.sqlpp      |   2 +-
 .../group-by/core-05/core-05.3.query.sqlpp      |   2 +-
 .../group-by/sugar-01/sugar-01.3.query.sqlpp    |   2 +-
 .../group-by/sugar-02/sugar-02.3.query.sqlpp    |   2 +-
 .../group-by/sugar-03/sugar-03.3.query.sqlpp    |   2 +-
 .../group-by/sugar-05/sugar-05.3.query.sqlpp    |   2 +-
 .../hdfs/hdfs_02/hdfs_02.3.query.sqlpp          |   2 +-
 .../hdfs/hdfs_03/hdfs_03.3.query.sqlpp          |   2 +-
 .../hdfs_shortcircuit.3.query.sqlpp             |   2 +-
 .../issue_251_dataset_hint_6.3.query.sqlpp      |   2 +-
 .../list/listify_03/listify_03.3.query.sqlpp    |   4 +-
 .../issue289_query/issue289_query.3.query.sqlpp |   2 +-
 .../assign-reuse/assign-reuse.3.query.sqlpp     |   4 +-
 .../groupby-orderby-count.3.query.sqlpp         |   4 +-
 .../query-issue258.2.update.sqlpp               |   2 +-
 .../everysat_03/everysat_03.3.query.sqlpp       |   2 +-
 .../somesat_03/somesat_03.3.query.sqlpp         |   2 +-
 .../somesat_04/somesat_04.3.query.sqlpp         |   2 +-
 .../count-nullable/count-nullable.3.query.sqlpp |   2 +-
 ...ell-aggregation-with-filtering.3.query.sqlpp |   2 +-
 .../cell-aggregation.3.query.sqlpp              |   2 +-
 .../q01_pricing_summary_report_nt.3.query.sqlpp |  16 +-
 .../temporal/agg_max/agg_max.3.query.sqlpp      |  10 +-
 .../temporal/agg_min/agg_min.3.query.sqlpp      |  10 +-
 .../overlap_bins_gby_1.3.query.sqlpp            |   2 +-
 .../overlap_bins_gby_3.3.query.sqlpp            |   4 +-
 .../query-ASTERIXDB-1331.25.query.sqlpp         |   4 +-
 .../tinysocial-suite.14.query.sqlpp             |   2 +-
 .../tinysocial-suite.22.query.sqlpp             |   2 +-
 .../tinysocial-suite.14.query.sqlpp             |   2 +-
 .../tinysocial-suite.22.query.sqlpp             |   2 +-
 .../tinysocial-suite.25.query.sqlpp             |   4 +-
 .../q01_pricing_summary_report_nt.3.query.sqlpp |  14 +-
 .../q02_minimum_cost_supplier.3.query.sqlpp     |   2 +-
 .../q03_shipping_priority_nt.3.query.sqlpp      |   2 +-
 .../q04_order_priority.3.query.sqlpp            |   2 +-
 .../q05_local_supplier_volume.3.query.sqlpp     |   2 +-
 .../q06_forecast_revenue_change.3.query.sqlpp   |  10 +-
 .../q07_volume_shipping.3.query.sqlpp           |   2 +-
 .../q08_national_market_share.3.query.sqlpp     |   4 +-
 .../q09_product_type_profit_nt.3.query.sqlpp    |   2 +-
 .../q10_returned_item.3.query.sqlpp             |   2 +-
 .../q10_returned_item_int64.3.query.sqlpp       |   2 +-
 .../q11_important_stock.3.query.sqlpp           |   4 +-
 .../q12_shipping/q12_shipping.3.query.sqlpp     |   4 +-
 .../q13_customer_distribution.3.query.sqlpp     |   4 +-
 .../q14_promotion_effect.3.query.sqlpp          |   4 +-
 .../q15_top_supplier.3.query.sqlpp              |   4 +-
 ...16_parts_supplier_relationship.3.query.sqlpp |   2 +-
 .../q17_large_gby_variant.3.query.sqlpp         |  20 +-
 ...7_small_quantity_order_revenue.3.query.sqlpp |   4 +-
 .../q18_large_volume_customer.3.query.sqlpp     |   4 +-
 .../q19_discounted_revenue.3.query.sqlpp        |   2 +-
 .../q20_potential_part_promotion.3.query.sqlpp  |   2 +-
 ...pliers_who_kept_orders_waiting.3.query.sqlpp |  10 +-
 .../q22_global_sales_opportunity.3.query.sqlpp  |   4 +-
 .../query-issue601/query-issue601.3.query.sqlpp |   2 +-
 .../query-issue638/query-issue638.3.query.sqlpp |   4 +-
 .../query-issue785-2.3.query.sqlpp              |   2 +-
 .../query-issue785/query-issue785.3.query.sqlpp |   4 +-
 .../query-issue786/query-issue786.3.query.sqlpp |   2 +-
 .../q06_forecast_revenue_change.3.query.sqlpp   |   7 +-
 .../q11_important_stock.3.query.sqlpp           |   8 +-
 .../q13_customer_distribution.3.query.sqlpp     |   2 +-
 .../q15_top_supplier.3.query.sqlpp              |   7 +-
 ...7_small_quantity_order_revenue.3.query.sqlpp |   9 +-
 .../q19_discounted_revenue.3.query.sqlpp        |  13 +-
 .../q22_global_sales_opportunity.3.query.sqlpp  |   6 +-
 .../query-issue562/query-issue562.3.query.sqlpp |   2 +-
 .../query-issue810-2.3.query.sqlpp              |   2 +-
 .../query-issue810-3.3.query.sqlpp              |   4 +-
 .../query-issue810/query-issue810.3.query.sqlpp |   4 +-
 .../nest_aggregate/nest_aggregate.3.query.sqlpp |   2 +-
 .../nest_aggregate2.3.query.sqlpp               |   2 +-
 .../q01_pricing_summary_report_nt.3.query.sqlpp |  14 +-
 .../q02_minimum_cost_supplier.3.query.sqlpp     |   2 +-
 .../q03_shipping_priority_nt.3.query.sqlpp      |   2 +-
 .../q05_local_supplier_volume.3.query.sqlpp     |   2 +-
 .../q06_forecast_revenue_change.3.query.sqlpp   |   2 +-
 .../q07_volume_shipping.3.query.sqlpp           |   2 +-
 .../q08_national_market_share.3.query.sqlpp     |   4 +-
 .../q09_product_type_profit_nt.3.query.sqlpp    |   2 +-
 .../q10_returned_item.3.query.sqlpp             |   2 +-
 .../q10_returned_item_int64.3.query.sqlpp       |   2 +-
 .../q11_important_stock.3.query.sqlpp           |   4 +-
 .../q12_shipping/q12_shipping.3.query.sqlpp     |   4 +-
 .../q13_customer_distribution.3.query.sqlpp     |   4 +-
 .../q14_promotion_effect.3.query.sqlpp          |   4 +-
 .../q15_top_supplier.3.query.sqlpp              |   4 +-
 ...16_parts_supplier_relationship.3.query.sqlpp |   2 +-
 .../q17_large_gby_variant.3.query.sqlpp         |  20 +-
 ...7_small_quantity_order_revenue.3.query.sqlpp |   4 +-
 .../q18_large_volume_customer.3.query.sqlpp     |   4 +-
 .../q19_discounted_revenue.3.query.sqlpp        |   2 +-
 .../q20_potential_part_promotion.3.query.sqlpp  |   2 +-
 ...pliers_who_kept_orders_waiting.3.query.sqlpp |   8 +-
 .../q22_global_sales_opportunity.3.query.sqlpp  |   4 +-
 .../query-issue562/query-issue562.3.query.sqlpp |   6 +-
 .../query-issue785-2.3.query.sqlpp              |   2 +-
 .../query-issue785/query-issue785.3.query.sqlpp |   4 +-
 .../query-issue786/query-issue786.3.query.sqlpp |   2 +-
 .../query-issue810-2.3.query.sqlpp              |   2 +-
 .../query-issue810-3.3.query.sqlpp              |   2 +-
 .../query-issue810/query-issue810.3.query.sqlpp |   2 +-
 .../query-issue827-2.3.query.sqlpp              |  16 +-
 .../query-issue827/query-issue827.3.query.sqlpp |   4 +-
 .../nest_aggregate/nest_aggregate.3.query.sqlpp |   2 +-
 .../nest_aggregate2.3.query.sqlpp               |   2 +-
 .../q01_pricing_summary_report_nt.3.query.sqlpp |  16 +-
 .../q02_minimum_cost_supplier.3.query.sqlpp     |   2 +-
 .../q03_shipping_priority_nt.3.query.sqlpp      |   2 +-
 .../q05_local_supplier_volume.3.query.sqlpp     |   2 +-
 .../q06_forecast_revenue_change.3.query.sqlpp   |   2 +-
 .../q07_volume_shipping.3.query.sqlpp           |   2 +-
 .../q08_national_market_share.3.query.sqlpp     |   4 +-
 .../q09_product_type_profit_nt.3.query.sqlpp    |   2 +-
 .../q10_returned_item.3.query.sqlpp             |   2 +-
 .../q10_returned_item_int64.3.query.sqlpp       |   2 +-
 .../q11_important_stock.3.query.sqlpp           |   4 +-
 .../q12_shipping/q12_shipping.3.query.sqlpp     |   4 +-
 .../q13_customer_distribution.3.query.sqlpp     |   4 +-
 .../q14_promotion_effect.3.query.sqlpp          |   6 +-
 .../q15_top_supplier.3.query.sqlpp              |   4 +-
 ...16_parts_supplier_relationship.3.query.sqlpp |   6 +-
 .../q17_large_gby_variant.3.query.sqlpp         |  20 +-
 ...7_small_quantity_order_revenue.3.query.sqlpp |   4 +-
 .../q18_large_volume_customer.3.query.sqlpp     |   4 +-
 .../q19_discounted_revenue.3.query.sqlpp        |   2 +-
 .../q20_potential_part_promotion.3.query.sqlpp  |   2 +-
 ...pliers_who_kept_orders_waiting.3.query.sqlpp |   8 +-
 .../q22_global_sales_opportunity.3.query.sqlpp  |   6 +-
 .../query-issue562/query-issue562.3.query.sqlpp |   6 +-
 .../query-issue638/query-issue638.3.query.sqlpp |   2 +-
 .../query-issue785-2.3.query.sqlpp              |   2 +-
 .../query-issue785/query-issue785.3.query.sqlpp |   4 +-
 .../query-issue786/query-issue786.3.query.sqlpp |   2 +-
 .../query-issue810-2.3.query.sqlpp              |   2 +-
 .../query-issue810-3.3.query.sqlpp              |   2 +-
 .../query-issue810/query-issue810.3.query.sqlpp |   2 +-
 .../query-issue827-2.3.query.sqlpp              |  16 +-
 .../query-issue827/query-issue827.3.query.sqlpp |   4 +-
 .../query-issue489/query-issue489.2.query.sqlpp |   2 +-
 .../query-issue489/query-issue489.4.query.sqlpp |   2 +-
 .../classad-parser/classad-parser.1.adm         | 100 ----
 .../classad-parser2/classad-parser2.1.adm       |   5 -
 .../feed-with-external-parser.1.adm             | 198 +++----
 .../q06_forecast_revenue_change.3.ast           | 148 ++---
 .../src/test/resources/runtimets/testsuite.xml  | 101 ++--
 .../resources/runtimets/testsuite_sqlpp.xml     |  49 +-
 .../common/context/DatasetLifecycleManager.java |  21 +-
 .../context/PrimaryIndexOperationTracker.java   |  26 +-
 .../asterix/common/utils/StoragePathUtil.java   |   2 +-
 .../apache/asterix/test/aql/TestExecutor.java   | 542 ++++++++++---------
 .../org/apache/asterix/test/aql/TestHelper.java |  34 --
 asterixdb/asterix-external-data/pom.xml         |   4 +-
 .../adapter/factory/GenericAdapterFactory.java  |  29 +-
 .../external/api/AsterixInputStream.java        |   8 +-
 .../asterix/external/api/IRecordReader.java     |   9 +-
 .../dataflow/ChangeFeedDataFlowController.java  |   4 +-
 .../ChangeFeedWithMetaDataFlowController.java   |   4 +-
 .../dataflow/FeedRecordDataFlowController.java  |   5 +-
 .../FeedWithMetaDataFlowController.java         |   3 +-
 .../external/input/HDFSDataSourceFactory.java   |  46 +-
 .../stream/AbstractStreamRecordReader.java      | 116 ----
 .../AbstractStreamRecordReaderFactory.java      |  95 ----
 .../stream/EmptyLineSeparatedRecordReader.java  |   7 +-
 .../EmptyLineSeparatedRecordReaderFactory.java  |  43 --
 .../record/reader/stream/LineRecordReader.java  | 147 ++---
 .../reader/stream/LineRecordReaderFactory.java  |  52 --
 .../reader/stream/QuotedLineRecordReader.java   | 134 ++---
 .../stream/SemiStructuredRecordReader.java      |  16 +-
 .../SemiStructuredRecordReaderFactory.java      |  51 --
 .../twitter/TwitterRecordReaderFactory.java     |  19 +-
 .../input/stream/AsterixInputStreamReader.java  |   3 +-
 .../external/input/stream/HDFSInputStream.java  |   9 +-
 .../input/stream/LocalFSInputStream.java        |  54 +-
 .../factory/LocalFSInputStreamFactory.java      |  42 +-
 .../provider/DataflowControllerProvider.java    |   9 +-
 .../provider/DatasourceFactoryProvider.java     |  74 +--
 .../provider/ParserFactoryProvider.java         |   2 +-
 .../external/util/ExternalDataConstants.java    |  10 +-
 .../external/util/ExternalDataUtils.java        |  20 +-
 .../asterix/external/util/FeedLogManager.java   |  34 +-
 .../apache/asterix/external/util/FeedUtils.java |  32 +-
 .../external/util/FileSystemWatcher.java        | 185 ++++---
 .../external/util/LocalFileSystemUtils.java     |  15 +-
 .../external/classad/test/ClassAdToADMTest.java |  97 +++-
 .../asterix/external/library/ClassAdParser.java |  74 ++-
 .../adapter/TestTypedAdapterFactory.java        |   8 +-
 .../parser/test/RecordWithMetaTest.java         |  15 +-
 .../record-parser/record-parser.1.adm           | 200 +++----
 .../external_index/external_index.2.ddl.aql     |   6 +-
 .../test/resources/transactionts/testsuite.xml  |   6 +-
 asterixdb/asterix-lang-common/pom.xml           |   4 +-
 .../lang/common/clause/GroupbyClause.java       |  12 +
 .../asterix/lang/common/clause/LimitClause.java |   4 +
 .../lang/common/expression/CallExpr.java        |   6 +-
 .../lang/common/expression/OperatorExpr.java    |  39 +-
 .../asterix/lang/common/statement/Query.java    |  12 +
 .../CloneAndSubstituteVariablesVisitor.java     |   8 +-
 .../asterix/lang/sqlpp/clause/SelectBlock.java  |   4 +
 .../rewrites/SqlppFunctionBodyRewriter.java     |   3 +
 .../lang/sqlpp/rewrites/SqlppQueryRewriter.java |  41 +-
 .../lang/sqlpp/util/SqlppRewriteUtil.java       |  19 +-
 .../lang/sqlpp/util/SqlppVariableUtil.java      |  84 +++
 .../sqlpp/visitor/InlineColumnAliasVisitor.java | 447 ---------------
 .../sqlpp/visitor/SqlppAstPrintVisitor.java     |  24 +
 .../visitor/SqlppDeleteRewriteVisitor.java      |   2 +-
 .../sqlpp/visitor/SqlppGroupBySugarVisitor.java | 127 -----
 .../lang/sqlpp/visitor/SqlppGroupByVisitor.java | 170 ------
 .../sqlpp/visitor/SqlppInlineUdfsVisitor.java   | 236 --------
 .../SqlppSubstituteVariablesVisitor.java        |   7 +-
 .../lang/sqlpp/visitor/UsedVariableVisitor.java | 362 -------------
 .../visitor/VariableCheckAndRewriteVisitor.java | 505 -----------------
 .../metadata/declared/AqlMetadataProvider.java  |  21 +-
 .../asterix/metadata/utils/DatasetUtils.java    |  17 +-
 .../asterix/om/util/AsterixRuntimeUtil.java     |   6 +-
 .../storage/LSMIndexFileProperties.java         |   2 +-
 asterixdb/asterix-runtime/pom.xml               |  10 -
 .../PersistentLocalResourceRepository.java      |  33 +-
 567 files changed, 7914 insertions(+), 4599 deletions(-)
----------------------------------------------------------------------



Mime
View raw message