This is an automated email from the ASF dual-hosted git repository.
mhubail pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/asterixdb.git
from 4741bc8b07 [NO ISSUE][*DB][STO] Support a no-op cloud storage scheme
(none)
new 63367364d1 [NO ISSUE][EXT]: Properly check if prefix is empty
new e60a6f09cc [NO ISSUE][HYR][STO] Introduce new modification op type to
disregard cache budget
new 12527d7d17 [NO ISSUE][HYR] Keep trying to cancel job tasks
new a4033e11b2 [NO ISSUE][*DB][CLOUD] Ensure interrupts are not lost
during GCS ops
new cd2ae755a9 [NO ISSUE][HYR] Retry cancelling tasks only after the
timeout
new b3db1a31f0 [NO ISSUE][HYR][MISC] Generalize timed interruptible
actions with Span
new 6a369d1395 [NO ISSUE][*DB][CLOUD] Cancel running GCS ops on interrupt
new 04de27152c [ASTERIXDB-3570][RT] Re-interrupt running threads on tasks
cancelation
new ce4d655623 [NO ISSUE][HYR][RT] Log pre-cancel thread stack on stuck
canceled tasks, some interrupt fixes
new 59ace80151 [ASTERIXDB-3572][COMP] Use hash-join when condition
contains equi predicate
new b38d2366d0 [ASTERIXDB-3563][STO] Delay activation of dataset until
accessed
new 17016ef608 [NO ISSUE][RT] Fixing LogMarkerTest
new 714fffa33e [NO ISSUE][EXT]: Correctly pass session token property for
hadoop
new a08dd5bfce [ASTERIXDB-3573][COMP] Do not pull predicates out of join
condition
new 9180ebe8b0 [ASTERIXDB-3578][EXT] Error with query on delta table with
IN predicate
new 00740fac49 NO ISSUE: Move IEvaluatorContext from algebricks to hyracks
new 3cc0323ce0 [ASTERIXDB-3509][EXT]: Raise warning for COPY TO CSV schema
mismatch
new 16ac1d8c0b [ASTERIXDB-3562][COMP] Align subplan variable propagation
with runtime output
new c44734e755 [ASTERIXDB-3562][COMP] Do not place array slice in a subplan
new 44f71b5584 Merge branch 'gerrit/neo' into 'gerrit/trinity'
new 0cde515801 [ASTERIXDB-3569][TEST] Reorganize and clean tests
new 8d21764a45 Merge branch 'trinity' into ionic
new 3c6b5dcd31 [ASTERIXDB-3580][COMP] Change collection delivered
partitioning property
new c42cd2602c [ASTERIXDB-3576][EXT] push predicates down to delta tables
to filter row groups
new 2667a63b72 [ASTERIXDB-3574][STO] Taking resource-level lock instead of
global lock
new 68765070a7 [ASTERIXDB-3580][COMP] minor refactoring
new 8c5e5efba4 [ASTERIXDB-3537][COMP] Support truncate Dataset Statements
new 6e83abc61c [ASTERIXDB-3564][STO]: Avoid halts on IO operation failures
new 73ed52c7bc [ASTERIXDB-3537][COMP] Follow-up patch to support truncate
new 6447488423 [ASTERIXDB-3581][EXT]: Do not retry GCS SDK requests if
thread is interrupted
new f9bbcf6a96 [ASTERIXDB-3582][COMP] Restricting to one unnest filter
pushdown for a datasource
new 571353167b [ASTERIXDB-3582][COMP] Fix Concurrent Modification in
Filter Pushdown
new 32627a4751 [ASTERIXDB-3582][COMP] Fix expected schema tree generation
new a92a3492a8 Merge branch 'ionic' into 'master'
The 34 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
asterixdb/asterix-active/pom.xml | 11 +
asterixdb/asterix-algebra/pom.xml | 7 +
.../operators/physical/SpatialJoinPOperator.java | 16 +-
.../asterix/optimizer/base/RuleCollections.java | 2 -
.../processor/AbstractFilterPushdownProcessor.java | 21 +-
.../processor/ColumnFilterPushdownProcessor.java | 24 +-
.../schema/AbstractComplexExpectedSchemaNode.java | 4 +
.../pushdown/schema/ArrayExpectedSchemaNode.java | 6 +
.../pushdown/schema/ExpectedSchemaBuilder.java | 37 +
.../pushdown/schema/ObjectExpectedSchemaNode.java | 13 +-
.../pushdown/schema/RootExpectedSchemaNode.java | 4 +
.../pushdown/schema/UnionExpectedSchemaNode.java | 10 +
.../pushdown/visitor/ArrayPathCheckerVisitor.java | 14 +-
.../rules/visitor/ConstantFoldingVisitor.java | 2 +-
.../translator/LangExpressionToPlanTranslator.java | 1 +
asterixdb/asterix-app/pom.xml | 73 +-
.../apache/asterix/app/nc/NCAppRuntimeContext.java | 9 +-
.../org/apache/asterix/app/nc/RecoveryManager.java | 18 +-
.../asterix/app/translator/QueryTranslator.java | 80 +-
.../asterix/hyracks/bootstrap/NCApplication.java | 2 +-
.../apache/asterix/runtime/CastTypeLaxTest.java | 2 +-
.../asterix/test/dataflow/LogMarkerTest.java | 2 -
.../test/runtime/NullMissingExceptionTest.java | 2 +-
.../asterix/test/runtime/NullMissingTest.java | 2 +-
.../optimizerts/queries/ASTERIXDB-3580.sqlpp | 11 +-
...ASTERIXDB-3572-1-equi-non-equi-condition.sqlpp} | 21 +-
...ASTERIXDB-3572-2-equi-non-equi-condition.sqlpp} | 20 +-
...above_eq_join.sqlpp => keep_pred_in_join.sqlpp} | 0
.../queries/query-ASTERIXDB-3562.sqlpp} | 23 +-
...above_eq_join.sqlpp => keep_pred_in_join.sqlpp} | 0
.../optimizerts/results/ASTERIXDB-2402.plan | 14 +-
.../optimizerts/results/ASTERIXDB-3580.plan | 67 +
.../resources/optimizerts/results/ch2/ch2_q17.plan | 182 +-
.../resources/optimizerts/results/ch2/ch2_q19.plan | 82 +-
.../resources/optimizerts/results/ch2/ch2_q21.plan | 6 +-
.../resources/optimizerts/results/collocated.plan | 4 +-
.../optimizerts/results/common-expr-01.plan | 2 +-
.../optimizerts/results/denorm-cust-order.plan | 2 +-
.../results/disjunction-to-join-delete-3.plan | 2 +-
.../broadcast_join_hint/broadcast_join_hint_4.plan | 2 +-
.../broadcast_join_hint/broadcast_join_hint_5.plan | 2 +-
.../broadcast_join_hint/broadcast_join_hint_6.plan | 2 +-
.../broadcast_join_hint/broadcast_join_hint_7.plan | 2 +-
.../hints/hashjoin_hint/hashjoin_hint_1.plan | 2 +-
.../hints/hashjoin_hint/hashjoin_hint_2.plan | 2 +-
.../hints/hashjoin_hint/hashjoin_hint_3.plan | 2 +-
.../hints/hashjoin_hint/hashjoin_hint_4.plan | 2 +-
.../hints/hashjoin_hint/hashjoin_hint_5.plan | 2 +-
.../hints/hashjoin_hint/hashjoin_hint_6.plan | 2 +-
.../ngram-jaccard-inline.plan | 2 +-
.../word-jaccard-inline.plan | 2 +-
.../results/inverted-index-join/issue741.plan | 2 +-
...-pidx-with-join-edit-distance-check-idx_01.plan | 2 +-
...dx-with-join-edit-distance-check-idx_01_ps.plan | 4 +-
...-probe-pidx-with-join-jaccard-check-idx_01.plan | 2 +-
...obe-pidx-with-join-jaccard-check-idx_01_ps.plan | 4 +-
.../ngram-edit-distance-check_02.plan | 2 +-
.../ngram-edit-distance-check_03.plan | 2 +-
.../ngram-edit-distance-check_04.plan | 2 +-
.../ngram-edit-distance_02.plan | 2 +-
.../ngram-edit-distance_03.plan | 2 +-
.../ngram-edit-distance_04.plan | 2 +-
.../ngram-fuzzyeq-edit-distance_01.plan | 2 +-
.../ngram-fuzzyeq-edit-distance_03.plan | 2 +-
.../ngram-fuzzyeq-jaccard_02.plan | 2 +-
.../ngram-fuzzyeq-jaccard_03.plan | 2 +-
.../ngram-jaccard-check_02.plan | 2 +-
.../ngram-jaccard-check_03.plan | 2 +-
.../ngram-jaccard-check_04.plan | 2 +-
.../inverted-index-join/ngram-jaccard_02.plan | 2 +-
.../inverted-index-join/ngram-jaccard_03.plan | 2 +-
.../inverted-index-join/ngram-jaccard_04.plan | 2 +-
.../olist-edit-distance-check_02.plan | 2 +-
.../olist-edit-distance-check_03.plan | 2 +-
.../olist-edit-distance-check_04.plan | 2 +-
.../olist-edit-distance_02.plan | 2 +-
.../olist-edit-distance_03.plan | 2 +-
.../olist-edit-distance_04.plan | 2 +-
.../olist-fuzzyeq-edit-distance_02.plan | 2 +-
.../olist-fuzzyeq-edit-distance_03.plan | 2 +-
.../olist-fuzzyeq-jaccard_02.plan | 2 +-
.../olist-fuzzyeq-jaccard_03.plan | 2 +-
.../olist-jaccard-check_02.plan | 2 +-
.../olist-jaccard-check_03.plan | 2 +-
.../olist-jaccard-check_04.plan | 2 +-
.../inverted-index-join/olist-jaccard_02.plan | 2 +-
.../inverted-index-join/olist-jaccard_03.plan | 2 +-
.../inverted-index-join/olist-jaccard_04.plan | 2 +-
.../ulist-fuzzyeq-jaccard_02.plan | 2 +-
.../ulist-fuzzyeq-jaccard_03.plan | 2 +-
.../ulist-jaccard-check_02.plan | 2 +-
.../ulist-jaccard-check_03.plan | 2 +-
.../ulist-jaccard-check_04.plan | 2 +-
.../inverted-index-join/ulist-jaccard_02.plan | 2 +-
.../inverted-index-join/ulist-jaccard_03.plan | 2 +-
.../inverted-index-join/ulist-jaccard_04.plan | 2 +-
.../word-fuzzyeq-jaccard_02.plan | 2 +-
.../word-fuzzyeq-jaccard_03.plan | 2 +-
.../word-jaccard-check-after-btree-access.plan | 2 +-
.../inverted-index-join/word-jaccard-check_02.plan | 2 +-
.../inverted-index-join/word-jaccard-check_03.plan | 2 +-
.../inverted-index-join/word-jaccard-check_04.plan | 2 +-
.../inverted-index-join/word-jaccard_02.plan | 2 +-
.../inverted-index-join/word-jaccard_03.plan | 2 +-
.../inverted-index-join/word-jaccard_04.plan | 2 +-
.../optimizerts/results/join-super-key_01.plan | 4 +-
.../optimizerts/results/join-super-key_02.plan | 4 +-
.../ASTERIXDB-3572-1-equi-non-equi-condition.plan | 46 +
.../ASTERIXDB-3572-2-equi-non-equi-condition.plan | 40 +
.../results/joins/inner_right_corr.plan | 4 +-
.../results/joins/nested_query_with_bcast.plan | 2 +-
.../{collocated.plan => keep_pred_in_join.plan} | 22 +-
.../leftouterjoin/query-ASTERIXDB-2857.plan | 4 +-
.../optimizerts/results/loj-super-key_01.plan | 4 +-
.../optimizerts/results/loj-super-key_02.plan | 6 +-
.../meta/indexes_on_dataset_with_meta_05.plan | 2 +-
.../meta/indexes_on_dataset_with_meta_06.plan | 6 +-
.../meta/indexes_on_dataset_with_meta_11.plan | 6 +-
.../btree-index-join/ASTERIXDB-2199.plan | 4 +-
...dx-with-join-edit-distance-check-idx_01_ps.plan | 4 +-
...obe-pidx-with-join-jaccard-check-idx_01_ps.plan | 4 +-
...dx-with-join-edit-distance-check-idx_01_ps.plan | 4 +-
.../resources/optimizerts/results/nested_loj2.plan | 2 +-
...dx-with-join-edit-distance-check-idx_01_ps.plan | 4 +-
.../delete-primary-key-index-with-secondary.plan | 2 +-
.../results/pull_select_above_eq_join.plan | 38 -
.../optimizerts/results/q08_group_by.plan | 6 +-
.../optimizerts/results/q09_group_by.plan | 6 +-
.../optimizerts/results/query-ASTERIXDB-159-3.plan | 50 +-
.../optimizerts/results/query-ASTERIXDB-2408.plan | 2 +-
.../results/query-ASTERIXDB-2408_ps.plan | 4 +-
.../optimizerts/results/query-ASTERIXDB-3562.plan | 18 +
.../optimizerts/results/query-issue562_ps.plan | 4 +-
.../optimizerts/results/query_issue3316.plan | 8 +-
.../optimizerts/results/query_issue849-2.plan | 2 +-
.../optimizerts/results/query_issue849.plan | 2 +-
.../results/rightouterjoin/roj-01-core.1.plan | 4 +-
.../results/rightouterjoin/roj-01-core.2.plan | 6 +-
.../resources/optimizerts/results/subquery/in.plan | 2 +-
.../results/subquery/in_correlated.plan | 2 +-
.../results/subquery/in_correlated_ps.plan | 4 +-
.../optimizerts/results/subquery/in_let_8.plan | 2 +-
.../optimizerts/results/subquery/in_ps.plan | 4 +-
.../results/subquery/query-ASTERIXDB-2815-2.plan | 2 +-
.../results/subquery/query-ASTERIXDB-2815-3.plan | 2 +-
.../results/subquery/query-ASTERIXDB-2815.plan | 2 +-
.../results/subquery/query-ASTERIXDB-2845.plan | 4 +-
.../interval_ended_by.3.query.plan | 66 +-
.../interval_ends/interval_ends.3.query.plan | 66 +-
.../interval_started_by.3.query.plan | 66 +-
.../interval_starts/interval_starts.3.query.plan | 66 +-
.../results/tpcds/query-ASTERIXDB-1580.plan | 6 +-
.../tpcds/query-ASTERIXDB-1581-correlated-2.plan | 80 +-
.../tpcds/query-ASTERIXDB-1581-correlated.plan | 32 +-
.../results/tpcds/query-ASTERIXDB-1591.plan | 8 +-
.../results/tpcds/query-ASTERIXDB-1596.plan | 6 +-
.../results/tpcds/query-ASTERIXDB-1596_ps.plan | 12 +-
.../optimizerts/results/tpch/q12_shipping.plan | 2 +-
.../optimizerts/results/tpch/q12_shipping_ps.plan | 4 +-
.../optimizerts/results_cbo/ASTERIXDB-2402.plan | 14 +-
.../optimizerts/results_cbo/ASTERIXDB-3580.plan | 67 +
.../optimizerts/results_cbo/ch2/ch2_q16.plan | 116 +-
.../optimizerts/results_cbo/ch2/ch2_q21.plan | 6 +-
.../optimizerts/results_cbo/ch2/ch2_q7.plan | 282 ++-
.../results_cbo/joins/inner_right_corr.plan | 4 +-
.../leftouterjoin/query-ASTERIXDB-2857.plan | 4 +-
.../btree-index-join/ASTERIXDB-2199.plan | 4 +-
.../optimizerts/results_cbo/nested_loj2.plan | 80 +-
.../optimizerts/results_cbo/q08_group_by.plan | 2 +-
.../optimizerts/results_cbo/q09_group_by.plan | 4 +-
.../optimizerts/results_cbo/query_issue3316.plan | 8 +-
.../optimizerts/results_cbo/query_issue849-2.plan | 2 +-
.../optimizerts/results_cbo/query_issue849.plan | 2 +-
.../results_cbo/tpcds/query-ASTERIXDB-1580.plan | 2 +-
.../results_cbo/tpcds/query-ASTERIXDB-1591.plan | 282 +--
.../results_cbo/tpcds/query-ASTERIXDB-1596.plan | 6 +-
.../results_cbo/tpcds/query-ASTERIXDB-1596_ps.plan | 12 +-
.../optimizerts/results_cbo/tpch/q12_shipping.plan | 2 +-
.../results_cbo/tpch/q12_shipping_ps.plan | 4 +-
...ect_above_eq_join.ast => keep_pred_in_join.ast} | 0
.../ASTERIXDB-3582-2.001.ddl.sqlpp} | 26 +-
.../ASTERIXDB-3582-2.002.update.sqlpp | 413 ++++
.../ASTERIXDB-3582-2.003.query.sqlpp | 11 +-
.../ASTERIXDB-3582-2.004.query.sqlpp} | 8 +-
.../ASTERIXDB-3582-2.005.query.sqlpp} | 9 +-
.../ASTERIXDB-3582-2.006.query.sqlpp | 12 +-
.../ASTERIXDB-3582-2.007.query.sqlpp} | 20 +-
.../ASTERIXDB-3582/ASTERIXDB-3582.001.ddl.sqlpp} | 38 +-
.../ASTERIXDB-3582/ASTERIXDB-3582.002.query.sqlpp} | 7 +-
.../test.000.update.sqlpp} | 21 +-
.../test.001.update.sqlpp} | 21 +-
.../test.002.update.sqlpp} | 21 +-
.../type-mismatch/type-mismatch.02.update.sqlpp | 15 +-
...deltalake-partitioned-file-read.02.query.sqlpp} | 6 +-
...deltalake-partitioned-file-read.03.query.sqlpp} | 6 +-
...deltalake-partitioned-file-read.04.query.sqlpp} | 6 +-
.../deltalake-partitioned-file-read.05.query.sqlpp | 9 +-
.../deltalake-partitioned-file-read.06.query.sqlpp | 9 +-
.../deltalake-partitioned-file-read.07.query.sqlpp | 9 +-
.../deltalake-partitioned-file-read.08.query.sqlpp | 10 +-
...deltalake-partitioned-file-read.09.query.sqlpp} | 8 +-
...RIXDB-3572-equi-non-equi-condition.01.ddl.sqlpp | 11 +-
...B-3572-equi-non-equi-condition.02.update.sqlpp} | 23 +-
...DB-3572-equi-non-equi-condition.03.query.sqlpp} | 23 +-
...DB-3572-equi-non-equi-condition.04.query.sqlpp} | 23 +-
.../subquery/not_in/not_in.1.ddl.sqlpp | 3 +
.../subquery/not_in/not_in.2.update.sqlpp | 7 +-
...{not_in.2.update.sqlpp => not_in.4.query.sqlpp} | 11 +-
.../join-queries/join-queries.3.plan | 2 +-
.../join-queries/join-queries.4.plan | 2 +-
.../join-queries/join-queries.5.plan | 4 +-
.../join-queries/join-queries.6.plan | 4 +-
.../join-queries/join-queries.7.plan | 4 +-
.../join-queries/join-queries.8.plan | 8 +-
.../filter/ASTERIXDB-3582-2/ASTERIXDB-3582.003.adm | 1 +
.../filter/ASTERIXDB-3582-2/ASTERIXDB-3582.004.adm | 1 +
.../ASTERIXDB-3582-2/ASTERIXDB-3582.005.plan | 26 +
.../filter/ASTERIXDB-3582-2/ASTERIXDB-3582.006.adm | 1 +
.../ASTERIXDB-3582-2/ASTERIXDB-3582.007.plan | 54 +
.../filter/ASTERIXDB-3582/ASTERIXDB-3582.002.plan | 133 ++
.../filter/not-in_every/not-in_every.201.plan | 2 +-
.../field-access-pushdown.006.plan | 4 +-
.../field-access-pushdown.008.plan | 4 +-
.../other-pushdowns/other-pushdowns.004.plan | 4 +-
.../other-pushdowns/other-pushdowns.018.plan | 2 +-
.../{read-data.2.adm => read-data.1.adm} | 0
.../read-data.2.adm | 5 +-
.../{read-data.2.adm => read-data.3.adm} | 4 +-
.../{read-data.2.adm => read-data.4.adm} | 6 +-
.../read-data.5.adm | 2 +
.../read-data.6.adm | 13 +
.../read-data.7.adm | 2 +
.../read-data.8.adm | 6 +
.../{read-data.2.adm => read-data.9.adm} | 0
.../avro/one-field/one-field.231.plan | 62 +-
.../dynamic-prefixes/one-field/one-field.231.plan | 62 +-
.../ASTERIXDB-3572-equi-non-equi-condition.03.adm | 3 +
.../ASTERIXDB-3572-equi-non-equi-condition.04.adm | 2 +
.../hash-join-with-redundant-variable.04.plan | 2 +-
.../hash-join-with-redundant-variable.06.plan | 4 +-
.../hash-join-with-redundant-variable.08.plan | 4 +-
.../hash-join-with-redundant-variable.14.plan | 4 +-
.../query-ASTERIXDB-3562.4.plan | 44 +-
.../runtimets/results/subquery/not_in/not_in.2.adm | 1 +
.../results/tpch/query-plans/query-plans.04.plan | 16 +-
.../results/tpch/query-plans/query-plans.05.plan | 2 +-
.../results/tpch/query-plans/query-plans.06.plan | 2 +-
.../results/tpch/query-plans/query-plans.07.plan | 10 +-
.../results/tpch/query-plans/query-plans.08.plan | 252 ++-
.../results/tpch/query-plans/query-plans.09.plan | 14 +-
.../results/tpch/query-plans/query-plans.10.plan | 10 +-
.../results/tpch/query-plans/query-plans.11.plan | 4 +-
.../join-queries/join-queries.8.plan | 4 +-
.../ASTERIXDB-3582-2/ASTERIXDB-3582.005.plan | 26 +
.../ASTERIXDB-3582-2/ASTERIXDB-3582.007.plan | 54 +
.../filter/ASTERIXDB-3582/ASTERIXDB-3582.002.plan | 133 ++
.../filter/not-in_every/not-in_every.201.plan | 2 +-
.../field-access-pushdown.006.plan | 4 +-
.../field-access-pushdown.008.plan | 4 +-
.../other-pushdowns/other-pushdowns.004.plan | 4 +-
.../other-pushdowns/other-pushdowns.018.plan | 2 +-
.../hash-join-with-redundant-variable.06.plan | 4 +-
.../hash-join-with-redundant-variable.08.plan | 4 +-
.../query-ASTERIXDB-3562.4.plan | 44 +-
.../tpch/query-plans/query-plans.04.plan | 8 +-
.../tpch/query-plans/query-plans.06.plan | 2 +-
.../tpch/query-plans/query-plans.08.plan | 4 +-
.../tpch/query-plans/query-plans.10.plan | 2 +-
.../join-queries/join-queries.3.plan | 2 +-
.../join-queries/join-queries.4.plan | 2 +-
.../join-queries/join-queries.5.plan | 4 +-
.../join-queries/join-queries.6.plan | 4 +-
.../join-queries/join-queries.7.plan | 4 +-
.../join-queries/join-queries.8.plan | 8 +-
.../hash-join-with-redundant-variable.04.plan | 2 +-
.../hash-join-with-redundant-variable.06.plan | 4 +-
.../hash-join-with-redundant-variable.08.plan | 4 +-
.../hash-join-with-redundant-variable.14.plan | 4 +-
.../query-ASTERIXDB-3562.4.plan | 44 +-
.../tpch/query-plans/query-plans.04.plan | 16 +-
.../tpch/query-plans/query-plans.05.plan | 2 +-
.../tpch/query-plans/query-plans.06.plan | 2 +-
.../tpch/query-plans/query-plans.07.plan | 10 +-
.../tpch/query-plans/query-plans.08.plan | 252 ++-
.../tpch/query-plans/query-plans.09.plan | 14 +-
.../tpch/query-plans/query-plans.10.plan | 10 +-
.../tpch/query-plans/query-plans.11.plan | 4 +-
.../join-queries/join-queries.3.plan | 0
.../join-queries/join-queries.4.plan | 0
.../join-queries/join-queries.5.plan | 0
.../join-queries/join-queries.6.plan | 0
.../join-queries/join-queries.7.plan | 0
.../join-queries/join-queries.8.plan | 0
.../ASTERIXDB-3582-2/ASTERIXDB-3582.007.plan | 54 +
.../join-queries/join-queries.3.plan | 0
.../join-queries/join-queries.4.plan | 0
.../join-queries/join-queries.5.plan | 0
.../join-queries/join-queries.6.plan | 0
.../join-queries/join-queries.7.plan | 0
.../join-queries/join-queries.8.plan | 0
.../single-collection-queries.3.plan | 0
.../single-collection-queries.4.plan | 0
.../single-collection-queries.5.plan | 0
.../single-collection-queries.6.plan | 0
.../single-collection-queries.7.plan | 0
.../ASTERIXDB-3582-2/ASTERIXDB-3582.007.plan | 54 +
.../src/test/resources/runtimets/sqlpp_queries.xml | 15 +
...stsuite_external_dataset_azure_blob_storage.xml | 6 +-
.../runtimets/testsuite_external_dataset_s3.xml | 19 +-
.../resources/runtimets/testsuite_sqlpp_hdfs.xml | 6 +-
asterixdb/asterix-benchmark/pom.xml | 7 +
asterixdb/asterix-client-helper/pom.xml | 7 +
.../asterix/cloud/AbstractCloudIOManager.java | 6 +-
.../apache/asterix/cloud/clients/ICloudClient.java | 8 +-
.../asterix/cloud/clients/UnstableCloudClient.java | 8 +-
.../cloud/clients/google/gcs/GCSCloudClient.java | 25 +-
.../clients/google/gcs/GCSParallelDownloader.java | 12 +-
.../cloud/clients/google/gcs/GCSWriter.java | 3 +-
.../writer/AzureExternalFileWriterFactory.java | 5 +-
.../cloud/writer/GCSExternalFileWriterFactory.java | 5 +-
.../cloud/writer/S3ExternalFileWriterFactory.java | 5 +-
.../ColumnFilterValueAccessorEvaluatorFactory.java | 2 +-
asterixdb/asterix-common/pom.xml | 8 +
.../common/cloud/IPartitionBootstrapper.java | 2 +-
.../apache/asterix/common/context/DatasetInfo.java | 10 +-
.../common/context/DatasetLifecycleManager.java | 710 +++++--
.../asterix/common/context/DatasetResource.java | 25 +-
.../context/PrimaryIndexOperationTracker.java | 6 +-
.../common/dataflow/IDataPartitioningProvider.java | 1 +
.../asterix/common/exceptions/ErrorCode.java | 10 +-
.../common/transactions/IRecoveryManager.java | 19 +-
.../asterix/common/utils/StoragePathUtil.java | 17 +-
.../src/main/resources/asx_errormsg/en.properties | 9 +-
.../DatasetLifecycleManagerConcurrentTest.java | 2104 ++++++++++++++++++++
.../DatasetLifecycleManagerLazyRecoveryTest.java | 1223 ++++++++++++
asterixdb/asterix-dashboard/pom.xml | 7 +
asterixdb/asterix-doc/pom.xml | 7 +
asterixdb/asterix-external-data/pom.xml | 8 +
.../ExternalFilterValueEvaluatorFactory.java | 2 +-
.../reader/aws/delta/DeltaFileRecordReader.java | 16 +-
.../reader/aws/delta/DeltaReaderFactory.java | 49 +-
.../record/reader/aws/delta/PredicateSerDe.java | 134 ++
.../library/ExternalScalarFunctionEvaluator.java | 2 +-
.../ExternalScalarFunctionEvaluatorFactory.java | 2 +-
.../ExternalScalarJavaFunctionEvaluator.java | 2 +-
.../ExternalScalarPythonFunctionEvaluator.java | 2 +-
.../evaluators/StringJsonParseDescriptor.java | 2 +-
.../parser/evaluators/StringJsonParseEval.java | 2 +-
.../external/util/ExternalDataConstants.java | 5 +-
.../asterix/external/util/ExternalDataUtils.java | 3 +-
.../external/util/WriterValidationUtil.java | 8 +-
.../asterix/external/util/aws/s3/S3AuthUtils.java | 3 +-
.../external/util/google/gcs/GCSConstants.java | 92 +-
.../asterix/external/util/google/gcs/GCSUtils.java | 14 +-
.../writer/HDFSExternalFileWriterFactory.java | 5 +-
.../writer/LocalFSExternalFileWriterFactory.java | 6 +-
.../printer/CsvExternalFilePrinterFactory.java | 5 +-
.../printer/ParquetExternalFilePrinterFactory.java | 4 +-
.../TextualExternalDatabasePrinterFactory.java | 5 +-
.../printer/TextualExternalFilePrinterFactory.java | 5 +-
.../parser/test/LosslessADMJSONDataParserTest.java | 2 +-
.../external/parser/test/RecordWithMetaTest.java | 2 +-
asterixdb/asterix-fuzzyjoin/pom.xml | 4 +
.../common/EditDistanceCheckEvaluator.java | 2 +-
.../common/EditDistanceContainsEvaluator.java | 2 +-
.../evaluators/common/EditDistanceEvaluator.java | 2 +-
.../evaluators/common/GramTokensEvaluator.java | 2 +-
.../common/SimilarityJaccardCheckEvaluator.java | 2 +-
.../common/SimilarityJaccardEvaluator.java | 2 +-
.../common/SimilarityJaccardPrefixEvaluator.java | 2 +-
.../SimilarityJaccardSortedCheckEvaluator.java | 2 +-
.../common/SimilarityJaccardSortedEvaluator.java | 2 +-
.../evaluators/common/WordTokensEvaluator.java | 2 +-
.../functions/CountHashedGramTokensDescriptor.java | 2 +-
.../functions/CountHashedWordTokensDescriptor.java | 2 +-
.../functions/EditDistanceCheckDescriptor.java | 2 +-
.../functions/EditDistanceContainsDescriptor.java | 2 +-
.../functions/EditDistanceDescriptor.java | 2 +-
.../EditDistanceListIsFilterableDescriptor.java | 2 +-
.../EditDistanceStringIsFilterableDescriptor.java | 2 +-
.../EditDistanceStringIsFilterableEvaluator.java | 2 +-
.../evaluators/functions/GramTokensDescriptor.java | 2 +-
.../functions/HashedGramTokensDescriptor.java | 2 +-
.../functions/HashedWordTokensDescriptor.java | 2 +-
.../evaluators/functions/PrefixLenDescriptor.java | 2 +-
.../functions/PrefixLenJaccardDescriptor.java | 2 +-
.../evaluators/functions/SimilarityDescriptor.java | 2 +-
.../SimilarityJaccardCheckDescriptor.java | 2 +-
.../functions/SimilarityJaccardDescriptor.java | 2 +-
.../SimilarityJaccardPrefixCheckDescriptor.java | 2 +-
.../SimilarityJaccardPrefixDescriptor.java | 2 +-
.../SimilarityJaccardSortedCheckDescriptor.java | 2 +-
.../SimilarityJaccardSortedDescriptor.java | 2 +-
.../evaluators/functions/WordTokensDescriptor.java | 2 +-
asterixdb/asterix-geo/pom.xml | 7 +
.../geo/aggregates/STUnionAggregateDescriptor.java | 2 +-
.../geo/aggregates/STUnionAggregateFunction.java | 2 +-
.../AbstractSTDoubleGeometryDescriptor.java | 2 +-
.../functions/AbstractSTGeometryNDescriptor.java | 2 +-
.../AbstractSTSingleGeometryDescriptor.java | 2 +-
.../functions/ParseGeoJSONDescriptor.java | 2 +-
.../functions/STGeomFromTextDescriptor.java | 2 +-
.../functions/STGeomFromTextSRIDDescriptor.java | 2 +-
.../functions/STGeomFromWKBDescriptor.java | 2 +-
.../functions/STMBREnlargeDescriptor.java | 2 +-
.../functions/STMakeEnvelopeDescriptorSRID.java | 2 +-
.../functions/STMakePoint3DDescriptor.java | 2 +-
.../functions/STMakePoint3DWithMDescriptor.java | 2 +-
.../functions/STMakePointDescriptor.java | 2 +-
.../functions/STPolygonizeDescriptor.java | 2 +-
.../evaluators/functions/STRelateDescriptor.java | 2 +-
asterixdb/asterix-lang-common/pom.xml | 7 +
asterixdb/asterix-lang-sqlpp/pom.xml | 8 +
asterixdb/asterix-license/pom.xml | 7 +
.../asterix-grammar-extension-maven-plugin/pom.xml | 8 +
.../pom.xml | 12 +
.../lexer-generator-maven-plugin/pom.xml | 12 +
.../record-manager-generator-maven-plugin/pom.xml | 12 +
asterixdb/asterix-metadata/pom.xml | 12 +
.../org/apache/asterix/metadata/MetadataNode.java | 15 +-
.../declared/DataSourcePartitioningProvider.java | 7 +-
.../metadata/declared/MetadataProvider.java | 16 +
.../metadata/provider/ExternalWriterProvider.java | 12 +-
.../utils/DynamicDataPartitioningProvider.java | 6 +
.../asterix/metadata/utils/PushdownUtil.java | 15 +-
.../utils/StaticDataPartitioningProvider.java | 6 +
.../utils/filter/DeltaTableFilterBuilder.java | 54 +-
asterixdb/asterix-om/pom.xml | 13 -
.../printers/adm/ABinaryHexPrinterFactory.java | 3 +-
.../printers/adm/ABooleanPrinterFactory.java | 3 +-
.../printers/adm/ACirclePrinterFactory.java | 3 +-
.../printers/adm/ADatePrinterFactory.java | 3 +-
.../printers/adm/ADateTimePrinterFactory.java | 3 +-
.../adm/ADayTimeDurationPrinterFactory.java | 3 +-
.../printers/adm/ADoublePrinterFactory.java | 3 +-
.../printers/adm/ADurationPrinterFactory.java | 3 +-
.../printers/adm/AFloatPrinterFactory.java | 3 +-
.../printers/adm/AInt16PrinterFactory.java | 3 +-
.../printers/adm/AInt32PrinterFactory.java | 3 +-
.../printers/adm/AInt64PrinterFactory.java | 3 +-
.../printers/adm/AInt8PrinterFactory.java | 3 +-
.../printers/adm/AIntervalPrinterFactory.java | 3 +-
.../printers/adm/ALinePrinterFactory.java | 3 +-
.../printers/adm/ANullPrinterFactory.java | 3 +-
.../printers/adm/AObjectPrinterFactory.java | 3 +-
.../printers/adm/AOptionalFieldPrinterFactory.java | 8 +-
.../printers/adm/AOrderedlistPrinterFactory.java | 3 +-
.../printers/adm/APoint3DPrinterFactory.java | 3 +-
.../printers/adm/APointPrinterFactory.java | 3 +-
.../printers/adm/APolygonPrinterFactory.java | 3 +-
.../printers/adm/ARecordPrinterFactory.java | 3 +-
.../printers/adm/ARectanglePrinterFactory.java | 3 +-
.../printers/adm/AStringPrinterFactory.java | 3 +-
.../printers/adm/ATimePrinterFactory.java | 3 +-
.../printers/adm/AUUIDPrinterFactory.java | 3 +-
.../printers/adm/AUnionPrinterFactory.java | 5 +-
.../printers/adm/AUnorderedlistPrinterFactory.java | 3 +-
.../adm/AYearMonthDurationPrinterFactory.java | 3 +-
.../adm/ShortWithoutTypeInfoPrinterFactory.java | 3 +-
.../printers/csv/ABinaryHexPrinterFactory.java | 3 +-
.../printers/csv/ABooleanPrinterFactory.java | 3 +-
.../printers/csv/ACirclePrinterFactory.java | 3 +-
.../printers/csv/ADatePrinterFactory.java | 3 +-
.../printers/csv/ADateTimePrinterFactory.java | 3 +-
.../csv/ADayTimeDurationPrinterFactory.java | 3 +-
.../printers/csv/ADoublePrinterFactory.java | 3 +-
.../printers/csv/ADurationPrinterFactory.java | 3 +-
.../printers/csv/AFloatPrinterFactory.java | 3 +-
.../printers/csv/AInt16PrinterFactory.java | 3 +-
.../printers/csv/AInt32PrinterFactory.java | 3 +-
.../printers/csv/AInt64PrinterFactory.java | 3 +-
.../printers/csv/AInt8PrinterFactory.java | 3 +-
.../printers/csv/AIntervalPrinterFactory.java | 3 +-
.../printers/csv/ALinePrinterFactory.java | 3 +-
.../printers/csv/ANullPrinterFactory.java | 21 +-
.../printers/csv/AObjectPrinterFactory.java | 60 +-
.../printers/csv/AOptionalFieldPrinterFactory.java | 9 +-
.../printers/csv/APoint3DPrinterFactory.java | 3 +-
.../printers/csv/APointPrinterFactory.java | 3 +-
.../printers/csv/APolygonPrinterFactory.java | 3 +-
.../printers/csv/ARecordPrinterFactory.java | 6 +-
.../printers/csv/ARectanglePrinterFactory.java | 3 +-
.../printers/csv/AStringPrinterFactory.java | 49 +-
.../printers/csv/ATimePrinterFactory.java | 3 +-
.../printers/csv/AUUIDPrinterFactory.java | 3 +-
.../printers/csv/AUnionPrinterFactory.java | 5 +-
.../csv/AYearMonthDurationPrinterFactory.java | 3 +-
.../data/nontagged/printers/csv/CSVUtils.java | 89 +-
.../json/clean/ABinaryHexPrinterFactory.java | 3 +-
.../json/clean/ABooleanPrinterFactory.java | 3 +-
.../printers/json/clean/ACirclePrinterFactory.java | 3 +-
.../printers/json/clean/ADatePrinterFactory.java | 3 +-
.../json/clean/ADateTimePrinterFactory.java | 3 +-
.../json/clean/ADayTimeDurationPrinterFactory.java | 3 +-
.../printers/json/clean/ADoublePrinterFactory.java | 3 +-
.../json/clean/ADurationPrinterFactory.java | 3 +-
.../printers/json/clean/AFloatPrinterFactory.java | 3 +-
.../json/clean/AGeometryPrinterFactory.java | 3 +-
.../printers/json/clean/AInt16PrinterFactory.java | 3 +-
.../printers/json/clean/AInt32PrinterFactory.java | 3 +-
.../printers/json/clean/AInt64PrinterFactory.java | 3 +-
.../printers/json/clean/AInt8PrinterFactory.java | 3 +-
.../json/clean/AIntervalPrinterFactory.java | 3 +-
.../printers/json/clean/ALinePrinterFactory.java | 3 +-
.../printers/json/clean/ANullPrinterFactory.java | 3 +-
.../printers/json/clean/AObjectPrinterFactory.java | 3 +-
.../json/clean/AOptionalFieldPrinterFactory.java | 7 +-
.../json/clean/AOrderedlistPrinterFactory.java | 3 +-
.../json/clean/APoint3DPrinterFactory.java | 3 +-
.../printers/json/clean/APointPrinterFactory.java | 3 +-
.../json/clean/APolygonPrinterFactory.java | 3 +-
.../printers/json/clean/ARecordPrinterFactory.java | 3 +-
.../json/clean/ARectanglePrinterFactory.java | 3 +-
.../printers/json/clean/AStringPrinterFactory.java | 3 +-
.../printers/json/clean/ATimePrinterFactory.java | 3 +-
.../printers/json/clean/AUUIDPrinterFactory.java | 3 +-
.../printers/json/clean/AUnionPrinterFactory.java | 5 +-
.../json/clean/AUnorderedlistPrinterFactory.java | 3 +-
.../clean/AYearMonthDurationPrinterFactory.java | 3 +-
.../json/lossless/ABinaryHexPrinterFactory.java | 3 +-
.../json/lossless/ABooleanPrinterFactory.java | 3 +-
.../json/lossless/ACirclePrinterFactory.java | 3 +-
.../json/lossless/ADatePrinterFactory.java | 3 +-
.../json/lossless/ADateTimePrinterFactory.java | 3 +-
.../lossless/ADayTimeDurationPrinterFactory.java | 3 +-
.../json/lossless/ADoublePrinterFactory.java | 3 +-
.../json/lossless/ADurationPrinterFactory.java | 3 +-
.../json/lossless/AFloatPrinterFactory.java | 3 +-
.../json/lossless/AInt16PrinterFactory.java | 3 +-
.../json/lossless/AInt32PrinterFactory.java | 3 +-
.../json/lossless/AInt64PrinterFactory.java | 3 +-
.../json/lossless/AInt8PrinterFactory.java | 3 +-
.../json/lossless/AIntervalPrinterFactory.java | 3 +-
.../json/lossless/ALinePrinterFactory.java | 3 +-
.../json/lossless/ANullPrinterFactory.java | 3 +-
.../json/lossless/AObjectPrinterFactory.java | 3 +-
.../lossless/AOptionalFieldPrinterFactory.java | 7 +-
.../json/lossless/AOrderedlistPrinterFactory.java | 3 +-
.../json/lossless/APoint3DPrinterFactory.java | 3 +-
.../json/lossless/APointPrinterFactory.java | 3 +-
.../json/lossless/APolygonPrinterFactory.java | 3 +-
.../json/lossless/ARecordPrinterFactory.java | 3 +-
.../json/lossless/ARectanglePrinterFactory.java | 3 +-
.../json/lossless/AStringPrinterFactory.java | 3 +-
.../json/lossless/ATimePrinterFactory.java | 3 +-
.../json/lossless/AUUIDPrinterFactory.java | 3 +-
.../json/lossless/AUnionPrinterFactory.java | 5 +-
.../lossless/AUnorderedlistPrinterFactory.java | 3 +-
.../lossless/AYearMonthDurationPrinterFactory.java | 3 +-
.../json/losslessadm/ABinaryPrinterFactory.java | 3 +-
.../json/losslessadm/ABooleanPrinterFactory.java | 3 +-
.../json/losslessadm/ACirclePrinterFactory.java | 3 +-
.../json/losslessadm/ADatePrinterFactory.java | 3 +-
.../json/losslessadm/ADateTimePrinterFactory.java | 3 +-
.../ADayTimeDurationPrinterFactory.java | 3 +-
.../json/losslessadm/ADoublePrinterFactory.java | 3 +-
.../json/losslessadm/ADurationPrinterFactory.java | 3 +-
.../json/losslessadm/AFloatPrinterFactory.java | 3 +-
.../json/losslessadm/AInt16PrinterFactory.java | 3 +-
.../json/losslessadm/AInt32PrinterFactory.java | 3 +-
.../json/losslessadm/AInt64PrinterFactory.java | 3 +-
.../json/losslessadm/AInt8PrinterFactory.java | 3 +-
.../json/losslessadm/ALinePrinterFactory.java | 3 +-
.../json/losslessadm/AMissingPrinterFactory.java | 5 +-
.../json/losslessadm/ANullPrinterFactory.java | 3 +-
.../json/losslessadm/AObjectPrinterFactory.java | 3 +-
.../losslessadm/AOptionalFieldPrinterFactory.java | 9 +-
.../losslessadm/AOrderedlistPrinterFactory.java | 3 +-
.../json/losslessadm/APoint3DPrinterFactory.java | 3 +-
.../json/losslessadm/APointPrinterFactory.java | 3 +-
.../json/losslessadm/APolygonPrinterFactory.java | 3 +-
.../json/losslessadm/ARecordPrinterFactory.java | 3 +-
.../json/losslessadm/ARectanglePrinterFactory.java | 3 +-
.../json/losslessadm/AStringPrinterFactory.java | 3 +-
.../json/losslessadm/ATimePrinterFactory.java | 3 +-
.../json/losslessadm/AUUIDPrinterFactory.java | 3 +-
.../json/losslessadm/AUnionPrinterFactory.java | 5 +-
.../losslessadm/AUnorderedlistPrinterFactory.java | 3 +-
.../AYearMonthDurationPrinterFactory.java | 3 +-
.../nontagged/CSVPrinterFactoryProvider.java | 12 +-
.../asterix/om/exceptions/ExceptionUtil.java | 2 +-
.../pointables/printer/csv/ACSVRecordPrinter.java | 167 +-
.../om/pointables/printer/csv/APrintVisitor.java | 20 +-
asterixdb/asterix-podman/pom.xml | 11 +
asterixdb/asterix-replication/pom.xml | 15 +
asterixdb/asterix-runtime/pom.xml | 12 +
.../collections/FirstElementEvalFactory.java | 2 +-
.../collections/LastElementEvalFactory.java | 2 +-
.../ListifyAggregateFunctionEvalFactory.java | 2 +-
.../collections/NullWriterAggregateDescriptor.java | 2 +-
.../scalar/AbstractScalarAggregateDescriptor.java | 2 +-
.../AbstractScalarDistinctAggregateDescriptor.java | 2 +-
.../scalar/GenericScalarAggregateFunction.java | 2 +-
.../GenericScalarDistinctAggregateFunction.java | 2 +-
.../AbstractSerializableAvgAggregateFunction.java | 2 +-
...AbstractSerializableCountAggregateFunction.java | 2 +-
...eSingleVariableStatisticsAggregateFunction.java | 2 +-
.../AbstractSerializableSumAggregateFunction.java | 2 +-
.../std/SerializableAvgAggregateDescriptor.java | 2 +-
.../std/SerializableAvgAggregateFunction.java | 2 +-
.../std/SerializableCountAggregateDescriptor.java | 2 +-
.../std/SerializableCountAggregateFunction.java | 2 +-
.../std/SerializableCountNAggregateDescriptor.java | 2 +-
.../std/SerializableCountNAggregateFunction.java | 2 +-
.../SerializableGlobalAvgAggregateDescriptor.java | 2 +-
.../SerializableGlobalAvgAggregateFunction.java | 2 +-
...ializableGlobalKurtosisAggregateDescriptor.java | 2 +-
...erializableGlobalKurtosisAggregateFunction.java | 2 +-
...ializableGlobalSkewnessAggregateDescriptor.java | 2 +-
...erializableGlobalSkewnessAggregateFunction.java | 2 +-
...erializableGlobalSqlAvgAggregateDescriptor.java | 2 +-
.../SerializableGlobalSqlAvgAggregateFunction.java | 2 +-
...izableGlobalSqlKurtosisAggregateDescriptor.java | 2 +-
...alizableGlobalSqlKurtosisAggregateFunction.java | 2 +-
...izableGlobalSqlSkewnessAggregateDescriptor.java | 2 +-
...alizableGlobalSqlSkewnessAggregateFunction.java | 2 +-
...alizableGlobalSqlStddevAggregateDescriptor.java | 2 +-
...rializableGlobalSqlStddevAggregateFunction.java | 2 +-
...zableGlobalSqlStddevPopAggregateDescriptor.java | 2 +-
...erializableGlobalSqlSumAggregateDescriptor.java | 2 +-
.../SerializableGlobalSqlSumAggregateFunction.java | 2 +-
...erializableGlobalSqlVarAggregateDescriptor.java | 2 +-
.../SerializableGlobalSqlVarAggregateFunction.java | 2 +-
...alizableGlobalSqlVarPopAggregateDescriptor.java | 2 +-
...erializableGlobalStddevAggregateDescriptor.java | 2 +-
.../SerializableGlobalStddevAggregateFunction.java | 2 +-
...alizableGlobalStddevPopAggregateDescriptor.java | 2 +-
.../SerializableGlobalSumAggregateDescriptor.java | 2 +-
.../SerializableGlobalSumAggregateFunction.java | 2 +-
.../SerializableGlobalVarAggregateDescriptor.java | 2 +-
.../SerializableGlobalVarAggregateFunction.java | 2 +-
...erializableGlobalVarPopAggregateDescriptor.java | 2 +-
...alizableIntermediateAvgAggregateDescriptor.java | 2 +-
...rializableIntermediateAvgAggregateFunction.java | 2 +-
...bleIntermediateKurtosisAggregateDescriptor.java | 2 +-
...zableIntermediateKurtosisAggregateFunction.java | 2 +-
...bleIntermediateSkewnessAggregateDescriptor.java | 2 +-
...zableIntermediateSkewnessAggregateFunction.java | 2 +-
...zableIntermediateSqlAvgAggregateDescriptor.java | 2 +-
...lizableIntermediateSqlAvgAggregateFunction.java | 2 +-
...IntermediateSqlKurtosisAggregateDescriptor.java | 2 +-
...leIntermediateSqlKurtosisAggregateFunction.java | 2 +-
...IntermediateSqlSkewnessAggregateDescriptor.java | 2 +-
...leIntermediateSqlSkewnessAggregateFunction.java | 2 +-
...leIntermediateSqlStddevAggregateDescriptor.java | 2 +-
...ableIntermediateSqlStddevAggregateFunction.java | 2 +-
...ntermediateSqlStddevPopAggregateDescriptor.java | 2 +-
...zableIntermediateSqlSumAggregateDescriptor.java | 2 +-
...lizableIntermediateSqlSumAggregateFunction.java | 2 +-
...zableIntermediateSqlVarAggregateDescriptor.java | 2 +-
...lizableIntermediateSqlVarAggregateFunction.java | 2 +-
...leIntermediateSqlVarPopAggregateDescriptor.java | 2 +-
...zableIntermediateStddevAggregateDescriptor.java | 2 +-
...lizableIntermediateStddevAggregateFunction.java | 2 +-
...leIntermediateStddevPopAggregateDescriptor.java | 2 +-
...alizableIntermediateSumAggregateDescriptor.java | 2 +-
...rializableIntermediateSumAggregateFunction.java | 2 +-
...alizableIntermediateVarAggregateDescriptor.java | 2 +-
...rializableIntermediateVarAggregateFunction.java | 2 +-
...zableIntermediateVarPopAggregateDescriptor.java | 2 +-
.../SerializableKurtosisAggregateDescriptor.java | 2 +-
.../std/SerializableKurtosisAggregateFunction.java | 2 +-
.../SerializableLocalAvgAggregateDescriptor.java | 2 +-
.../std/SerializableLocalAvgAggregateFunction.java | 2 +-
...rializableLocalKurtosisAggregateDescriptor.java | 2 +-
...SerializableLocalKurtosisAggregateFunction.java | 2 +-
...rializableLocalSkewnessAggregateDescriptor.java | 2 +-
...SerializableLocalSkewnessAggregateFunction.java | 2 +-
...SerializableLocalSqlAvgAggregateDescriptor.java | 2 +-
.../SerializableLocalSqlAvgAggregateFunction.java | 2 +-
...lizableLocalSqlKurtosisAggregateDescriptor.java | 2 +-
...ializableLocalSqlKurtosisAggregateFunction.java | 2 +-
...lizableLocalSqlSkewnessAggregateDescriptor.java | 2 +-
...ializableLocalSqlSkewnessAggregateFunction.java | 2 +-
...ializableLocalSqlStddevAggregateDescriptor.java | 2 +-
...erializableLocalSqlStddevAggregateFunction.java | 2 +-
...izableLocalSqlStddevPopAggregateDescriptor.java | 2 +-
...SerializableLocalSqlSumAggregateDescriptor.java | 2 +-
.../SerializableLocalSqlSumAggregateFunction.java | 2 +-
...SerializableLocalSqlVarAggregateDescriptor.java | 2 +-
.../SerializableLocalSqlVarAggregateFunction.java | 2 +-
...ializableLocalSqlVarPopAggregateDescriptor.java | 2 +-
...SerializableLocalStddevAggregateDescriptor.java | 2 +-
.../SerializableLocalStddevAggregateFunction.java | 2 +-
...ializableLocalStddevPopAggregateDescriptor.java | 2 +-
.../SerializableLocalSumAggregateDescriptor.java | 2 +-
.../std/SerializableLocalSumAggregateFunction.java | 2 +-
.../SerializableLocalVarAggregateDescriptor.java | 2 +-
.../std/SerializableLocalVarAggregateFunction.java | 2 +-
...SerializableLocalVarPopAggregateDescriptor.java | 2 +-
.../SerializableSkewnessAggregateDescriptor.java | 2 +-
.../std/SerializableSkewnessAggregateFunction.java | 2 +-
.../std/SerializableSqlAvgAggregateDescriptor.java | 2 +-
.../std/SerializableSqlAvgAggregateFunction.java | 2 +-
.../SerializableSqlCountAggregateDescriptor.java | 2 +-
.../std/SerializableSqlCountAggregateFunction.java | 2 +-
.../SerializableSqlCountNAggregateDescriptor.java | 2 +-
.../SerializableSqlCountNAggregateFunction.java | 2 +-
...SerializableSqlKurtosisAggregateDescriptor.java | 2 +-
.../SerializableSqlKurtosisAggregateFunction.java | 2 +-
...SerializableSqlSkewnessAggregateDescriptor.java | 2 +-
.../SerializableSqlSkewnessAggregateFunction.java | 2 +-
.../SerializableSqlStddevAggregateDescriptor.java | 2 +-
.../SerializableSqlStddevAggregateFunction.java | 2 +-
...erializableSqlStddevPopAggregateDescriptor.java | 2 +-
.../std/SerializableSqlSumAggregateDescriptor.java | 2 +-
.../std/SerializableSqlSumAggregateFunction.java | 2 +-
.../std/SerializableSqlVarAggregateDescriptor.java | 2 +-
.../std/SerializableSqlVarAggregateFunction.java | 2 +-
.../SerializableSqlVarPopAggregateDescriptor.java | 2 +-
.../std/SerializableStddevAggregateDescriptor.java | 2 +-
.../std/SerializableStddevAggregateFunction.java | 2 +-
.../SerializableStddevPopAggregateDescriptor.java | 2 +-
.../std/SerializableSumAggregateDescriptor.java | 2 +-
.../std/SerializableSumAggregateFunction.java | 2 +-
.../std/SerializableVarAggregateDescriptor.java | 2 +-
.../std/SerializableVarAggregateFunction.java | 2 +-
.../std/SerializableVarPopAggregateDescriptor.java | 2 +-
.../std/AbstractAvgAggregateFunction.java | 2 +-
.../std/AbstractCountAggregateFunction.java | 2 +-
.../std/AbstractLocalMedianAggregateFunction.java | 2 +-
.../std/AbstractMedianAggregateFunction.java | 2 +-
.../std/AbstractMinMaxAggregateFunction.java | 2 +-
...stractSingleVarStatisticsAggregateFunction.java | 2 +-
.../std/AbstractSumAggregateFunction.java | 2 +-
.../std/AbstractUnionMbrAggregateFunction.java | 2 +-
.../aggregates/std/AvgAggregateDescriptor.java | 2 +-
.../aggregates/std/AvgAggregateFunction.java | 2 +-
.../aggregates/std/CountAggregateDescriptor.java | 2 +-
.../aggregates/std/CountAggregateFunction.java | 2 +-
.../aggregates/std/CountNAggregateDescriptor.java | 2 +-
.../aggregates/std/CountNAggregateFunction.java | 2 +-
.../std/GlobalAvgAggregateDescriptor.java | 2 +-
.../aggregates/std/GlobalAvgAggregateFunction.java | 2 +-
.../std/GlobalKurtosisAggregateDescriptor.java | 2 +-
.../std/GlobalKurtosisAggregateFunction.java | 2 +-
.../std/GlobalMaxAggregateDescriptor.java | 2 +-
.../std/GlobalMinAggregateDescriptor.java | 2 +-
.../std/GlobalSkewnessAggregateDescriptor.java | 2 +-
.../std/GlobalSkewnessAggregateFunction.java | 2 +-
.../std/GlobalSqlAvgAggregateDescriptor.java | 2 +-
.../std/GlobalSqlAvgAggregateFunction.java | 2 +-
.../std/GlobalSqlKurtosisAggregateDescriptor.java | 2 +-
.../std/GlobalSqlKurtosisAggregateFunction.java | 2 +-
.../std/GlobalSqlMaxAggregateDescriptor.java | 2 +-
.../std/GlobalSqlMedianAggregateDescriptor.java | 2 +-
.../std/GlobalSqlMedianAggregateFunction.java | 2 +-
.../std/GlobalSqlMinAggregateDescriptor.java | 2 +-
.../std/GlobalSqlSkewnessAggregateDescriptor.java | 2 +-
.../std/GlobalSqlSkewnessAggregateFunction.java | 2 +-
.../std/GlobalSqlStddevAggregateDescriptor.java | 2 +-
.../std/GlobalSqlStddevAggregateFunction.java | 2 +-
.../std/GlobalSqlStddevPopAggregateDescriptor.java | 2 +-
.../std/GlobalSqlSumAggregateDescriptor.java | 2 +-
.../std/GlobalSqlSumAggregateFunction.java | 2 +-
.../std/GlobalSqlUnionMbrAggregateDescriptor.java | 2 +-
.../std/GlobalSqlVarAggregateDescriptor.java | 2 +-
.../std/GlobalSqlVarAggregateFunction.java | 2 +-
.../std/GlobalSqlVarPopAggregateDescriptor.java | 2 +-
.../std/GlobalStddevAggregateDescriptor.java | 2 +-
.../std/GlobalStddevAggregateFunction.java | 2 +-
.../std/GlobalStddevPopAggregateDescriptor.java | 2 +-
.../std/GlobalSumAggregateDescriptor.java | 2 +-
.../aggregates/std/GlobalSumAggregateFunction.java | 2 +-
.../std/GlobalUnionMbrAggregateDescriptor.java | 2 +-
.../std/GlobalVarAggregateDescriptor.java | 2 +-
.../aggregates/std/GlobalVarAggregateFunction.java | 2 +-
.../std/GlobalVarPopAggregateDescriptor.java | 2 +-
.../std/IntermediateAvgAggregateDescriptor.java | 2 +-
.../std/IntermediateAvgAggregateFunction.java | 2 +-
.../IntermediateKurtosisAggregateDescriptor.java | 2 +-
.../std/IntermediateKurtosisAggregateFunction.java | 2 +-
.../std/IntermediateMaxAggregateDescriptor.java | 2 +-
.../std/IntermediateMinAggregateDescriptor.java | 2 +-
.../IntermediateSkewnessAggregateDescriptor.java | 2 +-
.../std/IntermediateSkewnessAggregateFunction.java | 2 +-
.../std/IntermediateSqlAvgAggregateDescriptor.java | 2 +-
.../std/IntermediateSqlAvgAggregateFunction.java | 2 +-
...IntermediateSqlKurtosisAggregateDescriptor.java | 2 +-
.../IntermediateSqlKurtosisAggregateFunction.java | 2 +-
.../std/IntermediateSqlMaxAggregateDescriptor.java | 2 +-
.../IntermediateSqlMedianAggregateDescriptor.java | 2 +-
.../IntermediateSqlMedianAggregateFunction.java | 2 +-
.../std/IntermediateSqlMinAggregateDescriptor.java | 2 +-
...IntermediateSqlSkewnessAggregateDescriptor.java | 2 +-
.../IntermediateSqlSkewnessAggregateFunction.java | 2 +-
.../IntermediateSqlStddevAggregateDescriptor.java | 2 +-
.../IntermediateSqlStddevAggregateFunction.java | 2 +-
...ntermediateSqlStddevPopAggregateDescriptor.java | 2 +-
.../std/IntermediateSqlSumAggregateDescriptor.java | 2 +-
.../std/IntermediateSqlSumAggregateFunction.java | 2 +-
...IntermediateSqlUnionMbrAggregateDescriptor.java | 2 +-
.../std/IntermediateSqlVarAggregateDescriptor.java | 2 +-
.../std/IntermediateSqlVarAggregateFunction.java | 2 +-
.../IntermediateSqlVarPopAggregateDescriptor.java | 2 +-
.../std/IntermediateStddevAggregateDescriptor.java | 2 +-
.../std/IntermediateStddevAggregateFunction.java | 2 +-
.../IntermediateStddevPopAggregateDescriptor.java | 2 +-
.../std/IntermediateSumAggregateDescriptor.java | 2 +-
.../std/IntermediateSumAggregateFunction.java | 2 +-
.../IntermediateUnionMbrAggregateDescriptor.java | 2 +-
.../std/IntermediateVarAggregateDescriptor.java | 2 +-
.../std/IntermediateVarAggregateFunction.java | 2 +-
.../std/IntermediateVarPopAggregateDescriptor.java | 2 +-
.../std/KurtosisAggregateDescriptor.java | 2 +-
.../aggregates/std/KurtosisAggregateFunction.java | 2 +-
.../std/LocalAvgAggregateDescriptor.java | 2 +-
.../aggregates/std/LocalAvgAggregateFunction.java | 2 +-
.../std/LocalKurtosisAggregateDescriptor.java | 2 +-
.../std/LocalKurtosisAggregateFunction.java | 2 +-
.../std/LocalMaxAggregateDescriptor.java | 2 +-
.../std/LocalMinAggregateDescriptor.java | 2 +-
.../std/LocalSamplingAggregateDescriptor.java | 2 +-
.../std/LocalSkewnessAggregateDescriptor.java | 2 +-
.../std/LocalSkewnessAggregateFunction.java | 2 +-
.../std/LocalSqlAvgAggregateDescriptor.java | 2 +-
.../std/LocalSqlAvgAggregateFunction.java | 2 +-
.../std/LocalSqlKurtosisAggregateDescriptor.java | 2 +-
.../std/LocalSqlKurtosisAggregateFunction.java | 2 +-
.../std/LocalSqlMaxAggregateDescriptor.java | 2 +-
.../std/LocalSqlMedianAggregateDescriptor.java | 2 +-
.../std/LocalSqlMedianAggregateFunction.java | 2 +-
.../std/LocalSqlMinAggregateDescriptor.java | 2 +-
.../std/LocalSqlSkewnessAggregateDescriptor.java | 2 +-
.../std/LocalSqlSkewnessAggregateFunction.java | 2 +-
.../std/LocalSqlStddevAggregateDescriptor.java | 2 +-
.../std/LocalSqlStddevAggregateFunction.java | 2 +-
.../std/LocalSqlStddevPopAggregateDescriptor.java | 2 +-
.../std/LocalSqlSumAggregateDescriptor.java | 2 +-
.../std/LocalSqlSumAggregateFunction.java | 2 +-
.../std/LocalSqlUnionMbrAggregateDescriptor.java | 2 +-
.../std/LocalSqlVarAggregateDescriptor.java | 2 +-
.../std/LocalSqlVarAggregateFunction.java | 2 +-
.../std/LocalSqlVarPopAggregateDescriptor.java | 2 +-
.../std/LocalStddevAggregateDescriptor.java | 2 +-
.../std/LocalStddevAggregateFunction.java | 2 +-
.../std/LocalStddevPopAggregateDescriptor.java | 2 +-
.../std/LocalSumAggregateDescriptor.java | 2 +-
.../aggregates/std/LocalSumAggregateFunction.java | 2 +-
.../std/LocalUnionMbrAggregateDescriptor.java | 2 +-
.../std/LocalVarAggregateDescriptor.java | 2 +-
.../aggregates/std/LocalVarAggregateFunction.java | 2 +-
.../std/LocalVarPopAggregateDescriptor.java | 2 +-
.../aggregates/std/MaxAggregateDescriptor.java | 2 +-
.../aggregates/std/MinAggregateDescriptor.java | 2 +-
.../aggregates/std/MinMaxAggregateFunction.java | 2 +-
.../std/RangeMapAggregateDescriptor.java | 2 +-
.../std/SkewnessAggregateDescriptor.java | 2 +-
.../aggregates/std/SkewnessAggregateFunction.java | 2 +-
.../aggregates/std/SqlAvgAggregateDescriptor.java | 2 +-
.../aggregates/std/SqlAvgAggregateFunction.java | 2 +-
.../std/SqlCountAggregateDescriptor.java | 2 +-
.../aggregates/std/SqlCountAggregateFunction.java | 2 +-
.../std/SqlCountNAggregateDescriptor.java | 2 +-
.../aggregates/std/SqlCountNAggregateFunction.java | 2 +-
.../std/SqlKurtosisAggregateDescriptor.java | 2 +-
.../std/SqlKurtosisAggregateFunction.java | 2 +-
.../aggregates/std/SqlMaxAggregateDescriptor.java | 2 +-
.../std/SqlMedianAggregateDescriptor.java | 2 +-
.../aggregates/std/SqlMedianAggregateFunction.java | 4 +-
.../aggregates/std/SqlMinAggregateDescriptor.java | 2 +-
.../aggregates/std/SqlMinMaxAggregateFunction.java | 2 +-
.../std/SqlSkewnessAggregateDescriptor.java | 2 +-
.../std/SqlSkewnessAggregateFunction.java | 2 +-
.../std/SqlStddevAggregateDescriptor.java | 2 +-
.../aggregates/std/SqlStddevAggregateFunction.java | 2 +-
.../std/SqlStddevPopAggregateDescriptor.java | 2 +-
.../aggregates/std/SqlSumAggregateDescriptor.java | 2 +-
.../aggregates/std/SqlSumAggregateFunction.java | 2 +-
.../std/SqlUnionMbrAggregateDescriptor.java | 2 +-
.../std/SqlUnionMbrAggregateFunction.java | 2 +-
.../aggregates/std/SqlVarAggregateDescriptor.java | 2 +-
.../aggregates/std/SqlVarAggregateFunction.java | 2 +-
.../std/SqlVarPopAggregateDescriptor.java | 2 +-
.../aggregates/std/StddevAggregateDescriptor.java | 2 +-
.../aggregates/std/StddevAggregateFunction.java | 2 +-
.../std/StddevPopAggregateDescriptor.java | 2 +-
.../aggregates/std/SumAggregateDescriptor.java | 2 +-
.../aggregates/std/SumAggregateFunction.java | 2 +-
.../std/UnionMbrAggregateDescriptor.java | 2 +-
.../aggregates/std/UnionMbrAggregateFunction.java | 2 +-
.../aggregates/std/VarAggregateDescriptor.java | 2 +-
.../aggregates/std/VarAggregateFunction.java | 2 +-
.../aggregates/std/VarPopAggregateDescriptor.java | 2 +-
.../stream/EmptyStreamAggregateDescriptor.java | 2 +-
.../stream/NonEmptyStreamAggregateDescriptor.java | 2 +-
.../asterix/runtime/base/AsterixTupleFilter.java | 2 +-
.../runtime/base/AsterixTupleFilterFactory.java | 2 +-
.../evaluators/accessors/CircleCenterAccessor.java | 2 +-
.../evaluators/accessors/CircleRadiusAccessor.java | 2 +-
.../accessors/LineRectanglePolygonAccessor.java | 2 +-
.../accessors/PointXCoordinateAccessor.java | 2 +-
.../accessors/PointYCoordinateAccessor.java | 2 +-
.../evaluators/accessors/TemporalDayAccessor.java | 2 +-
.../evaluators/accessors/TemporalHourAccessor.java | 2 +-
.../accessors/TemporalIntervalEndAccessor.java | 2 +-
.../accessors/TemporalIntervalEndDateAccessor.java | 2 +-
.../TemporalIntervalEndDatetimeAccessor.java | 2 +-
.../accessors/TemporalIntervalEndTimeAccessor.java | 2 +-
.../accessors/TemporalIntervalStartAccessor.java | 2 +-
.../TemporalIntervalStartDateAccessor.java | 2 +-
.../TemporalIntervalStartDatetimeAccessor.java | 2 +-
.../TemporalIntervalStartTimeAccessor.java | 2 +-
.../accessors/TemporalMillisecondAccessor.java | 2 +-
.../accessors/TemporalMinuteAccessor.java | 2 +-
.../accessors/TemporalMonthAccessor.java | 2 +-
.../accessors/TemporalSecondAccessor.java | 2 +-
.../evaluators/accessors/TemporalYearAccessor.java | 2 +-
.../runtime/evaluators/common/ArgumentUtils.java | 2 +-
.../common/ClosedRecordConstructorEvalFactory.java | 2 +-
.../evaluators/common/CreateMBREvalFactory.java | 2 +-
.../common/FullTextContainsFunctionEvaluator.java | 2 +-
.../comparisons/AbstractComparisonEvaluator.java | 2 +-
.../comparisons/AbstractIfEqualsEvaluator.java | 2 +-
.../AbstractValueComparisonEvaluator.java | 2 +-
.../evaluators/comparisons/EqualsDescriptor.java | 2 +-
.../comparisons/GreaterThanDescriptor.java | 2 +-
.../comparisons/GreaterThanOrEqualsDescriptor.java | 2 +-
.../evaluators/comparisons/LessThanDescriptor.java | 2 +-
.../comparisons/LessThanOrEqualsDescriptor.java | 2 +-
.../comparisons/MissingIfEqualsDescriptor.java | 2 +-
.../comparisons/NanIfEqualsDescriptor.java | 2 +-
.../comparisons/NegInfIfEqualsDescriptor.java | 2 +-
.../comparisons/NotEqualsDescriptor.java | 2 +-
.../comparisons/NullIfEqualsDescriptor.java | 2 +-
.../comparisons/PosInfIfEqualsDescriptor.java | 2 +-
.../ABinaryBase64StringConstructorDescriptor.java | 2 +-
...se64StringDefaultNullConstructorDescriptor.java | 2 +-
.../ABinaryHexStringConstructorDescriptor.java | 2 +-
.../ABooleanConstructorDescriptor.java | 2 +-
.../ABooleanDefaultNullConstructorDescriptor.java | 2 +-
.../constructors/ACircleConstructorDescriptor.java | 2 +-
.../constructors/ADateConstructorDescriptor.java | 2 +-
.../ADateConstructorWithFormatDescriptor.java | 2 +-
.../ADateDefaultNullConstructorDescriptor.java | 2 +-
...DefaultNullConstructorWithFormatDescriptor.java | 2 +-
.../ADateTimeConstructorDescriptor.java | 2 +-
.../ADateTimeConstructorWithFormatDescriptor.java | 2 +-
.../ADateTimeDefaultNullConstructorDescriptor.java | 2 +-
...DefaultNullConstructorWithFormatDescriptor.java | 2 +-
.../ADayTimeDurationConstructorDescriptor.java | 2 +-
...meDurationDefaultNullConstructorDescriptor.java | 2 +-
.../constructors/ADoubleConstructorDescriptor.java | 2 +-
.../ADoubleDefaultNullConstructorDescriptor.java | 2 +-
.../ADurationConstructorDescriptor.java | 2 +-
.../ADurationDefaultNullConstructorDescriptor.java | 2 +-
.../constructors/AFloatConstructorDescriptor.java | 2 +-
.../AFloatDefaultNullConstructorDescriptor.java | 2 +-
.../constructors/AInt16ConstructorDescriptor.java | 2 +-
.../AInt16DefaultNullConstructorDescriptor.java | 2 +-
.../constructors/AInt32ConstructorDescriptor.java | 2 +-
.../AInt32DefaultNullConstructorDescriptor.java | 2 +-
.../constructors/AInt64ConstructorDescriptor.java | 2 +-
.../AInt64DefaultNullConstructorDescriptor.java | 2 +-
.../constructors/AInt8ConstructorDescriptor.java | 2 +-
.../AInt8DefaultNullConstructorDescriptor.java | 2 +-
.../AIntervalConstructorDescriptor.java | 2 +-
...IntervalStartFromDateConstructorDescriptor.java | 2 +-
...rvalStartFromDateTimeConstructorDescriptor.java | 2 +-
...IntervalStartFromTimeConstructorDescriptor.java | 2 +-
.../constructors/ALineConstructorDescriptor.java | 2 +-
.../APoint3DConstructorDescriptor.java | 2 +-
.../constructors/APointConstructorDescriptor.java | 2 +-
.../APolygonConstructorDescriptor.java | 2 +-
.../ARectangleConstructorDescriptor.java | 2 +-
.../constructors/AStringConstructorDescriptor.java | 2 +-
.../AStringDefaultNullConstructorDescriptor.java | 2 +-
.../constructors/ATimeConstructorDescriptor.java | 2 +-
.../ATimeConstructorWithFormatDescriptor.java | 2 +-
.../ATimeDefaultNullConstructorDescriptor.java | 2 +-
...DefaultNullConstructorWithFormatDescriptor.java | 2 +-
.../AUUIDFromStringConstructorDescriptor.java | 2 +-
...FromStringDefaultNullConstructorDescriptor.java | 2 +-
.../AYearMonthDurationConstructorDescriptor.java | 2 +-
...thDurationDefaultNullConstructorDescriptor.java | 2 +-
.../AbstractBinaryConstructorEvaluator.java | 2 +-
.../AbstractBooleanConstructorEvaluator.java | 2 +-
.../constructors/AbstractConstructorEvaluator.java | 2 +-
.../AbstractDateConstructorEvaluator.java | 2 +-
...AbstractDateConstructorWithFormatEvaluator.java | 2 +-
.../AbstractDateTimeConstructorEvaluator.java | 2 +-
...ractDateTimeConstructorWithFormatEvaluator.java | 2 +-
...bstractDayTimeDurationConstructorEvaluator.java | 2 +-
.../AbstractDoubleConstructorEvaluator.java | 2 +-
.../AbstractDurationConstructorEvaluator.java | 2 +-
.../AbstractFloatConstructorEvaluator.java | 2 +-
.../AbstractInt16ConstructorEvaluator.java | 2 +-
.../AbstractInt32ConstructorEvaluator.java | 2 +-
.../AbstractInt64ConstructorEvaluator.java | 2 +-
.../AbstractInt8ConstructorEvaluator.java | 2 +-
.../AbstractIntConstructorEvaluator.java | 2 +-
.../AbstractStringConstructorEvaluator.java | 2 +-
.../AbstractTimeConstructorEvaluator.java | 2 +-
...AbstractTimeWithFormatConstructorEvaluator.java | 2 +-
...AbstractUUIDFromStringConstructorEvaluator.java | 2 +-
...tractYearMonthDurationConstructorEvaluator.java | 2 +-
.../OpenRecordConstructorDescriptor.java | 2 +-
.../OrderedListConstructorDescriptor.java | 2 +-
.../UnorderedListConstructorDescriptor.java | 2 +-
.../functions/AbstractArrayAddRemoveEval.java | 2 +-
.../functions/AbstractArrayMoveSwapEval.java | 2 +-
.../functions/AbstractArrayProcessArraysEval.java | 2 +-
.../functions/AbstractArrayProcessEval.java | 2 +-
.../functions/AbstractArraySearchEval.java | 2 +-
.../functions/AbstractBinaryStringBoolEval.java | 2 +-
.../functions/AbstractBinaryStringEval.java | 2 +-
.../functions/AbstractBinaryStringIntEval.java | 2 +-
.../functions/AbstractBinaryStringStringEval.java | 2 +-
.../functions/AbstractConcatStringEval.java | 2 +-
.../functions/AbstractNumericArithmeticEval.java | 2 +-
.../functions/AbstractQuadStringStringEval.java | 2 +-
.../AbstractStringStringStringIntEval.java | 2 +-
.../functions/AbstractTripleStringBoolEval.java | 2 +-
.../functions/AbstractTripleStringEval.java | 2 +-
.../functions/AbstractTripleStringIntEval.java | 2 +-
.../functions/AbstractTripleStringStringEval.java | 2 +-
.../AbstractUnaryNumericDoubleFunctionEval.java | 2 +-
.../AbstractUnaryNumericFunctionEval.java | 2 +-
.../functions/AbstractUnaryStringStringEval.java | 2 +-
.../evaluators/functions/AndDescriptor.java | 2 +-
.../functions/AnyCollectionMemberDescriptor.java | 2 +-
.../functions/ArrayAppendDescriptor.java | 2 +-
.../functions/ArrayBinarySearchDescriptor.java | 2 +-
.../functions/ArrayConcatDescriptor.java | 2 +-
.../functions/ArrayContainsDescriptor.java | 2 +-
.../functions/ArrayDistinctDescriptor.java | 2 +-
.../functions/ArrayExceptDescriptor.java | 2 +-
.../functions/ArrayFlattenDescriptor.java | 2 +-
.../functions/ArrayIfNullDescriptor.java | 2 +-
.../functions/ArrayInsertDescriptor.java | 2 +-
.../functions/ArrayIntersectDescriptor.java | 2 +-
.../evaluators/functions/ArrayMoveDescriptor.java | 2 +-
.../functions/ArrayPositionDescriptor.java | 2 +-
.../functions/ArrayPrependDescriptor.java | 2 +-
.../evaluators/functions/ArrayPutDescriptor.java | 2 +-
.../evaluators/functions/ArrayRangeEvaluator.java | 2 +-
.../functions/ArrayRangeWithStepDescriptor.java | 2 +-
.../functions/ArrayRangeWithoutStepDescriptor.java | 2 +-
.../functions/ArrayRemoveDescriptor.java | 2 +-
.../functions/ArrayRepeatDescriptor.java | 2 +-
.../functions/ArrayReplaceEvaluator.java | 2 +-
.../ArrayReplaceWithMaximumDescriptor.java | 2 +-
.../ArrayReplaceWithoutMaximumDescriptor.java | 2 +-
.../functions/ArrayReverseDescriptor.java | 2 +-
.../evaluators/functions/ArraySliceEvaluator.java | 2 +-
.../ArraySliceWithEndPositionDescriptor.java | 2 +-
.../ArraySliceWithoutEndPositionDescriptor.java | 2 +-
.../evaluators/functions/ArraySortDescriptor.java | 2 +-
.../evaluators/functions/ArrayStarDescriptor.java | 2 +-
.../evaluators/functions/ArraySwapDescriptor.java | 2 +-
.../functions/ArraySymDiffDescriptor.java | 2 +-
.../evaluators/functions/ArraySymDiffEval.java | 2 +-
.../functions/ArraySymDiffnDescriptor.java | 2 +-
.../evaluators/functions/ArrayUnionDescriptor.java | 2 +-
.../functions/CastTypeEvaluatorFactory.java | 2 +-
.../functions/CastTypeLaxDescriptor.java | 2 +-
.../functions/CheckUnknownDescriptor.java | 2 +-
.../functions/CodePointToStringDescriptor.java | 2 +-
.../functions/CreateCircleDescriptor.java | 2 +-
.../evaluators/functions/CreateLineDescriptor.java | 2 +-
.../functions/CreatePointDescriptor.java | 2 +-
.../functions/CreatePolygonDescriptor.java | 2 +-
.../functions/CreateQueryUIDDescriptor.java | 2 +-
.../functions/CreateRectangleDescriptor.java | 2 +-
.../evaluators/functions/CreateUUIDDescriptor.java | 2 +-
.../functions/DecodeDataverseNameDescriptor.java | 2 +-
.../functions/DeepEqualityDescriptor.java | 2 +-
.../FullTextContainsFunctionDescriptor.java | 2 +-
.../functions/GetIntersectionDescriptor.java | 2 +-
.../evaluators/functions/GetItemDescriptor.java | 2 +-
.../functions/GetJobParameterByNameDescriptor.java | 2 +-
.../evaluators/functions/GetTypeDescriptor.java | 2 +-
.../evaluators/functions/IfInfDescriptor.java | 2 +-
.../evaluators/functions/IfMissingDescriptor.java | 2 +-
.../functions/IfMissingOrNullDescriptor.java | 2 +-
.../evaluators/functions/IfNanDescriptor.java | 2 +-
.../evaluators/functions/IfNanOrInfDescriptor.java | 2 +-
.../evaluators/functions/IfNullDescriptor.java | 2 +-
.../functions/IfSystemNullDescriptor.java | 2 +-
.../functions/InjectFailureDescriptor.java | 2 +-
.../evaluators/functions/IsArrayDescriptor.java | 2 +-
.../evaluators/functions/IsAtomicDescriptor.java | 2 +-
.../evaluators/functions/IsBinaryDescriptor.java | 2 +-
.../evaluators/functions/IsBooleanDescriptor.java | 2 +-
.../evaluators/functions/IsCircleDescriptor.java | 2 +-
.../evaluators/functions/IsDateDescriptor.java | 2 +-
.../evaluators/functions/IsDatetimeDescriptor.java | 2 +-
.../evaluators/functions/IsDurationDescriptor.java | 2 +-
.../evaluators/functions/IsIntervalDescriptor.java | 2 +-
.../evaluators/functions/IsLineDescriptor.java | 2 +-
.../evaluators/functions/IsMissingDescriptor.java | 2 +-
.../evaluators/functions/IsMultisetDescriptor.java | 2 +-
.../evaluators/functions/IsNullDescriptor.java | 2 +-
.../evaluators/functions/IsNumberDescriptor.java | 2 +-
.../IsNumericAddCompatibleDescriptor.java | 2 +-
.../evaluators/functions/IsObjectDescriptor.java | 2 +-
.../evaluators/functions/IsPointDescriptor.java | 2 +-
.../evaluators/functions/IsPolygonDescriptor.java | 2 +-
.../functions/IsRectangleDescriptor.java | 2 +-
.../evaluators/functions/IsSpatialDescriptor.java | 2 +-
.../evaluators/functions/IsStringDescriptor.java | 2 +-
.../functions/IsSystemNullDescriptor.java | 2 +-
.../evaluators/functions/IsTemporalDescriptor.java | 2 +-
.../evaluators/functions/IsTimeDescriptor.java | 2 +-
.../evaluators/functions/IsUUIDDescriptor.java | 2 +-
.../evaluators/functions/IsUnknownDescriptor.java | 2 +-
.../evaluators/functions/LenDescriptor.java | 2 +-
.../evaluators/functions/NotDescriptor.java | 2 +-
.../functions/NumericACosDescriptor.java | 2 +-
.../functions/NumericASinDescriptor.java | 2 +-
.../functions/NumericATan2Descriptor.java | 2 +-
.../functions/NumericATanDescriptor.java | 2 +-
.../evaluators/functions/NumericAbsDescriptor.java | 2 +-
.../evaluators/functions/NumericAddDescriptor.java | 2 +-
.../functions/NumericCeilingDescriptor.java | 2 +-
.../evaluators/functions/NumericCosDescriptor.java | 2 +-
.../functions/NumericCoshDescriptor.java | 2 +-
.../functions/NumericDegreesDescriptor.java | 2 +-
.../evaluators/functions/NumericDivDescriptor.java | 2 +-
.../functions/NumericDivideDescriptor.java | 2 +-
.../evaluators/functions/NumericExpDescriptor.java | 2 +-
.../functions/NumericFloorDescriptor.java | 2 +-
.../evaluators/functions/NumericLnDescriptor.java | 2 +-
.../evaluators/functions/NumericLogDescriptor.java | 2 +-
.../functions/NumericModuloDescriptor.java | 2 +-
.../functions/NumericMultiplyDescriptor.java | 2 +-
.../functions/NumericPowerDescriptor.java | 2 +-
.../functions/NumericRadiansDescriptor.java | 2 +-
.../functions/NumericRoundDescriptor.java | 2 +-
.../functions/NumericRoundEvaluator.java | 2 +-
.../NumericRoundHalfToEven2Descriptor.java | 2 +-
.../NumericRoundHalfToEvenDescriptor.java | 2 +-
.../functions/NumericRoundHalfUp2Descriptor.java | 2 +-
.../functions/NumericRoundTruncEvaluator.java | 2 +-
.../NumericRoundWithRoundDigitDescriptor.java | 2 +-
.../functions/NumericSignDescriptor.java | 2 +-
.../evaluators/functions/NumericSinDescriptor.java | 2 +-
.../functions/NumericSinhDescriptor.java | 2 +-
.../functions/NumericSqrtDescriptor.java | 2 +-
.../evaluators/functions/NumericSubDescriptor.java | 2 +-
.../functions/NumericSubtractDescriptor.java | 2 +-
.../evaluators/functions/NumericTanDescriptor.java | 2 +-
.../functions/NumericTanhDescriptor.java | 2 +-
.../functions/NumericTruncDescriptor.java | 2 +-
.../functions/NumericUnaryMinusDescriptor.java | 2 +-
.../runtime/evaluators/functions/OrDescriptor.java | 2 +-
.../evaluators/functions/RandomDescriptor.java | 2 +-
.../functions/RandomWithSeedDescriptor.java | 2 +-
.../functions/ReferenceTileDescriptor.java | 2 +-
.../functions/SerializedSizeDescriptor.java | 2 +-
.../evaluators/functions/SleepDescriptor.java | 2 +-
.../functions/SpatialAreaDescriptor.java | 2 +-
.../functions/SpatialCellDescriptor.java | 2 +-
.../functions/SpatialDistanceDescriptor.java | 2 +-
.../functions/SpatialIntersectDescriptor.java | 2 +-
.../functions/StringConcatDescriptor.java | 2 +-
.../functions/StringContainsDescriptor.java | 2 +-
.../functions/StringEndsWithDescriptor.java | 2 +-
.../functions/StringEqualDescriptor.java | 2 +-
.../functions/StringInitCapDescriptor.java | 2 +-
.../evaluators/functions/StringJoinDescriptor.java | 2 +-
.../functions/StringLTrim2Descriptor.java | 2 +-
.../functions/StringLTrimDescriptor.java | 2 +-
.../functions/StringLengthDescriptor.java | 2 +-
.../evaluators/functions/StringLikeDescriptor.java | 2 +-
.../functions/StringLowerCaseDescriptor.java | 2 +-
.../functions/StringPositionDescriptor.java | 2 +-
.../functions/StringPositionOffset1Descriptor.java | 2 +-
.../functions/StringRTrim2Descriptor.java | 2 +-
.../functions/StringRTrimDescriptor.java | 2 +-
.../functions/StringRegExpContainsDescriptor.java | 2 +-
.../StringRegExpContainsWithFlagDescriptor.java | 2 +-
.../functions/StringRegExpLikeDescriptor.java | 2 +-
.../StringRegExpLikeWithFlagDescriptor.java | 2 +-
.../functions/StringRegExpMatchesDescriptor.java | 2 +-
.../functions/StringRegExpPositionDescriptor.java | 2 +-
.../StringRegExpPositionOffset1Descriptor.java | 2 +-
...ingRegExpPositionOffset1WithFlagDescriptor.java | 2 +-
.../StringRegExpPositionWithFlagDescriptor.java | 2 +-
.../functions/StringRegExpReplaceDescriptor.java | 2 +-
.../StringRegExpReplaceWithFlagDescriptor.java | 2 +-
.../functions/StringRegExpSplitDescriptor.java | 2 +-
.../functions/StringRepeatDescriptor.java | 2 +-
.../functions/StringReplaceDescriptor.java | 2 +-
.../StringReplaceWithLimitDescriptor.java | 2 +-
.../functions/StringReverseDescriptor.java | 2 +-
.../functions/StringSplitDescriptor.java | 2 +-
.../functions/StringStartsWithDescriptor.java | 2 +-
.../functions/StringToCodePointDescriptor.java | 2 +-
.../functions/StringTrim2Descriptor.java | 2 +-
.../evaluators/functions/StringTrimDescriptor.java | 2 +-
.../functions/StringUpperCaseDescriptor.java | 2 +-
.../evaluators/functions/Substring2Descriptor.java | 2 +-
.../evaluators/functions/Substring2Eval.java | 2 +-
.../functions/Substring2Offset1Descriptor.java | 2 +-
.../functions/SubstringAfterDescriptor.java | 2 +-
.../functions/SubstringBeforeDescriptor.java | 2 +-
.../evaluators/functions/SubstringDescriptor.java | 2 +-
.../evaluators/functions/SubstringEval.java | 2 +-
.../functions/SubstringOffset1Descriptor.java | 2 +-
.../evaluators/functions/SwitchCaseDescriptor.java | 2 +-
.../evaluators/functions/ToArrayDescriptor.java | 2 +-
.../evaluators/functions/ToAtomicDescriptor.java | 2 +-
.../evaluators/functions/ToBigIntDescriptor.java | 2 +-
.../evaluators/functions/ToBooleanDescriptor.java | 2 +-
.../evaluators/functions/ToDoubleDescriptor.java | 2 +-
.../evaluators/functions/ToNumberDescriptor.java | 2 +-
.../evaluators/functions/ToObjectDescriptor.java | 2 +-
.../functions/ToObjectVarStrDescriptor.java | 2 +-
.../evaluators/functions/ToStringDescriptor.java | 2 +-
.../functions/TreatAsIntegerDescriptor.java | 2 +-
.../evaluators/functions/UUIDDescriptor.java | 2 +-
.../binary/AbstractBinaryScalarEvaluator.java | 2 +-
.../binary/AbstractFindBinaryEvaluator.java | 2 +-
.../binary/AbstractSubBinaryEvaluator.java | 2 +-
.../functions/binary/BinaryConcatDescriptor.java | 2 +-
.../functions/binary/BinaryLengthDescriptor.java | 2 +-
.../functions/binary/FindBinaryDescriptor.java | 2 +-
.../functions/binary/FindBinaryFromDescriptor.java | 2 +-
.../functions/binary/ParseBinaryDescriptor.java | 2 +-
.../functions/binary/PrintBinaryDescriptor.java | 2 +-
.../functions/binary/SubBinaryFromDescriptor.java | 2 +-
.../binary/SubBinaryFromToDescriptor.java | 2 +-
.../AbstractBitMultipleValuesEvaluator.java | 2 +-
.../bitwise/AbstractBitSingleValueEvaluator.java | 2 +-
.../bitwise/AbstractBitValuePositionEvaluator.java | 2 +-
.../functions/bitwise/BitAndDescriptor.java | 2 +-
.../functions/bitwise/BitClearDescriptor.java | 2 +-
.../functions/bitwise/BitCountDescriptor.java | 2 +-
.../functions/bitwise/BitNotDescriptor.java | 2 +-
.../functions/bitwise/BitOrDescriptor.java | 2 +-
.../functions/bitwise/BitSetDescriptor.java | 2 +-
.../bitwise/BitShiftWithRotateFlagDescriptor.java | 2 +-
.../BitShiftWithoutRotateFlagDescriptor.java | 2 +-
.../bitwise/BitTestWithAllFlagDescriptor.java | 2 +-
.../bitwise/BitTestWithoutAllFlagDescriptor.java | 2 +-
.../bitwise/BitValueCountFlagEvaluator.java | 2 +-
.../bitwise/BitValuePositionFlagEvaluator.java | 2 +-
.../functions/bitwise/BitXorDescriptor.java | 2 +-
.../bitwise/IsBitSetWithAllFlagDescriptor.java | 2 +-
.../bitwise/IsBitSetWithoutAllFlagDescriptor.java | 2 +-
.../records/FieldAccessByIndexEvalFactory.java | 2 +-
.../records/FieldAccessByNameEvalFactory.java | 2 +-
.../records/FieldAccessNestedEvalFactory.java | 2 +-
.../records/GetRecordFieldValueEvalFactory.java | 2 +-
.../records/GetRecordFieldsEvalFactory.java | 2 +-
.../functions/records/PairsDescriptor.java | 2 +-
.../records/PutAutogeneratedKeyDescriptor.java | 2 +-
.../records/PutAutogeneratedKeyEvaluator.java | 2 +-
.../functions/records/RecordAddDescriptor.java | 2 +-
.../records/RecordAddFieldsDescriptor.java | 2 +-
.../functions/records/RecordConcatEvalFactory.java | 2 +-
.../functions/records/RecordLengthDescriptor.java | 2 +-
.../functions/records/RecordMergeDescriptor.java | 2 +-
.../functions/records/RecordMergeEvaluator.java | 2 +-
.../RecordMergeIgnoreDuplicatesDescriptor.java | 2 +-
.../functions/records/RecordNamesDescriptor.java | 2 +-
.../functions/records/RecordPairsDescriptor.java | 2 +-
.../functions/records/RecordPutDescriptor.java | 2 +-
.../functions/records/RecordRemoveDescriptor.java | 2 +-
.../records/RecordRemoveFieldsEvalFactory.java | 2 +-
.../functions/records/RecordRenameDescriptor.java | 2 +-
.../functions/records/RecordReplaceDescriptor.java | 2 +-
.../functions/records/RecordUnwrapDescriptor.java | 2 +-
.../functions/records/RecordValuesDescriptor.java | 2 +-
.../temporal/AbstractCurrentDateEval.java | 2 +-
.../temporal/AbstractCurrentDateTimeEval.java | 2 +-
.../temporal/AbstractCurrentTemporalValueEval.java | 2 +-
.../temporal/AbstractCurrentTimeEval.java | 2 +-
.../AbstractIntervalLogicFuncDescriptor.java | 2 +-
.../AdjustDateTimeForTimeZoneDescriptor.java | 2 +-
.../temporal/AdjustTimeForTimeZoneDescriptor.java | 2 +-
.../CalendarDurationFromDateDescriptor.java | 2 +-
.../CalendarDurationFromDateTimeDescriptor.java | 2 +-
.../functions/temporal/CurrentDateDescriptor.java | 2 +-
.../functions/temporal/CurrentDateEval.java | 2 +-
.../temporal/CurrentDateImmediateDescriptor.java | 2 +-
.../temporal/CurrentDateImmediateEval.java | 2 +-
.../temporal/CurrentDateTimeDescriptor.java | 2 +-
.../functions/temporal/CurrentDateTimeEval.java | 2 +-
.../CurrentDateTimeImmediateDescriptor.java | 2 +-
.../temporal/CurrentDateTimeImmediateEval.java | 2 +-
.../functions/temporal/CurrentTimeDescriptor.java | 2 +-
.../functions/temporal/CurrentTimeEval.java | 2 +-
.../temporal/CurrentTimeImmediateDescriptor.java | 2 +-
.../temporal/CurrentTimeImmediateEval.java | 2 +-
.../temporal/DateFromDatetimeDescriptor.java | 2 +-
.../temporal/DateFromUnixTimeInDaysDescriptor.java | 2 +-
.../DatetimeFromDateAndTimeDescriptor.java | 2 +-
.../DatetimeFromUnixTimeInMsDescriptor.java | 2 +-
.../DatetimeFromUnixTimeInMsWithTzDescriptor.java | 2 +-
.../DatetimeFromUnixTimeInSecsDescriptor.java | 2 +-
...DatetimeFromUnixTimeInSecsWithTzDescriptor.java | 2 +-
.../functions/temporal/DayOfWeek2Descriptor.java | 2 +-
.../functions/temporal/DayOfWeekDescriptor.java | 2 +-
.../functions/temporal/DayOfYearDescriptor.java | 2 +-
.../DayTimeDurationComparatorDescriptor.java | 2 +-
.../temporal/DurationEqualDescriptor.java | 2 +-
.../temporal/DurationFromIntervalDescriptor.java | 2 +-
.../DurationFromMillisecondsDescriptor.java | 2 +-
.../temporal/DurationFromMonthsDescriptor.java | 2 +-
.../temporal/GetDayTimeDurationDescriptor.java | 2 +-
.../temporal/GetOverlappingIntervalDescriptor.java | 2 +-
.../temporal/GetYearMonthDurationDescriptor.java | 2 +-
.../functions/temporal/IntervalBinDescriptor.java | 2 +-
.../MillisecondsFromDayTimeDurationDescriptor.java | 2 +-
.../MonthsFromYearMonthDurationDescriptor.java | 2 +-
.../functions/temporal/OverlapBinsDescriptor.java | 2 +-
.../functions/temporal/ParseDateDescriptor.java | 2 +-
.../temporal/ParseDateTimeDescriptor.java | 2 +-
.../functions/temporal/ParseTimeDescriptor.java | 2 +-
.../functions/temporal/PrintDateDescriptor.java | 2 +-
.../temporal/PrintDateTimeDescriptor.java | 2 +-
.../functions/temporal/PrintTimeDescriptor.java | 2 +-
.../temporal/QuarterOfYearDescriptor.java | 2 +-
.../temporal/TimeFromDatetimeDescriptor.java | 2 +-
.../temporal/TimeFromUnixTimeInMsDescriptor.java | 2 +-
.../temporal/UnixTimeFromDateInDaysDescriptor.java | 2 +-
.../temporal/UnixTimeFromDateInMsDescriptor.java | 2 +-
.../UnixTimeFromDatetimeInMsDescriptor.java | 2 +-
.../UnixTimeFromDatetimeInMsWithTzDescriptor.java | 2 +-
.../UnixTimeFromDatetimeInSecsDescriptor.java | 2 +-
...UnixTimeFromDatetimeInSecsWithTzDescriptor.java | 2 +-
.../temporal/UnixTimeFromTimeInMsDescriptor.java | 2 +-
.../functions/temporal/WeekOfYear2Descriptor.java | 2 +-
.../functions/temporal/WeekOfYearDescriptor.java | 2 +-
.../YearMonthDurationComparatorDescriptor.java | 2 +-
.../LSMPrimaryInsertOperatorNodePushable.java | 4 +-
.../std/DenseRankRunningAggregateDescriptor.java | 2 +-
.../std/NtileRunningAggregateDescriptor.java | 2 +-
.../std/PercentRankRunningAggregateDescriptor.java | 2 +-
.../std/RankRunningAggregateDescriptor.java | 2 +-
.../std/RowNumberRunningAggregateDescriptor.java | 2 +-
.../SampleSlotRunningAggregateFunctionFactory.java | 2 +-
.../std/TidRunningAggregateDescriptor.java | 2 +-
...MarkFirstMissingRunningAggregateDescriptor.java | 2 +-
...WinMarkFirstNullRunningAggregateDescriptor.java | 2 +-
.../WinPartitionLenRunningAggregateDescriptor.java | 2 +-
.../unnestingfunctions/std/RangeDescriptor.java | 2 +-
.../std/ScanCollectionDescriptor.java | 2 +-
.../std/SpatialTileDescriptor.java | 2 +-
.../std/SubsetCollectionDescriptor.java | 2 +-
.../runtime/writer/IExternalPrinterFactory.java | 4 +-
asterixdb/asterix-server/pom.xml | 11 +
asterixdb/asterix-spidersilk/pom.xml | 12 +
asterixdb/asterix-test-framework/pom.xml | 7 +
asterixdb/asterix-tools/pom.xml | 11 +
asterixdb/asterix-transactions/pom.xml | 8 +
.../PersistentLocalResourceRepository.java | 21 +-
asterixdb/pom.xml | 145 +-
.../common/exceptions/AlgebricksException.java | 4 +
.../algebricks/algebricks-compiler/pom.xml | 9 +
.../core/algebra/metadata/IMetadataProvider.java | 3 +
.../physical/AbstractHashJoinPOperator.java | 66 +-
.../AbstractPreSortedDistinctByPOperator.java | 8 +-
.../AbstractPreclusteredGroupByPOperator.java | 6 +-
.../physical/AbstractWindowPOperator.java | 8 +-
.../physical/ExternalGroupByPOperator.java | 10 +-
.../operators/physical/SinkWritePOperator.java | 9 +-
.../IPartitioningRequirementsCoordinator.java | 54 +-
.../core/algebra/util/OperatorPropertiesUtil.java | 11 +
.../hyracks/algebricks/data/IAWriterFactory.java | 3 +-
.../hyracks/algebricks/data/IPrinterFactory.java | 4 +-
.../data/impl/IntegerPrinterFactory.java | 3 +-
.../data/impl/UTF8StringPrinterFactory.java | 3 +-
.../rewriter/rules/PullSelectOutOfEqJoin.java | 7 +
.../algebricks/rewriter/util/JoinUtils.java | 42 +-
.../TupleCountAggregateFunctionFactory.java | 2 +-
.../TupleCountRunningAggregateFunctionFactory.java | 2 +-
.../runtime/base/IAggregateEvaluatorFactory.java | 1 +
.../base/IRunningAggregateEvaluatorFactory.java | 1 +
.../runtime/base/IScalarEvaluatorFactory.java | 1 +
.../base/ISerializedAggregateEvaluatorFactory.java | 1 +
.../runtime/base/IUnnestingEvaluatorFactory.java | 1 +
.../evaluators/ColumnAccessEvalFactory.java | 2 +-
.../runtime/evaluators/ConstantEvalFactory.java | 2 +-
.../runtime/evaluators/EvaluatorContext.java | 2 +-
.../evaluators/TupleFieldEvaluatorFactory.java | 2 +-
.../evaluators/TuplePairEvaluatorFactory.java | 2 +-
.../operators/aggreg/AggregatePushRuntime.java | 2 +-
.../SerializableAggregatorDescriptorFactory.java | 2 +-
...pleAlgebricksAccumulatingAggregatorFactory.java | 2 +-
.../AbstractRunningAggregatePushRuntime.java | 2 +-
.../base/AbstractOneInputPushRuntime.java | 3 +-
.../operators/std/AssignRuntimeFactory.java | 4 +-
.../operators/std/PrinterRuntimeFactory.java | 2 +-
.../operators/std/SinkWriterRuntimeFactory.java | 2 +-
.../operators/std/SplitOperatorDescriptor.java | 2 +-
.../operators/std/StreamLimitRuntimeFactory.java | 2 +-
.../operators/std/StreamSelectRuntimeFactory.java | 2 +-
.../std/StringStreamingRuntimeFactory.java | 5 +-
.../operators/std/SwitchOperatorDescriptor.java | 2 +-
.../operators/std/UnnestRuntimeFactory.java | 2 +-
.../win/AbstractWindowNestedPlansPushRuntime.java | 2 +-
.../ResultSerializerFactoryProvider.java | 6 +-
.../runtime/writers/PrinterBasedWriterFactory.java | 8 +-
.../writers/SerializedDataWriterFactory.java | 5 +-
.../algebricks/algebricks-tests/pom.xml | 4 +
.../tests/pushruntime/IntArrayUnnester.java | 5 +-
.../tests/pushruntime/IntegerAddEvalFactory.java | 2 +-
.../pushruntime/IntegerConstantEvalFactory.java | 2 +-
.../pushruntime/IntegerEqualsEvalFactory.java | 2 +-
.../pushruntime/IntegerGreaterThanEvalFactory.java | 2 +-
hyracks-fullstack/hyracks/hyracks-api/pom.xml | 4 +
.../hyracks/api/context}/IEvaluatorContext.java | 3 +-
.../dataflow/value/IResultSerializerFactory.java | 5 +-
.../api/exceptions/HyracksDataException.java | 4 +-
.../hyracks/api/exceptions/HyracksException.java | 4 +
.../runtime/SuperActivityOperatorNodePushable.java | 65 +-
.../org/apache/hyracks/api/util/CleanupUtils.java | 4 +-
.../apache/hyracks/api/util/ExceptionUtils.java | 3 +
.../org/apache/hyracks/api/util/InvokeUtil.java | 33 +
hyracks-fullstack/hyracks/hyracks-client/pom.xml | 4 +
.../cloud/util/CloudRetryableRequestUtil.java | 14 +-
.../hyracks-control/hyracks-control-cc/pom.xml | 7 +-
.../hyracks-control/hyracks-control-common/pom.xml | 9 +
.../hyracks-control/hyracks-nc-service/pom.xml | 9 +
.../hyracks/hyracks-data/hyracks-data-std/pom.xml | 10 +
.../hyracks/hyracks-dataflow-common/pom.xml | 9 +
.../hyracks/hyracks-dataflow-std/pom.xml | 9 +
.../std/result/ResultWriterOperatorDescriptor.java | 2 +-
.../examples/btree/helper/RuntimeContext.java | 2 +-
.../hyracks-integration-tests/pom.xml | 4 +
.../util/ResultSerializerFactoryProvider.java | 5 +-
hyracks-fullstack/hyracks/hyracks-hdfs/pom.xml | 4 +
hyracks-fullstack/hyracks/hyracks-ipc/pom.xml | 9 +
hyracks-fullstack/hyracks/hyracks-net/pom.xml | 9 +
.../hyracks/hyracks-storage-am-btree/pom.xml | 9 +
.../hyracks/hyracks-storage-am-common/pom.xml | 4 +
.../storage/am/common/build/IndexBuilder.java | 7 +-
.../am/common/dataflow/IndexDataflowHelper.java | 59 +-
.../am/common/dataflow/IndexLifecycleManager.java | 62 +-
.../am/lsm/common/api/LSMOperationType.java | 3 +-
.../lsm/common/impls/AbstractLSMDiskComponent.java | 2 +
.../common/impls/AbstractLSMMemoryComponent.java | 19 +
.../storage/am/lsm/common/impls/LSMHarness.java | 10 +-
.../storage/common/ILocalResourceRepository.java | 8 +
.../storage/common/IResourceLifecycleManager.java | 15 +-
.../common/TransientLocalResourceRepository.java | 9 +
.../hyracks/test/support/TestStorageManager.java | 2 +-
.../support/TestStorageManagerComponentHolder.java | 4 +-
.../hyracks/util/InterruptableBiFunction.java | 31 +-
.../main/java/org/apache/hyracks/util/Span.java | 38 +
hyracks-fullstack/pom.xml | 56 +-
1444 files changed, 9912 insertions(+), 3654 deletions(-)
copy
hyracks-fullstack/algebricks/algebricks-data/src/main/java/org/apache/hyracks/algebricks/data/IPrinterFactory.java
=>
asterixdb/asterix-app/src/test/resources/optimizerts/queries/ASTERIXDB-3580.sqlpp
(82%)
copy
asterixdb/asterix-app/src/test/resources/{runtimets/queries_sqlpp/copy-to/csv/type-mismatch/type-mismatch.02.update.sqlpp
=> optimizerts/queries/joins/ASTERIXDB-3572-1-equi-non-equi-condition.sqlpp}
(69%)
copy
asterixdb/asterix-app/src/test/resources/{runtimets/queries_sqlpp/copy-to/csv/type-mismatch/type-mismatch.02.update.sqlpp
=> optimizerts/queries/joins/ASTERIXDB-3572-2-equi-non-equi-condition.sqlpp}
(70%)
rename
asterixdb/asterix-app/src/test/resources/optimizerts/queries/{pull_select_above_eq_join.sqlpp
=> keep_pred_in_join.sqlpp} (100%)
copy
asterixdb/{asterix-runtime/src/main/java/org/apache/asterix/runtime/writer/IExternalPrinterFactory.java
=>
asterix-app/src/test/resources/optimizerts/queries/query-ASTERIXDB-3562.sqlpp}
(67%)
rename
asterixdb/asterix-app/src/test/resources/optimizerts/queries_sqlpp/{pull_select_above_eq_join.sqlpp
=> keep_pred_in_join.sqlpp} (100%)
create mode 100644
asterixdb/asterix-app/src/test/resources/optimizerts/results/ASTERIXDB-3580.plan
create mode 100644
asterixdb/asterix-app/src/test/resources/optimizerts/results/joins/ASTERIXDB-3572-1-equi-non-equi-condition.plan
create mode 100644
asterixdb/asterix-app/src/test/resources/optimizerts/results/joins/ASTERIXDB-3572-2-equi-non-equi-condition.plan
copy
asterixdb/asterix-app/src/test/resources/optimizerts/results/{collocated.plan
=> keep_pred_in_join.plan} (54%)
delete mode 100644
asterixdb/asterix-app/src/test/resources/optimizerts/results/pull_select_above_eq_join.plan
create mode 100644
asterixdb/asterix-app/src/test/resources/optimizerts/results/query-ASTERIXDB-3562.plan
create mode 100644
asterixdb/asterix-app/src/test/resources/optimizerts/results_cbo/ASTERIXDB-3580.plan
rename
asterixdb/asterix-app/src/test/resources/optimizerts/results_parser_sqlpp/{pull_select_above_eq_join.ast
=> keep_pred_in_join.ast} (100%)
copy
asterixdb/{asterix-om/src/main/java/org/apache/asterix/dataflow/data/nontagged/printers/adm/ANullPrinterFactory.java
=>
asterix-app/src/test/resources/runtimets/queries_sqlpp/column/filter/ASTERIXDB-3582-2/ASTERIXDB-3582-2.001.ddl.sqlpp}
(55%)
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/column/filter/ASTERIXDB-3582-2/ASTERIXDB-3582-2.002.update.sqlpp
copy
hyracks-fullstack/algebricks/algebricks-data/src/main/java/org/apache/hyracks/algebricks/data/IPrinterFactory.java
=>
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/column/filter/ASTERIXDB-3582-2/ASTERIXDB-3582-2.003.query.sqlpp
(79%)
copy
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/{subquery/not_in/not_in.2.update.sqlpp
=> column/filter/ASTERIXDB-3582-2/ASTERIXDB-3582-2.004.query.sqlpp} (86%)
copy
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/{subquery/not_in/not_in.2.update.sqlpp
=> column/filter/ASTERIXDB-3582-2/ASTERIXDB-3582-2.005.query.sqlpp} (86%)
copy
hyracks-fullstack/algebricks/algebricks-data/src/main/java/org/apache/hyracks/algebricks/data/IPrinterFactory.java
=>
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/column/filter/ASTERIXDB-3582-2/ASTERIXDB-3582-2.006.query.sqlpp
(81%)
copy
asterixdb/{asterix-common/src/main/java/org/apache/asterix/common/dataflow/IDataPartitioningProvider.java
=>
asterix-app/src/test/resources/runtimets/queries_sqlpp/column/filter/ASTERIXDB-3582-2/ASTERIXDB-3582-2.007.query.sqlpp}
(70%)
copy
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/{copy-to/csv/type-mismatch/type-mismatch.02.update.sqlpp
=> column/filter/ASTERIXDB-3582/ASTERIXDB-3582.001.ddl.sqlpp} (53%)
copy
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/{subquery/not_in/not_in.2.update.sqlpp
=> column/filter/ASTERIXDB-3582/ASTERIXDB-3582.002.query.sqlpp} (93%)
copy
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/copy-to/csv/{type-mismatch/type-mismatch.02.update.sqlpp
=> negative/test.000.update.sqlpp} (68%)
copy
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/copy-to/csv/{type-mismatch/type-mismatch.02.update.sqlpp
=> negative/test.001.update.sqlpp} (68%)
copy
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/copy-to/csv/{type-mismatch/type-mismatch.02.update.sqlpp
=> negative/test.002.update.sqlpp} (68%)
copy
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/{subquery/not_in/not_in.2.update.sqlpp
=>
external-dataset/common/deltalake-partitioned-file-read/deltalake-partitioned-file-read.02.query.sqlpp}
(83%)
copy
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/{subquery/not_in/not_in.2.update.sqlpp
=>
external-dataset/common/deltalake-partitioned-file-read/deltalake-partitioned-file-read.03.query.sqlpp}
(85%)
copy
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/{subquery/not_in/not_in.2.update.sqlpp
=>
external-dataset/common/deltalake-partitioned-file-read/deltalake-partitioned-file-read.04.query.sqlpp}
(85%)
copy
hyracks-fullstack/algebricks/algebricks-data/src/main/java/org/apache/hyracks/algebricks/data/IPrinterFactory.java
=>
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/external-dataset/common/deltalake-partitioned-file-read/deltalake-partitioned-file-read.05.query.sqlpp
(82%)
copy
hyracks-fullstack/algebricks/algebricks-data/src/main/java/org/apache/hyracks/algebricks/data/IPrinterFactory.java
=>
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/external-dataset/common/deltalake-partitioned-file-read/deltalake-partitioned-file-read.06.query.sqlpp
(80%)
copy
hyracks-fullstack/algebricks/algebricks-data/src/main/java/org/apache/hyracks/algebricks/data/IPrinterFactory.java
=>
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/external-dataset/common/deltalake-partitioned-file-read/deltalake-partitioned-file-read.07.query.sqlpp
(79%)
copy
hyracks-fullstack/algebricks/algebricks-data/src/main/java/org/apache/hyracks/algebricks/data/IPrinterFactory.java
=>
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/external-dataset/common/deltalake-partitioned-file-read/deltalake-partitioned-file-read.08.query.sqlpp
(78%)
copy
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/{subquery/not_in/not_in.2.update.sqlpp
=>
external-dataset/common/deltalake-partitioned-file-read/deltalake-partitioned-file-read.09.query.sqlpp}
(86%)
copy
hyracks-fullstack/algebricks/algebricks-data/src/main/java/org/apache/hyracks/algebricks/data/IPrinterFactory.java
=>
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/join/ASTERIXDB-3572-equi-non-equi-condition/ASTERIXDB-3572-equi-non-equi-condition.01.ddl.sqlpp
(81%)
copy
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/{copy-to/csv/type-mismatch/type-mismatch.02.update.sqlpp
=>
join/ASTERIXDB-3572-equi-non-equi-condition/ASTERIXDB-3572-equi-non-equi-condition.02.update.sqlpp}
(76%)
copy
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/{copy-to/csv/type-mismatch/type-mismatch.02.update.sqlpp
=>
join/ASTERIXDB-3572-equi-non-equi-condition/ASTERIXDB-3572-equi-non-equi-condition.03.query.sqlpp}
(56%)
copy
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/{copy-to/csv/type-mismatch/type-mismatch.02.update.sqlpp
=>
join/ASTERIXDB-3572-equi-non-equi-condition/ASTERIXDB-3572-equi-non-equi-condition.04.query.sqlpp}
(56%)
copy
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/subquery/not_in/{not_in.2.update.sqlpp
=> not_in.4.query.sqlpp} (85%)
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/column/filter/ASTERIXDB-3582-2/ASTERIXDB-3582.003.adm
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/column/filter/ASTERIXDB-3582-2/ASTERIXDB-3582.004.adm
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/column/filter/ASTERIXDB-3582-2/ASTERIXDB-3582.005.plan
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/column/filter/ASTERIXDB-3582-2/ASTERIXDB-3582.006.adm
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/column/filter/ASTERIXDB-3582-2/ASTERIXDB-3582.007.plan
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/column/filter/ASTERIXDB-3582/ASTERIXDB-3582.002.plan
copy
asterixdb/asterix-app/src/test/resources/runtimets/results/external-dataset/common/deltalake-partitioned-file-read/{read-data.2.adm
=> read-data.1.adm} (100%)
copy
asterixdb/asterix-app/src/test/resources/runtimets/results/external-dataset/common/deltalake-partitioned-file-read/{read-data.2.adm
=> read-data.3.adm} (59%)
copy
asterixdb/asterix-app/src/test/resources/runtimets/results/external-dataset/common/deltalake-partitioned-file-read/{read-data.2.adm
=> read-data.4.adm} (55%)
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/external-dataset/common/deltalake-partitioned-file-read/read-data.5.adm
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/external-dataset/common/deltalake-partitioned-file-read/read-data.6.adm
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/external-dataset/common/deltalake-partitioned-file-read/read-data.7.adm
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/external-dataset/common/deltalake-partitioned-file-read/read-data.8.adm
copy
asterixdb/asterix-app/src/test/resources/runtimets/results/external-dataset/common/deltalake-partitioned-file-read/{read-data.2.adm
=> read-data.9.adm} (100%)
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/join/ASTERIXDB-3572-equi-non-equi-condition/ASTERIXDB-3572-equi-non-equi-condition.03.adm
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/join/ASTERIXDB-3572-equi-non-equi-condition/ASTERIXDB-3572-equi-non-equi-condition.04.adm
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/subquery/not_in/not_in.2.adm
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results_cbo/column/filter/ASTERIXDB-3582-2/ASTERIXDB-3582.005.plan
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results_cbo/column/filter/ASTERIXDB-3582-2/ASTERIXDB-3582.007.plan
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results_cbo/column/filter/ASTERIXDB-3582/ASTERIXDB-3582.002.plan
copy asterixdb/asterix-app/src/test/resources/runtimets/{results =>
results_cbo}/column/filter/not-in_every/not-in_every.201.plan (98%)
copy asterixdb/asterix-app/src/test/resources/runtimets/{results =>
results_full_parallelism}/cardinality-estimation/join-queries/join-queries.3.plan
(100%)
copy asterixdb/asterix-app/src/test/resources/runtimets/{results =>
results_full_parallelism}/cardinality-estimation/join-queries/join-queries.4.plan
(100%)
copy asterixdb/asterix-app/src/test/resources/runtimets/{results =>
results_full_parallelism}/cardinality-estimation/join-queries/join-queries.5.plan
(100%)
copy asterixdb/asterix-app/src/test/resources/runtimets/{results =>
results_full_parallelism}/cardinality-estimation/join-queries/join-queries.6.plan
(100%)
copy asterixdb/asterix-app/src/test/resources/runtimets/{results =>
results_full_parallelism}/cardinality-estimation/join-queries/join-queries.7.plan
(100%)
copy asterixdb/asterix-app/src/test/resources/runtimets/{results =>
results_full_parallelism}/cardinality-estimation/join-queries/join-queries.8.plan
(100%)
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results_full_parallelism/column/filter/ASTERIXDB-3582-2/ASTERIXDB-3582.007.plan
copy asterixdb/asterix-app/src/test/resources/runtimets/{results =>
results_less_parallelism}/cardinality-estimation/join-queries/join-queries.3.plan
(100%)
copy asterixdb/asterix-app/src/test/resources/runtimets/{results =>
results_less_parallelism}/cardinality-estimation/join-queries/join-queries.4.plan
(100%)
copy asterixdb/asterix-app/src/test/resources/runtimets/{results =>
results_less_parallelism}/cardinality-estimation/join-queries/join-queries.5.plan
(100%)
copy asterixdb/asterix-app/src/test/resources/runtimets/{results =>
results_less_parallelism}/cardinality-estimation/join-queries/join-queries.6.plan
(100%)
copy asterixdb/asterix-app/src/test/resources/runtimets/{results =>
results_less_parallelism}/cardinality-estimation/join-queries/join-queries.7.plan
(100%)
copy asterixdb/asterix-app/src/test/resources/runtimets/{results =>
results_less_parallelism}/cardinality-estimation/join-queries/join-queries.8.plan
(100%)
copy asterixdb/asterix-app/src/test/resources/runtimets/{results =>
results_less_parallelism}/cardinality-estimation/single-collection-queries/single-collection-queries.3.plan
(100%)
copy asterixdb/asterix-app/src/test/resources/runtimets/{results =>
results_less_parallelism}/cardinality-estimation/single-collection-queries/single-collection-queries.4.plan
(100%)
copy asterixdb/asterix-app/src/test/resources/runtimets/{results =>
results_less_parallelism}/cardinality-estimation/single-collection-queries/single-collection-queries.5.plan
(100%)
copy asterixdb/asterix-app/src/test/resources/runtimets/{results =>
results_less_parallelism}/cardinality-estimation/single-collection-queries/single-collection-queries.6.plan
(100%)
copy asterixdb/asterix-app/src/test/resources/runtimets/{results =>
results_less_parallelism}/cardinality-estimation/single-collection-queries/single-collection-queries.7.plan
(100%)
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results_less_parallelism/column/filter/ASTERIXDB-3582-2/ASTERIXDB-3582.007.plan
create mode 100644
asterixdb/asterix-common/src/test/java/org/apache/asterix/common/context/DatasetLifecycleManagerConcurrentTest.java
create mode 100644
asterixdb/asterix-common/src/test/java/org/apache/asterix/common/context/DatasetLifecycleManagerLazyRecoveryTest.java
create mode 100644
asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/aws/delta/PredicateSerDe.java
rename
hyracks-fullstack/{algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/base
=>
hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/context}/IEvaluatorContext.java
(93%)
copy
asterixdb/asterix-om/src/main/java/org/apache/asterix/dataflow/data/nontagged/printers/adm/AFloatPrinterFactory.java
=>
hyracks-fullstack/hyracks/hyracks-util/src/main/java/org/apache/hyracks/util/InterruptableBiFunction.java
(54%)
