You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by im...@apache.org on 2015/08/25 18:45:33 UTC
[51/51] [partial] incubator-asterixdb git commit: Change Java package
from edu.uci.ics to org.apache
Change Java package from edu.uci.ics to org.apache
Change-Id: I2f01d2b5614e9e9c94fda4bf1294a8eba6a26c54
Reviewed-on: https://asterix-gerrit.ics.uci.edu/309
Reviewed-by: Till Westmann <ti...@apache.org>
Tested-by: Jenkins <je...@fulliautomatix.ics.uci.edu>
Project: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/commit/f18bba26
Tree: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/tree/f18bba26
Diff: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/diff/f18bba26
Branch: refs/heads/master
Commit: f18bba26e4cdbc748399bc058540c70f5cbc9bb4
Parents: 34d8163
Author: Ian Maxon <im...@apache.org>
Authored: Fri Aug 21 12:35:14 2015 -0700
Committer: Ian Maxon <im...@apache.org>
Committed: Sat Aug 22 12:57:04 2015 -0700
----------------------------------------------------------------------
asterix-algebra/pom.xml | 14 +-
.../base/AsterixOperatorAnnotations.java | 2 +-
.../base/LogicalExpressionDeepCopyVisitor.java | 28 +-
.../base/LogicalOperatorDeepCopyVisitor.java | 90 +--
.../algebra/operators/CommitOperator.java | 12 +-
.../physical/BTreeSearchPOperator.java | 70 +-
.../operators/physical/CommitPOperator.java | 34 +-
.../operators/physical/CommitRuntime.java | 34 +-
.../physical/CommitRuntimeFactory.java | 12 +-
.../physical/ExternalDataLookupPOperator.java | 74 +-
.../physical/IndexSearchPOperator.java | 32 +-
.../physical/InvertedIndexPOperator.java | 118 ++--
.../physical/RTreeSearchPOperator.java | 48 +-
.../jobgen/AqlLogicalExpressionJobGen.java | 66 +-
.../asterix/optimizer/base/AnalysisUtil.java | 30 +-
.../asterix/optimizer/base/FuzzyUtils.java | 26 +-
.../asterix/optimizer/base/RuleCollections.java | 200 +++---
.../handle/FieldIndexAndTypeHandle.java | 4 +-
.../optimizer/handle/FieldNameHandle.java | 4 +-
.../asterix/optimizer/handle/IHandle.java | 2 +-
...quivalenceClassForRecordConstructorRule.java | 42 +-
...ixExtractFunctionsFromJoinConditionRule.java | 8 +-
.../rules/AsterixInlineVariablesRule.java | 6 +-
.../AsterixIntroduceGroupByCombinerRule.java | 26 +-
...oveFreeVariableOperatorOutOfSubplanRule.java | 6 +-
.../rules/ByNameToByHandleFieldAccessRule.java | 32 +-
.../rules/ByNameToByIndexFieldAccessRule.java | 56 +-
.../CancelUnnestWithNestedListifyRule.java | 54 +-
.../rules/CheckFilterExpressionTypeRule.java | 28 +-
.../optimizer/rules/ConstantFoldingRule.java | 102 +--
.../optimizer/rules/CountVarToCountOneRule.java | 34 +-
.../rules/DisjunctivePredicateToJoinRule.java | 54 +-
.../rules/ExtractDistinctByExpressionsRule.java | 24 +-
.../rules/ExtractOrderExpressionsRule.java | 30 +-
.../rules/FeedScanCollectionToUnnest.java | 38 +-
.../asterix/optimizer/rules/FuzzyEqRule.java | 46 +-
.../asterix/optimizer/rules/FuzzyJoinRule.java | 70 +-
.../rules/IfElseToSwitchCaseFunctionRule.java | 40 +-
.../rules/InlineUnnestFunctionRule.java | 34 +-
.../rules/IntroduceAutogenerateIDRule.java | 54 +-
...eDynamicTypeCastForExternalFunctionRule.java | 40 +-
.../rules/IntroduceDynamicTypeCastRule.java | 52 +-
.../rules/IntroduceEnforcedListTypeRule.java | 30 +-
.../IntroduceInstantLockSearchCallbackRule.java | 46 +-
...aterializationForInsertWithSelfScanRule.java | 42 +-
...ceRandomPartitioningFeedComputationRule.java | 36 +-
...troduceRapidFrameFlushProjectAssignRule.java | 26 +-
...IntroduceSecondaryIndexInsertDeleteRule.java | 98 +--
.../IntroduceStaticTypeCastForInsertRule.java | 38 +-
...ntroduceTransactionCommitByAssignOpRule.java | 24 +-
.../optimizer/rules/IntroduceUnionRule.java | 34 +-
...roduceUnnestForCollectionToSequenceRule.java | 36 +-
.../optimizer/rules/LoadRecordFieldsRule.java | 62 +-
.../optimizer/rules/NestGroupByRule.java | 42 +-
.../PullPositionalVariableFromUnnestRule.java | 32 +-
.../PushAggFuncIntoStandaloneAggregateRule.java | 40 +-
.../rules/PushAggregateIntoGroupbyRule.java | 54 +-
.../optimizer/rules/PushFieldAccessRule.java | 80 +--
.../rules/PushGroupByThroughProduct.java | 38 +-
.../rules/PushProperJoinThroughProduct.java | 26 +-
.../rules/PushSimilarityFunctionsBelowJoin.java | 8 +-
.../rules/RemoveRedundantListifyRule.java | 50 +-
.../rules/RemoveRedundantSelectRule.java | 24 +-
.../rules/RemoveSortInFeedIngestionRule.java | 20 +-
.../rules/RemoveUnusedOneToOneEquiJoinRule.java | 40 +-
.../rules/ReplaceSinkOpWithCommitOpRule.java | 38 +-
.../rules/SetAsterixPhysicalOperatorsRule.java | 78 +--
.../rules/SetClosedRecordConstructorsRule.java | 48 +-
.../optimizer/rules/SimilarityCheckRule.java | 56 +-
.../SweepIllegalNonfunctionalFunctions.java | 90 +--
.../optimizer/rules/UnnestToDataScanRule.java | 76 +--
.../am/AbstractIntroduceAccessMethodRule.java | 74 +-
.../rules/am/AccessMethodAnalysisContext.java | 12 +-
.../rules/am/AccessMethodJobGenParams.java | 16 +-
.../optimizer/rules/am/AccessMethodUtils.java | 98 +--
.../optimizer/rules/am/BTreeAccessMethod.java | 64 +-
.../optimizer/rules/am/BTreeJobGenParams.java | 10 +-
.../optimizer/rules/am/IAccessMethod.java | 16 +-
.../rules/am/IOptimizableFuncExpr.java | 12 +-
.../rules/am/IntroduceJoinAccessMethodRule.java | 38 +-
.../am/IntroduceLSMComponentFilterRule.java | 74 +-
.../am/IntroduceSelectAccessMethodRule.java | 30 +-
.../rules/am/InvertedIndexAccessMethod.java | 116 ++--
.../rules/am/InvertedIndexJobGenParams.java | 18 +-
.../optimizer/rules/am/OptimizableFuncExpr.java | 14 +-
.../rules/am/OptimizableOperatorSubTree.java | 46 +-
.../optimizer/rules/am/RTreeAccessMethod.java | 62 +-
.../optimizer/rules/am/RTreeJobGenParams.java | 8 +-
.../TranslateIntervalExpressionRule.java | 32 +-
.../rules/typecast/StaticTypeCastUtil.java | 50 +-
.../rules/util/EquivalenceClassUtils.java | 36 +-
.../translator/AbstractAqlTranslator.java | 36 +-
.../AqlExpressionToPlanTranslator.java | 290 ++++----
.../AqlPlusExpressionToPlanTranslator.java | 272 ++++----
.../asterix/translator/AqlPositionWriter.java | 6 +-
.../asterix/translator/CompiledStatements.java | 50 +-
.../asterix/translator/ConstantHelper.java | 30 +-
.../asterix/translator/TranslationContext.java | 8 +-
.../translator/TranslationException.java | 4 +-
.../asterix/translator/TypeTranslator.java | 52 +-
asterix-algebra/src/main/javacc/AQLPlus.jj | 54 +-
asterix-app/pom.xml | 34 +-
.../apache/asterix/api/common/APIFramework.java | 110 +--
.../api/common/AsterixAppRuntimeContext.java | 102 +--
...rixAppRuntimeContextProdiverForRecovery.java | 28 +-
.../asterix/api/common/AsterixClientConfig.java | 2 +-
.../common/AsterixHyracksIntegrationUtil.java | 26 +-
.../asterix/api/common/FeedWorkCollection.java | 28 +-
.../java/org/apache/asterix/api/common/Job.java | 4 +-
.../asterix/api/common/SessionConfig.java | 2 +-
.../asterix/api/http/servlet/APIServlet.java | 36 +-
.../asterix/api/http/servlet/AQLAPIServlet.java | 4 +-
.../api/http/servlet/ConnectorAPIServlet.java | 24 +-
.../asterix/api/http/servlet/DDLAPIServlet.java | 6 +-
.../asterix/api/http/servlet/FeedServlet.java | 16 +-
.../api/http/servlet/FeedServletUtil.java | 8 +-
.../api/http/servlet/HyracksProperties.java | 2 +-
.../api/http/servlet/QueryAPIServlet.java | 6 +-
.../api/http/servlet/QueryResultAPIServlet.java | 24 +-
.../api/http/servlet/QueryStatusAPIServlet.java | 18 +-
.../api/http/servlet/RESTAPIServlet.java | 40 +-
.../api/http/servlet/ShutdownAPIServlet.java | 14 +-
.../api/http/servlet/UpdateAPIServlet.java | 6 +-
.../asterix/api/java/AsterixJavaClient.java | 26 +-
.../asterix/aql/translator/AqlTranslator.java | 308 ++++-----
.../org/apache/asterix/drivers/AsterixCLI.java | 8 +-
.../asterix/drivers/AsterixClientDriver.java | 10 +-
.../asterix/drivers/AsterixWebServer.java | 4 +-
.../asterix/feeds/CentralFeedManager.java | 30 +-
.../apache/asterix/feeds/FeedCollectInfo.java | 10 +-
.../java/org/apache/asterix/feeds/FeedInfo.java | 8 +-
.../feeds/FeedJobNotificationHandler.java | 82 +--
.../org/apache/asterix/feeds/FeedJoint.java | 14 +-
.../asterix/feeds/FeedLifecycleListener.java | 76 +--
.../apache/asterix/feeds/FeedLoadManager.java | 46 +-
.../org/apache/asterix/feeds/FeedManager.java | 36 +-
.../asterix/feeds/FeedMessageReceiver.java | 30 +-
.../asterix/feeds/FeedMetadataManager.java | 28 +-
.../asterix/feeds/FeedTrackingManager.java | 14 +-
.../feeds/FeedWorkRequestResponseHandler.java | 44 +-
.../apache/asterix/feeds/FeedsActivator.java | 20 +-
.../apache/asterix/file/DatasetOperations.java | 78 +--
.../asterix/file/DataverseOperations.java | 18 +-
.../file/ExternalIndexingOperations.java | 148 ++--
.../org/apache/asterix/file/FeedOperations.java | 60 +-
.../apache/asterix/file/IndexOperations.java | 56 +-
.../asterix/file/JobSpecificationUtils.java | 8 +-
.../file/SecondaryBTreeOperationsHelper.java | 108 +--
.../file/SecondaryIndexOperationsHelper.java | 142 ++--
.../SecondaryInvertedIndexOperationsHelper.java | 102 +--
.../file/SecondaryRTreeOperationsHelper.java | 114 ++--
.../bootstrap/AsterixGlobalRecoveryManager.java | 46 +-
.../bootstrap/AsterixStateDumpHandler.java | 6 +-
.../bootstrap/CCApplicationEntryPoint.java | 56 +-
.../bootstrap/ClusterLifecycleListener.java | 28 +-
.../hyracks/bootstrap/ClusterWorkExecutor.java | 16 +-
.../bootstrap/ExternalLibraryBootstrap.java | 48 +-
.../hyracks/bootstrap/FeedBootstrap.java | 10 +-
.../bootstrap/NCApplicationEntryPoint.java | 44 +-
.../org/apache/asterix/result/ResultReader.java | 26 +-
.../org/apache/asterix/result/ResultUtils.java | 24 +-
.../ConstantTupleSourceOperatorDescriptor.java | 16 +-
...ConstantTupleSourceOperatorNodePushable.java | 12 +-
.../resources/hyracks-deployment.properties | 4 +-
.../http/servlet/ConnectorAPIServletTest.java | 34 +-
.../apache/asterix/test/aql/AQLTestCase.java | 14 +-
.../apache/asterix/test/aql/AQLTestSuite.java | 4 +-
.../apache/asterix/test/common/TestHelper.java | 2 +-
.../org/apache/asterix/test/dml/DmlTest.java | 12 +-
.../asterix/test/metadata/MetadataTest.java | 14 +-
.../asterix/test/optimizer/OptimizerTest.java | 22 +-
.../asterix/test/runtime/ExecutionTest.java | 18 +-
.../asterix/test/runtime/HDFSCluster.java | 4 +-
.../asterix/test/runtime/RepeatedTest.java | 8 +-
.../test/resources/AQLTS/queries/IfThenElse.aql | 6 +-
.../AQLTS/queries/load-del-dataset.aql | 2 +-
asterix-app/src/test/resources/dapd/q2.aql | 2 +-
.../resources/demo0216/01-load-dblp-large.aql | 2 +-
.../resources/demo0216/03-load-dblp-small.aql | 2 +-
.../test/resources/demo0927/local/load-cust.aql | 2 +-
.../test/resources/demo0927/local/load-ord.aql | 2 +-
.../resources/demo1112/local/01-load-cust.aql | 2 +-
.../resources/demo1112/local/03-load-ord.aql | 2 +-
.../resources/demo_aql/local/01-load-cust.aql | 2 +-
.../resources/demo_aql/local/04-load-ord.aql | 2 +-
.../resources/demo_aql/local/101-load-dblp.aql | 2 +-
.../test/resources/dmlts/scripts/load-cust.aql | 2 +-
.../fuzzyjoin/amerix/10-load-csx-small.aql | 2 +-
.../resources/fuzzyjoin/amerix/10-load-csx.aql | 2 +-
.../resources/fuzzyjoin/amerix/10-load-dblp.aql | 2 +-
.../resources/fuzzyjoin/dblp/000-1-char-at.aql | 18 +-
.../test/resources/fuzzyjoin/dblp/010-load.aql | 2 +-
.../resources/fuzzyjoin/pub/010-load-dblp.aql | 2 +-
.../resources/fuzzyjoin/pub/040-load-csx.aql | 2 +-
.../fuzzyjoin/pub/fuzzy-join-aql-plus.json | 192 +++---
.../resources/fuzzyjoin/pub/fuzzy-join-aql.json | 196 +++---
.../fuzzyjoin/users-visitors/010-load-users.aql | 2 +-
.../users-visitors/040-load-visitors.aql | 2 +-
.../resources/hyracks-deployment.properties | 4 +-
.../integration/updates/load-dataset.aql | 2 +-
.../src/test/resources/logging.properties | 12 +-
.../check-state-results/check_dataverse.adm | 4 +-
.../issue_255_create_feed_error.1.ddl.aql | 2 +-
.../resources/metadata/results/basic/meta01.adm | 4 +-
.../metadata/results/basic/meta01/meta01.1.adm | 4 +-
.../resources/metadata/results/basic/meta15.adm | 22 +-
.../metadata/results/basic/meta15/meta15.1.adm | 24 +-
.../resources/metadata/results/basic/meta18.adm | 2 +-
.../metadata/results/basic/meta18/meta18.1.adm | 6 +-
.../metadata_compaction_policy.1.adm | 8 +-
.../results/basic/metadata_dataverse.adm | 2 +-
.../metadata_dataverse/metadata_dataverse.1.adm | 6 +-
.../results/custord/custord_dataverse.adm | 2 +-
.../metadata/results/custord/custord_q10.adm | 4 +-
.../src/test/resources/metadata/testsuite.xml | 28 +-
.../nontagged/custord/local/all-drop.aql | 2 +-
.../nontagged/custord/local/all-load.aql | 2 +-
.../nontagged/custord/local/all-scan.aql | 2 +-
.../nontagged/custord/local/cust-drop.aql | 2 +-
.../nontagged/custord/local/cust-load.aql | 2 +-
.../nontagged/custord/local/cust-q1.aql | 2 +-
.../nontagged/custord/local/cust-scan.aql | 2 +-
.../nontagged/custord/local/emp-drop.aql | 2 +-
.../nontagged/custord/local/emp-load.aql | 2 +-
.../nontagged/custord/local/emp-q1.aql | 2 +-
.../nontagged/custord/local/emp-scan.aql | 2 +-
.../nontagged/custord/local/join-01.aql | 2 +-
.../nontagged/custord/local/join-02.aql | 2 +-
.../nontagged/custord/local/join-03.aql | 2 +-
.../nontagged/custord/local/numeric-drop.aql | 2 +-
.../nontagged/custord/local/numeric-load.aql | 2 +-
.../nontagged/custord/local/numeric-scan.aql | 2 +-
.../nontagged/custord/local/ord-drop.aql | 2 +-
.../nontagged/custord/local/ord-load.aql | 2 +-
.../nontagged/custord/local/ord-q1.aql | 2 +-
.../nontagged/custord/local/ord-scan.aql | 2 +-
.../nontagged/custord/local/spatial-drop.aql | 2 +-
.../nontagged/custord/local/spatial-load.aql | 2 +-
.../nontagged/custord/local/spatial-scan.aql | 2 +-
.../nontagged/custord/local/temp-drop.aql | 2 +-
.../nontagged/custord/local/temp-load.aql | 2 +-
.../nontagged/custord/local/temp-scan.aql | 2 +-
.../tpch/local/alltables-loadAsOpen.aql | 2 +-
.../tpch/local/alltablesAsopen-scan.aql | 2 +-
.../nontagged/tpch/local/closedtables-drop.aql | 2 +-
.../nontagged/tpch/local/closedtables-load.aql | 2 +-
.../nontagged/tpch/local/closedtables-q1.aql | 2 +-
.../nontagged/tpch/local/closedtables-q3.aql | 2 +-
.../nontagged/tpch/local/closedtables-q5.aql | 2 +-
.../nontagged/tpch/local/closedtables-q9.aql | 2 +-
.../nontagged/tpch/local/closedtables-scan.aql | 2 +-
.../nontagged/tpch/local/opentables-drop.aql | 2 +-
.../nontagged/tpch/local/opentables-load.aql | 2 +-
.../nontagged/tpch/local/opentables-q1.aql | 2 +-
.../nontagged/tpch/local/opentables-q3.aql | 2 +-
.../nontagged/tpch/local/opentables-q5.aql | 2 +-
.../nontagged/tpch/local/opentables-q9.aql | 2 +-
.../queries/consolidate-selects-complex.aql | 2 +-
.../optimizerts/queries/count-tweets.aql | 2 +-
.../orders-index-search-conjunctive-open_01.aql | 2 +-
.../orders-index-search-conjunctive-open_02.aql | 2 +-
.../orders-index-search-conjunctive_01.aql | 2 +-
.../orders-index-search-conjunctive_02.aql | 2 +-
.../queries/q01_pricing_summary_report_nt.aql | 2 +-
.../queries/rtree-secondary-index-open.aql | 2 +-
.../queries/rtree-secondary-index.aql | 2 +-
.../scan-delete-rtree-secondary-index.aql | 2 +-
.../skip-index/skip-rtree-secondary-index.aql | 2 +-
.../src/test/resources/runtimets/only.xml | 2 +-
.../avg_double_null/avg_double_null.1.ddl.aql | 2 +-
.../avg_float_null/avg_float_nu.1.ddl.aql | 2 +-
.../avg_int16_null/avg_int16_null.1.ddl.aql | 2 +-
.../avg_int32_null/avg_int32_null.1.ddl.aql | 2 +-
.../avg_int64_null/avg_int64_null.1.ddl.aql | 2 +-
.../avg_int8_null/avg_int8_null.1.ddl.aql | 2 +-
.../count_null/count_null.1.ddl.aql | 2 +-
.../sum_double_null/sum_double_null.1.ddl.aql | 2 +-
.../sum_float_null/sum_float_null.1.ddl.aql | 2 +-
.../sum_int16_null/sum_int16_null.1.ddl.aql | 2 +-
.../sum_int32_null/sum_int32_null.1.ddl.aql | 2 +-
.../sum_int64_null/sum_int64_null.1.ddl.aql | 2 +-
.../sum_int8_null/sum_int8_null.1.ddl.aql | 2 +-
.../avg_double_null/avg_double_null.1.ddl.aql | 2 +-
.../avg_float_null/avg_float_nu.1.ddl.aql | 2 +-
.../avg_int16_null/avg_int16_null.1.ddl.aql | 2 +-
.../avg_int32_null/avg_int32_null.1.ddl.aql | 2 +-
.../avg_int64_null/avg_int64_null.1.ddl.aql | 2 +-
.../avg_int8_null/avg_int8_null.1.ddl.aql | 2 +-
.../aggregate/count_null/count_null.1.ddl.aql | 2 +-
.../global-avg_null/global-avg_null.1.ddl.aql | 2 +-
.../local-avg_double_null.1.ddl.aql | 2 +-
.../local-avg_float_null.1.ddl.aql | 2 +-
.../local-avg_int16_null.1.ddl.aql | 2 +-
.../local-avg_int32_null.1.ddl.aql | 2 +-
.../local-avg_int64_null.1.ddl.aql | 2 +-
.../local-avg_int8_null.1.ddl.aql | 2 +-
.../sum_double_null/sum_double_null.1.ddl.aql | 2 +-
.../sum_float_null/sum_float_null.1.ddl.aql | 2 +-
.../sum_int16_null/sum_int16_null.1.ddl.aql | 2 +-
.../sum_int32_null/sum_int32_null.1.ddl.aql | 2 +-
.../sum_int64_null/sum_int64_null.1.ddl.aql | 2 +-
.../sum_int8_null/sum_int8_null.1.ddl.aql | 2 +-
.../binary/equal_join/equal_join.2.update.aql | 4 +-
.../binary/index_join/index_join.2.update.aql | 4 +-
.../queries/binary/insert/insert.2.update.aql | 4 +-
.../datetime_range/datetime_range.2.update.aql | 2 +-
.../cross-dv07/cross-dv07.2.update.aql | 2 +-
.../cross-dv19/cross-dv19.1.ddl.aql | 2 +-
.../insert_across_dataverses.2.update.aql | 2 +-
.../join_across_dataverses.2.update.aql | 4 +-
.../customer_q_01/customer_q_01.1.ddl.aql | 2 +-
.../customer_q_02/customer_q_02.1.ddl.aql | 2 +-
.../customer_q_03/customer_q_03.1.ddl.aql | 2 +-
.../customer_q_04/customer_q_04.1.ddl.aql | 2 +-
.../customer_q_05/customer_q_05.1.ddl.aql | 2 +-
.../customer_q_06/customer_q_06.1.ddl.aql | 2 +-
.../customer_q_07/customer_q_07.1.ddl.aql | 2 +-
.../customer_q_08/customer_q_08.1.ddl.aql | 2 +-
.../denorm-cust-order_01.2.update.aql | 4 +-
.../denorm-cust-order_02.2.update.aql | 4 +-
.../denorm-cust-order_03.2.update.aql | 4 +-
.../custord/freq-clerk/freq-clerk.2.update.aql | 2 +-
.../custord/join_q_01/join_q_01.1.ddl.aql | 4 +-
.../custord/join_q_02/join_q_02.1.ddl.aql | 4 +-
.../custord/join_q_03/join_q_03.1.ddl.aql | 4 +-
.../custord/join_q_04/join_q_04.1.ddl.aql | 4 +-
.../custord/load-test/load-test.2.update.aql | 2 +-
.../custord/order_q_01/order_q_01.1.ddl.aql | 2 +-
.../custord/order_q_02/order_q_02.1.ddl.aql | 2 +-
.../custord/order_q_03/order_q_03.1.ddl.aql | 2 +-
.../custord/order_q_04/order_q_04.1.ddl.aql | 2 +-
.../custord/order_q_05/order_q_05.1.ddl.aql | 2 +-
.../custord/order_q_06/order_q_06.1.ddl.aql | 2 +-
.../runtimets/queries/dapd/q1/q1.1.ddl.aql | 2 +-
.../runtimets/queries/dapd/q2/q2.1.ddl.aql | 2 +-
.../runtimets/queries/dapd/q3/q3.2.update.aql | 2 +-
...compact-dataset-and-its-indexes.2.update.aql | 2 +-
...-from-loaded-dataset-with-index.2.update.aql | 2 +-
.../delete-from-loaded-dataset.2.update.aql | 2 +-
.../delete-multi-statement.2.update.aql | 16 +-
.../queries/dml/delete-syntax-change.aql | 2 +-
.../delete-syntax-change.2.update.aql | 2 +-
.../dml/drop-index/drop-index.2.update.aql | 2 +-
.../empty-load-with-index.2.update.aql | 4 +-
...ataset-with-index-on-open-field.2.update.aql | 2 +-
...ert-and-scan-dataset-with-index.2.update.aql | 2 +-
.../insert-and-scan-dataset.2.update.aql | 2 +-
...insert-and-scan-joined-datasets.2.update.aql | 4 +-
...to-loaded-dataset-with-index_01.2.update.aql | 2 +-
...to-loaded-dataset-with-index_02.2.update.aql | 4 +-
.../insert-into-loaded-dataset_01.2.update.aql | 2 +-
.../insert-into-loaded-dataset_02.2.update.aql | 6 +-
.../queries/dml/insert/insert.2.update.aql | 4 +-
.../insert_less_nc/insert_less_nc.2.update.aql | 4 +-
.../load-from-hdfs/load-from-hdfs.2.update.aql | 2 +-
...ad-with-autogenerated-pk_txt_01.2.update.aql | 2 +-
.../load-with-index-open.2.update.aql | 2 +-
.../load-with-index.2.update.aql | 2 +-
.../load-with-ngram-index-open.2.update.aql | 2 +-
.../load-with-ngram-index.2.update.aql | 2 +-
.../load-with-rtree-index-open.2.update.aql | 2 +-
.../load-with-rtree-index.2.update.aql | 2 +-
.../load-with-word-index-open.2.update.aql | 2 +-
.../load-with-word-index.2.update.aql | 2 +-
.../query-issue288/query-issue288.2.update.aql | 2 +-
.../query-issue382/query-issue382.2.update.aql | 2 +-
...-btree-secondary-index-nullable.2.update.aql | 2 +-
...lete-btree-secondary-index-open.2.update.aql | 2 +-
...-ngram-secondary-index-nullable.2.update.aql | 2 +-
...ndex-ngram-secondary-index-open.2.update.aql | 2 +-
...ted-index-ngram-secondary-index.2.update.aql | 2 +-
...x-word-secondary-index-nullable.2.update.aql | 2 +-
...index-word-secondary-index-open.2.update.aql | 2 +-
...rted-index-word-secondary-index.2.update.aql | 2 +-
...-rtree-secondary-index-nullable.2.update.aql | 2 +-
...lete-rtree-secondary-index-open.2.update.aql | 2 +-
...an-delete-rtree-secondary-index.2.update.aql | 2 +-
...-btree-secondary-index-nullable.2.update.aql | 2 +-
...sert-btree-secondary-index-open.2.update.aql | 2 +-
...-ngram-secondary-index-nullable.2.update.aql | 2 +-
...ndex-ngram-secondary-index-open.2.update.aql | 2 +-
...ted-index-ngram-secondary-index.2.update.aql | 2 +-
...x-word-secondary-index-nullable.2.update.aql | 2 +-
...index-word-secondary-index-open.2.update.aql | 2 +-
...rted-index-word-secondary-index.2.update.aql | 2 +-
...-rtree-secondary-index-nullable.2.update.aql | 2 +-
...sert-rtree-secondary-index-open.2.update.aql | 2 +-
...an-insert-rtree-secondary-index.2.update.aql | 4 +-
.../using-constant-merge-policy.2.update.aql | 2 +-
...-correlated-prefix-merge-policy.2.update.aql | 2 +-
.../using-no-merge-policy.2.update.aql | 2 +-
.../using-prefix-merge-policy.2.update.aql | 2 +-
.../queries/employee/q_01/q_01.1.ddl.aql | 2 +-
.../queries/employee/q_02/q_02.1.ddl.aql | 2 +-
..._pricing_summary_report_failure.2.update.aql | 2 +-
.../queries/flwor/at00/at00.2.update.aql | 2 +-
.../queries/flwor/at04/at04.2.update.aql | 2 +-
.../queries/flwor/at05/at05.2.update.aql | 2 +-
.../queries/flwor/at06/at06.2.update.aql | 2 +-
.../fuzzyjoin/dblp-1_1/dblp-1_1.2.update.aql | 2 +-
.../dblp-1_2.1.1/dblp-1_2.1.1.2.update.aql | 2 +-
.../dblp-1_2.1/dblp-1_2.1.2.update.aql | 2 +-
.../fuzzyjoin/dblp-1_2/dblp-1_2.2.update.aql | 2 +-
.../dblp-2.1_5.3.1/dblp-2.1_5.3.1.2.update.aql | 2 +-
.../fuzzyjoin/dblp-2.2/dblp-2.2.2.update.aql | 4 +-
.../fuzzyjoin/dblp-2_1/dblp-2_1.2.update.aql | 2 +-
.../fuzzyjoin/dblp-2_2/dblp-2_2.2.update.aql | 2 +-
.../fuzzyjoin/dblp-2_3/dblp-2_3.2.update.aql | 2 +-
.../fuzzyjoin/dblp-2_4/dblp-2_4.2.update.aql | 2 +-
.../dblp-2_5.1/dblp-2_5.1.2.update.aql | 2 +-
.../dblp-2_5.2/dblp-2_5.2.2.update.aql | 2 +-
.../dblp-2_5.3.1/dblp-2_5.3.1.2.update.aql | 2 +-
.../dblp-2_5.3/dblp-2_5.3.2.update.aql | 2 +-
.../fuzzyjoin/dblp-2_5/dblp-2_5.2.update.aql | 2 +-
.../dblp-3_1.1/dblp-3_1.1.2.update.aql | 2 +-
.../dblp-3_1.2/dblp-3_1.2.2.update.aql | 2 +-
.../fuzzyjoin/dblp-3_1/dblp-3_1.2.update.aql | 2 +-
.../dblp-aqlplus_1/dblp-aqlplus_1.2.update.aql | 2 +-
.../dblp-aqlplus_2/dblp-aqlplus_2.2.update.aql | 2 +-
.../dblp-csx-2_1/dblp-csx-2_1.2.update.aql | 4 +-
.../dblp-csx-2_2/dblp-csx-2_2.2.update.aql | 4 +-
.../dblp-csx-2_3/dblp-csx-2_3.2.update.aql | 4 +-
.../dblp-csx-2_4/dblp-csx-2_4.2.update.aql | 4 +-
.../dblp-csx-2_5.1/dblp-csx-2_5.1.2.update.aql | 4 +-
.../dblp-csx-2_5.2/dblp-csx-2_5.2.2.update.aql | 4 +-
.../dblp-csx-2_5.3.1.2.update.aql | 4 +-
.../dblp-csx-2_5.3/dblp-csx-2_5.3.2.update.aql | 4 +-
.../dblp-csx-2_5/dblp-csx-2_5.2.update.aql | 4 +-
.../dblp-csx-3_1/dblp-csx-3_1.2.update.aql | 4 +-
.../dblp-csx-3_2/dblp-csx-3_2.2.update.aql | 4 +-
.../dblp-csx-3_3/dblp-csx-3_3.2.update.aql | 4 +-
.../dblp-csx-3_4/dblp-csx-3_4.2.update.aql | 4 +-
.../dblp-csx-3_5.1/dblp-csx-3_5.1.2.update.aql | 4 +-
.../dblp-csx-3_5.2/dblp-csx-3_5.2.2.update.aql | 4 +-
.../dblp-csx-3_5.3.1.2.update.aql | 4 +-
.../dblp-csx-3_5.3/dblp-csx-3_5.3.2.update.aql | 4 +-
.../dblp-csx-3_5.4.1.2.update.aql | 4 +-
.../dblp-csx-3_5.4/dblp-csx-3_5.4.2.update.aql | 4 +-
.../dblp-csx-3_5/dblp-csx-3_5.2.update.aql | 4 +-
.../dblp-csx-aqlplus_1.2.update.aql | 4 +-
.../dblp-csx-aqlplus_2.2.update.aql | 4 +-
.../dblp-csx-aqlplus_3.2.update.aql | 4 +-
.../dblp-csx-dblp-aqlplus_1.2.update.aql | 4 +-
.../dblp-lookup_1/dblp-lookup_1.2.update.aql | 2 +-
.../dblp-splits-3_1/dblp-splits-3_1.1.ddl.aql | 2 +-
.../dblp-splits-3_1.2.update.aql | 2 +-
.../dblp-splits-3_1/dblp-splits-3_1.3.query.aql | 82 +--
.../events-users-aqlplus_1.2.update.aql | 2 +-
.../fuzzyjoin/opentype/opentype.2.update.aql | 2 +-
.../user-int-aqlplus_1.2.update.aql | 2 +-
.../user-int-aqlplus_2.2.update.aql | 2 +-
.../user-int-aqlplus_3.2.update.aql | 2 +-
.../user-lot-aqlplus_1.1.2.update.aql | 2 +-
.../user-lot-aqlplus_1.2.update.aql | 2 +-
.../user-lot-aqlplus_2.2.update.aql | 2 +-
.../user-lot-aqlplus_3.2.update.aql | 2 +-
.../user-vis-int-3_1.2.update.aql | 4 +-
.../user-vis-int-aqlplus_1.2.update.aql | 4 +-
.../user-vis-int-aqlplus_2.2.update.aql | 4 +-
.../user-vis-int-aqlplus_3.2.update.aql | 4 +-
...-vis-int-vis-user-lot-aqlplus_1.2.update.aql | 4 +-
.../user-vis-lot-3_1.2.update.aql | 4 +-
.../user-vis-lot-aqlplus_1.2.update.aql | 4 +-
.../user-vis-lot-aqlplus_2.2.update.aql | 4 +-
.../user-vis-lot-aqlplus_3.2.update.aql | 4 +-
.../user-vis-lot-aqlplus_4.2.update.aql | 4 +-
.../user-vis-lot-aqlplus_5.2.update.aql | 4 +-
.../user-vis-lot-int-aqlplus_1.2.update.aql | 4 +-
.../user-vis-lot-int-aqlplus_2.2.update.aql | 4 +-
.../graph/pregel-q01/pregel-q01.3.query.aql | 2 +-
.../graph/pregel-q02/pregel-q02.3.query.aql | 2 +-
.../graph/pregel-q03/pregel-q03.3.query.aql | 2 +-
.../issue_251_dataset_hint_5.2.update.aql | 2 +-
.../btree-primary-equi-join.2.update.aql | 4 +-
.../btree-secondary-equi-join.2.update.aql | 4 +-
.../rtree-spatial-intersect-point.2.update.aql | 4 +-
...robe-pidx-with-join-btree-sidx1.2.update.aql | 2 +-
...robe-pidx-with-join-btree-sidx2.2.update.aql | 2 +-
...obe-pidx-with-join-invidx-sidx1.2.update.aql | 2 +-
...obe-pidx-with-join-invidx-sidx2.2.update.aql | 2 +-
...robe-pidx-with-join-rtree-sidx1.2.update.aql | 2 +-
...robe-pidx-with-join-rtree-sidx2.2.update.aql | 2 +-
...x-composite-key-mixed-intervals.2.update.aql | 2 +-
.../btree-index-composite-key.2.update.aql | 2 +-
.../btree-index-rewrite-multiple.2.update.aql | 2 +-
.../cust-index-age-nullable.2.update.aql | 2 +-
.../inverted-index-ngram-contains.2.update.aql | 2 +-
...ex-ngram-edit-distance-contains.2.update.aql | 2 +-
...index-ngram-edit-distance-panic.2.update.aql | 2 +-
...ngram-edit-distance-word-tokens.2.update.aql | 2 +-
...erted-index-ngram-edit-distance.2.update.aql | 2 +-
.../inverted-index-ngram-jaccard.2.update.aql | 2 +-
...index-olist-edit-distance-panic.2.update.aql | 2 +-
...erted-index-olist-edit-distance.2.update.aql | 2 +-
.../inverted-index-olist-jaccard.2.update.aql | 2 +-
.../inverted-index-ulist-jaccard.2.update.aql | 2 +-
.../inverted-index-word-contains.2.update.aql | 2 +-
.../inverted-index-word-jaccard.2.update.aql | 2 +-
...-index-custkey-conjunctive-open.2.update.aql | 2 +-
...rders-index-custkey-conjunctive.2.update.aql | 2 +-
.../orders-index-custkey-open.2.update.aql | 2 +-
.../orders-index-custkey.2.update.aql | 2 +-
.../range-search-open.2.update.aql | 2 +-
.../range-search/range-search.2.update.aql | 2 +-
...-secondary-index-circular-query.2.update.aql | 2 +-
.../rtree-secondary-index-nullable.2.update.aql | 2 +-
.../rtree-secondary-index-open.2.update.aql | 2 +-
.../rtree-secondary-index.2.update.aql | 2 +-
.../ngram-edit-distance-inline.2.update.aql | 4 +-
.../ngram-edit-distance.2.update.aql | 4 +-
.../ngram-jaccard-inline.2.update.aql | 4 +-
.../ngram-jaccard/ngram-jaccard.2.update.aql | 4 +-
.../olist-edit-distance-inline.2.update.aql | 4 +-
.../olist-edit-distance.2.update.aql | 4 +-
.../olist-jaccard-inline.2.update.aql | 4 +-
.../olist-jaccard/olist-jaccard.2.update.aql | 4 +-
.../ulist-jaccard-inline.2.update.aql | 4 +-
.../ulist-jaccard/ulist-jaccard.2.update.aql | 4 +-
.../word-jaccard-inline.2.update.aql | 4 +-
.../word-jaccard/word-jaccard.2.update.aql | 4 +-
.../ngram-edit-distance-inline.2.update.aql | 4 +-
.../ngram-edit-distance.2.update.aql | 4 +-
.../ngram-jaccard-inline.2.update.aql | 4 +-
.../ngram-jaccard/ngram-jaccard.2.update.aql | 4 +-
.../olist-edit-distance-inline.2.update.aql | 4 +-
.../olist-edit-distance.2.update.aql | 4 +-
.../olist-jaccard-inline.2.update.aql | 4 +-
.../olist-jaccard/olist-jaccard.2.update.aql | 4 +-
.../ulist-jaccard-inline.2.update.aql | 4 +-
.../ulist-jaccard/ulist-jaccard.2.update.aql | 4 +-
.../word-jaccard-inline.2.update.aql | 4 +-
.../word-jaccard/word-jaccard.2.update.aql | 4 +-
.../query_issue285-2.2.update.aql | 4 +-
.../query_issue285/query_issue285.2.update.aql | 4 +-
.../query_issue658/query_issue658.2.update.aql | 4 +-
.../load/adm_binary/adm_binary.2.update.aql | 2 +-
.../queries/load/csv_01/csv_01.2.update.aql | 2 +-
.../queries/load/csv_02/csv_02.2.update.aql | 2 +-
.../queries/load/csv_03/csv_03.2.update.aql | 2 +-
.../queries/load/csv_04/csv_04.2.update.aql | 2 +-
.../queries/load/csv_05/csv_05.2.update.aql | 2 +-
.../queries/load/csv_06/csv_06.2.update.aql | 2 +-
.../queries/load/csv_07/csv_07.2.update.aql | 2 +-
.../load/csv_08_header_cr/csv_08.2.update.aql | 2 +-
.../load/csv_08_header_crlf/csv_08.2.update.aql | 2 +-
.../load/csv_08_header_lf/csv_08.2.update.aql | 2 +-
.../issue289_query/issue289_query.2.update.aql | 2 +-
.../issue650_query/issue650_query.2.update.aql | 2 +-
.../misc/flushtest/flushtest.2.update.aql | 2 +-
.../groupby-orderby-count.1.ddl.aql | 2 +-
.../nested-loop-join_01.2.update.aql | 4 +-
.../prefix-search/prefix-search.2.update.aql | 2 +-
.../misc/stable_sort/stable_sort.2.update.aql | 2 +-
...compact-dataset-and-its-indexes.2.update.aql | 2 +-
...-from-loaded-dataset-with-index.2.update.aql | 2 +-
.../nested-index-dml/delete-syntax-change.aql | 2 +-
.../drop-index/drop-index.2.update.aql | 2 +-
...to-loaded-dataset-with-index_01.2.update.aql | 2 +-
...to-loaded-dataset-with-index_02.2.update.aql | 2 +-
.../load-with-index.2.update.aql | 2 +-
.../load-with-ngram-index.2.update.aql | 2 +-
.../load-with-rtree-index.2.update.aql | 2 +-
.../load-with-word-index.2.update.aql | 2 +-
.../nested-uuid-load.2.update.aql | 2 +-
...-btree-secondary-index-nullable.2.update.aql | 2 +-
...-ngram-secondary-index-nullable.2.update.aql | 2 +-
...ted-index-ngram-secondary-index.2.update.aql | 2 +-
...x-word-secondary-index-nullable.2.update.aql | 2 +-
...rted-index-word-secondary-index.2.update.aql | 2 +-
...-rtree-secondary-index-nullable.2.update.aql | 2 +-
...an-delete-rtree-secondary-index.2.update.aql | 2 +-
...-btree-secondary-index-nullable.2.update.aql | 2 +-
...-ngram-secondary-index-nullable.2.update.aql | 2 +-
...ted-index-ngram-secondary-index.2.update.aql | 2 +-
...x-word-secondary-index-nullable.2.update.aql | 2 +-
...rted-index-word-secondary-index.2.update.aql | 2 +-
...-rtree-secondary-index-nullable.2.update.aql | 2 +-
...an-insert-rtree-secondary-index.2.update.aql | 4 +-
.../btree-primary-equi-join.2.update.aql | 4 +-
.../btree-secondary-equi-join.2.update.aql | 4 +-
.../ngram-edit-distance-inline.2.update.aql | 4 +-
.../ngram-edit-distance.2.update.aql | 4 +-
.../ngram-jaccard-inline.2.update.aql | 4 +-
.../ngram-jaccard/ngram-jaccard.2.update.aql | 4 +-
.../rtree-spatial-intersect-point.2.update.aql | 4 +-
.../word-jaccard-inline.2.update.aql | 4 +-
.../word-jaccard/word-jaccard.2.update.aql | 4 +-
...robe-pidx-with-join-btree-sidx1.2.update.aql | 2 +-
...robe-pidx-with-join-btree-sidx2.2.update.aql | 2 +-
...obe-pidx-with-join-invidx-sidx1.2.update.aql | 2 +-
...obe-pidx-with-join-invidx-sidx2.2.update.aql | 2 +-
...robe-pidx-with-join-rtree-sidx1.2.update.aql | 2 +-
...robe-pidx-with-join-rtree-sidx2.2.update.aql | 2 +-
...x-composite-key-mixed-intervals.2.update.aql | 2 +-
.../btree-index-composite-key.2.update.aql | 2 +-
.../btree-index-rewrite-multiple.2.update.aql | 2 +-
.../cust-index-age-nullable.2.update.aql | 2 +-
.../inverted-index-ngram-contains.2.update.aql | 2 +-
...ex-ngram-edit-distance-contains.2.update.aql | 2 +-
...index-ngram-edit-distance-panic.2.update.aql | 2 +-
...ngram-edit-distance-word-tokens.2.update.aql | 2 +-
...erted-index-ngram-edit-distance.2.update.aql | 2 +-
.../inverted-index-ngram-jaccard.2.update.aql | 2 +-
...index-olist-edit-distance-panic.2.update.aql | 2 +-
...erted-index-olist-edit-distance.2.update.aql | 2 +-
.../inverted-index-olist-jaccard.2.update.aql | 2 +-
.../inverted-index-ulist-jaccard.2.update.aql | 2 +-
.../inverted-index-word-contains.2.update.aql | 2 +-
.../inverted-index-word-jaccard.2.update.aql | 2 +-
...-index-custkey-conjunctive-open.2.update.aql | 2 +-
...rders-index-custkey-conjunctive.2.update.aql | 2 +-
.../orders-index-custkey-open.2.update.aql | 2 +-
.../orders-index-custkey.2.update.aql | 2 +-
.../range-search-open.2.update.aql | 2 +-
.../range-search/range-search.2.update.aql | 2 +-
.../rtree-secondary-index-nullable.2.update.aql | 2 +-
.../rtree-secondary-index-open.2.update.aql | 2 +-
.../rtree-secondary-index.2.update.aql | 2 +-
.../btree-secondary-equi-join.2.update.aql | 4 +-
.../ngram-edit-distance-inline.2.update.aql | 4 +-
.../ngram-edit-distance.2.update.aql | 4 +-
.../ngram-jaccard-inline.2.update.aql | 4 +-
.../ngram-jaccard/ngram-jaccard.2.update.aql | 4 +-
.../rtree-spatial-intersect-point.2.update.aql | 4 +-
.../word-jaccard-inline.2.update.aql | 4 +-
.../word-jaccard/word-jaccard.2.update.aql | 4 +-
...robe-pidx-with-join-btree-sidx1.2.update.aql | 2 +-
...robe-pidx-with-join-btree-sidx2.2.update.aql | 2 +-
...obe-pidx-with-join-invidx-sidx2.2.update.aql | 2 +-
...robe-pidx-with-join-rtree-sidx1.2.update.aql | 2 +-
...robe-pidx-with-join-rtree-sidx2.2.update.aql | 2 +-
...x-composite-key-mixed-intervals.2.update.aql | 2 +-
.../btree-index-composite-key.2.update.aql | 2 +-
.../btree-index-rewrite-multiple.2.update.aql | 2 +-
.../inverted-index-ngram-contains.2.update.aql | 2 +-
...ex-ngram-edit-distance-contains.2.update.aql | 2 +-
...index-ngram-edit-distance-panic.2.update.aql | 2 +-
...ngram-edit-distance-word-tokens.2.update.aql | 2 +-
...erted-index-ngram-edit-distance.2.update.aql | 2 +-
.../inverted-index-ngram-jaccard.2.update.aql | 2 +-
.../inverted-index-word-contains.2.update.aql | 2 +-
.../inverted-index-word-jaccard.2.update.aql | 2 +-
...rders-index-custkey-conjunctive.2.update.aql | 2 +-
.../orders-index-custkey.2.update.aql | 2 +-
.../range-search/range-search.2.update.aql | 2 +-
.../rtree-secondary-index.2.update.aql | 2 +-
.../query-issue208/query-issue208.2.update.aql | 2 +-
.../query-issue350-2.2.update.aql | 2 +-
.../query-issue350/query-issue350.2.update.aql | 2 +-
.../btree-secondary-equi-join.2.update.aql | 4 +-
.../ngram-edit-distance-inline.2.update.aql | 4 +-
.../ngram-edit-distance.2.update.aql | 4 +-
.../ngram-jaccard-inline.2.update.aql | 4 +-
.../ngram-jaccard/ngram-jaccard.2.update.aql | 4 +-
.../rtree-spatial-intersect-point.2.update.aql | 4 +-
.../word-jaccard-inline.2.update.aql | 4 +-
.../word-jaccard/word-jaccard.2.update.aql | 4 +-
...robe-pidx-with-join-btree-sidx1.2.update.aql | 2 +-
...robe-pidx-with-join-btree-sidx2.2.update.aql | 2 +-
...obe-pidx-with-join-invidx-sidx2.2.update.aql | 2 +-
...robe-pidx-with-join-rtree-sidx1.2.update.aql | 2 +-
...robe-pidx-with-join-rtree-sidx2.2.update.aql | 2 +-
...x-composite-key-mixed-intervals.2.update.aql | 2 +-
.../btree-index-composite-key.2.update.aql | 2 +-
.../btree-index-rewrite-multiple.2.update.aql | 2 +-
.../inverted-index-ngram-contains.2.update.aql | 2 +-
...ex-ngram-edit-distance-contains.2.update.aql | 2 +-
...index-ngram-edit-distance-panic.2.update.aql | 2 +-
...ngram-edit-distance-word-tokens.2.update.aql | 2 +-
...erted-index-ngram-edit-distance.2.update.aql | 2 +-
.../inverted-index-ngram-jaccard.2.update.aql | 2 +-
.../inverted-index-word-contains.2.update.aql | 2 +-
.../inverted-index-word-jaccard.2.update.aql | 2 +-
...rders-index-custkey-conjunctive.2.update.aql | 2 +-
.../orders-index-custkey.2.update.aql | 2 +-
.../range-search/range-search.2.update.aql | 2 +-
.../rtree-secondary-index.2.update.aql | 2 +-
.../somesat_02/somesat_02.2.update.aql | 4 +-
.../queries/records/RecordsQueries.xml | 6 +-
.../runtimets/queries/scan/10/10.2.update.aql | 2 +-
.../runtimets/queries/scan/20/20.2.update.aql | 2 +-
.../runtimets/queries/scan/30/30.1.ddl.aql | 2 +-
.../scan/alltypes_01/alltypes_01.1.ddl.aql | 2 +-
.../runtimets/queries/scan/alltypes_02.aql | 2 +-
.../scan/alltypes_02/alltypes_02.1.ddl.aql | 2 +-
.../issue238_query_1.2.update.aql | 2 +-
.../issue238_query_2.2.update.aql | 2 +-
.../numeric_types_01/numeric_types_01.1.ddl.aql | 2 +-
.../spatial_types_01/spatial_types_01.1.ddl.aql | 2 +-
.../spatial_types_02/spatial_types_02.1.ddl.aql | 2 +-
.../scan/temp_types_01/temp_types_01.1.ddl.aql | 2 +-
.../temp_types_02/temp_types_02.2.update.aql | 2 +-
.../count-nullable/count-nullable.1.ddl.aql | 2 +-
.../cust-filter/cust-filter.1.ddl.aql | 2 +-
.../has-param1/has-param1.1.ddl.aql | 2 +-
.../fuzzyeq-edit-distance.2.update.aql | 2 +-
.../fuzzyeq-similarity-jaccard.2.update.aql | 2 +-
.../similarity-jaccard-check_query.2.update.aql | 2 +-
...rity-jaccard-sorted-check_query.2.update.aql | 2 +-
...similarity-jaccard-sorted_query.2.update.aql | 2 +-
.../similarity-jaccard_query.2.update.aql | 2 +-
...cell-aggregation-with-filtering.2.update.aql | 2 +-
.../cell-aggregation/cell-aggregation.1.ddl.aql | 2 +-
.../circle-intersect-circle.1.ddl.aql | 2 +-
.../create-rtree-index.2.update.aql | 2 +-
.../distance-between-points.1.ddl.aql | 2 +-
.../line-intersect-circle.1.ddl.aql | 2 +-
.../line-intersect-line.1.ddl.aql | 2 +-
.../line-intersect-polygon.1.ddl.aql | 2 +-
.../line-intersect-rectangle.1.ddl.aql | 2 +-
.../point-equals-point.1.ddl.aql | 2 +-
.../point-in-circle/point-in-circle.1.ddl.aql | 2 +-
.../point-in-polygon/point-in-polygon.1.ddl.aql | 2 +-
.../point-in-rectangle.1.ddl.aql | 2 +-
.../point-on-line/point-on-line.1.ddl.aql | 2 +-
.../polygon-intersect-circle.1.ddl.aql | 2 +-
.../polygon-intersect-polygon.1.ddl.aql | 2 +-
.../polygon-intersect-rectangle.1.ddl.aql | 2 +-
.../rectangle-intersect-circle.1.ddl.aql | 2 +-
.../rectangle-intersect-rectangle.1.ddl.aql | 2 +-
.../spatial/spatial-area/spatial-area.1.ddl.aql | 2 +-
.../queries/subset-collection/04/04.3.query.aql | 4 +-
...-from-loaded-dataset-with-index.2.update.aql | 2 +-
.../delete-from-loaded-dataset.2.update.aql | 2 +-
.../drop-index/drop-index.2.update.aql | 2 +-
.../empty-load-with-index.2.update.aql | 4 +-
...ert-and-scan-dataset-with-index.2.update.aql | 2 +-
.../insert-and-scan-dataset.2.update.aql | 2 +-
.../q01_pricing_summary_report_nt.2.update.aql | 2 +-
...an-delete-rtree-secondary-index.2.update.aql | 2 +-
.../scan-insert-persistent-to-temp.2.update.aql | 4 +-
...an-insert-rtree-secondary-index.2.update.aql | 4 +-
.../scan-insert-temp-to-persistent.2.update.aql | 4 +-
.../insert_from_delimited_ds.2.update.aql | 2 +-
.../insert_from_ext_ds.1.ddl.aql | 2 +-
.../q01_pricing_summary_report_nt.2.update.aql | 2 +-
.../q02_minimum_cost_supplier.2.update.aql | 16 +-
.../q03_shipping_priority_nt.2.update.aql | 6 +-
.../q04_order_priority.2.update.aql | 16 +-
.../q05_local_supplier_volume.2.update.aql | 16 +-
.../q06_forecast_revenue_change.2.update.aql | 16 +-
.../q07_volume_shipping.2.update.aql | 16 +-
.../q08_national_market_share.2.update.aql | 16 +-
.../q09_product_type_profit_nt.2.update.aql | 16 +-
.../q10_returned_item.2.update.aql | 16 +-
.../q10_returned_item_int64.2.update.aql | 16 +-
.../q11_important_stock.2.update.aql | 16 +-
.../q12_shipping/q12_shipping.2.update.aql | 16 +-
.../q13_customer_distribution.2.update.aql | 16 +-
.../q14_promotion_effect.2.update.aql | 16 +-
.../q15_top_supplier.2.update.aql | 16 +-
...q16_parts_supplier_relationship.2.update.aql | 16 +-
.../q17_large_gby_variant.2.update.aql | 16 +-
...17_small_quantity_order_revenue.2.update.aql | 16 +-
.../q18_large_volume_customer.2.update.aql | 16 +-
.../q19_discounted_revenue.2.update.aql | 16 +-
.../q20_potential_part_promotion.2.update.aql | 16 +-
...ppliers_who_kept_orders_waiting.2.update.aql | 16 +-
.../q22_global_sales_opportunity.2.update.aql | 16 +-
.../query-issue601/query-issue601.2.update.aql | 2 +-
.../query-issue785-2.2.update.aql | 12 +-
.../query-issue785/query-issue785.2.update.aql | 12 +-
.../query-issue786/query-issue786.2.update.aql | 12 +-
.../tpch/distinct_by/distinct_by.2.update.aql | 2 +-
.../tpch/group_no_agg/group_no_agg.2.update.aql | 2 +-
.../nest_aggregate/nest_aggregate.2.update.aql | 12 +-
.../q01_pricing_summary_report_nt.2.update.aql | 2 +-
.../q02_minimum_cost_supplier.2.update.aql | 16 +-
.../q03_shipping_priority_nt.2.update.aql | 6 +-
.../q04_order_priority.2.update.aql | 16 +-
.../q05_local_supplier_volume.2.update.aql | 16 +-
.../q06_forecast_revenue_change.2.update.aql | 16 +-
.../q07_volume_shipping.2.update.aql | 16 +-
.../q08_national_market_share.2.update.aql | 16 +-
.../q09_product_type_profit_nt.2.update.aql | 16 +-
.../q10_returned_item.2.update.aql | 16 +-
.../q10_returned_item_int64.2.update.aql | 16 +-
.../q11_important_stock.2.update.aql | 16 +-
.../tpch/q12_shipping/q12_shipping.2.update.aql | 16 +-
.../q13_customer_distribution.2.update.aql | 16 +-
.../q14_promotion_effect.2.update.aql | 16 +-
.../q15_top_supplier.2.update.aql | 16 +-
...q16_parts_supplier_relationship.2.update.aql | 16 +-
.../q17_large_gby_variant.2.update.aql | 16 +-
...17_small_quantity_order_revenue.2.update.aql | 16 +-
.../q18_large_volume_customer.2.update.aql | 16 +-
.../q19_discounted_revenue.2.update.aql | 16 +-
.../q20_potential_part_promotion.2.update.aql | 16 +-
...ppliers_who_kept_orders_waiting.2.update.aql | 16 +-
.../q22_global_sales_opportunity.2.update.aql | 16 +-
.../query-issue562/query-issue562.2.update.aql | 16 +-
.../query-issue601/query-issue601.2.update.aql | 2 +-
.../query-issue785-2.2.update.aql | 12 +-
.../query-issue785/query-issue785.2.update.aql | 12 +-
.../query-issue786/query-issue786.2.update.aql | 12 +-
.../query-issue810-2.2.update.aql | 2 +-
.../query-issue810-3.2.update.aql | 2 +-
.../query-issue810/query-issue810.2.update.aql | 2 +-
.../query-issue827-2.2.update.aql | 2 +-
.../query-issue827/query-issue827.2.update.aql | 2 +-
.../resources/runtimets/repeatedtestsuite.xml | 2 +-
.../cross-dataverse/cross-dv19/cross-dv19.1.adm | 2 +-
.../writers/serialized_01/serialized_01.1.adm | Bin 948 -> 937 bytes
.../src/test/resources/runtimets/testsuite.xml | 92 +--
.../resources/spatial/local/spatial-drop.aql | 2 +-
.../resources/spatial/local/spatial-load.aql | 4 +-
.../tpch/queries/asterix/load_data_adm.aql | 16 +-
.../tpch/queries/asterix/load_data_tbl_100x.aql | 16 +-
.../tpch/queries/asterix/load_data_tbl_1x.aql | 16 +-
.../tpch/queries/local/load_adm_data.aql | 16 +-
.../local/load_tbl_data_0.001x_2nodes.aql | 16 +-
.../queries/local/load_tbl_data_10x_1node.aql | 16 +-
.../queries/local/load_tbl_data_1x_1node.aql | 16 +-
.../queries/local/load_tbl_data_20x_2node.aql | 16 +-
asterix-aql/pom.xml | 14 +-
.../asterix/aql/base/AbstractExpression.java | 4 +-
.../org/apache/asterix/aql/base/Clause.java | 2 +-
.../org/apache/asterix/aql/base/Expression.java | 2 +-
.../apache/asterix/aql/base/IAqlExpression.java | 8 +-
.../org/apache/asterix/aql/base/Literal.java | 2 +-
.../org/apache/asterix/aql/base/Statement.java | 2 +-
.../aql/context/FunctionExpressionMap.java | 4 +-
.../asterix/aql/context/FunctionSignatures.java | 4 +-
.../asterix/aql/context/RootScopeFactory.java | 4 +-
.../org/apache/asterix/aql/context/Scope.java | 10 +-
.../aql/expression/AbstractAccessor.java | 4 +-
.../asterix/aql/expression/AdmSplitInfo.java | 2 +-
.../apache/asterix/aql/expression/CallExpr.java | 14 +-
.../aql/expression/CompactStatement.java | 10 +-
.../aql/expression/ConnectFeedStatement.java | 48 +-
.../asterix/aql/expression/ConstructorType.java | 2 +-
.../expression/CreateDataverseStatement.java | 12 +-
.../expression/CreateFeedPolicyStatement.java | 10 +-
.../aql/expression/CreateFeedStatement.java | 14 +-
.../aql/expression/CreateFunctionStatement.java | 12 +-
.../aql/expression/CreateIndexStatement.java | 16 +-
.../expression/CreatePrimaryFeedStatement.java | 12 +-
.../CreateSecondaryFeedStatement.java | 12 +-
.../asterix/aql/expression/DatasetDecl.java | 14 +-
.../asterix/aql/expression/DataverseDecl.java | 10 +-
.../aql/expression/DataverseDropStatement.java | 10 +-
.../asterix/aql/expression/DeleteStatement.java | 12 +-
.../aql/expression/DisconnectFeedStatement.java | 12 +-
.../asterix/aql/expression/DistinctClause.java | 12 +-
.../asterix/aql/expression/DropStatement.java | 10 +-
.../aql/expression/ExternalDetailsDecl.java | 2 +-
.../aql/expression/FLWOGRExpression.java | 14 +-
.../asterix/aql/expression/FeedDetailsDecl.java | 4 +-
.../aql/expression/FeedDropStatement.java | 10 +-
.../aql/expression/FeedPolicyDropStatement.java | 10 +-
.../asterix/aql/expression/FieldAccessor.java | 10 +-
.../asterix/aql/expression/FieldBinding.java | 4 +-
.../asterix/aql/expression/ForClause.java | 12 +-
.../asterix/aql/expression/FunctionDecl.java | 14 +-
.../aql/expression/FunctionDropStatement.java | 12 +-
.../expression/GbyVariableExpressionPair.java | 4 +-
.../asterix/aql/expression/GroupbyClause.java | 10 +-
.../asterix/aql/expression/HdfsPathInfo.java | 2 +-
.../aql/expression/IDatasetDetailsDecl.java | 2 +-
.../asterix/aql/expression/Identifier.java | 2 +-
.../apache/asterix/aql/expression/IfExpr.java | 10 +-
.../asterix/aql/expression/IndexAccessor.java | 10 +-
.../asterix/aql/expression/IndexDecl.java | 2 +-
.../aql/expression/IndexDropStatement.java | 10 +-
.../asterix/aql/expression/InsertStatement.java | 10 +-
.../aql/expression/InternalDetailsDecl.java | 2 +-
.../asterix/aql/expression/JoinClause.java | 16 +-
.../asterix/aql/expression/LetClause.java | 12 +-
.../asterix/aql/expression/LimitClause.java | 12 +-
.../asterix/aql/expression/ListConstructor.java | 10 +-
.../asterix/aql/expression/LiteralExpr.java | 12 +-
.../asterix/aql/expression/LoadStatement.java | 10 +-
.../aql/expression/MetaVariableClause.java | 14 +-
.../aql/expression/MetaVariableExpr.java | 12 +-
.../aql/expression/NodeGroupDropStatement.java | 10 +-
.../asterix/aql/expression/NodegroupDecl.java | 10 +-
.../asterix/aql/expression/OperatorExpr.java | 12 +-
.../asterix/aql/expression/OperatorType.java | 2 +-
.../asterix/aql/expression/OrderbyClause.java | 14 +-
.../expression/OrderedListTypeDefinition.java | 8 +-
.../aql/expression/QuantifiedExpression.java | 10 +-
.../asterix/aql/expression/QuantifiedPair.java | 4 +-
.../apache/asterix/aql/expression/Query.java | 12 +-
.../aql/expression/RecordConstructor.java | 10 +-
.../aql/expression/RecordTypeDefinition.java | 12 +-
.../RefreshExternalDatasetStatement.java | 10 +-
.../asterix/aql/expression/RunStatement.java | 12 +-
.../asterix/aql/expression/SetStatement.java | 10 +-
.../aql/expression/SubscribeFeedStatement.java | 52 +-
.../apache/asterix/aql/expression/TypeDecl.java | 12 +-
.../aql/expression/TypeDropStatement.java | 10 +-
.../asterix/aql/expression/TypeExpression.java | 4 +-
.../aql/expression/TypeReferenceExpression.java | 8 +-
.../asterix/aql/expression/UnaryExpr.java | 10 +-
.../asterix/aql/expression/UnionExpr.java | 10 +-
.../expression/UnorderedListTypeDefinition.java | 8 +-
.../asterix/aql/expression/UpdateClause.java | 12 +-
.../asterix/aql/expression/UpdateStatement.java | 12 +-
.../asterix/aql/expression/VarIdentifier.java | 2 +-
.../asterix/aql/expression/VariableExpr.java | 10 +-
.../asterix/aql/expression/WhereClause.java | 12 +-
.../asterix/aql/expression/WriteStatement.java | 10 +-
.../aql/expression/visitor/AQLPrintVisitor.java | 136 ++--
.../visitor/IAqlExpressionVisitor.java | 114 ++--
.../visitor/IAqlPlusExpressionVisitor.java | 10 +-
.../visitor/IAqlVisitorWithVoidReturn.java | 114 ++--
.../asterix/aql/literal/DoubleLiteral.java | 4 +-
.../asterix/aql/literal/FalseLiteral.java | 4 +-
.../asterix/aql/literal/FloatLiteral.java | 4 +-
.../asterix/aql/literal/IntegerLiteral.java | 4 +-
.../asterix/aql/literal/LongIntegerLiteral.java | 4 +-
.../apache/asterix/aql/literal/NullLiteral.java | 4 +-
.../asterix/aql/literal/StringLiteral.java | 4 +-
.../apache/asterix/aql/literal/TrueLiteral.java | 4 +-
.../apache/asterix/aql/parser/ScopeChecker.java | 10 +-
.../asterix/aql/rewrites/AqlRewriter.java | 144 ++--
.../aql/rewrites/AqlRewritingContext.java | 4 +-
.../CloneAndSubstituteVariablesVisitor.java | 130 ++--
.../asterix/aql/rewrites/InlineUdfsVisitor.java | 134 ++--
.../aql/rewrites/VariableSubstitution.java | 4 +-
.../apache/asterix/aql/util/FunctionUtils.java | 24 +-
.../asterix/aql/util/RangeMapBuilder.java | 66 +-
asterix-aql/src/main/javacc/AQL.jj | 212 +++---
asterix-common/pom.xml | 26 +-
.../asterix/common/annotations/AutoDataGen.java | 2 +-
.../annotations/DateBetweenYearsDataGen.java | 2 +-
.../DatetimeAddRandHoursDataGen.java | 2 +-
.../DatetimeBetweenYearsDataGen.java | 2 +-
.../annotations/FieldIntervalDataGen.java | 2 +-
.../common/annotations/FieldValFileDataGen.java | 2 +-
.../FieldValFileSameIndexDataGen.java | 2 +-
.../common/annotations/IRecordFieldDataGen.java | 2 +-
.../annotations/IRecordTypeAnnotation.java | 2 +-
.../annotations/InsertRandIntDataGen.java | 2 +-
.../asterix/common/annotations/ListDataGen.java | 2 +-
.../common/annotations/ListValFileDataGen.java | 2 +-
.../annotations/RecordDataGenAnnotation.java | 2 +-
...econdaryIndexSearchExpressionAnnotation.java | 4 +-
.../asterix/common/annotations/TypeDataGen.java | 2 +-
.../annotations/UndeclaredFieldsDataGen.java | 2 +-
.../asterix/common/api/AsterixContextInfo.java | 4 +-
.../common/api/AsterixThreadExecutor.java | 2 +-
.../common/api/AsterixThreadFactory.java | 4 +-
.../common/api/IAsterixAppRuntimeContext.java | 32 +-
.../asterix/common/api/IAsterixContextInfo.java | 4 +-
.../api/IAsterixRuntimeComponentsProvider.java | 24 +-
.../common/api/IClusterEventsSubscriber.java | 4 +-
.../common/api/IClusterManagementWork.java | 2 +-
.../api/IClusterManagementWorkResponse.java | 2 +-
.../common/api/ILocalResourceMetadata.java | 8 +-
.../config/AbstractAsterixProperties.java | 2 +-
.../config/AsterixCompilerProperties.java | 2 +-
.../config/AsterixExternalProperties.java | 2 +-
.../common/config/AsterixFeedProperties.java | 2 +-
.../config/AsterixMetadataProperties.java | 2 +-
.../config/AsterixPropertiesAccessor.java | 14 +-
.../common/config/AsterixStorageProperties.java | 2 +-
.../config/AsterixTransactionProperties.java | 2 +-
.../asterix/common/config/DatasetConfig.java | 2 +-
.../asterix/common/config/GlobalConfig.java | 4 +-
.../config/IAsterixPropertiesProvider.java | 2 +-
.../common/config/IPropertyInterpreter.java | 4 +-
.../common/config/OptimizationConfUtil.java | 4 +-
.../common/config/PropertyInterpreters.java | 4 +-
.../common/context/AsterixFileMapManager.java | 8 +-
.../AsterixVirtualBufferCacheProvider.java | 10 +-
.../common/context/BaseOperationTracker.java | 16 +-
.../context/CorrelatedPrefixMergePolicy.java | 24 +-
.../CorrelatedPrefixMergePolicyFactory.java | 12 +-
.../common/context/DatasetLifecycleManager.java | 44 +-
.../context/ITransactionSubsystemProvider.java | 6 +-
.../context/PrimaryIndexOperationTracker.java | 36 +-
.../context/TransactionSubsystemProvider.java | 8 +-
.../common/dataflow/AsterixLSMIndexUtil.java | 12 +-
...erixLSMInsertDeleteOperatorNodePushable.java | 34 +-
...rtedIndexInsertDeleteOperatorDescriptor.java | 34 +-
...ixLSMTreeInsertDeleteOperatorDescriptor.java | 32 +-
.../IAsterixApplicationContextInfo.java | 8 +-
.../common/exceptions/ACIDException.java | 4 +-
.../common/exceptions/AsterixException.java | 2 +-
.../exceptions/AsterixRuntimeException.java | 2 +-
.../common/exceptions/FrameDataException.java | 4 +-
.../common/exceptions/TypeException.java | 2 +-
.../common/feeds/BasicMonitoredBuffer.java | 16 +-
.../asterix/common/feeds/CollectionRuntime.java | 12 +-
.../feeds/ComputeSideMonitoredBuffer.java | 16 +-
.../apache/asterix/common/feeds/DataBucket.java | 2 +-
.../asterix/common/feeds/DataBucketPool.java | 6 +-
.../common/feeds/DistributeFeedFrameWriter.java | 18 +-
.../asterix/common/feeds/FeedActivity.java | 2 +-
.../feeds/FeedCollectRuntimeInputHandler.java | 14 +-
.../common/feeds/FeedConnectJobInfo.java | 8 +-
.../asterix/common/feeds/FeedConnectionId.java | 2 +-
.../common/feeds/FeedConnectionRequest.java | 4 +-
.../asterix/common/feeds/FeedConstants.java | 2 +-
.../common/feeds/FeedExceptionHandler.java | 20 +-
.../asterix/common/feeds/FeedFrameCache.java | 18 +-
.../common/feeds/FeedFrameCollector.java | 10 +-
.../common/feeds/FeedFrameDiscarder.java | 4 +-
.../asterix/common/feeds/FeedFrameHandlers.java | 10 +-
.../asterix/common/feeds/FeedFrameSpiller.java | 8 +-
.../common/feeds/FeedFrameTupleAccessor.java | 8 +-
.../asterix/common/feeds/FeedFrameUtil.java | 14 +-
.../org/apache/asterix/common/feeds/FeedId.java | 2 +-
.../asterix/common/feeds/FeedIntakeInfo.java | 8 +-
.../asterix/common/feeds/FeedJobInfo.java | 6 +-
.../asterix/common/feeds/FeedJointKey.java | 2 +-
.../asterix/common/feeds/FeedMemoryManager.java | 10 +-
.../common/feeds/FeedMessageService.java | 8 +-
.../common/feeds/FeedMetricCollector.java | 4 +-
.../common/feeds/FeedPolicyAccessor.java | 2 +-
.../asterix/common/feeds/FeedRuntime.java | 8 +-
.../asterix/common/feeds/FeedRuntimeId.java | 4 +-
.../common/feeds/FeedRuntimeInputHandler.java | 30 +-
.../common/feeds/FeedRuntimeManager.java | 4 +-
.../asterix/common/feeds/FeedRuntimeReport.java | 2 +-
.../common/feeds/FeedStorageStatistics.java | 2 +-
.../common/feeds/FeedTupleCommitAckMessage.java | 4 +-
.../feeds/FeedTupleCommitResponseMessage.java | 4 +-
.../asterix/common/feeds/FrameCollection.java | 6 +-
.../asterix/common/feeds/FrameDistributor.java | 16 +-
.../common/feeds/FrameEventCallback.java | 10 +-
.../common/feeds/IFramePostProcessor.java | 4 +-
.../common/feeds/IFramePreprocessor.java | 2 +-
.../asterix/common/feeds/IngestionRuntime.java | 6 +-
.../common/feeds/IntakePartitionStatistics.java | 2 +-
.../common/feeds/IntakeSideMonitoredBuffer.java | 16 +-
.../asterix/common/feeds/MessageListener.java | 2 +-
.../asterix/common/feeds/MessageReceiver.java | 4 +-
.../asterix/common/feeds/MonitoredBuffer.java | 34 +-
.../common/feeds/MonitoredBufferTimerTasks.java | 24 +-
.../apache/asterix/common/feeds/NodeLoad.java | 4 +-
.../asterix/common/feeds/NodeLoadReport.java | 2 +-
.../common/feeds/NodeLoadReportService.java | 10 +-
.../org/apache/asterix/common/feeds/Series.java | 4 +-
.../apache/asterix/common/feeds/SeriesAvg.java | 4 +-
.../apache/asterix/common/feeds/SeriesRate.java | 4 +-
.../common/feeds/StorageFrameHandler.java | 6 +-
.../feeds/StorageSideMonitoredBuffer.java | 18 +-
.../common/feeds/SubscribableFeedRuntimeId.java | 4 +-
.../common/feeds/SubscribableRuntime.java | 8 +-
.../feeds/api/IAdapterRuntimeManager.java | 4 +-
.../common/feeds/api/ICentralFeedManager.java | 4 +-
.../common/feeds/api/IDatasourceAdapter.java | 4 +-
.../common/feeds/api/IExceptionHandler.java | 4 +-
.../asterix/common/feeds/api/IFeedAdapter.java | 2 +-
.../feeds/api/IFeedConnectionManager.java | 10 +-
.../common/feeds/api/IFeedFrameHandler.java | 6 +-
.../asterix/common/feeds/api/IFeedJoint.java | 12 +-
.../api/IFeedLifecycleEventSubscriber.java | 6 +-
.../IFeedLifecycleIntakeEventSubscriber.java | 6 +-
.../feeds/api/IFeedLifecycleListener.java | 12 +-
.../common/feeds/api/IFeedLoadManager.java | 20 +-
.../asterix/common/feeds/api/IFeedManager.java | 16 +-
.../common/feeds/api/IFeedMemoryComponent.java | 2 +-
.../common/feeds/api/IFeedMemoryManager.java | 4 +-
.../asterix/common/feeds/api/IFeedMessage.java | 4 +-
.../common/feeds/api/IFeedMessageService.java | 2 +-
.../common/feeds/api/IFeedMetadataManager.java | 6 +-
.../common/feeds/api/IFeedMetricCollector.java | 6 +-
.../api/IFeedOperatorOutputSideHandler.java | 6 +-
.../asterix/common/feeds/api/IFeedProvider.java | 4 +-
.../asterix/common/feeds/api/IFeedRuntime.java | 8 +-
.../asterix/common/feeds/api/IFeedService.java | 2 +-
.../feeds/api/IFeedSubscriptionManager.java | 4 +-
.../common/feeds/api/IFeedTrackingManager.java | 6 +-
.../asterix/common/feeds/api/IFeedWork.java | 2 +-
.../feeds/api/IFeedWorkEventListener.java | 2 +-
.../common/feeds/api/IFeedWorkManager.java | 2 +-
.../common/feeds/api/IFrameEventCallback.java | 2 +-
.../feeds/api/IIntakeProgressTracker.java | 2 +-
.../common/feeds/api/IMessageReceiver.java | 2 +-
.../common/feeds/api/ISubscribableRuntime.java | 10 +-
.../common/feeds/api/ISubscriberRuntime.java | 4 +-
.../common/feeds/api/ISubscriptionProvider.java | 4 +-
.../feeds/api/ITupleTrackingFeedAdapter.java | 2 +-
.../common/feeds/message/EndFeedMessage.java | 10 +-
.../feeds/message/FeedCongestionMessage.java | 16 +-
.../common/feeds/message/FeedMessage.java | 6 +-
.../feeds/message/FeedMessageService.java | 10 +-
.../common/feeds/message/FeedReportMessage.java | 16 +-
.../message/FeedTupleCommitAckMessage.java | 8 +-
.../message/FeedTupleCommitResponseMessage.java | 8 +-
.../common/feeds/message/NodeReportMessage.java | 6 +-
.../feeds/message/ScaleInReportMessage.java | 10 +-
.../feeds/message/StorageReportFeedMessage.java | 10 +-
.../message/ThrottlingEnabledFeedMessage.java | 12 +-
.../common/functions/FunctionConstants.java | 2 +-
.../common/functions/FunctionDescriptorTag.java | 2 +-
.../common/functions/FunctionSignature.java | 4 +-
.../AbstractLSMIOOperationCallback.java | 22 +-
.../LSMBTreeIOOperationCallback.java | 12 +-
.../LSMBTreeIOOperationCallbackFactory.java | 6 +-
.../LSMBTreeWithBuddyIOOperationCallback.java | 10 +-
...TreeWithBuddyIOOperationCallbackFactory.java | 6 +-
.../LSMInvertedIndexIOOperationCallback.java | 10 +-
...InvertedIndexIOOperationCallbackFactory.java | 6 +-
.../LSMRTreeIOOperationCallback.java | 10 +-
.../LSMRTreeIOOperationCallbackFactory.java | 6 +-
.../common/parse/IAsterixTupleParser.java | 4 +-
.../common/parse/IParseFileSplitsDecl.java | 4 +-
.../common/parse/ITupleForwardPolicy.java | 10 +-
.../common/parse/ITupleParserPolicy.java | 10 +-
.../transactions/AbstractOperationCallback.java | 6 +-
.../AbstractOperationCallbackFactory.java | 6 +-
.../asterix/common/transactions/DatasetId.java | 2 +-
.../IAsterixAppRuntimeContextProvider.java | 24 +-
.../common/transactions/ILockHashTable.java | 2 +-
.../common/transactions/ILockManager.java | 4 +-
.../common/transactions/ILockMatrix.java | 2 +-
.../common/transactions/ILogManager.java | 4 +-
.../asterix/common/transactions/ILogPage.java | 2 +-
.../asterix/common/transactions/ILogReader.java | 4 +-
.../asterix/common/transactions/ILogRecord.java | 4 +-
.../common/transactions/IRecoveryManager.java | 6 +-
.../transactions/ITransactionContext.java | 4 +-
.../transactions/ITransactionManager.java | 6 +-
.../transactions/ITransactionSubsystem.java | 2 +-
.../asterix/common/transactions/JobId.java | 2 +-
.../transactions/LogManagerProperties.java | 4 +-
.../asterix/common/transactions/LogRecord.java | 10 +-
.../asterix/common/transactions/LogType.java | 2 +-
.../common/transactions/MutableLong.java | 2 +-
.../transactions/PrimaryKeyTupleReference.java | 4 +-
.../asterix/common/utils/ANameSchema.java | 2 +-
.../asterix/common/utils/UTF8CharSequence.java | 6 +-
.../asterix/test/base/AsterixTestHelper.java | 2 +-
.../org/apache/asterix/test/aql/TestHelper.java | 2 +-
.../org/apache/asterix/test/aql/TestsUtils.java | 14 +-
asterix-doc/pom.xml | 2 +-
.../src/site/markdown/aql/externaldata.md | 4 +-
asterix-doc/src/site/markdown/feeds/tutorial.md | 12 +-
asterix-doc/src/site/site.xml | 2 +-
asterix-events/pom.xml | 12 +-
.../apache/asterix/event/api/ClusterInfo.java | 2 +-
.../org/apache/asterix/event/api/NodeInfo.java | 2 +-
.../asterix/event/driver/EventConfig.java | 2 +-
.../asterix/event/driver/EventDriver.java | 22 +-
.../asterix/event/error/EventException.java | 2 +-
.../asterix/event/error/OutputHandler.java | 10 +-
.../asterix/event/error/VerificationUtil.java | 18 +-
.../management/AsterixEventServiceClient.java | 24 +-
.../event/management/DefaultOutputHandler.java | 4 +-
.../asterix/event/management/ErrorHandler.java | 2 +-
.../asterix/event/management/EventExecutor.java | 16 +-
.../asterix/event/management/EventTask.java | 12 +-
.../event/management/EventTaskReport.java | 2 +-
.../asterix/event/management/EventUtil.java | 16 +-
.../event/management/IOutputHandler.java | 4 +-
.../event/management/IPatternListener.java | 2 +-
.../event/management/OutputAnalysis.java | 2 +-
.../asterix/event/management/Randomizer.java | 2 +-
.../asterix/event/management/ValueType.java | 4 +-
.../asterix/event/model/AsterixInstance.java | 12 +-
.../event/model/AsterixRuntimeState.java | 2 +-
.../apache/asterix/event/model/BackupInfo.java | 6 +-
.../apache/asterix/event/model/EventList.java | 2 +-
.../apache/asterix/event/model/ProcessInfo.java | 2 +-
.../event/service/AsterixEventService.java | 10 +-
.../event/service/AsterixEventServiceUtil.java | 34 +-
.../asterix/event/service/ILookupService.java | 6 +-
.../asterix/event/service/ServiceProvider.java | 2 +-
.../asterix/event/service/ZooKeeperService.java | 8 +-
.../asterix/event/util/AsterixConstants.java | 2 +-
.../asterix/event/util/PatternCreator.java | 38 +-
asterix-examples/pom.xml | 2 +-
asterix-external-data/pom.xml | 16 +-
.../adapter/factory/CNNFeedAdapterFactory.java | 20 +-
.../adapter/factory/HDFSAdapterFactory.java | 44 +-
.../factory/HDFSIndexingAdapterFactory.java | 56 +-
.../adapter/factory/HiveAdapterFactory.java | 24 +-
.../factory/NCFileSystemAdapterFactory.java | 38 +-
.../PullBasedAzureTwitterAdapterFactory.java | 32 +-
.../factory/PullBasedTwitterAdapterFactory.java | 26 +-
.../factory/PushBasedTwitterAdapterFactory.java | 22 +-
.../adapter/factory/RSSFeedAdapterFactory.java | 20 +-
.../factory/StreamBasedAdapterFactory.java | 16 +-
.../dataset/adapter/AzureTweetEntity.java | 2 +-
.../adapter/AzureTweetMetadataEntity.java | 2 +-
.../dataset/adapter/ClientBasedFeedAdapter.java | 24 +-
.../external/dataset/adapter/FeedClient.java | 52 +-
.../dataset/adapter/FileSystemBasedAdapter.java | 16 +-
.../external/dataset/adapter/HDFSAdapter.java | 24 +-
.../dataset/adapter/HDFSIndexingAdapter.java | 22 +-
.../external/dataset/adapter/HiveAdapter.java | 10 +-
.../external/dataset/adapter/IFeedClient.java | 4 +-
.../dataset/adapter/IFeedClientFactory.java | 8 +-
.../dataset/adapter/IPullBasedFeedClient.java | 4 +-
.../dataset/adapter/NCFileSystemAdapter.java | 14 +-
.../dataset/adapter/PullBasedAdapter.java | 24 +-
.../adapter/PullBasedAzureFeedClient.java | 12 +-
.../adapter/PullBasedAzureTwitterAdapter.java | 10 +-
.../adapter/PullBasedTwitterAdapter.java | 16 +-
.../adapter/PullBasedTwitterFeedClient.java | 14 +-
.../adapter/PushBasedTwitterAdapter.java | 14 +-
.../adapter/PushBasedTwitterFeedClient.java | 16 +-
.../dataset/adapter/RSSFeedAdapter.java | 14 +-
.../external/dataset/adapter/RSSFeedClient.java | 10 +-
.../dataset/adapter/StreamBasedAdapter.java | 16 +-
.../dataflow/AbstractIndexingTupleParser.java | 30 +-
.../AdmOrDelimitedControlledTupleParser.java | 40 +-
.../AdmOrDelimitedIndexingTupleParser.java | 34 +-
.../dataflow/FileIndexTupleTranslator.java | 38 +-
.../dataflow/HDFSIndexingParserFactory.java | 26 +-
.../indexing/dataflow/HDFSLookupAdapter.java | 42 +-
.../dataflow/HDFSLookupAdapterFactory.java | 76 +--
.../dataflow/HDFSObjectTupleParser.java | 22 +-
.../dataflow/HDFSObjectTupleParserFactory.java | 14 +-
.../indexing/dataflow/HiveObjectParser.java | 34 +-
.../dataflow/IAsterixHDFSRecordParser.java | 4 +-
.../dataflow/IControlledTupleParser.java | 6 +-
.../dataflow/IControlledTupleParserFactory.java | 2 +-
.../indexing/dataflow/IndexingScheduler.java | 14 +-
.../dataflow/RCFileControlledTupleParser.java | 36 +-
.../dataflow/RCFileIndexingTupleParser.java | 12 +-
.../dataflow/SeqOrTxtControlledTupleParser.java | 36 +-
.../dataflow/TextOrSeqIndexingTupleParser.java | 12 +-
.../input/AbstractHDFSLookupInputStream.java | 8 +-
.../indexing/input/AbstractHDFSReader.java | 2 +-
.../input/GenericFileAwareRecordReader.java | 4 +-
.../indexing/input/GenericRecordReader.java | 4 +-
.../indexing/input/HDFSSeekableLineReader.java | 2 +-
.../external/indexing/input/ILookupReader.java | 2 +-
.../indexing/input/RCFileDataReader.java | 6 +-
.../indexing/input/RCFileLookupReader.java | 8 +-
.../input/SequenceFileLookupInputStream.java | 4 +-
.../input/SequenceFileLookupReader.java | 8 +-
.../input/TextFileLookupInputStream.java | 4 +-
.../indexing/input/TextFileLookupReader.java | 8 +-
.../indexing/input/TextualDataReader.java | 6 +-
.../input/TextualFullScanDataReader.java | 4 +-
...xternalDatasetIndexesOperatorDescriptor.java | 28 +-
...alDatasetIndexesAbortOperatorDescriptor.java | 20 +-
...lDatasetIndexesCommitOperatorDescriptor.java | 22 +-
...DatasetIndexesRecoverOperatorDescriptor.java | 20 +-
...ternalIndexBulkModifyOperatorDescriptor.java | 32 +-
...rnalIndexBulkModifyOperatorNodePushable.java | 28 +-
.../operators/IndexInfoOperatorDescriptor.java | 36 +-
.../external/library/ExternalFunction.java | 30 +-
.../ExternalFunctionDescriptorProvider.java | 18 +-
.../library/ExternalFunctionProvider.java | 18 +-
.../ExternalScalarFunctionEvaluatorFactory.java | 12 +-
.../external/library/IExternalFunction.java | 2 +-
.../library/IExternalScalarFunction.java | 2 +-
.../external/library/IFunctionFactory.java | 2 +-
.../external/library/IFunctionHelper.java | 8 +-
.../external/library/IResultCollector.java | 10 +-
.../external/library/JTypeObjectFactory.java | 58 +-
.../external/library/JavaFunctionHelper.java | 44 +-
.../external/library/ResultCollector.java | 36 +-
.../library/RuntimeExternalFunctionUtil.java | 20 +-
.../asterix/external/library/TypeInfo.java | 10 +-
.../external/library/java/IJListAccessor.java | 10 +-
.../asterix/external/library/java/IJObject.java | 10 +-
.../external/library/java/IJObjectAccessor.java | 10 +-
.../external/library/java/IJRecordAccessor.java | 14 +-
.../asterix/external/library/java/IJType.java | 6 +-
.../external/library/java/JObjectAccessors.java | 128 ++--
.../library/java/JObjectPointableVisitor.java | 26 +-
.../external/library/java/JObjectUtil.java | 78 +--
.../asterix/external/library/java/JObjects.java | 132 ++--
.../asterix/external/library/java/JTypeTag.java | 2 +-
.../asterix/external/util/DNSResolver.java | 6 +-
.../external/util/DNSResolverFactory.java | 2 +-
.../apache/asterix/external/util/Datatypes.java | 2 +-
.../asterix/external/util/INodeResolver.java | 4 +-
.../external/util/INodeResolverFactory.java | 2 +-
.../external/util/IdentitiyResolverFactory.java | 2 +-
.../asterix/external/util/IdentityResolver.java | 2 +-
.../asterix/external/util/TweetProcessor.java | 16 +-
.../asterix/external/util/TwitterUtil.java | 4 +-
.../external/library/AddHashTagsFactory.java | 6 +-
.../external/library/AddHashTagsFunction.java | 16 +-
.../library/AddHashTagsInPlaceFactory.java | 2 +-
.../library/AddHashTagsInPlaceFunction.java | 12 +-
.../external/library/AllTypesFactory.java | 6 +-
.../external/library/AllTypesFunction.java | 38 +-
.../external/library/CapitalFinderFactory.java | 6 +-
.../external/library/CapitalFinderFunction.java | 8 +-
.../external/library/EchoDelayFactory.java | 2 +-
.../external/library/EchoDelayFunction.java | 4 +-
.../external/library/ParseTweetFactory.java | 6 +-
.../external/library/ParseTweetFunction.java | 10 +-
.../asterix/external/library/SumFactory.java | 2 +-
.../asterix/external/library/SumFunction.java | 8 +-
.../external/library/UpperCaseFactory.java | 6 +-
.../external/library/UpperCaseFunction.java | 10 +-
.../library/adapter/TestTypedAdapter.java | 16 +-
.../adapter/TestTypedAdapterFactory.java | 34 +-
.../src/test/resources/library_descriptor.xml | 18 +-
asterix-fuzzyjoin/pom.xml | 6 +-
.../asterix/fuzzyjoin/FuzzyFiltersJaccard.java | 4 +-
.../fuzzyjoin/FuzzyJoinAppendLength.java | 8 +-
.../asterix/fuzzyjoin/FuzzyJoinConfig.java | 4 +-
.../asterix/fuzzyjoin/FuzzyJoinContext.java | 6 +-
.../asterix/fuzzyjoin/FuzzyJoinMemory.java | 10 +-
.../asterix/fuzzyjoin/FuzzyJoinTokenize.java | 14 +-
.../apache/asterix/fuzzyjoin/FuzzyJoinUtil.java | 4 +-
.../org/apache/asterix/fuzzyjoin/IntArray.java | 4 +-
.../org/apache/asterix/fuzzyjoin/IntPair.java | 4 +-
.../fuzzyjoin/LittleEndianIntInputStream.java | 4 +-
.../fuzzyjoin/LittleEndianIntOutputStream.java | 4 +-
.../asterix/fuzzyjoin/MutableInteger.java | 4 +-
.../asterix/fuzzyjoin/RIDPairSimilarity.java | 4 +-
.../apache/asterix/fuzzyjoin/ResultJoin.java | 4 +-
.../asterix/fuzzyjoin/ResultSelfJoin.java | 4 +-
.../fuzzyjoin/invertedlist/InvertedList.java | 4 +-
.../invertedlist/InvertedListLengthFixed.java | 4 +-
.../invertedlist/InvertedListLengthList.java | 4 +-
.../invertedlist/InvertedListPlain.java | 4 +-
.../fuzzyjoin/invertedlist/InvertedLists.java | 4 +-
.../invertedlist/InvertedListsLengthFixed.java | 4 +-
.../invertedlist/InvertedListsLengthList.java | 4 +-
.../fuzzyjoin/recordgroup/RecordGroup.java | 6 +-
.../recordgroup/RecordGroupFactory.java | 6 +-
.../recordgroup/RecordGroupLengthCount.java | 6 +-
.../recordgroup/RecordGroupLengthIdentity.java | 6 +-
.../recordgroup/RecordGroupLengthRange.java | 6 +-
.../recordgroup/RecordGroupSingle.java | 6 +-
.../recordgroup/RecordGroupTokenFrequency.java | 6 +-
.../RecordGroupTokenFrequencyMirror.java | 6 +-
.../recordgroup/RecordGroupTokenIdentity.java | 6 +-
.../similarity/IGenericSimilarityMetric.java | 6 +-
.../fuzzyjoin/similarity/IListIterator.java | 6 +-
.../fuzzyjoin/similarity/PartialIntersect.java | 4 +-
.../fuzzyjoin/similarity/SimilarityFilters.java | 4 +-
.../similarity/SimilarityFiltersFactory.java | 4 +-
.../similarity/SimilarityFiltersJaccard.java | 4 +-
.../fuzzyjoin/similarity/SimilarityMetric.java | 8 +-
.../SimilarityMetricEditDistance.java | 8 +-
.../similarity/SimilarityMetricFactory.java | 4 +-
.../similarity/SimilarityMetricJaccard.java | 8 +-
.../AbstractUTF8StringBinaryTokenizer.java | 6 +-
.../fuzzyjoin/tokenizer/AbstractUTF8Token.java | 4 +-
.../tokenizer/AbstractUTF8TokenFactory.java | 4 +-
.../DelimitedUTF8StringBinaryTokenizer.java | 4 +-
...limitedUTF8StringBinaryTokenizerFactory.java | 4 +-
.../tokenizer/HashedUTF8NGramToken.java | 4 +-
.../tokenizer/HashedUTF8NGramTokenFactory.java | 4 +-
.../tokenizer/HashedUTF8WordToken.java | 4 +-
.../tokenizer/HashedUTF8WordTokenFactory.java | 4 +-
.../fuzzyjoin/tokenizer/IBinaryTokenizer.java | 4 +-
.../tokenizer/IBinaryTokenizerFactory.java | 4 +-
.../fuzzyjoin/tokenizer/INGramToken.java | 4 +-
.../asterix/fuzzyjoin/tokenizer/IToken.java | 4 +-
.../fuzzyjoin/tokenizer/ITokenFactory.java | 4 +-
.../fuzzyjoin/tokenizer/NGramTokenizer.java | 4 +-
.../NGramUTF8StringBinaryTokenizer.java | 4 +-
.../fuzzyjoin/tokenizer/StringUtils.java | 4 +-
.../asterix/fuzzyjoin/tokenizer/Token.java | 4 +-
.../asterix/fuzzyjoin/tokenizer/Tokenizer.java | 4 +-
.../fuzzyjoin/tokenizer/TokenizerBuffered.java | 4 +-
.../tokenizer/TokenizerBufferedFactory.java | 4 +-
.../fuzzyjoin/tokenizer/TokenizerFactory.java | 4 +-
.../fuzzyjoin/tokenizer/UTF8NGramToken.java | 4 +-
.../tokenizer/UTF8NGramTokenFactory.java | 4 +-
.../fuzzyjoin/tokenizer/UTF8WordToken.java | 4 +-
.../tokenizer/UTF8WordTokenFactory.java | 4 +-
.../fuzzyjoin/tokenizer/WordTokenizer.java | 4 +-
.../tokenizer/WordTokenizerBuffered.java | 6 +-
.../fuzzyjoin/tokenorder/IntTokenCountRank.java | 4 +-
.../tokenorder/IntTokenCountRankFrequency.java | 6 +-
.../fuzzyjoin/tokenorder/IntTokenRank.java | 4 +-
.../tokenorder/IntTokenRankFrequency.java | 4 +-
.../asterix/fuzzyjoin/tokenorder/TokenLoad.java | 6 +-
.../asterix/fuzzyjoin/tokenorder/TokenRank.java | 4 +-
.../tokenorder/TokenRankBufferedFrequency.java | 6 +-
.../tokenorder/TokenRankFrequency.java | 4 +-
.../asterix/fuzzyjoin/tests/FuzzyJoinTest.java | 14 +-
.../fuzzyjoin/tests/FuzzyJoinTestUtil.java | 4 +-
.../fuzzyjoin/tests/NGramTokenizerTest.java | 14 +-
.../fuzzyjoin/tests/WordTokenizerTest.java | 14 +-
.../tests/dataset/AbstractDataset.java | 4 +-
.../dataset/AbstractTokenizableDataset.java | 2 +-
.../fuzzyjoin/tests/dataset/DBLPDataset.java | 4 +-
.../tests/dataset/DBLPSmallDataset.java | 4 +-
.../tests/dataset/IntArrayBagSmallDataset.java | 4 +-
.../tests/dataset/IntArraySetSmallDataset.java | 4 +-
.../fuzzyjoin/tests/dataset/PUBDataset.java | 4 +-
.../tests/dataset/PUBSmallDataset.java | 4 +-
.../tests/dataset/PublicationsDataset.java | 4 +-
.../dataset/UsersVisitorsSmallDataset.java | 4 +-
asterix-fuzzyjoin/src/test/scripts/inmemory.sh | 6 +-
asterix-installer/pom.xml | 14 +-
.../src/main/assembly/binary-assembly.xml | 4 +-
.../installer/command/AbstractCommand.java | 2 +-
.../asterix/installer/command/AlterCommand.java | 18 +-
.../installer/command/BackupCommand.java | 22 +-
.../installer/command/CommandConfig.java | 2 +-
.../installer/command/CommandHandler.java | 4 +-
.../installer/command/ConfigureCommand.java | 14 +-
.../installer/command/CreateCommand.java | 30 +-
.../installer/command/DeleteCommand.java | 18 +-
.../installer/command/DescribeCommand.java | 18 +-
.../asterix/installer/command/HelpCommand.java | 2 +-
.../asterix/installer/command/ICommand.java | 2 +-
.../installer/command/InstallCommand.java | 16 +-
.../asterix/installer/command/LogCommand.java | 20 +-
.../installer/command/RestoreCommand.java | 18 +-
.../installer/command/ShutdownCommand.java | 10 +-
.../asterix/installer/command/StartCommand.java | 24 +-
.../installer/command/StartNodeCommand.java | 34 +-
.../asterix/installer/command/StopCommand.java | 24 +-
.../installer/command/StopNodeCommand.java | 32 +-
.../installer/command/UninstallCommand.java | 22 +-
.../installer/command/ValidateCommand.java | 18 +-
.../installer/command/VersionCommand.java | 6 +-
.../installer/driver/InstallerDriver.java | 14 +-
.../asterix/installer/driver/InstallerUtil.java | 8 +-
.../installer/error/InstallerException.java | 2 +-
.../asterix/installer/error/OutputHandler.java | 10 +-
.../src/main/resources/conf/log4j.properties | 2 +-
.../src/main/resources/scripts/managix | 2 +-
.../test/AsterixClusterLifeCycleIT.java | 6 +-
.../test/AsterixExternalLibraryIT.java | 8 +-
.../test/AsterixInstallerIntegrationUtil.java | 22 +-
.../installer/test/AsterixLifecycleIT.java | 18 +-
.../installer/transaction/DmlRecoveryIT.java | 10 +-
.../installer/transaction/RecoveryIT.java | 6 +-
.../dataverseDataset/dataverseDataset.1.adm | 4 +-
.../functionDataset/functionDataset.1.adm | 16 +-
.../integrationts/library/testsuite.xml | 2 +-
.../backupRestore/backupRestore.1.adm | 2 +-
.../integrationts/lifecycle/testsuite.xml | 2 +-
.../primary_index_only.3.update.aql | 2 +-
...ry_plus_default_secondary_index.3.update.aql | 2 +-
...ry_plus_keyword_secondary_index.3.update.aql | 2 +-
...plus_multiple_secondary_indices.3.update.aql | 2 +-
.../primary_plus_ngram_index.3.update.aql | 2 +-
.../primary_plus_rtree_index.3.update.aql | 2 +-
.../primary_index_only.3.update.aql | 2 +-
...ry_plus_default_secondary_index.3.update.aql | 2 +-
...ry_plus_keyword_secondary_index.3.update.aql | 2 +-
...plus_multiple_secondary_indices.3.update.aql | 2 +-
.../primary_plus_ngram_index.3.update.aql | 2 +-
.../primary_plus_rtree_index.3.update.aql | 2 +-
.../delete_after_recovery.3.update.aql | 2 +-
.../insert_after_recovery.3.update.aql | 2 +-
.../load_after_recovery.5.update.aql | 2 +-
.../delete_after_recovery.3.update.aql | 2 +-
.../insert_after_recovery.3.update.aql | 2 +-
.../load_after_recovery.5.update.aql | 2 +-
.../test/resources/transactionts/testsuite.xml | 24 +-
.../Asterix_ADM_Parser.md | 4 +-
.../lexer-generator-maven-plugin/README.md | 6 +-
.../lexer-generator-maven-plugin/pom.xml | 4 +-
.../asterix/lexergenerator/LexerGenerator.java | 2 +-
.../lexergenerator/LexerGeneratorMojo.java | 4 +-
.../asterix/lexergenerator/LexerNode.java | 10 +-
.../lexergenerator/NodeChainFactory.java | 4 +-
.../apache/asterix/lexergenerator/Token.java | 2 +-
.../apache/asterix/lexergenerator/TokenAux.java | 2 +-
.../rulegenerators/RuleGenerator.java | 4 +-
.../RuleGeneratorAnythingUntil.java | 6 +-
.../RuleGeneratorCaseInsensitiveChar.java | 6 +-
.../rulegenerators/RuleGeneratorChar.java | 6 +-
.../RuleGeneratorCharOrNothing.java | 8 +-
.../RuleGeneratorDigitSequence.java | 6 +-
.../rulegenerators/RuleGeneratorNothing.java | 6 +-
.../rulegenerators/RuleGeneratorSign.java | 6 +-
.../RuleGeneratorSignOrNothing.java | 8 +-
.../rulegenerators/RuleGeneratorString.java | 6 +-
.../rulegenerators/RuleGeneratorToken.java | 6 +-
.../asterix/lexergenerator/rules/Rule.java | 2 +-
.../lexergenerator/rules/RuleAnythingUntil.java | 2 +-
.../asterix/lexergenerator/rules/RuleChar.java | 2 +-
.../lexergenerator/rules/RuleDigitSequence.java | 2 +-
.../lexergenerator/rules/RuleEpsilon.java | 2 +-
.../lexergenerator/rules/RulePartial.java | 2 +-
.../apache/asterix/lexergenerator/Fixtures.java | 6 +-
.../lexergenerator/LexerNodeAddRuleTest.java | 6 +-
.../lexergenerator/LexerNodeAppendNodeTest.java | 8 +-
.../lexergenerator/LexerNodeAppendRuleTest.java | 6 +-
.../LexerNodeAuxFunctionsTest.java | 12 +-
.../lexergenerator/LexerNodeCloneTest.java | 12 +-
.../lexergenerator/LexerNodeMergeNodeTest.java | 28 +-
asterix-maven-plugins/pom.xml | 4 +-
.../pom.xml | 4 +-
.../recordmanagergenerator/Generator.java | 4 +-
.../RecordManagerGeneratorMojo.java | 2 +-
.../recordmanagergenerator/RecordType.java | 2 +-
asterix-metadata/pom.xml | 18 +-
.../asterix/metadata/GarbageCollector.java | 2 +-
.../asterix/metadata/IDatasetDetails.java | 6 +-
.../apache/asterix/metadata/MetadataCache.java | 34 +-
.../asterix/metadata/MetadataException.java | 4 +-
.../asterix/metadata/MetadataManager.java | 52 +-
.../apache/asterix/metadata/MetadataNode.java | 164 ++---
.../metadata/MetadataTransactionContext.java | 38 +-
.../metadata/api/IAsterixStateProxy.java | 2 +-
.../asterix/metadata/api/IClusterManager.java | 8 +-
.../asterix/metadata/api/IMetadataEntity.java | 4 +-
.../api/IMetadataEntityTupleTranslator.java | 6 +-
.../asterix/metadata/api/IMetadataIndex.java | 18 +-
.../asterix/metadata/api/IMetadataManager.java | 36 +-
.../asterix/metadata/api/IMetadataNode.java | 36 +-
.../asterix/metadata/api/IValueExtractor.java | 10 +-
.../metadata/bootstrap/AsterixStateProxy.java | 6 +-
.../metadata/bootstrap/MetadataBootstrap.java | 152 ++---
.../metadata/bootstrap/MetadataConstants.java | 2 +-
.../metadata/bootstrap/MetadataIndex.java | 32 +-
.../bootstrap/MetadataPrimaryIndexes.java | 10 +-
.../metadata/bootstrap/MetadataRecordTypes.java | 22 +-
.../bootstrap/MetadataSecondaryIndexes.java | 10 +-
.../cluster/AbstractClusterManagementWork.java | 6 +-
.../asterix/metadata/cluster/AddNodeWork.java | 4 +-
.../metadata/cluster/AddNodeWorkResponse.java | 2 +-
.../cluster/ClusterManagementWorkResponse.java | 6 +-
.../metadata/cluster/ClusterManager.java | 38 +-
.../metadata/cluster/RemoveNodeWork.java | 4 +-
.../cluster/RemoveNodeWorkResponse.java | 2 +-
.../metadata/dataset/hints/DatasetHints.java | 6 +-
.../asterix/metadata/dataset/hints/IHint.java | 4 +-
.../AqlCompiledMetadataDeclarations.java | 52 +-
.../metadata/declared/AqlDataSource.java | 36 +-
.../asterix/metadata/declared/AqlIndex.java | 8 +-
.../declared/AqlLogicalPlanAndMetadataImpl.java | 10 +-
.../declared/AqlMetadataImplConfig.java | 2 +-
.../metadata/declared/AqlMetadataProvider.java | 326 ++++-----
.../asterix/metadata/declared/AqlSourceId.java | 2 +-
.../metadata/declared/DatasetDataSource.java | 24 +-
.../metadata/declared/FeedDataSource.java | 24 +-
.../declared/FieldExtractingAdapter.java | 28 +-
.../declared/FieldExtractingAdapterFactory.java | 16 +-
.../metadata/declared/FileSplitDataSink.java | 6 +-
.../metadata/declared/FileSplitSinkId.java | 4 +-
.../metadata/declared/LoadableDataSource.java | 28 +-
.../metadata/declared/PKGeneratingAdapter.java | 34 +-
.../declared/PKGeneratingAdapterFactory.java | 14 +-
.../metadata/declared/ResultSetDataSink.java | 10 +-
.../metadata/declared/ResultSetSinkId.java | 4 +-
.../entities/AsterixBuiltinTypeMap.java | 14 +-
.../metadata/entities/CompactionPolicy.java | 6 +-
.../asterix/metadata/entities/Dataset.java | 10 +-
.../metadata/entities/DatasourceAdapter.java | 8 +-
.../asterix/metadata/entities/Datatype.java | 8 +-
.../asterix/metadata/entities/Dataverse.java | 6 +-
.../entities/ExternalDatasetDetails.java | 40 +-
.../asterix/metadata/entities/ExternalFile.java | 8 +-
.../apache/asterix/metadata/entities/Feed.java | 10 +-
.../asterix/metadata/entities/FeedPolicy.java | 6 +-
.../asterix/metadata/entities/Function.java | 6 +-
.../apache/asterix/metadata/entities/Index.java | 20 +-
.../entities/InternalDatasetDetails.java | 38 +-
.../asterix/metadata/entities/Library.java | 6 +-
.../apache/asterix/metadata/entities/Node.java | 2 +-
.../asterix/metadata/entities/NodeGroup.java | 6 +-
.../asterix/metadata/entities/PrimaryFeed.java | 6 +-
.../metadata/entities/SecondaryFeed.java | 6 +-
.../AbstractTupleTranslator.java | 28 +-
.../CompactionPolicyTupleTranslator.java | 22 +-
.../DatasetTupleTranslator.java | 74 +-
.../DatasourceAdapterTupleTranslator.java | 26 +-
.../DatatypeTupleTranslator.java | 64 +-
.../DataverseTupleTranslator.java | 28 +-
.../ExternalFileTupleTranslator.java | 38 +-
.../FeedPolicyTupleTranslator.java | 46 +-
.../FeedTupleTranslator.java | 52 +-
.../FunctionTupleTranslator.java | 32 +-
.../IndexTupleTranslator.java | 52 +-
.../LibraryTupleTranslator.java | 22 +-
.../NodeGroupTupleTranslator.java | 32 +-
.../NodeTupleTranslator.java | 26 +-
.../external/ExternalFileIndexAccessor.java | 46 +-
.../ExternalLoopkupOperatorDiscriptor.java | 32 +-
.../external/FilesIndexDescription.java | 30 +-
.../metadata/external/IAdapterFactory.java | 10 +-
.../metadata/external/IControlledAdapter.java | 10 +-
.../external/IControlledAdapterFactory.java | 8 +-
.../metadata/external/IndexingConstants.java | 28 +-
.../feeds/AbstractDatasourceAdapter.java | 10 +-
.../feeds/AbstractFeedDatasourceAdapter.java | 4 +-
.../asterix/metadata/feeds/AdapterExecutor.java | 10 +-
.../metadata/feeds/AdapterIdentifier.java | 2 +-
.../metadata/feeds/AdapterRuntimeManager.java | 14 +-
.../metadata/feeds/BuiltinFeedPolicies.java | 8 +-
.../feeds/CollectTransformFeedFrameWriter.java | 30 +-
.../asterix/metadata/feeds/EndFeedMessage.java | 4 +-
.../ExternalDataScanOperatorDescriptor.java | 22 +-
.../metadata/feeds/FeedActivityIdFactory.java | 2 +-
.../feeds/FeedCollectOperatorDescriptor.java | 38 +-
.../feeds/FeedCollectOperatorNodePushable.java | 44 +-
.../metadata/feeds/FeedConnectionManager.java | 12 +-
.../metadata/feeds/FeedFrameTupleDecorator.java | 30 +-
.../feeds/FeedIntakeOperatorDescriptor.java | 34 +-
.../feeds/FeedIntakeOperatorNodePushable.java | 40 +-
.../feeds/FeedLifecycleEventSubscriber.java | 6 +-
.../metadata/feeds/FeedManagerElectMessage.java | 4 +-
.../asterix/metadata/feeds/FeedMessage.java | 4 +-
.../feeds/FeedMessageOperatorDescriptor.java | 18 +-
.../feeds/FeedMessageOperatorNodePushable.java | 64 +-
.../feeds/FeedMetaComputeNodePushable.java | 40 +-
.../metadata/feeds/FeedMetaNodePushable.java | 32 +-
.../feeds/FeedMetaOperatorDescriptor.java | 22 +-
.../feeds/FeedMetaStoreNodePushable.java | 32 +-
.../metadata/feeds/FeedPolicyEnforcer.java | 8 +-
.../metadata/feeds/FeedSubscriptionManager.java | 8 +-
.../apache/asterix/metadata/feeds/FeedUtil.java | 104 +--
.../asterix/metadata/feeds/FeedWorkManager.java | 8 +-
.../metadata/feeds/IAdapterExecutor.java | 4 +-
.../metadata/feeds/IFeedAdapterFactory.java | 6 +-
.../asterix/metadata/feeds/IFeedMessage.java | 2 +-
.../metadata/feeds/IPullBasedFeedAdapter.java | 4 +-
.../metadata/feeds/ITypedAdapterFactory.java | 6 +-
.../asterix/metadata/feeds/MessageListener.java | 2 +-
.../metadata/feeds/PrepareStallMessage.java | 8 +-
.../feeds/RemoteSocketMessageListener.java | 2 +-
.../metadata/feeds/SocketMessageListener.java | 4 +-
.../feeds/TerminateDataFlowMessage.java | 8 +-
.../asterix/metadata/feeds/XAQLFeedMessage.java | 8 +-
.../AsterixExternalScalarFunctionInfo.java | 12 +-
.../functions/ExternalFunctionCompilerUtil.java | 48 +-
.../functions/ExternalLibraryManager.java | 2 +-
.../functions/MetadataBuiltinFunctions.java | 36 +-
.../asterix/metadata/utils/DatasetLock.java | 4 +-
.../asterix/metadata/utils/DatasetUtils.java | 64 +-
.../utils/ExternalDatasetAccessManager.java | 2 +-
.../utils/ExternalDatasetsRegistry.java | 6 +-
.../metadata/utils/MetadataLockManager.java | 4 +-
.../DatasetNameValueExtractor.java | 16 +-
.../DatatypeNameValueExtractor.java | 18 +-
.../MetadataEntityValueExtractor.java | 14 +-
.../NestedDatatypeNameValueExtractor.java | 16 +-
.../TupleCopyValueExtractor.java | 18 +-
asterix-om/pom.xml | 12 +-
.../asterix/builders/AbstractListBuilder.java | 18 +-
.../asterix/builders/AbvsBuilderFactory.java | 10 +-
.../asterix/builders/IARecordBuilder.java | 8 +-
.../asterix/builders/IAsterixListBuilder.java | 8 +-
.../asterix/builders/ListBuilderFactory.java | 6 +-
.../asterix/builders/OrderedListBuilder.java | 6 +-
.../apache/asterix/builders/RecordBuilder.java | 30 +-
.../asterix/builders/RecordBuilderFactory.java | 6 +-
.../asterix/builders/UnorderedListBuilder.java | 4 +-
.../dataflow/data/common/AListElementToken.java | 6 +-
.../data/common/AListElementTokenFactory.java | 6 +-
.../common/AOrderedListBinaryTokenizer.java | 18 +-
.../AOrderedListBinaryTokenizerFactory.java | 8 +-
.../common/AUnorderedListBinaryTokenizer.java | 8 +-
.../AUnorderedListBinaryTokenizerFactory.java | 8 +-
.../data/common/AqlExpressionTypeComputer.java | 42 +-
.../AqlMergeAggregationExpressionFactory.java | 20 +-
.../data/common/AqlNullableTypeComputer.java | 12 +-
.../AqlPartialAggregationTypeComputer.java | 28 +-
.../common/IBinaryTokenizerFactoryProvider.java | 6 +-
.../dataflow/data/common/SerializationUtil.java | 2 +-
.../data/nontagged/AqlNullWriterFactory.java | 10 +-
.../dataflow/data/nontagged/Coordinate.java | 2 +-
.../comparators/ABinaryComparator.java | 16 +-
.../ACirclePartialBinaryComparatorFactory.java | 16 +-
...ADurationPartialBinaryComparatorFactory.java | 14 +-
...AIntervalPartialBinaryComparatorFactory.java | 12 +-
.../ALinePartialBinaryComparatorFactory.java | 16 +-
.../AObjectAscBinaryComparatorFactory.java | 34 +-
.../AObjectDescBinaryComparatorFactory.java | 8 +-
.../APoint3DPartialBinaryComparatorFactory.java | 16 +-
.../APointPartialBinaryComparatorFactory.java | 16 +-
.../APolygonPartialBinaryComparatorFactory.java | 18 +-
...RectanglePartialBinaryComparatorFactory.java | 8 +-
.../AUUIDPartialBinaryComparatorFactory.java | 8 +-
.../BooleanBinaryComparatorFactory.java | 8 +-
.../ListItemBinaryComparatorFactory.java | 26 +-
.../LongBinaryComparatorFactory.java | 8 +-
.../comparators/RawBinaryComparatorFactory.java | 6 +-
.../AMurmurHash3BinaryHashFunctionFamily.java | 20 +-
.../hash/AObjectBinaryHashFunctionFactory.java | 10 +-
.../hash/BooleanBinaryHashFunctionFactory.java | 8 +-
.../hash/DoubleBinaryHashFunctionFactory.java | 8 +-
.../hash/ListItemBinaryHashFunctionFactory.java | 20 +-
.../hash/LongBinaryHashFunctionFactory.java | 8 +-
...AWrappedAscNormalizedKeyComputerFactory.java | 6 +-
...WrappedDescNormalizedKeyComputerFactory.java | 6 +-
.../printers/ABinaryBase64Printer.java | 8 +-
.../nontagged/printers/ABinaryHexPrinter.java | 8 +-
.../printers/ABinaryPrinterFactory.java | 6 +-
.../nontagged/printers/ABooleanPrinter.java | 8 +-
.../printers/ABooleanPrinterFactory.java | 6 +-
.../data/nontagged/printers/ACirclePrinter.java | 8 +-
.../printers/ACirclePrinterFactory.java | 6 +-
.../data/nontagged/printers/ADatePrinter.java | 12 +-
.../nontagged/printers/ADatePrinterFactory.java | 6 +-
.../nontagged/printers/ADateTimePrinter.java | 12 +-
.../printers/ADateTimePrinterFactory.java | 6 +-
.../printers/ADayTimeDurationPrinter.java | 12 +-
.../ADayTimeDurationPrinterFactory.java | 6 +-
.../data/nontagged/printers/ADoublePrinter.java | 8 +-
.../printers/ADoublePrinterFactory.java | 6 +-
.../nontagged/printers/ADurationPrinter.java | 14 +-
.../printers/ADurationPrinterFactory.java | 6 +-
.../data/nontagged/printers/AFloatPrinter.java | 8 +-
.../printers/AFloatPrinterFactory.java | 6 +-
.../data/nontagged/printers/AInt16Printer.java | 12 +-
.../printers/AInt16PrinterFactory.java | 6 +-
.../data/nontagged/printers/AInt32Printer.java | 12 +-
.../printers/AInt32PrinterFactory.java | 6 +-
.../data/nontagged/printers/AInt64Printer.java | 10 +-
.../printers/AInt64PrinterFactory.java | 6 +-
.../data/nontagged/printers/AInt8Printer.java | 12 +-
.../nontagged/printers/AInt8PrinterFactory.java | 6 +-
.../nontagged/printers/AIntervalPrinter.java | 14 +-
.../printers/AIntervalPrinterFactory.java | 6 +-
.../data/nontagged/printers/ALinePrinter.java | 8 +-
.../nontagged/printers/ALinePrinterFactory.java | 6 +-
.../data/nontagged/printers/ANullPrinter.java | 6 +-
.../nontagged/printers/ANullPrinterFactory.java | 6 +-
.../printers/ANullableFieldPrinterFactory.java | 16 +-
.../data/nontagged/printers/AObjectPrinter.java | 12 +-
.../printers/AObjectPrinterFactory.java | 6 +-
.../printers/AOrderedlistPrinterFactory.java | 24 +-
.../nontagged/printers/APoint3DPrinter.java | 8 +-
.../printers/APoint3DPrinterFactory.java | 6 +-
.../data/nontagged/printers/APointPrinter.java | 8 +-
.../printers/APointPrinterFactory.java | 6 +-
.../nontagged/printers/APolygonPrinter.java | 10 +-
.../printers/APolygonPrinterFactory.java | 6 +-
.../printers/ARecordPrinterFactory.java | 24 +-
.../nontagged/printers/ARectanglePrinter.java | 8 +-
.../printers/ARectanglePrinterFactory.java | 6 +-
.../data/nontagged/printers/AStringPrinter.java | 6 +-
.../printers/AStringPrinterFactory.java | 6 +-
.../data/nontagged/printers/ATimePrinter.java | 12 +-
.../nontagged/printers/ATimePrinterFactory.java | 6 +-
.../data/nontagged/printers/AUUIDPrinter.java | 10 +-
.../nontagged/printers/AUUIDPrinterFactory.java | 6 +-
.../printers/AUnionPrinterFactory.java | 16 +-
.../printers/AUnorderedlistPrinterFactory.java | 24 +-
.../printers/AYearMonthDurationPrinter.java | 16 +-
.../AYearMonthDurationPrinterFactory.java | 8 +-
.../data/nontagged/printers/PrintTools.java | 4 +-
.../printers/ShortWithoutTypeInfoPrinter.java | 10 +-
.../ShortWithoutTypeInfoPrinterFactory.java | 6 +-
.../nontagged/printers/csv/ABooleanPrinter.java | 8 +-
.../printers/csv/ABooleanPrinterFactory.java | 6 +-
.../nontagged/printers/csv/ACirclePrinter.java | 8 +-
.../printers/csv/ACirclePrinterFactory.java | 6 +-
.../nontagged/printers/csv/ADatePrinter.java | 6 +-
.../printers/csv/ADatePrinterFactory.java | 6 +-
.../printers/csv/ADateTimePrinter.java | 6 +-
.../printers/csv/ADateTimePrinterFactory.java | 6 +-
.../printers/csv/ADayTimeDurationPrinter.java | 8 +-
.../csv/ADayTimeDurationPrinterFactory.java | 6 +-
.../nontagged/printers/csv/ADoublePrinter.java | 8 +-
.../printers/csv/ADoublePrinterFactory.java | 6 +-
.../printers/csv/ADurationPrinter.java | 10 +-
.../printers/csv/ADurationPrinterFactory.java | 6 +-
.../nontagged/printers/csv/AFloatPrinter.java | 8 +-
.../printers/csv/AFloatPrinterFactory.java | 6 +-
.../nontagged/printers/csv/AInt16Printer.java | 8 +-
.../printers/csv/AInt16PrinterFactory.java | 6 +-
.../nontagged/printers/csv/AInt32Printer.java | 8 +-
.../printers/csv/AInt32PrinterFactory.java | 6 +-
.../nontagged/printers/csv/AInt64Printer.java | 8 +-
.../printers/csv/AInt64PrinterFactory.java | 6 +-
.../nontagged/printers/csv/AInt8Printer.java | 8 +-
.../printers/csv/AInt8PrinterFactory.java | 6 +-
.../printers/csv/AIntervalPrinter.java | 10 +-
.../printers/csv/AIntervalPrinterFactory.java | 6 +-
.../nontagged/printers/csv/ALinePrinter.java | 8 +-
.../printers/csv/ALinePrinterFactory.java | 6 +-
.../nontagged/printers/csv/ANullPrinter.java | 6 +-
.../printers/csv/ANullPrinterFactory.java | 6 +-
.../csv/ANullableFieldPrinterFactory.java | 16 +-
.../nontagged/printers/csv/AObjectPrinter.java | 12 +-
.../printers/csv/AObjectPrinterFactory.java | 6 +-
.../nontagged/printers/csv/APoint3DPrinter.java | 8 +-
.../printers/csv/APoint3DPrinterFactory.java | 6 +-
.../nontagged/printers/csv/APointPrinter.java | 8 +-
.../printers/csv/APointPrinterFactory.java | 6 +-
.../nontagged/printers/csv/APolygonPrinter.java | 10 +-
.../printers/csv/APolygonPrinterFactory.java | 6 +-
.../printers/csv/ARecordPrinterFactory.java | 24 +-
.../printers/csv/ARectanglePrinter.java | 8 +-
.../printers/csv/ARectanglePrinterFactory.java | 6 +-
.../nontagged/printers/csv/AStringPrinter.java | 8 +-
.../printers/csv/AStringPrinterFactory.java | 6 +-
.../nontagged/printers/csv/ATimePrinter.java | 8 +-
.../printers/csv/ATimePrinterFactory.java | 6 +-
.../printers/csv/AUnionPrinterFactory.java | 16 +-
.../printers/csv/AYearMonthDurationPrinter.java | 12 +-
.../csv/AYearMonthDurationPrinterFactory.java | 8 +-
.../printers/json/ABooleanPrinter.java | 8 +-
.../printers/json/ABooleanPrinterFactory.java | 6 +-
.../nontagged/printers/json/ACirclePrinter.java | 8 +-
.../printers/json/ACirclePrinterFactory.java | 6 +-
.../nontagged/printers/json/ADatePrinter.java | 8 +-
.../printers/json/ADatePrinterFactory.java | 6 +-
.../printers/json/ADateTimePrinter.java | 8 +-
.../printers/json/ADateTimePrinterFactory.java | 6 +-
.../printers/json/ADayTimeDurationPrinter.java | 8 +-
.../json/ADayTimeDurationPrinterFactory.java | 6 +-
.../nontagged/printers/json/ADoublePrinter.java | 8 +-
.../printers/json/ADoublePrinterFactory.java | 6 +-
.../printers/json/ADurationPrinter.java | 10 +-
.../printers/json/ADurationPrinterFactory.java | 6 +-
.../nontagged/printers/json/AFloatPrinter.java | 8 +-
.../printers/json/AFloatPrinterFactory.java | 6 +-
.../nontagged/printers/json/AInt16Printer.java | 8 +-
.../printers/json/AInt16PrinterFactory.java | 6 +-
.../nontagged/printers/json/AInt32Printer.java | 8 +-
.../printers/json/AInt32PrinterFactory.java | 6 +-
.../nontagged/printers/json/AInt64Printer.java | 8 +-
.../printers/json/AInt64PrinterFactory.java | 6 +-
.../nontagged/printers/json/AInt8Printer.java | 8 +-
.../printers/json/AInt8PrinterFactory.java | 6 +-
.../printers/json/AIntervalPrinter.java | 14 +-
.../printers/json/AIntervalPrinterFactory.java | 6 +-
.../nontagged/printers/json/ALinePrinter.java | 8 +-
.../printers/json/ALinePrinterFactory.java | 6 +-
.../nontagged/printers/json/ANullPrinter.java | 6 +-
.../printers/json/ANullPrinterFactory.java | 6 +-
.../json/ANullableFieldPrinterFactory.java | 16 +-
.../nontagged/printers/json/AObjectPrinter.java | 14 +-
.../printers/json/AObjectPrinterFactory.java | 6 +-
.../json/AOrderedlistPrinterFactory.java | 24 +-
.../printers/json/APoint3DPrinter.java | 8 +-
.../printers/json/APoint3DPrinterFactory.java | 6 +-
.../nontagged/printers/json/APointPrinter.java | 8 +-
.../printers/json/APointPrinterFactory.java | 6 +-
.../printers/json/APolygonPrinter.java | 10 +-
.../printers/json/APolygonPrinterFactory.java | 6 +-
.../printers/json/ARecordPrinterFactory.java | 24 +-
.../printers/json/ARectanglePrinter.java | 8 +-
.../printers/json/ARectanglePrinterFactory.java | 6 +-
.../nontagged/printers/json/AStringPrinter.java | 8 +-
.../printers/json/AStringPrinterFactory.java | 6 +-
.../nontagged/printers/json/ATimePrinter.java | 8 +-
.../printers/json/ATimePrinterFactory.java | 6 +-
.../printers/json/AUnionPrinterFactory.java | 16 +-
.../json/AUnorderedlistPrinterFactory.java | 24 +-
.../json/AYearMonthDurationPrinter.java | 12 +-
.../json/AYearMonthDurationPrinterFactory.java | 8 +-
.../serde/ABinarySerializerDeserializer.java | 12 +-
.../serde/ABooleanSerializerDeserializer.java | 8 +-
.../serde/ACircleSerializerDeserializer.java | 20 +-
.../serde/ADateSerializerDeserializer.java | 18 +-
.../serde/ADateTimeSerializerDeserializer.java | 20 +-
.../ADayTimeDurationSerializerDeserializer.java | 18 +-
.../serde/ADoubleSerializerDeserializer.java | 8 +-
.../serde/ADurationSerializerDeserializer.java | 18 +-
.../serde/AFloatSerializerDeserializer.java | 12 +-
.../serde/AInt16SerializerDeserializer.java | 8 +-
.../serde/AInt32SerializerDeserializer.java | 10 +-
.../serde/AInt64SerializerDeserializer.java | 8 +-
.../serde/AInt8SerializerDeserializer.java | 8 +-
.../serde/AIntervalSerializerDeserializer.java | 24 +-
.../serde/ALineSerializerDeserializer.java | 20 +-
.../serde/ANullSerializerDeserializer.java | 8 +-
.../serde/AObjectSerializerDeserializer.java | 62 +-
.../AOrderedListSerializerDeserializer.java | 30 +-
.../serde/APoint3DSerializerDeserializer.java | 18 +-
.../serde/APointSerializerDeserializer.java | 16 +-
.../serde/APolygonSerializerDeserializer.java | 14 +-
.../serde/ARecordSerializerDeserializer.java | 44 +-
.../serde/ARectangleSerializerDeserializer.java | 20 +-
.../serde/AStringSerializerDeserializer.java | 10 +-
.../serde/ATimeSerializerDeserializer.java | 16 +-
.../serde/ATypeSerializerDeserializer.java | 10 +-
.../serde/AUUIDSerializerDeserializer.java | 10 +-
.../AUUIDStringSerializerDeserializer.java | 14 +-
.../AUnorderedListSerializerDeserializer.java | 30 +-
...YearMonthDurationSerializerDeserializer.java | 18 +-
.../serde/SerializerDeserializerUtil.java | 12 +-
.../AqlPrimitiveValueProviderFactory.java | 18 +-
.../asterix/formats/base/IDataFormat.java | 50 +-
.../AqlBinaryBooleanInspectorImpl.java | 12 +-
.../AqlBinaryComparatorFactoryProvider.java | 60 +-
.../AqlBinaryHashFunctionFactoryProvider.java | 20 +-
.../AqlBinaryHashFunctionFamilyProvider.java | 10 +-
.../nontagged/AqlBinaryIntegerInspector.java | 12 +-
.../AqlBinaryTokenizerFactoryProvider.java | 22 +-
.../nontagged/AqlCSVPrinterFactoryProvider.java | 70 +-
.../AqlJSONPrinterFactoryProvider.java | 80 +--
.../AqlLinearizeComparatorFactoryProvider.java | 22 +-
...AqlNormalizedKeyComputerFactoryProvider.java | 24 +-
.../AqlPredicateEvaluatorFactoryProvider.java | 14 +-
.../nontagged/AqlPrinterFactoryProvider.java | 80 +--
.../AqlSerializerDeserializerProvider.java | 86 +--
.../formats/nontagged/AqlTypeTraitProvider.java | 8 +-
.../NGramUTF8StringBinaryTokenizerFactory.java | 10 +-
.../nontagged/UTF8StringLowercasePointable.java | 18 +-
.../org/apache/asterix/om/base/ABinary.java | 16 +-
.../org/apache/asterix/om/base/ABitArray.java | 10 +-
.../org/apache/asterix/om/base/ABoolean.java | 10 +-
.../org/apache/asterix/om/base/ACircle.java | 10 +-
.../asterix/om/base/ACollectionCursor.java | 2 +-
.../java/org/apache/asterix/om/base/ADate.java | 12 +-
.../org/apache/asterix/om/base/ADateTime.java | 12 +-
.../asterix/om/base/ADayTimeDuration.java | 20 +-
.../org/apache/asterix/om/base/ADouble.java | 10 +-
.../org/apache/asterix/om/base/ADuration.java | 12 +-
.../java/org/apache/asterix/om/base/AFloat.java | 10 +-
.../java/org/apache/asterix/om/base/AInt16.java | 10 +-
.../java/org/apache/asterix/om/base/AInt32.java | 10 +-
.../java/org/apache/asterix/om/base/AInt64.java | 10 +-
.../java/org/apache/asterix/om/base/AInt8.java | 10 +-
.../org/apache/asterix/om/base/AInterval.java | 22 +-
.../java/org/apache/asterix/om/base/ALine.java | 10 +-
.../apache/asterix/om/base/AMutableBinary.java | 2 +-
.../apache/asterix/om/base/AMutableCircle.java | 2 +-
.../apache/asterix/om/base/AMutableDate.java | 2 +-
.../asterix/om/base/AMutableDateTime.java | 2 +-
.../om/base/AMutableDayTimeDuration.java | 2 +-
.../apache/asterix/om/base/AMutableDouble.java | 2 +-
.../asterix/om/base/AMutableDuration.java | 2 +-
.../apache/asterix/om/base/AMutableFloat.java | 2 +-
.../apache/asterix/om/base/AMutableInt16.java | 2 +-
.../apache/asterix/om/base/AMutableInt32.java | 2 +-
.../apache/asterix/om/base/AMutableInt64.java | 2 +-
.../apache/asterix/om/base/AMutableInt8.java | 2 +-
.../asterix/om/base/AMutableInterval.java | 4 +-
.../apache/asterix/om/base/AMutableLine.java | 2 +-
.../asterix/om/base/AMutableOrderedList.java | 4 +-
.../apache/asterix/om/base/AMutablePoint.java | 2 +-
.../apache/asterix/om/base/AMutablePoint3D.java | 2 +-
.../apache/asterix/om/base/AMutablePolygon.java | 2 +-
.../apache/asterix/om/base/AMutableRecord.java | 4 +-
.../asterix/om/base/AMutableRectangle.java | 2 +-
.../apache/asterix/om/base/AMutableString.java | 2 +-
.../apache/asterix/om/base/AMutableTime.java | 2 +-
.../apache/asterix/om/base/AMutableUUID.java | 2 +-
.../asterix/om/base/AMutableUnorderedList.java | 4 +-
.../om/base/AMutableYearMonthDuration.java | 2 +-
.../java/org/apache/asterix/om/base/ANull.java | 10 +-
.../apache/asterix/om/base/AOrderedList.java | 12 +-
.../java/org/apache/asterix/om/base/APoint.java | 10 +-
.../org/apache/asterix/om/base/APoint3D.java | 10 +-
.../org/apache/asterix/om/base/APolygon.java | 10 +-
.../org/apache/asterix/om/base/ARecord.java | 8 +-
.../org/apache/asterix/om/base/ARectangle.java | 10 +-
.../org/apache/asterix/om/base/AString.java | 10 +-
.../java/org/apache/asterix/om/base/ATime.java | 12 +-
.../java/org/apache/asterix/om/base/AUUID.java | 10 +-
.../apache/asterix/om/base/AUnorderedList.java | 10 +-
.../asterix/om/base/AYearMonthDuration.java | 20 +-
.../apache/asterix/om/base/IACollection.java | 2 +-
.../org/apache/asterix/om/base/IACursor.java | 2 +-
.../org/apache/asterix/om/base/IAObject.java | 10 +-
.../org/apache/asterix/om/base/InMemUtils.java | 2 +-
.../asterix/om/base/ShortWithoutTypeInfo.java | 10 +-
.../om/base/temporal/ADateParserFactory.java | 8 +-
.../base/temporal/ADateTimeParserFactory.java | 8 +-
.../base/temporal/ADurationParserFactory.java | 16 +-
.../om/base/temporal/ATimeParserFactory.java | 8 +-
.../AsterixTemporalTypeParseException.java | 4 +-
.../om/base/temporal/DateTimeFormatUtils.java | 4 +-
.../temporal/DurationArithmeticOperations.java | 2 +-
.../base/temporal/GregorianCalendarSystem.java | 2 +-
.../om/base/temporal/ICalendarSystem.java | 2 +-
.../om/constants/AsterixConstantValue.java | 10 +-
.../functions/AbstractFunctionDescriptor.java | 20 +-
.../om/functions/AsterixBuiltinFunctions.java | 186 ++---
.../functions/AsterixExternalFunctionInfo.java | 8 +-
.../asterix/om/functions/AsterixFunction.java | 2 +-
.../om/functions/AsterixFunctionIdentifier.java | 2 +-
.../om/functions/AsterixFunctionInfo.java | 8 +-
.../om/functions/FunctionInfoRepository.java | 8 +-
.../om/functions/FunctionManagerHolder.java | 2 +-
.../om/functions/IExternalFunctionInfo.java | 10 +-
.../om/functions/IFunctionDescriptor.java | 18 +-
.../functions/IFunctionDescriptorFactory.java | 2 +-
.../asterix/om/functions/IFunctionManager.java | 6 +-
.../asterix/om/io/AsterixIOException.java | 4 +-
.../org/apache/asterix/om/io/IALocation.java | 2 +-
.../org/apache/asterix/om/io/IAOMReader.java | 4 +-
.../asterix/om/io/IAOMReaderWriterFactory.java | 2 +-
.../org/apache/asterix/om/io/IAOMWriter.java | 4 +-
.../om/pointables/AFlatValuePointable.java | 14 +-
.../om/pointables/AListVisitablePointable.java | 26 +-
.../pointables/ARecordVisitablePointable.java | 30 +-
.../pointables/AbstractVisitablePointable.java | 6 +-
.../om/pointables/PointableAllocator.java | 24 +-
.../pointables/base/DefaultOpenFieldType.java | 20 +-
.../om/pointables/base/IVisitablePointable.java | 8 +-
.../om/pointables/cast/ACastVisitor.java | 34 +-
.../asterix/om/pointables/cast/AListCaster.java | 32 +-
.../om/pointables/cast/ARecordCaster.java | 54 +-
.../pointables/nonvisitor/AListPointable.java | 26 +-
.../pointables/nonvisitor/ARecordPointable.java | 34 +-
.../om/pointables/printer/AListPrinter.java | 14 +-
.../om/pointables/printer/APrintVisitor.java | 70 +-
.../om/pointables/printer/ARecordPrinter.java | 14 +-
.../pointables/printer/csv/APrintVisitor.java | 66 +-
.../pointables/printer/csv/ARecordPrinter.java | 14 +-
.../pointables/printer/json/AListPrinter.java | 14 +-
.../pointables/printer/json/APrintVisitor.java | 68 +-
.../pointables/printer/json/ARecordPrinter.java | 14 +-
.../visitor/IVisitablePointableVisitor.java | 10 +-
.../typecomputer/base/IResultTypeComputer.java | 12 +-
.../base/TypeComputerUtilities.java | 20 +-
.../typecomputer/impl/ABinaryTypeComputer.java | 16 +-
.../typecomputer/impl/ABooleanTypeComputer.java | 16 +-
.../typecomputer/impl/ACircleTypeComputer.java | 16 +-
.../impl/ADateTimeTypeComputer.java | 16 +-
.../om/typecomputer/impl/ADateTypeComputer.java | 16 +-
.../typecomputer/impl/ADoubleTypeComputer.java | 16 +-
.../typecomputer/impl/AFloatTypeComputer.java | 14 +-
.../typecomputer/impl/AInt32TypeComputer.java | 16 +-
.../typecomputer/impl/AInt64TypeComputer.java | 16 +-
.../impl/AIntervalTypeComputer.java | 18 +-
.../om/typecomputer/impl/ALineTypeComputer.java | 16 +-
.../om/typecomputer/impl/ANullTypeComputer.java | 16 +-
.../typecomputer/impl/APoint3DTypeComputer.java | 16 +-
.../typecomputer/impl/APointTypeComputer.java | 16 +-
.../typecomputer/impl/APolygonTypeComputer.java | 16 +-
.../impl/ARectangleTypeComputer.java | 16 +-
.../typecomputer/impl/AStringTypeComputer.java | 16 +-
.../om/typecomputer/impl/ATimeTypeComputer.java | 16 +-
.../om/typecomputer/impl/AUUIDTypeComputer.java | 18 +-
.../impl/AbstractBinaryStringTypeComputer.java | 18 +-
.../impl/AbstractQuadStringTypeComputer.java | 20 +-
.../impl/AbstractTripleStringTypeComputer.java | 18 +-
.../om/typecomputer/impl/AnyTypeComputer.java | 16 +-
...BinaryBooleanOrNullFunctionTypeComputer.java | 24 +-
.../BinaryStringBoolOrNullTypeComputer.java | 10 +-
.../BinaryStringStringOrNullTypeComputer.java | 10 +-
.../impl/CastListResultTypeComputer.java | 18 +-
.../impl/CastRecordResultTypeComputer.java | 18 +-
.../impl/ClosedRecordConstructorResultType.java | 34 +-
.../impl/CollectionToSequenceTypeComputer.java | 22 +-
.../impl/ConcatNonNullTypeComputer.java | 18 +-
.../impl/FieldAccessByIndexResultType.java | 32 +-
.../impl/FieldAccessNestedResultType.java | 34 +-
.../impl/FlowRecordResultTypeComputer.java | 18 +-
.../om/typecomputer/impl/GetItemResultType.java | 18 +-
.../GetOverlappingInvervalTypeComputer.java | 18 +-
.../impl/InjectFailureTypeComputer.java | 24 +-
.../NonTaggedCollectionMemberResultType.java | 26 +-
.../NonTaggedFieldAccessByNameResultType.java | 36 +-
.../impl/NonTaggedGetItemResultType.java | 26 +-
.../impl/NonTaggedLocalAvgTypeComputer.java | 24 +-
.../impl/NonTaggedMinMaxAggTypeComputer.java | 26 +-
...onTaggedNumericAddSubMulDivTypeComputer.java | 26 +-
.../impl/NonTaggedNumericAggTypeComputer.java | 26 +-
...ggedNumericRoundHalfToEven2TypeComputer.java | 26 +-
...nTaggedNumericUnaryFunctionTypeComputer.java | 24 +-
.../impl/NonTaggedSwitchCaseComputer.java | 16 +-
.../impl/NonTaggedUnaryMinusTypeComputer.java | 20 +-
.../typecomputer/impl/NotNullTypeComputer.java | 20 +-
.../impl/NumericAddSubMulTypeDescriptor.java | 20 +-
.../impl/OpenRecordConstructorResultType.java | 34 +-
.../impl/OptionalABinaryTypeComputer.java | 20 +-
.../impl/OptionalABooleanTypeComputer.java | 20 +-
.../impl/OptionalACircleTypeComputer.java | 20 +-
.../impl/OptionalADateTimeTypeComputer.java | 20 +-
.../impl/OptionalADateTypeComputer.java | 20 +-
.../OptionalADayTimeDurationTypeComputer.java | 22 +-
.../impl/OptionalADoubleTypeComputer.java | 20 +-
.../impl/OptionalADurationTypeComputer.java | 20 +-
.../impl/OptionalAFloatTypeComputer.java | 20 +-
.../impl/OptionalAInt16TypeComputer.java | 20 +-
.../impl/OptionalAInt32TypeComputer.java | 20 +-
.../impl/OptionalAInt64TypeComputer.java | 20 +-
.../impl/OptionalAInt8TypeComputer.java | 20 +-
.../impl/OptionalAIntervalTypeComputer.java | 20 +-
.../impl/OptionalALineTypeComputer.java | 20 +-
.../impl/OptionalAPoint3DTypeComputer.java | 20 +-
.../impl/OptionalAPointTypeComputer.java | 20 +-
.../impl/OptionalAPolygonTypeComputer.java | 20 +-
.../impl/OptionalARectangleTypeComputer.java | 20 +-
.../impl/OptionalAStringTypeComputer.java | 20 +-
.../OptionalATemporalInstanceTypeComputer.java | 20 +-
.../impl/OptionalATimeTypeComputer.java | 20 +-
.../OptionalAYearMonthDurationTypeComputer.java | 22 +-
.../impl/OrderedListConstructorResultType.java | 26 +-
.../impl/OrderedListOfAInt32TypeComputer.java | 18 +-
.../impl/OrderedListOfAInt64TypeComputer.java | 18 +-
.../OrderedListOfAIntervalTypeComputer.java | 18 +-
.../impl/OrderedListOfAPointTypeComputer.java | 18 +-
.../impl/OrderedListOfAStringTypeComputer.java | 18 +-
.../impl/OrderedListOfAnyTypeComputer.java | 18 +-
.../QuadStringStringOrNullTypeComputer.java | 10 +-
.../impl/RecordConstructorResultType.java | 32 +-
.../impl/RecordMergeTypeComputer.java | 28 +-
.../ScalarVersionOfAggregateResultType.java | 24 +-
.../impl/SubsetCollectionTypeComputer.java | 26 +-
.../impl/Substring2TypeComputer.java | 24 +-
.../impl/SubstringTypeComputer.java | 24 +-
.../TripleStringBoolOrNullTypeComputer.java | 10 +-
.../TripleStringStringOrNullTypeComputer.java | 10 +-
.../impl/TypeCompatibilityChecker.java | 10 +-
.../UnaryBinaryInt64OrNullTypeComputer.java | 26 +-
.../UnaryBooleanOrNullFunctionTypeComputer.java | 24 +-
.../UnaryStringInt64OrNullTypeComputer.java | 24 +-
.../impl/UnaryStringOrNullTypeComputer.java | 24 +-
.../UnorderedListConstructorResultType.java | 26 +-
.../asterix/om/types/AOrderedListType.java | 4 +-
.../apache/asterix/om/types/ARecordType.java | 34 +-
.../org/apache/asterix/om/types/ATypeTag.java | 2 +-
.../org/apache/asterix/om/types/AUnionType.java | 8 +-
.../asterix/om/types/AUnorderedListType.java | 4 +-
.../om/types/AbstractCollectionType.java | 6 +-
.../asterix/om/types/AbstractComplexType.java | 4 +-
.../apache/asterix/om/types/BuiltinType.java | 8 +-
.../asterix/om/types/EnumDeserializer.java | 2 +-
.../org/apache/asterix/om/types/IAType.java | 4 +-
.../asterix/om/types/IEnumSerializer.java | 2 +-
.../org/apache/asterix/om/types/TypeHelper.java | 2 +-
.../apache/asterix/om/types/TypeHierarchy.java | 2 +-
.../apache/asterix/om/types/TypeSignature.java | 2 +-
.../apache/asterix/om/types/TypeTagUtil.java | 4 +-
.../om/types/hierachy/ATypeHierarchy.java | 38 +-
.../AbstractIntegerTypeConvertComputer.java | 4 +-
.../DoubleToFloatTypeConvertComputer.java | 6 +-
.../DoubleToInt16TypeConvertComputer.java | 6 +-
.../DoubleToInt32TypeConvertComputer.java | 6 +-
.../DoubleToInt64TypeConvertComputer.java | 6 +-
.../DoubleToInt8TypeConvertComputer.java | 6 +-
.../FloatToDoubleTypeConvertComputer.java | 8 +-
.../FloatToInt16TypeConvertComputer.java | 6 +-
.../FloatToInt32TypeConvertComputer.java | 6 +-
.../FloatToInt64TypeConvertComputer.java | 6 +-
.../FloatToInt8TypeConvertComputer.java | 6 +-
.../om/types/hierachy/ITypeConvertComputer.java | 2 +-
.../IntegerToDoubleTypeConvertComputer.java | 6 +-
.../IntegerToFloatTypeConvertComputer.java | 6 +-
.../IntegerToInt16TypeConvertComputer.java | 4 +-
.../IntegerToInt32TypeConvertComputer.java | 4 +-
.../IntegerToInt64TypeConvertComputer.java | 4 +-
.../IntegerToInt8TypeConvertComputer.java | 4 +-
.../asterix/om/util/AsterixAppContextInfo.java | 34 +-
.../om/util/AsterixClusterProperties.java | 12 +-
.../asterix/om/util/AsterixRuntimeUtil.java | 2 +-
.../om/util/JSONDeserializerForTypes.java | 14 +-
.../asterix/om/util/NonTaggedFormatUtil.java | 44 +-
.../util/ResettableByteArrayOutputStream.java | 4 +-
.../om/util/container/IObjectFactory.java | 2 +-
.../asterix/om/util/container/IObjectPool.java | 2 +-
.../om/util/container/ListObjectPool.java | 2 +-
.../apache/asterix/om/visitors/IOMVisitor.java | 66 +-
.../om/visitors/OMPrintToStringVisitor.java | 76 +--
.../nontagged/printers/ABinaryPrinterTest.java | 6 +-
.../om/util/JSONDeserializerForTypesTest.java | 16 +-
asterix-runtime/pom.xml | 18 +-
...tractAggregateFunctionDynamicDescriptor.java | 6 +-
...zableAggregateFunctionDynamicDescriptor.java | 6 +-
.../base/SingleFieldFrameTupleReference.java | 6 +-
.../collections/ListifyAggregateDescriptor.java | 22 +-
.../ListifyAggregateFunctionEvalFactory.java | 22 +-
.../AbstractScalarAggregateDescriptor.java | 30 +-
.../scalar/GenericScalarAggregateFunction.java | 18 +-
.../scalar/ScalarAvgAggregateDescriptor.java | 10 +-
.../scalar/ScalarCountAggregateDescriptor.java | 10 +-
.../scalar/ScalarMaxAggregateDescriptor.java | 10 +-
.../scalar/ScalarMinAggregateDescriptor.java | 10 +-
.../scalar/ScalarSqlAvgAggregateDescriptor.java | 10 +-
.../ScalarSqlCountAggregateDescriptor.java | 10 +-
.../scalar/ScalarSqlMaxAggregateDescriptor.java | 10 +-
.../scalar/ScalarSqlMinAggregateDescriptor.java | 10 +-
.../scalar/ScalarSqlSumAggregateDescriptor.java | 10 +-
.../scalar/ScalarSumAggregateDescriptor.java | 10 +-
...bstractSerializableAvgAggregateFunction.java | 68 +-
...tractSerializableCountAggregateFunction.java | 30 +-
...bstractSerializableSumAggregateFunction.java | 54 +-
.../serializable/std/BufferSerDeUtil.java | 2 +-
.../std/SerializableAvgAggregateDescriptor.java | 20 +-
.../std/SerializableAvgAggregateFunction.java | 12 +-
.../SerializableCountAggregateDescriptor.java | 20 +-
.../std/SerializableCountAggregateFunction.java | 6 +-
...erializableGlobalAvgAggregateDescriptor.java | 22 +-
.../SerializableGlobalAvgAggregateFunction.java | 12 +-
...alizableGlobalSqlAvgAggregateDescriptor.java | 22 +-
...rializableGlobalSqlAvgAggregateFunction.java | 8 +-
...zableIntermediateAvgAggregateDescriptor.java | 22 +-
...lizableIntermediateAvgAggregateFunction.java | 12 +-
...leIntermediateSqlAvgAggregateDescriptor.java | 22 +-
...ableIntermediateSqlAvgAggregateFunction.java | 8 +-
...SerializableLocalAvgAggregateDescriptor.java | 22 +-
.../SerializableLocalAvgAggregateFunction.java | 12 +-
...ializableLocalSqlAvgAggregateDescriptor.java | 22 +-
...erializableLocalSqlAvgAggregateFunction.java | 8 +-
...ializableLocalSqlSumAggregateDescriptor.java | 20 +-
...SerializableLocalSumAggregateDescriptor.java | 20 +-
.../SerializableSqlAvgAggregateDescriptor.java | 20 +-
.../SerializableSqlAvgAggregateFunction.java | 8 +-
...SerializableSqlCountAggregateDescriptor.java | 20 +-
.../SerializableSqlCountAggregateFunction.java | 6 +-
.../SerializableSqlSumAggregateDescriptor.java | 20 +-
.../SerializableSqlSumAggregateFunction.java | 14 +-
.../std/SerializableSumAggregateDescriptor.java | 20 +-
.../std/SerializableSumAggregateFunction.java | 16 +-
.../std/AbstractAvgAggregateFunction.java | 70 +-
.../std/AbstractCountAggregateFunction.java | 30 +-
.../std/AbstractMinMaxAggregateFunction.java | 32 +-
.../std/AbstractSumAggregateFunction.java | 56 +-
.../aggregates/std/AvgAggregateDescriptor.java | 24 +-
.../aggregates/std/AvgAggregateFunction.java | 12 +-
.../std/CountAggregateDescriptor.java | 22 +-
.../aggregates/std/CountAggregateFunction.java | 8 +-
.../std/GlobalAvgAggregateDescriptor.java | 24 +-
.../std/GlobalAvgAggregateFunction.java | 12 +-
.../std/GlobalSqlAvgAggregateDescriptor.java | 24 +-
.../std/GlobalSqlAvgAggregateFunction.java | 10 +-
.../std/IntermediateAvgAggregateDescriptor.java | 24 +-
.../std/IntermediateAvgAggregateFunction.java | 12 +-
.../IntermediateSqlAvgAggregateDescriptor.java | 24 +-
.../IntermediateSqlAvgAggregateFunction.java | 10 +-
.../std/LocalAvgAggregateDescriptor.java | 22 +-
.../std/LocalAvgAggregateFunction.java | 12 +-
.../std/LocalMaxAggregateDescriptor.java | 22 +-
.../std/LocalMinAggregateDescriptor.java | 22 +-
.../std/LocalSqlAvgAggregateDescriptor.java | 22 +-
.../std/LocalSqlAvgAggregateFunction.java | 10 +-
.../std/LocalSqlMaxAggregateDescriptor.java | 22 +-
.../std/LocalSqlMinAggregateDescriptor.java | 22 +-
.../std/LocalSqlSumAggregateDescriptor.java | 22 +-
.../std/LocalSumAggregateDescriptor.java | 22 +-
.../aggregates/std/MaxAggregateDescriptor.java | 22 +-
.../aggregates/std/MinAggregateDescriptor.java | 22 +-
.../aggregates/std/MinMaxAggregateFunction.java | 10 +-
.../std/SqlAvgAggregateDescriptor.java | 24 +-
.../aggregates/std/SqlAvgAggregateFunction.java | 10 +-
.../std/SqlCountAggregateDescriptor.java | 22 +-
.../std/SqlCountAggregateFunction.java | 8 +-
.../std/SqlMaxAggregateDescriptor.java | 22 +-
.../std/SqlMinAggregateDescriptor.java | 22 +-
.../std/SqlMinMaxAggregateFunction.java | 10 +-
.../std/SqlSumAggregateDescriptor.java | 22 +-
.../aggregates/std/SqlSumAggregateFunction.java | 16 +-
.../aggregates/std/SumAggregateDescriptor.java | 22 +-
.../aggregates/std/SumAggregateFunction.java | 16 +-
.../stream/EmptyStreamAggregateDescriptor.java | 36 +-
.../NonEmptyStreamAggregateDescriptor.java | 34 +-
.../runtime/base/AsterixTupleFilter.java | 20 +-
.../runtime/base/AsterixTupleFilterFactory.java | 16 +-
.../accessors/CircleCenterAccessor.java | 46 +-
.../accessors/CircleRadiusAccessor.java | 42 +-
.../accessors/LineRectanglePolygonAccessor.java | 56 +-
.../accessors/PointXCoordinateAccessor.java | 44 +-
.../accessors/PointYCoordinateAccessor.java | 44 +-
.../accessors/TemporalDayAccessor.java | 52 +-
.../accessors/TemporalHourAccessor.java | 52 +-
.../accessors/TemporalIntervalEndAccessor.java | 52 +-
.../TemporalIntervalEndDateAccessor.java | 44 +-
.../TemporalIntervalEndDatetimeAccessor.java | 44 +-
.../TemporalIntervalEndTimeAccessor.java | 44 +-
.../TemporalIntervalStartAccessor.java | 52 +-
.../TemporalIntervalStartDateAccessor.java | 44 +-
.../TemporalIntervalStartDatetimeAccessor.java | 44 +-
.../TemporalIntervalStartTimeAccessor.java | 44 +-
.../accessors/TemporalMillisecondAccessor.java | 52 +-
.../accessors/TemporalMinuteAccessor.java | 52 +-
.../accessors/TemporalMonthAccessor.java | 52 +-
.../accessors/TemporalSecondAccessor.java | 52 +-
.../accessors/TemporalYearAccessor.java | 50 +-
...AbstractScalarFunctionDynamicDescriptor.java | 6 +-
.../common/AbstractAsterixListIterator.java | 20 +-
.../common/AccessibleByteArrayEval.java | 10 +-
.../evaluators/common/AsterixListAccessor.java | 14 +-
.../common/AsterixOrderedListIterator.java | 6 +-
.../common/AsterixUnorderedListIterator.java | 6 +-
.../ClosedRecordConstructorEvalFactory.java | 24 +-
.../evaluators/common/CreateMBREvalFactory.java | 40 +-
.../runtime/evaluators/common/DoubleArray.java | 2 +-
.../common/EditDistanceCheckEvaluator.java | 34 +-
.../common/EditDistanceContainsEvaluator.java | 16 +-
.../common/EditDistanceEvaluator.java | 34 +-
.../evaluators/common/FunctionManagerImpl.java | 14 +-
.../evaluators/common/GramTokensEvaluator.java | 30 +-
.../common/SimilarityFiltersCache.java | 14 +-
.../common/SimilarityJaccardCheckEvaluator.java | 34 +-
.../common/SimilarityJaccardEvaluator.java | 44 +-
.../SimilarityJaccardPrefixEvaluator.java | 48 +-
.../SimilarityJaccardSortedCheckEvaluator.java | 14 +-
.../SimilarityJaccardSortedEvaluator.java | 14 +-
.../runtime/evaluators/common/SpatialUtils.java | 10 +-
.../evaluators/common/WordTokensEvaluator.java | 22 +-
.../AbstractComparisonEvaluator.java | 72 +-
.../comparisons/ComparisonEvalFactory.java | 20 +-
...BinaryBase64StringConstructorDescriptor.java | 22 +-
.../ABinaryHexStringConstructorDescriptor.java | 40 +-
.../ABooleanConstructorDescriptor.java | 40 +-
.../ACircleConstructorDescriptor.java | 40 +-
.../ADateConstructorDescriptor.java | 42 +-
.../ADateTimeConstructorDescriptor.java | 42 +-
.../ADayTimeDurationConstructorDescriptor.java | 44 +-
.../ADoubleConstructorDescriptor.java | 42 +-
.../ADurationConstructorDescriptor.java | 42 +-
.../AFloatConstructorDescriptor.java | 42 +-
.../AInt16ConstructorDescriptor.java | 38 +-
.../AInt32ConstructorDescriptor.java | 38 +-
.../AInt64ConstructorDescriptor.java | 38 +-
.../AInt8ConstructorDescriptor.java | 38 +-
.../AIntervalFromDateConstructorDescriptor.java | 46 +-
...tervalFromDateTimeConstructorDescriptor.java | 48 +-
.../AIntervalFromTimeConstructorDescriptor.java | 48 +-
...ervalStartFromDateConstructorDescriptor.java | 60 +-
...lStartFromDateTimeConstructorDescriptor.java | 60 +-
...ervalStartFromTimeConstructorDescriptor.java | 58 +-
.../ALineConstructorDescriptor.java | 40 +-
.../ANullConstructorDescriptor.java | 38 +-
.../APoint3DConstructorDescriptor.java | 38 +-
.../APointConstructorDescriptor.java | 38 +-
.../APolygonConstructorDescriptor.java | 36 +-
.../ARectangleConstructorDescriptor.java | 40 +-
.../AStringConstructorDescriptor.java | 50 +-
.../ATimeConstructorDescriptor.java | 42 +-
.../AUUIDFromStringConstructorDescriptor.java | 38 +-
...AYearMonthDurationConstructorDescriptor.java | 44 +-
.../ClosedRecordConstructorDescriptor.java | 20 +-
.../OpenRecordConstructorDescriptor.java | 32 +-
.../functions/AbstractBinaryStringBoolEval.java | 30 +-
.../AbstractNumericArithmeticEval.java | 78 +--
.../functions/AbstractQuadStringStringEval.java | 32 +-
.../functions/AbstractStringContainsEval.java | 30 +-
.../functions/AbstractTripleStringBoolEval.java | 30 +-
.../AbstractTripleStringStringEval.java | 32 +-
.../evaluators/functions/AndDescriptor.java | 40 +-
.../AnyCollectionMemberDescriptor.java | 44 +-
.../evaluators/functions/BinaryHashMap.java | 12 +-
.../functions/CastListDescriptor.java | 36 +-
.../functions/CastRecordDescriptor.java | 36 +-
.../functions/CodePointToStringDescriptor.java | 36 +-
.../evaluators/functions/CodepointIterator.java | 4 +-
.../functions/ContainsDescriptor.java | 22 +-
.../CountHashedGramTokensDescriptor.java | 30 +-
.../CountHashedWordTokensDescriptor.java | 32 +-
.../functions/CreateCircleDescriptor.java | 46 +-
.../functions/CreateLineDescriptor.java | 46 +-
.../functions/CreateMBRDescriptor.java | 18 +-
.../functions/CreatePointDescriptor.java | 42 +-
.../functions/CreatePolygonDescriptor.java | 44 +-
.../functions/CreateRectangleDescriptor.java | 46 +-
.../functions/CreateUUIDDescriptor.java | 34 +-
.../functions/EditDistanceCheckDescriptor.java | 22 +-
.../EditDistanceContainsDescriptor.java | 22 +-
.../functions/EditDistanceDescriptor.java | 22 +-
.../functions/EditDistanceListIsFilterable.java | 44 +-
.../EditDistanceStringIsFilterable.java | 44 +-
.../functions/EmbedTypeDescriptor.java | 24 +-
.../functions/EndsWithDescriptor.java | 22 +-
.../functions/FlowRecordDescriptor.java | 30 +-
.../evaluators/functions/FuzzyEqDescriptor.java | 18 +-
.../evaluators/functions/GetItemDescriptor.java | 44 +-
.../functions/GramTokensDescriptor.java | 30 +-
.../functions/HashedGramTokensDescriptor.java | 30 +-
.../functions/HashedWordTokensDescriptor.java | 32 +-
.../functions/InjectFailureDescriptor.java | 30 +-
.../evaluators/functions/IsNullDescriptor.java | 32 +-
.../functions/IsSystemNullDescriptor.java | 32 +-
.../evaluators/functions/LenDescriptor.java | 46 +-
.../evaluators/functions/LikeDescriptor.java | 50 +-
.../evaluators/functions/NotDescriptor.java | 40 +-
.../evaluators/functions/NotNullDescriptor.java | 26 +-
.../functions/NumericAbsDescriptor.java | 64 +-
.../functions/NumericAddDescriptor.java | 14 +-
.../functions/NumericCaretDescriptor.java | 20 +-
.../functions/NumericCeilingDescriptor.java | 64 +-
.../functions/NumericDivideDescriptor.java | 16 +-
.../functions/NumericFloorDescriptor.java | 64 +-
.../functions/NumericModuloDescriptor.java | 64 +-
.../functions/NumericMultiplyDescriptor.java | 14 +-
.../functions/NumericRoundDescriptor.java | 64 +-
.../NumericRoundHalfToEven2Descriptor.java | 64 +-
.../NumericRoundHalfToEvenDescriptor.java | 64 +-
.../functions/NumericSubDescriptor.java | 22 +-
.../functions/NumericSubtractDescriptor.java | 64 +-
.../functions/NumericUnaryMinusDescriptor.java | 64 +-
.../evaluators/functions/OrDescriptor.java | 40 +-
.../OrderedListConstructorDescriptor.java | 30 +-
.../functions/PrefixLenDescriptor.java | 46 +-
.../functions/PrefixLenJaccardDescriptor.java | 46 +-
.../evaluators/functions/RegExpDescriptor.java | 50 +-
.../functions/SimilarityDescriptor.java | 58 +-
.../SimilarityJaccardCheckDescriptor.java | 22 +-
.../functions/SimilarityJaccardDescriptor.java | 22 +-
.../SimilarityJaccardPrefixCheckDescriptor.java | 40 +-
.../SimilarityJaccardPrefixDescriptor.java | 22 +-
.../SimilarityJaccardSortedCheckDescriptor.java | 22 +-
.../SimilarityJaccardSortedDescriptor.java | 22 +-
.../functions/SpatialAreaDescriptor.java | 52 +-
.../functions/SpatialCellDescriptor.java | 48 +-
.../functions/SpatialDistanceDescriptor.java | 46 +-
.../functions/SpatialIntersectDescriptor.java | 62 +-
.../functions/StartsWithDescriptor.java | 22 +-
.../functions/StringConcatDescriptor.java | 44 +-
.../functions/StringEndWithDescrtiptor.java | 24 +-
.../functions/StringEqualDescriptor.java | 24 +-
.../functions/StringEvaluatorUtils.java | 4 +-
.../functions/StringJoinDescriptor.java | 36 +-
.../functions/StringLengthDescriptor.java | 42 +-
.../functions/StringLowerCaseDescriptor.java | 40 +-
.../functions/StringMatchesDescriptor.java | 40 +-
.../StringMatchesWithFlagDescriptor.java | 40 +-
.../functions/StringReplaceDescriptor.java | 40 +-
.../StringReplaceWithFlagsDescriptor.java | 40 +-
.../functions/StringStartWithDescrtiptor.java | 24 +-
.../functions/StringToCodePointDescriptor.java | 44 +-
.../functions/StringUpperCaseDescriptor.java | 40 +-
.../functions/Substring2Descriptor.java | 34 +-
.../functions/SubstringAfterDescriptor.java | 30 +-
.../functions/SubstringBeforeDescriptor.java | 30 +-
.../functions/SubstringDescriptor.java | 38 +-
.../functions/SwitchCaseDescriptor.java | 26 +-
.../UnorderedListConstructorDescriptor.java | 30 +-
.../functions/WordTokensDescriptor.java | 32 +-
.../functions/binary/AbstractCopyEvaluator.java | 28 +-
.../binary/BinaryConcatDescriptor.java | 32 +-
.../binary/BinaryLengthDescriptor.java | 38 +-
.../functions/binary/FindBinaryDescriptor.java | 40 +-
.../binary/FindBinaryFromDescriptor.java | 28 +-
.../functions/binary/ParseBinaryDescriptor.java | 44 +-
.../functions/binary/PrintBinaryDescriptor.java | 38 +-
.../binary/SubBinaryFromDescriptor.java | 24 +-
.../binary/SubBinaryFromToDescriptor.java | 30 +-
.../records/FieldAccessByIndexDescriptor.java | 18 +-
.../records/FieldAccessByIndexEvalFactory.java | 42 +-
.../records/FieldAccessByNameDescriptor.java | 14 +-
.../records/FieldAccessByNameEvalFactory.java | 34 +-
.../records/FieldAccessNestedDescriptor.java | 16 +-
.../records/FieldAccessNestedEvalFactory.java | 18 +-
.../functions/records/FieldAccessUtil.java | 42 +-
.../records/GetRecordFieldValueDescriptor.java | 18 +-
.../records/GetRecordFieldValueEvalFactory.java | 28 +-
.../records/GetRecordFieldsDescriptor.java | 18 +-
.../records/GetRecordFieldsEvalFactory.java | 34 +-
.../functions/records/RecordFieldsUtil.java | 62 +-
.../records/RecordMergeDescriptor.java | 56 +-
.../AbstractIntervalLogicFuncDescriptor.java | 36 +-
.../AdjustDateTimeForTimeZoneDescriptor.java | 48 +-
.../AdjustTimeForTimeZoneDescriptor.java | 48 +-
.../CalendarDuartionFromDateDescriptor.java | 54 +-
.../CalendarDurationFromDateTimeDescriptor.java | 54 +-
.../temporal/CurrentDateDescriptor.java | 36 +-
.../temporal/CurrentDateTimeDescriptor.java | 36 +-
.../temporal/CurrentTimeDescriptor.java | 40 +-
.../temporal/DateFromDatetimeDescriptor.java | 46 +-
.../DateFromUnixTimeInDaysDescriptor.java | 42 +-
.../DatetimeFromDateAndTimeDescriptor.java | 52 +-
.../DatetimeFromUnixTimeInMsDescriptor.java | 52 +-
.../DatetimeFromUnixTimeInSecsDescriptor.java | 52 +-
.../functions/temporal/DayOfWeekDescriptor.java | 48 +-
.../DayTimeDurationComparatorDescriptor.java | 44 +-
.../temporal/DurationEqualDescriptor.java | 44 +-
.../DurationFromIntervalDescriptor.java | 46 +-
.../DurationFromMillisecondsDescriptor.java | 50 +-
.../temporal/DurationFromMonthsDescriptor.java | 44 +-
.../temporal/GetDayTimeDurationDescriptor.java | 46 +-
.../GetOverlappingIntervalDescriptor.java | 44 +-
.../GetYearMonthDurationDescriptor.java | 46 +-
.../temporal/IntervalAfterDescriptor.java | 14 +-
.../temporal/IntervalBeforeDescriptor.java | 12 +-
.../temporal/IntervalBinDescriptor.java | 58 +-
.../temporal/IntervalCoveredByDescriptor.java | 14 +-
.../temporal/IntervalCoversDescriptor.java | 14 +-
.../temporal/IntervalEndedByDescriptor.java | 14 +-
.../temporal/IntervalEndsDecriptor.java | 14 +-
.../functions/temporal/IntervalLogic.java | 2 +-
.../temporal/IntervalMeetsDescriptor.java | 14 +-
.../temporal/IntervalMetByDescriptor.java | 14 +-
.../IntervalOverlappedByDescriptor.java | 14 +-
.../temporal/IntervalOverlapsDescriptor.java | 14 +-
.../temporal/IntervalStartedByDescriptor.java | 14 +-
.../temporal/IntervalStartsDescriptor.java | 14 +-
...llisecondsFromDayTimeDurationDescriptor.java | 46 +-
.../MonthsFromYearMonthDurationDescriptor.java | 46 +-
.../temporal/OverlapBinsDescriptor.java | 64 +-
.../functions/temporal/OverlapDescriptor.java | 14 +-
.../functions/temporal/ParseDateDescriptor.java | 52 +-
.../temporal/ParseDateTimeDescriptor.java | 50 +-
.../functions/temporal/ParseTimeDescriptor.java | 50 +-
.../functions/temporal/PrintDateDescriptor.java | 46 +-
.../temporal/PrintDateTimeDescriptor.java | 44 +-
.../functions/temporal/PrintTimeDescriptor.java | 44 +-
.../temporal/TimeFromDatetimeDescriptor.java | 50 +-
.../TimeFromUnixTimeInMsDescriptor.java | 46 +-
.../YearMonthDurationComparatorDecriptor.java | 44 +-
.../ExternalBTreeSearchOperatorDescriptor.java | 30 +-
...ExternalBTreeSearchOperatorNodePushable.java | 26 +-
.../ExternalRTreeSearchOperatorDescriptor.java | 30 +-
...ExternalRTreeSearchOperatorNodePushable.java | 28 +-
.../asterix/runtime/formats/FormatUtils.java | 4 +-
.../runtime/formats/NonTaggedDataFormat.java | 672 +++++++++----------
.../job/listener/JobEventListenerFactory.java | 22 +-
.../runtime/operators/file/ADMDataParser.java | 60 +-
.../operators/file/AbstractDataParser.java | 110 +--
.../operators/file/AbstractTupleParser.java | 18 +-
.../file/AsterixTupleParserFactory.java | 40 +-
.../file/CounterTimerTupleForwardPolicy.java | 20 +-
.../operators/file/DelimitedDataParser.java | 30 +-
.../file/FrameFullTupleForwardPolicy.java | 20 +-
.../runtime/operators/file/IDataParser.java | 6 +-
.../file/RateContolledParserPolicy.java | 20 +-
.../file/RateControlledTupleForwardPolicy.java | 20 +-
.../std/FlushDatasetOperatorDescriptor.java | 34 +-
.../std/NoTupleSourceRuntimeFactory.java | 12 +-
...nningAggregateFunctionDynamicDescriptor.java | 6 +-
.../std/TidRunningAggregateDescriptor.java | 36 +-
...tractUnnestingFunctionDynamicDescriptor.java | 6 +-
.../unnestingfunctions/std/RangeDescriptor.java | 40 +-
.../std/ScanCollectionDescriptor.java | 36 +-
.../std/SubsetCollectionDescriptor.java | 50 +-
asterix-runtime/src/main/resources/adm.grammar | 2 +-
asterix-server/pom.xml | 24 +-
asterix-test-framework/pom.xml | 2 +-
.../testframework/context/TestCaseContext.java | 14 +-
.../testframework/context/TestFileContext.java | 2 +-
.../testframework/xml/TestSuiteParser.java | 8 +-
.../src/main/resources/Catalog.xsd | 4 +-
asterix-tools/pom.xml | 20 +-
.../asterix/tools/datagen/AdgClientDriver.java | 2 +-
.../asterix/tools/datagen/AdmDataGen.java | 74 +-
.../asterix/tools/datagen/CustOrdDataGen.java | 2 +-
.../asterix/tools/datagen/EventDataGen.java | 2 +-
.../tools/external/data/DataGenerator.java | 4 +-
.../ExternalFilesIndexOperatorDescriptor.java | 54 +-
.../tools/external/data/GULongIDGenerator.java | 2 +-
.../external/data/GenericSocketFeedAdapter.java | 16 +-
.../data/GenericSocketFeedAdapterFactory.java | 28 +-
.../RateControlledFileSystemBasedAdapter.java | 12 +-
...ControlledFileSystemBasedAdapterFactory.java | 28 +-
.../external/data/SocketClientAdapter.java | 8 +-
.../data/SocketClientAdapterFactory.java | 18 +-
.../tools/external/data/TweetGenerator.java | 8 +-
.../data/TwitterFirehoseFeedAdapter.java | 14 +-
.../data/TwitterFirehoseFeedAdapterFactory.java | 26 +-
.../apache/asterix/tools/tbltoadm/TblToAdm.java | 2 +-
.../tools/translator/ADGenDmlTranslator.java | 26 +-
.../asterix/tools/test/AdmDataGenTest.java | 6 +-
.../src/test/resources/logging.properties | 6 +-
asterix-transactions/pom.xml | 22 +-
...tractIndexModificationOperationCallback.java | 26 +-
...maryIndexInstantSearchOperationCallback.java | 18 +-
...exInstantSearchOperationCallbackFactory.java | 22 +-
...imaryIndexModificationOperationCallback.java | 20 +-
...dexModificationOperationCallbackFactory.java | 30 +-
.../PrimaryIndexOperationTrackerProvider.java | 12 +-
.../PrimaryIndexSearchOperationCallback.java | 18 +-
...maryIndexSearchOperationCallbackFactory.java | 22 +-
...ndaryIndexModificationOperationCallback.java | 18 +-
...dexModificationOperationCallbackFactory.java | 30 +-
.../SecondaryIndexOperationTrackerProvider.java | 14 +-
.../SecondaryIndexSearchOperationCallback.java | 10 +-
...daryIndexSearchOperationCallbackFactory.java | 10 +-
...tasetIndexModificationOperationCallback.java | 18 +-
...dexModificationOperationCallbackFactory.java | 30 +-
...dexModificationOperationCallbackFactory.java | 30 +-
.../AbstractLSMLocalResourceMetadata.java | 8 +-
.../ExternalBTreeLocalResourceMetadata.java | 24 +-
...rnalBTreeWithBuddyLocalResourceMetadata.java | 24 +-
.../ExternalRTreeLocalResourceMetadata.java | 32 +-
.../resource/LSMBTreeLocalResourceMetadata.java | 26 +-
.../LSMInvertedIndexLocalResourceMetadata.java | 28 +-
.../resource/LSMRTreeLocalResourceMetadata.java | 34 +-
.../PersistentLocalResourceFactory.java | 8 +-
.../PersistentLocalResourceFactoryProvider.java | 8 +-
.../PersistentLocalResourceRepository.java | 12 +-
...ersistentLocalResourceRepositoryFactory.java | 10 +-
.../service/locking/ConcurrentLockManager.java | 20 +-
.../service/locking/DatasetLockInfo.java | 4 +-
.../service/locking/DeadlockDetector.java | 6 +-
.../service/locking/DummyLockManager.java | 14 +-
.../service/locking/EntityInfoManager.java | 2 +-
.../service/locking/EntityLockInfoManager.java | 4 +-
.../service/locking/ILockHashTable.java | 2 +-
.../management/service/locking/ILockMatrix.java | 2 +-
.../management/service/locking/JobInfo.java | 6 +-
.../management/service/locking/LockManager.java | 30 +-
.../LockManagerDeterministicUnitTest.java | 28 +-
.../locking/LockManagerRandomUnitTest.java | 30 +-
.../service/locking/LockManagerStats.java | 2 +-
.../locking/LockMgrLatchHandlerException.java | 4 +-
.../service/locking/LockRequestTracker.java | 2 +-
.../management/service/locking/LockWaiter.java | 2 +-
.../service/locking/LockWaiterManager.java | 2 +-
.../service/locking/PrimitiveIntHashMap.java | 2 +-
.../management/service/locking/Resource.json | 2 +-
.../locking/TestRuntimeContextProvider.java | 32 +-
.../service/locking/TimeOutDetector.java | 4 +-
.../management/service/logging/LogManager.java | 24 +-
.../management/service/logging/LogPage.java | 28 +-
.../service/logging/LogPageReader.java | 4 +-
.../management/service/logging/LogReader.java | 12 +-
.../service/recovery/CheckpointObject.java | 2 +-
.../service/recovery/CheckpointThread.java | 12 +-
.../service/recovery/RecoveryManager.java | 56 +-
.../AsterixRuntimeComponentsProvider.java | 24 +-
.../service/transaction/DatasetIdFactory.java | 2 +-
.../transaction/FieldsHashValueGenerator.java | 8 +-
.../service/transaction/JobIdFactory.java | 4 +-
.../service/transaction/MutableResourceId.java | 2 +-
.../service/transaction/TransactionContext.java | 28 +-
.../TransactionManagementConstants.java | 2 +-
.../service/transaction/TransactionManager.java | 16 +-
.../transaction/TransactionSubsystem.java | 26 +-
.../TransactionSubsystemProvider.java | 10 +-
asterix-yarn/pom.xml | 18 +-
.../src/main/assembly/binary-assembly.xml | 4 +-
.../org/apache/asterix/aoya/AConstants.java | 2 +-
.../asterix/aoya/AsterixApplicationMaster.java | 24 +-
.../apache/asterix/aoya/AsterixYARNClient.java | 18 +-
.../java/org/apache/asterix/aoya/Deleter.java | 2 +-
.../org/apache/asterix/aoya/HDFSBackup.java | 2 +-
.../java/org/apache/asterix/aoya/Utils.java | 8 +-
.../configs/asterix-client-log4j.properties | 2 +-
asterix-yarn/src/main/resources/scripts/asterix | 2 +-
.../src/main/resources/scripts/asterix.cmd | 2 +-
.../aoya/test/AsterixYARNInstanceUtil.java | 10 +-
.../aoya/test/AsterixYARNLibraryTestIT.java | 8 +-
.../aoya/test/AsterixYARNLifecycleIT.java | 28 +-
.../apache/asterix/aoya/test/YARNCluster.java | 4 +-
.../dataverseDataset/dataverseDataset.1.adm | 4 +-
.../functionDataset/functionDataset.1.adm | 16 +-
.../src/test/resources/library/testsuite.xml | 2 +-
pom.xml | 36 +-
tlp/pom.xml | 2 +-
2605 files changed, 20785 insertions(+), 20791 deletions(-)
----------------------------------------------------------------------