You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by im...@apache.org on 2016/04/07 17:00:11 UTC
[36/50] [abbrv] incubator-asterixdb git commit: Merge branch 'master'
into hyracks-merge2
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 <im...@apache.org>
Authored: Wed Apr 6 18:56:39 2016 -0700
Committer: Ian Maxon <im...@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(-)
----------------------------------------------------------------------