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:44:39 UTC
[51/51] [partial] incubator-asterixdb git commit: Change folder
structure for Java repackage
Change folder structure for Java repackage
Change only the folders, not the files, for our package name change.
This will break the build, and needs to be followed by a change to
the package name in all of the source files. However performing
the folder move and file change in two steps lets Git understand
that the files are the same, and lets us track revisions across
those files.
Change-Id: Iefd2a576415ebc1416cba2a3334d2b64f042ba92
Reviewed-on: https://asterix-gerrit.ics.uci.edu/306
Tested-by: Ian Maxon <im...@apache.org>
Reviewed-by: Till Westmann <ti...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/commit/34d81630
Tree: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/tree/34d81630
Diff: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/diff/34d81630
Branch: refs/heads/master
Commit: 34d816305a0ddaab5d54f23b60ff985eeb12193c
Parents: 95350e2
Author: Ian Maxon <im...@apache.org>
Authored: Fri Aug 21 11:49:23 2015 -0700
Committer: Ian Maxon <im...@apache.org>
Committed: Sat Aug 22 12:56:53 2015 -0700
----------------------------------------------------------------------
.../base/AsterixOperatorAnnotations.java | 22 -
.../base/LogicalExpressionDeepCopyVisitor.java | 149 -
.../base/LogicalOperatorDeepCopyVisitor.java | 469 ---
.../algebra/operators/CommitOperator.java | 66 -
.../physical/BTreeSearchPOperator.java | 161 -
.../operators/physical/CommitPOperator.java | 98 -
.../operators/physical/CommitRuntime.java | 139 -
.../physical/CommitRuntimeFactory.java | 53 -
.../physical/ExternalDataLookupPOperator.java | 180 -
.../physical/IndexSearchPOperator.java | 87 -
.../physical/InvertedIndexPOperator.java | 288 --
.../physical/RTreeSearchPOperator.java | 98 -
.../jobgen/AqlLogicalExpressionJobGen.java | 217 --
.../asterix/optimizer/base/AnalysisUtil.java | 138 -
.../ics/asterix/optimizer/base/FuzzyUtils.java | 119 -
.../asterix/optimizer/base/RuleCollections.java | 331 --
.../handle/FieldIndexAndTypeHandle.java | 41 -
.../optimizer/handle/FieldNameHandle.java | 44 -
.../ics/asterix/optimizer/handle/IHandle.java | 31 -
...quivalenceClassForRecordConstructorRule.java | 127 -
...ixExtractFunctionsFromJoinConditionRule.java | 33 -
.../rules/AsterixInlineVariablesRule.java | 38 -
.../AsterixIntroduceGroupByCombinerRule.java | 74 -
...oveFreeVariableOperatorOutOfSubplanRule.java | 26 -
.../rules/ByNameToByHandleFieldAccessRule.java | 116 -
.../rules/ByNameToByIndexFieldAccessRule.java | 175 -
.../CancelUnnestWithNestedListifyRule.java | 282 --
.../rules/CheckFilterExpressionTypeRule.java | 83 -
.../optimizer/rules/ConstantFoldingRule.java | 264 --
.../optimizer/rules/CountVarToCountOneRule.java | 86 -
.../rules/DisjunctivePredicateToJoinRule.java | 191 --
.../rules/ExtractDistinctByExpressionsRule.java | 80 -
.../rules/ExtractOrderExpressionsRule.java | 80 -
.../rules/FeedScanCollectionToUnnest.java | 135 -
.../asterix/optimizer/rules/FuzzyEqRule.java | 124 -
.../asterix/optimizer/rules/FuzzyJoinRule.java | 404 ---
.../rules/IfElseToSwitchCaseFunctionRule.java | 126 -
.../rules/InlineUnnestFunctionRule.java | 174 -
.../rules/IntroduceAutogenerateIDRule.java | 168 -
...eDynamicTypeCastForExternalFunctionRule.java | 141 -
.../rules/IntroduceDynamicTypeCastRule.java | 288 --
.../rules/IntroduceEnforcedListTypeRule.java | 96 -
.../IntroduceInstantLockSearchCallbackRule.java | 149 -
...aterializationForInsertWithSelfScanRule.java | 118 -
...ceRandomPartitioningFeedComputationRule.java | 98 -
...troduceRapidFrameFlushProjectAssignRule.java | 102 -
...IntroduceSecondaryIndexInsertDeleteRule.java | 598 ----
.../IntroduceStaticTypeCastForInsertRule.java | 157 -
...ntroduceTransactionCommitByAssignOpRule.java | 76 -
.../optimizer/rules/IntroduceUnionRule.java | 123 -
...roduceUnnestForCollectionToSequenceRule.java | 94 -
.../optimizer/rules/LoadRecordFieldsRule.java | 368 ---
.../optimizer/rules/NestGroupByRule.java | 191 --
.../PullPositionalVariableFromUnnestRule.java | 74 -
.../PushAggFuncIntoStandaloneAggregateRule.java | 265 --
.../rules/PushAggregateIntoGroupbyRule.java | 462 ---
.../optimizer/rules/PushFieldAccessRule.java | 391 ---
.../rules/PushGroupByThroughProduct.java | 172 -
.../rules/PushProperJoinThroughProduct.java | 107 -
.../rules/PushSimilarityFunctionsBelowJoin.java | 63 -
.../rules/RemoveRedundantListifyRule.java | 254 --
.../rules/RemoveRedundantSelectRule.java | 78 -
.../rules/RemoveSortInFeedIngestionRule.java | 72 -
.../rules/RemoveUnusedOneToOneEquiJoinRule.java | 213 --
.../rules/ReplaceSinkOpWithCommitOpRule.java | 116 -
.../rules/SetAsterixPhysicalOperatorsRule.java | 300 --
.../rules/SetClosedRecordConstructorsRule.java | 252 --
.../optimizer/rules/SimilarityCheckRule.java | 336 --
.../SweepIllegalNonfunctionalFunctions.java | 296 --
.../optimizer/rules/UnnestToDataScanRule.java | 248 --
.../am/AbstractIntroduceAccessMethodRule.java | 747 -----
.../rules/am/AccessMethodAnalysisContext.java | 82 -
.../rules/am/AccessMethodJobGenParams.java | 140 -
.../optimizer/rules/am/AccessMethodUtils.java | 609 ----
.../optimizer/rules/am/BTreeAccessMethod.java | 660 ----
.../optimizer/rules/am/BTreeJobGenParams.java | 134 -
.../optimizer/rules/am/IAccessMethod.java | 96 -
.../rules/am/IOptimizableFuncExpr.java | 70 -
.../rules/am/IntroduceJoinAccessMethodRule.java | 246 --
.../am/IntroduceLSMComponentFilterRule.java | 451 ---
.../am/IntroduceSelectAccessMethodRule.java | 154 -
.../rules/am/InvertedIndexAccessMethod.java | 1166 -------
.../rules/am/InvertedIndexJobGenParams.java | 125 -
.../optimizer/rules/am/OptimizableFuncExpr.java | 215 --
.../rules/am/OptimizableOperatorSubTree.java | 242 --
.../optimizer/rules/am/RTreeAccessMethod.java | 255 --
.../optimizer/rules/am/RTreeJobGenParams.java | 61 -
.../TranslateIntervalExpressionRule.java | 150 -
.../rules/typecast/StaticTypeCastUtil.java | 548 ----
.../rules/util/EquivalenceClassUtils.java | 99 -
.../translator/AbstractAqlTranslator.java | 185 --
.../AqlExpressionToPlanTranslator.java | 1608 ---------
.../AqlPlusExpressionToPlanTranslator.java | 1498 ---------
.../asterix/translator/AqlPositionWriter.java | 33 -
.../asterix/translator/CompiledStatements.java | 625 ----
.../ics/asterix/translator/ConstantHelper.java | 71 -
.../asterix/translator/TranslationContext.java | 73 -
.../translator/TranslationException.java | 32 -
.../ics/asterix/translator/TypeTranslator.java | 392 ---
.../base/AsterixOperatorAnnotations.java | 22 +
.../base/LogicalExpressionDeepCopyVisitor.java | 149 +
.../base/LogicalOperatorDeepCopyVisitor.java | 469 +++
.../algebra/operators/CommitOperator.java | 66 +
.../physical/BTreeSearchPOperator.java | 161 +
.../operators/physical/CommitPOperator.java | 98 +
.../operators/physical/CommitRuntime.java | 139 +
.../physical/CommitRuntimeFactory.java | 53 +
.../physical/ExternalDataLookupPOperator.java | 180 +
.../physical/IndexSearchPOperator.java | 87 +
.../physical/InvertedIndexPOperator.java | 288 ++
.../physical/RTreeSearchPOperator.java | 98 +
.../jobgen/AqlLogicalExpressionJobGen.java | 217 ++
.../asterix/optimizer/base/AnalysisUtil.java | 138 +
.../asterix/optimizer/base/FuzzyUtils.java | 119 +
.../asterix/optimizer/base/RuleCollections.java | 331 ++
.../handle/FieldIndexAndTypeHandle.java | 41 +
.../optimizer/handle/FieldNameHandle.java | 44 +
.../asterix/optimizer/handle/IHandle.java | 31 +
...quivalenceClassForRecordConstructorRule.java | 127 +
...ixExtractFunctionsFromJoinConditionRule.java | 33 +
.../rules/AsterixInlineVariablesRule.java | 38 +
.../AsterixIntroduceGroupByCombinerRule.java | 74 +
...oveFreeVariableOperatorOutOfSubplanRule.java | 26 +
.../rules/ByNameToByHandleFieldAccessRule.java | 116 +
.../rules/ByNameToByIndexFieldAccessRule.java | 175 +
.../CancelUnnestWithNestedListifyRule.java | 282 ++
.../rules/CheckFilterExpressionTypeRule.java | 83 +
.../optimizer/rules/ConstantFoldingRule.java | 264 ++
.../optimizer/rules/CountVarToCountOneRule.java | 86 +
.../rules/DisjunctivePredicateToJoinRule.java | 191 ++
.../rules/ExtractDistinctByExpressionsRule.java | 80 +
.../rules/ExtractOrderExpressionsRule.java | 80 +
.../rules/FeedScanCollectionToUnnest.java | 135 +
.../asterix/optimizer/rules/FuzzyEqRule.java | 124 +
.../asterix/optimizer/rules/FuzzyJoinRule.java | 404 +++
.../rules/IfElseToSwitchCaseFunctionRule.java | 126 +
.../rules/InlineUnnestFunctionRule.java | 174 +
.../rules/IntroduceAutogenerateIDRule.java | 168 +
...eDynamicTypeCastForExternalFunctionRule.java | 141 +
.../rules/IntroduceDynamicTypeCastRule.java | 288 ++
.../rules/IntroduceEnforcedListTypeRule.java | 96 +
.../IntroduceInstantLockSearchCallbackRule.java | 149 +
...aterializationForInsertWithSelfScanRule.java | 118 +
...ceRandomPartitioningFeedComputationRule.java | 98 +
...troduceRapidFrameFlushProjectAssignRule.java | 102 +
...IntroduceSecondaryIndexInsertDeleteRule.java | 598 ++++
.../IntroduceStaticTypeCastForInsertRule.java | 157 +
...ntroduceTransactionCommitByAssignOpRule.java | 76 +
.../optimizer/rules/IntroduceUnionRule.java | 123 +
...roduceUnnestForCollectionToSequenceRule.java | 94 +
.../optimizer/rules/LoadRecordFieldsRule.java | 368 +++
.../optimizer/rules/NestGroupByRule.java | 191 ++
.../PullPositionalVariableFromUnnestRule.java | 74 +
.../PushAggFuncIntoStandaloneAggregateRule.java | 265 ++
.../rules/PushAggregateIntoGroupbyRule.java | 462 +++
.../optimizer/rules/PushFieldAccessRule.java | 391 +++
.../rules/PushGroupByThroughProduct.java | 172 +
.../rules/PushProperJoinThroughProduct.java | 107 +
.../rules/PushSimilarityFunctionsBelowJoin.java | 63 +
.../rules/RemoveRedundantListifyRule.java | 254 ++
.../rules/RemoveRedundantSelectRule.java | 78 +
.../rules/RemoveSortInFeedIngestionRule.java | 72 +
.../rules/RemoveUnusedOneToOneEquiJoinRule.java | 213 ++
.../rules/ReplaceSinkOpWithCommitOpRule.java | 116 +
.../rules/SetAsterixPhysicalOperatorsRule.java | 300 ++
.../rules/SetClosedRecordConstructorsRule.java | 252 ++
.../optimizer/rules/SimilarityCheckRule.java | 336 ++
.../SweepIllegalNonfunctionalFunctions.java | 296 ++
.../optimizer/rules/UnnestToDataScanRule.java | 248 ++
.../am/AbstractIntroduceAccessMethodRule.java | 747 +++++
.../rules/am/AccessMethodAnalysisContext.java | 82 +
.../rules/am/AccessMethodJobGenParams.java | 140 +
.../optimizer/rules/am/AccessMethodUtils.java | 609 ++++
.../optimizer/rules/am/BTreeAccessMethod.java | 660 ++++
.../optimizer/rules/am/BTreeJobGenParams.java | 134 +
.../optimizer/rules/am/IAccessMethod.java | 96 +
.../rules/am/IOptimizableFuncExpr.java | 70 +
.../rules/am/IntroduceJoinAccessMethodRule.java | 246 ++
.../am/IntroduceLSMComponentFilterRule.java | 451 +++
.../am/IntroduceSelectAccessMethodRule.java | 154 +
.../rules/am/InvertedIndexAccessMethod.java | 1166 +++++++
.../rules/am/InvertedIndexJobGenParams.java | 125 +
.../optimizer/rules/am/OptimizableFuncExpr.java | 215 ++
.../rules/am/OptimizableOperatorSubTree.java | 242 ++
.../optimizer/rules/am/RTreeAccessMethod.java | 255 ++
.../optimizer/rules/am/RTreeJobGenParams.java | 61 +
.../TranslateIntervalExpressionRule.java | 150 +
.../rules/typecast/StaticTypeCastUtil.java | 548 ++++
.../rules/util/EquivalenceClassUtils.java | 99 +
.../translator/AbstractAqlTranslator.java | 185 ++
.../AqlExpressionToPlanTranslator.java | 1608 +++++++++
.../AqlPlusExpressionToPlanTranslator.java | 1498 +++++++++
.../asterix/translator/AqlPositionWriter.java | 33 +
.../asterix/translator/CompiledStatements.java | 625 ++++
.../asterix/translator/ConstantHelper.java | 71 +
.../asterix/translator/TranslationContext.java | 73 +
.../translator/TranslationException.java | 32 +
.../asterix/translator/TypeTranslator.java | 392 +++
.../ics/asterix/api/common/APIFramework.java | 411 ---
.../api/common/AsterixAppRuntimeContext.java | 271 --
...rixAppRuntimeContextProdiverForRecovery.java | 105 -
.../asterix/api/common/AsterixClientConfig.java | 45 -
.../common/AsterixHyracksIntegrationUtil.java | 155 -
.../asterix/api/common/FeedWorkCollection.java | 197 --
.../edu/uci/ics/asterix/api/common/Job.java | 47 -
.../ics/asterix/api/common/SessionConfig.java | 201 --
.../asterix/api/http/servlet/APIServlet.java | 173 -
.../asterix/api/http/servlet/AQLAPIServlet.java | 53 -
.../api/http/servlet/ConnectorAPIServlet.java | 168 -
.../asterix/api/http/servlet/DDLAPIServlet.java | 43 -
.../asterix/api/http/servlet/FeedServlet.java | 166 -
.../api/http/servlet/FeedServletUtil.java | 70 -
.../api/http/servlet/HyracksProperties.java | 52 -
.../api/http/servlet/QueryAPIServlet.java | 40 -
.../api/http/servlet/QueryResultAPIServlet.java | 95 -
.../api/http/servlet/QueryStatusAPIServlet.java | 97 -
.../api/http/servlet/RESTAPIServlet.java | 197 --
.../api/http/servlet/ShutdownAPIServlet.java | 79 -
.../api/http/servlet/UpdateAPIServlet.java | 41 -
.../ics/asterix/api/java/AsterixJavaClient.java | 100 -
.../asterix/aql/translator/AqlTranslator.java | 3069 ------------------
.../edu/uci/ics/asterix/drivers/AsterixCLI.java | 85 -
.../asterix/drivers/AsterixClientDriver.java | 64 -
.../ics/asterix/drivers/AsterixWebServer.java | 34 -
.../ics/asterix/feeds/CentralFeedManager.java | 100 -
.../uci/ics/asterix/feeds/FeedCollectInfo.java | 50 -
.../edu/uci/ics/asterix/feeds/FeedInfo.java | 49 -
.../feeds/FeedJobNotificationHandler.java | 739 -----
.../edu/uci/ics/asterix/feeds/FeedJoint.java | 186 --
.../asterix/feeds/FeedLifecycleListener.java | 486 ---
.../uci/ics/asterix/feeds/FeedLoadManager.java | 298 --
.../edu/uci/ics/asterix/feeds/FeedManager.java | 140 -
.../ics/asterix/feeds/FeedMessageReceiver.java | 88 -
.../ics/asterix/feeds/FeedMetadataManager.java | 107 -
.../ics/asterix/feeds/FeedTrackingManager.java | 184 --
.../feeds/FeedWorkRequestResponseHandler.java | 263 --
.../uci/ics/asterix/feeds/FeedsActivator.java | 109 -
.../uci/ics/asterix/file/DatasetOperations.java | 252 --
.../ics/asterix/file/DataverseOperations.java | 36 -
.../file/ExternalIndexingOperations.java | 761 -----
.../uci/ics/asterix/file/FeedOperations.java | 251 --
.../uci/ics/asterix/file/IndexOperations.java | 131 -
.../ics/asterix/file/JobSpecificationUtils.java | 28 -
.../file/SecondaryBTreeOperationsHelper.java | 363 ---
.../file/SecondaryIndexOperationsHelper.java | 575 ----
.../SecondaryInvertedIndexOperationsHelper.java | 373 ---
.../file/SecondaryRTreeOperationsHelper.java | 408 ---
.../bootstrap/AsterixGlobalRecoveryManager.java | 213 --
.../bootstrap/AsterixStateDumpHandler.java | 48 -
.../bootstrap/CCApplicationEntryPoint.java | 184 --
.../bootstrap/ClusterLifecycleListener.java | 204 --
.../hyracks/bootstrap/ClusterWorkExecutor.java | 102 -
.../bootstrap/ExternalLibraryBootstrap.java | 318 --
.../hyracks/bootstrap/FeedBootstrap.java | 64 -
.../bootstrap/NCApplicationEntryPoint.java | 279 --
.../uci/ics/asterix/result/ResultReader.java | 61 -
.../edu/uci/ics/asterix/result/ResultUtils.java | 343 --
.../ConstantTupleSourceOperatorDescriptor.java | 47 -
...ConstantTupleSourceOperatorNodePushable.java | 53 -
.../apache/asterix/api/common/APIFramework.java | 411 +++
.../api/common/AsterixAppRuntimeContext.java | 271 ++
...rixAppRuntimeContextProdiverForRecovery.java | 105 +
.../asterix/api/common/AsterixClientConfig.java | 45 +
.../common/AsterixHyracksIntegrationUtil.java | 155 +
.../asterix/api/common/FeedWorkCollection.java | 197 ++
.../java/org/apache/asterix/api/common/Job.java | 47 +
.../asterix/api/common/SessionConfig.java | 201 ++
.../asterix/api/http/servlet/APIServlet.java | 173 +
.../asterix/api/http/servlet/AQLAPIServlet.java | 53 +
.../api/http/servlet/ConnectorAPIServlet.java | 168 +
.../asterix/api/http/servlet/DDLAPIServlet.java | 43 +
.../asterix/api/http/servlet/FeedServlet.java | 166 +
.../api/http/servlet/FeedServletUtil.java | 70 +
.../api/http/servlet/HyracksProperties.java | 52 +
.../api/http/servlet/QueryAPIServlet.java | 40 +
.../api/http/servlet/QueryResultAPIServlet.java | 95 +
.../api/http/servlet/QueryStatusAPIServlet.java | 97 +
.../api/http/servlet/RESTAPIServlet.java | 197 ++
.../api/http/servlet/ShutdownAPIServlet.java | 79 +
.../api/http/servlet/UpdateAPIServlet.java | 41 +
.../asterix/api/java/AsterixJavaClient.java | 100 +
.../asterix/aql/translator/AqlTranslator.java | 3069 ++++++++++++++++++
.../org/apache/asterix/drivers/AsterixCLI.java | 85 +
.../asterix/drivers/AsterixClientDriver.java | 64 +
.../asterix/drivers/AsterixWebServer.java | 34 +
.../asterix/feeds/CentralFeedManager.java | 100 +
.../apache/asterix/feeds/FeedCollectInfo.java | 50 +
.../java/org/apache/asterix/feeds/FeedInfo.java | 49 +
.../feeds/FeedJobNotificationHandler.java | 739 +++++
.../org/apache/asterix/feeds/FeedJoint.java | 186 ++
.../asterix/feeds/FeedLifecycleListener.java | 486 +++
.../apache/asterix/feeds/FeedLoadManager.java | 298 ++
.../org/apache/asterix/feeds/FeedManager.java | 140 +
.../asterix/feeds/FeedMessageReceiver.java | 88 +
.../asterix/feeds/FeedMetadataManager.java | 107 +
.../asterix/feeds/FeedTrackingManager.java | 184 ++
.../feeds/FeedWorkRequestResponseHandler.java | 263 ++
.../apache/asterix/feeds/FeedsActivator.java | 109 +
.../apache/asterix/file/DatasetOperations.java | 252 ++
.../asterix/file/DataverseOperations.java | 36 +
.../file/ExternalIndexingOperations.java | 761 +++++
.../org/apache/asterix/file/FeedOperations.java | 251 ++
.../apache/asterix/file/IndexOperations.java | 131 +
.../asterix/file/JobSpecificationUtils.java | 28 +
.../file/SecondaryBTreeOperationsHelper.java | 363 +++
.../file/SecondaryIndexOperationsHelper.java | 575 ++++
.../SecondaryInvertedIndexOperationsHelper.java | 373 +++
.../file/SecondaryRTreeOperationsHelper.java | 408 +++
.../bootstrap/AsterixGlobalRecoveryManager.java | 213 ++
.../bootstrap/AsterixStateDumpHandler.java | 48 +
.../bootstrap/CCApplicationEntryPoint.java | 184 ++
.../bootstrap/ClusterLifecycleListener.java | 204 ++
.../hyracks/bootstrap/ClusterWorkExecutor.java | 102 +
.../bootstrap/ExternalLibraryBootstrap.java | 318 ++
.../hyracks/bootstrap/FeedBootstrap.java | 64 +
.../bootstrap/NCApplicationEntryPoint.java | 279 ++
.../org/apache/asterix/result/ResultReader.java | 61 +
.../org/apache/asterix/result/ResultUtils.java | 343 ++
.../ConstantTupleSourceOperatorDescriptor.java | 47 +
...ConstantTupleSourceOperatorNodePushable.java | 53 +
.../http/servlet/ConnectorAPIServletTest.java | 176 -
.../uci/ics/asterix/test/aql/AQLTestCase.java | 67 -
.../uci/ics/asterix/test/aql/AQLTestSuite.java | 58 -
.../uci/ics/asterix/test/common/TestHelper.java | 30 -
.../edu/uci/ics/asterix/test/dml/DmlTest.java | 82 -
.../ics/asterix/test/metadata/MetadataTest.java | 109 -
.../asterix/test/optimizer/OptimizerTest.java | 220 --
.../ics/asterix/test/runtime/ExecutionTest.java | 142 -
.../ics/asterix/test/runtime/HDFSCluster.java | 127 -
.../ics/asterix/test/runtime/RepeatedTest.java | 105 -
.../http/servlet/ConnectorAPIServletTest.java | 176 +
.../apache/asterix/test/aql/AQLTestCase.java | 67 +
.../apache/asterix/test/aql/AQLTestSuite.java | 58 +
.../apache/asterix/test/common/TestHelper.java | 30 +
.../org/apache/asterix/test/dml/DmlTest.java | 82 +
.../asterix/test/metadata/MetadataTest.java | 109 +
.../asterix/test/optimizer/OptimizerTest.java | 220 ++
.../asterix/test/runtime/ExecutionTest.java | 142 +
.../asterix/test/runtime/HDFSCluster.java | 127 +
.../asterix/test/runtime/RepeatedTest.java | 105 +
.../asterix/aql/base/AbstractExpression.java | 39 -
.../edu/uci/ics/asterix/aql/base/Clause.java | 31 -
.../uci/ics/asterix/aql/base/Expression.java | 38 -
.../ics/asterix/aql/base/IAqlExpression.java | 25 -
.../edu/uci/ics/asterix/aql/base/Literal.java | 61 -
.../edu/uci/ics/asterix/aql/base/Statement.java | 57 -
.../aql/context/FunctionExpressionMap.java | 56 -
.../asterix/aql/context/FunctionSignatures.java | 47 -
.../asterix/aql/context/RootScopeFactory.java | 26 -
.../edu/uci/ics/asterix/aql/context/Scope.java | 122 -
.../aql/expression/AbstractAccessor.java | 35 -
.../asterix/aql/expression/AdmSplitInfo.java | 33 -
.../ics/asterix/aql/expression/CallExpr.java | 66 -
.../aql/expression/CompactStatement.java | 54 -
.../aql/expression/ConnectFeedStatement.java | 189 --
.../asterix/aql/expression/ConstructorType.java | 21 -
.../expression/CreateDataverseStatement.java | 65 -
.../expression/CreateFeedPolicyStatement.java | 91 -
.../aql/expression/CreateFeedStatement.java | 64 -
.../aql/expression/CreateFunctionStatement.java | 79 -
.../aql/expression/CreateIndexStatement.java | 123 -
.../expression/CreatePrimaryFeedStatement.java | 54 -
.../CreateSecondaryFeedStatement.java | 57 -
.../ics/asterix/aql/expression/DatasetDecl.java | 109 -
.../asterix/aql/expression/DataverseDecl.java | 50 -
.../aql/expression/DataverseDropStatement.java | 55 -
.../asterix/aql/expression/DeleteStatement.java | 89 -
.../aql/expression/DisconnectFeedStatement.java | 79 -
.../asterix/aql/expression/DistinctClause.java | 52 -
.../asterix/aql/expression/DropStatement.java | 61 -
.../aql/expression/ExternalDetailsDecl.java | 44 -
.../aql/expression/FLWOGRExpression.java | 80 -
.../asterix/aql/expression/FeedDetailsDecl.java | 50 -
.../aql/expression/FeedDropStatement.java | 61 -
.../aql/expression/FeedPolicyDropStatement.java | 61 -
.../asterix/aql/expression/FieldAccessor.java | 53 -
.../asterix/aql/expression/FieldBinding.java | 48 -
.../ics/asterix/aql/expression/ForClause.java | 76 -
.../asterix/aql/expression/FunctionDecl.java | 85 -
.../aql/expression/FunctionDropStatement.java | 56 -
.../expression/GbyVariableExpressionPair.java | 49 -
.../asterix/aql/expression/GroupbyClause.java | 88 -
.../asterix/aql/expression/HdfsPathInfo.java | 27 -
.../aql/expression/IDatasetDetailsDecl.java | 22 -
.../ics/asterix/aql/expression/Identifier.java | 53 -
.../uci/ics/asterix/aql/expression/IfExpr.java | 75 -
.../asterix/aql/expression/IndexAccessor.java | 65 -
.../ics/asterix/aql/expression/IndexDecl.java | 22 -
.../aql/expression/IndexDropStatement.java | 66 -
.../asterix/aql/expression/InsertStatement.java | 67 -
.../aql/expression/InternalDetailsDecl.java | 50 -
.../ics/asterix/aql/expression/JoinClause.java | 88 -
.../ics/asterix/aql/expression/LetClause.java | 71 -
.../ics/asterix/aql/expression/LimitClause.java | 65 -
.../asterix/aql/expression/ListConstructor.java | 72 -
.../ics/asterix/aql/expression/LiteralExpr.java | 55 -
.../asterix/aql/expression/LoadStatement.java | 88 -
.../aql/expression/MetaVariableClause.java | 49 -
.../aql/expression/MetaVariableExpr.java | 43 -
.../aql/expression/NodeGroupDropStatement.java | 55 -
.../asterix/aql/expression/NodegroupDecl.java | 66 -
.../asterix/aql/expression/OperatorExpr.java | 144 -
.../asterix/aql/expression/OperatorType.java | 35 -
.../asterix/aql/expression/OrderbyClause.java | 99 -
.../expression/OrderedListTypeDefinition.java | 48 -
.../aql/expression/QuantifiedExpression.java | 83 -
.../asterix/aql/expression/QuantifiedPair.java | 47 -
.../uci/ics/asterix/aql/expression/Query.java | 78 -
.../aql/expression/RecordConstructor.java | 58 -
.../aql/expression/RecordTypeDefinition.java | 106 -
.../RefreshExternalDatasetStatement.java | 59 -
.../asterix/aql/expression/RunStatement.java | 83 -
.../asterix/aql/expression/SetStatement.java | 56 -
.../aql/expression/SubscribeFeedStatement.java | 207 --
.../ics/asterix/aql/expression/TypeDecl.java | 79 -
.../aql/expression/TypeDropStatement.java | 61 -
.../asterix/aql/expression/TypeExpression.java | 30 -
.../aql/expression/TypeReferenceExpression.java | 48 -
.../ics/asterix/aql/expression/UnaryExpr.java | 69 -
.../ics/asterix/aql/expression/UnionExpr.java | 64 -
.../expression/UnorderedListTypeDefinition.java | 48 -
.../asterix/aql/expression/UpdateClause.java | 93 -
.../asterix/aql/expression/UpdateStatement.java | 70 -
.../asterix/aql/expression/VarIdentifier.java | 49 -
.../asterix/aql/expression/VariableExpr.java | 67 -
.../ics/asterix/aql/expression/WhereClause.java | 57 -
.../asterix/aql/expression/WriteStatement.java | 62 -
.../aql/expression/visitor/AQLPrintVisitor.java | 578 ----
.../visitor/IAqlExpressionVisitor.java | 183 --
.../visitor/IAqlPlusExpressionVisitor.java | 28 -
.../visitor/IAqlVisitorWithVoidReturn.java | 182 --
.../ics/asterix/aql/literal/DoubleLiteral.java | 44 -
.../ics/asterix/aql/literal/FalseLiteral.java | 57 -
.../ics/asterix/aql/literal/FloatLiteral.java | 44 -
.../ics/asterix/aql/literal/IntegerLiteral.java | 43 -
.../asterix/aql/literal/LongIntegerLiteral.java | 44 -
.../ics/asterix/aql/literal/NullLiteral.java | 55 -
.../ics/asterix/aql/literal/StringLiteral.java | 46 -
.../ics/asterix/aql/literal/TrueLiteral.java | 56 -
.../ics/asterix/aql/parser/ScopeChecker.java | 249 --
.../ics/asterix/aql/rewrites/AqlRewriter.java | 598 ----
.../aql/rewrites/AqlRewritingContext.java | 58 -
.../CloneAndSubstituteVariablesVisitor.java | 640 ----
.../asterix/aql/rewrites/InlineUdfsVisitor.java | 572 ----
.../aql/rewrites/VariableSubstitution.java | 39 -
.../uci/ics/asterix/aql/util/FunctionUtils.java | 84 -
.../ics/asterix/aql/util/RangeMapBuilder.java | 171 -
.../asterix/aql/base/AbstractExpression.java | 39 +
.../org/apache/asterix/aql/base/Clause.java | 31 +
.../org/apache/asterix/aql/base/Expression.java | 38 +
.../apache/asterix/aql/base/IAqlExpression.java | 25 +
.../org/apache/asterix/aql/base/Literal.java | 61 +
.../org/apache/asterix/aql/base/Statement.java | 57 +
.../aql/context/FunctionExpressionMap.java | 56 +
.../asterix/aql/context/FunctionSignatures.java | 47 +
.../asterix/aql/context/RootScopeFactory.java | 26 +
.../org/apache/asterix/aql/context/Scope.java | 122 +
.../aql/expression/AbstractAccessor.java | 35 +
.../asterix/aql/expression/AdmSplitInfo.java | 33 +
.../apache/asterix/aql/expression/CallExpr.java | 66 +
.../aql/expression/CompactStatement.java | 54 +
.../aql/expression/ConnectFeedStatement.java | 189 ++
.../asterix/aql/expression/ConstructorType.java | 21 +
.../expression/CreateDataverseStatement.java | 65 +
.../expression/CreateFeedPolicyStatement.java | 91 +
.../aql/expression/CreateFeedStatement.java | 64 +
.../aql/expression/CreateFunctionStatement.java | 79 +
.../aql/expression/CreateIndexStatement.java | 123 +
.../expression/CreatePrimaryFeedStatement.java | 54 +
.../CreateSecondaryFeedStatement.java | 57 +
.../asterix/aql/expression/DatasetDecl.java | 109 +
.../asterix/aql/expression/DataverseDecl.java | 50 +
.../aql/expression/DataverseDropStatement.java | 55 +
.../asterix/aql/expression/DeleteStatement.java | 89 +
.../aql/expression/DisconnectFeedStatement.java | 79 +
.../asterix/aql/expression/DistinctClause.java | 52 +
.../asterix/aql/expression/DropStatement.java | 61 +
.../aql/expression/ExternalDetailsDecl.java | 44 +
.../aql/expression/FLWOGRExpression.java | 80 +
.../asterix/aql/expression/FeedDetailsDecl.java | 50 +
.../aql/expression/FeedDropStatement.java | 61 +
.../aql/expression/FeedPolicyDropStatement.java | 61 +
.../asterix/aql/expression/FieldAccessor.java | 53 +
.../asterix/aql/expression/FieldBinding.java | 48 +
.../asterix/aql/expression/ForClause.java | 76 +
.../asterix/aql/expression/FunctionDecl.java | 85 +
.../aql/expression/FunctionDropStatement.java | 56 +
.../expression/GbyVariableExpressionPair.java | 49 +
.../asterix/aql/expression/GroupbyClause.java | 88 +
.../asterix/aql/expression/HdfsPathInfo.java | 27 +
.../aql/expression/IDatasetDetailsDecl.java | 22 +
.../asterix/aql/expression/Identifier.java | 53 +
.../apache/asterix/aql/expression/IfExpr.java | 75 +
.../asterix/aql/expression/IndexAccessor.java | 65 +
.../asterix/aql/expression/IndexDecl.java | 22 +
.../aql/expression/IndexDropStatement.java | 66 +
.../asterix/aql/expression/InsertStatement.java | 67 +
.../aql/expression/InternalDetailsDecl.java | 50 +
.../asterix/aql/expression/JoinClause.java | 88 +
.../asterix/aql/expression/LetClause.java | 71 +
.../asterix/aql/expression/LimitClause.java | 65 +
.../asterix/aql/expression/ListConstructor.java | 72 +
.../asterix/aql/expression/LiteralExpr.java | 55 +
.../asterix/aql/expression/LoadStatement.java | 88 +
.../aql/expression/MetaVariableClause.java | 49 +
.../aql/expression/MetaVariableExpr.java | 43 +
.../aql/expression/NodeGroupDropStatement.java | 55 +
.../asterix/aql/expression/NodegroupDecl.java | 66 +
.../asterix/aql/expression/OperatorExpr.java | 144 +
.../asterix/aql/expression/OperatorType.java | 35 +
.../asterix/aql/expression/OrderbyClause.java | 99 +
.../expression/OrderedListTypeDefinition.java | 48 +
.../aql/expression/QuantifiedExpression.java | 83 +
.../asterix/aql/expression/QuantifiedPair.java | 47 +
.../apache/asterix/aql/expression/Query.java | 78 +
.../aql/expression/RecordConstructor.java | 58 +
.../aql/expression/RecordTypeDefinition.java | 106 +
.../RefreshExternalDatasetStatement.java | 59 +
.../asterix/aql/expression/RunStatement.java | 83 +
.../asterix/aql/expression/SetStatement.java | 56 +
.../aql/expression/SubscribeFeedStatement.java | 207 ++
.../apache/asterix/aql/expression/TypeDecl.java | 79 +
.../aql/expression/TypeDropStatement.java | 61 +
.../asterix/aql/expression/TypeExpression.java | 30 +
.../aql/expression/TypeReferenceExpression.java | 48 +
.../asterix/aql/expression/UnaryExpr.java | 69 +
.../asterix/aql/expression/UnionExpr.java | 64 +
.../expression/UnorderedListTypeDefinition.java | 48 +
.../asterix/aql/expression/UpdateClause.java | 93 +
.../asterix/aql/expression/UpdateStatement.java | 70 +
.../asterix/aql/expression/VarIdentifier.java | 49 +
.../asterix/aql/expression/VariableExpr.java | 67 +
.../asterix/aql/expression/WhereClause.java | 57 +
.../asterix/aql/expression/WriteStatement.java | 62 +
.../aql/expression/visitor/AQLPrintVisitor.java | 578 ++++
.../visitor/IAqlExpressionVisitor.java | 183 ++
.../visitor/IAqlPlusExpressionVisitor.java | 28 +
.../visitor/IAqlVisitorWithVoidReturn.java | 182 ++
.../asterix/aql/literal/DoubleLiteral.java | 44 +
.../asterix/aql/literal/FalseLiteral.java | 57 +
.../asterix/aql/literal/FloatLiteral.java | 44 +
.../asterix/aql/literal/IntegerLiteral.java | 43 +
.../asterix/aql/literal/LongIntegerLiteral.java | 44 +
.../apache/asterix/aql/literal/NullLiteral.java | 55 +
.../asterix/aql/literal/StringLiteral.java | 46 +
.../apache/asterix/aql/literal/TrueLiteral.java | 56 +
.../apache/asterix/aql/parser/ScopeChecker.java | 249 ++
.../asterix/aql/rewrites/AqlRewriter.java | 598 ++++
.../aql/rewrites/AqlRewritingContext.java | 58 +
.../CloneAndSubstituteVariablesVisitor.java | 640 ++++
.../asterix/aql/rewrites/InlineUdfsVisitor.java | 572 ++++
.../aql/rewrites/VariableSubstitution.java | 39 +
.../apache/asterix/aql/util/FunctionUtils.java | 84 +
.../asterix/aql/util/RangeMapBuilder.java | 171 +
.../asterix/common/annotations/AutoDataGen.java | 34 -
.../annotations/DateBetweenYearsDataGen.java | 40 -
.../DatetimeAddRandHoursDataGen.java | 46 -
.../DatetimeBetweenYearsDataGen.java | 40 -
.../annotations/FieldIntervalDataGen.java | 53 -
.../common/annotations/FieldValFileDataGen.java | 36 -
.../FieldValFileSameIndexDataGen.java | 41 -
.../common/annotations/IRecordFieldDataGen.java | 32 -
.../annotations/IRecordTypeAnnotation.java | 23 -
.../annotations/InsertRandIntDataGen.java | 40 -
.../asterix/common/annotations/ListDataGen.java | 40 -
.../common/annotations/ListValFileDataGen.java | 48 -
.../annotations/RecordDataGenAnnotation.java | 43 -
...econdaryIndexSearchExpressionAnnotation.java | 42 -
.../asterix/common/annotations/TypeDataGen.java | 39 -
.../annotations/UndeclaredFieldsDataGen.java | 52 -
.../asterix/common/api/AsterixContextInfo.java | 40 -
.../common/api/AsterixThreadExecutor.java | 39 -
.../common/api/AsterixThreadFactory.java | 41 -
.../common/api/IAsterixAppRuntimeContext.java | 76 -
.../asterix/common/api/IAsterixContextInfo.java | 28 -
.../api/IAsterixRuntimeComponentsProvider.java | 61 -
.../common/api/IClusterEventsSubscriber.java | 47 -
.../common/api/IClusterManagementWork.java | 34 -
.../api/IClusterManagementWorkResponse.java | 41 -
.../common/api/ILocalResourceMetadata.java | 29 -
.../config/AbstractAsterixProperties.java | 23 -
.../config/AsterixCompilerProperties.java | 54 -
.../config/AsterixExternalProperties.java | 89 -
.../common/config/AsterixFeedProperties.java | 62 -
.../config/AsterixMetadataProperties.java | 53 -
.../config/AsterixPropertiesAccessor.java | 164 -
.../common/config/AsterixStorageProperties.java | 100 -
.../config/AsterixTransactionProperties.java | 113 -
.../asterix/common/config/DatasetConfig.java | 53 -
.../ics/asterix/common/config/GlobalConfig.java | 68 -
.../config/IAsterixPropertiesProvider.java | 29 -
.../common/config/IPropertyInterpreter.java | 21 -
.../common/config/OptimizationConfUtil.java | 26 -
.../common/config/PropertyInterpreters.java | 94 -
.../common/context/AsterixFileMapManager.java | 87 -
.../AsterixVirtualBufferCacheProvider.java | 39 -
.../common/context/BaseOperationTracker.java | 64 -
.../context/CorrelatedPrefixMergePolicy.java | 126 -
.../CorrelatedPrefixMergePolicyFactory.java | 68 -
.../common/context/DatasetLifecycleManager.java | 603 ----
.../context/ITransactionSubsystemProvider.java | 25 -
.../context/PrimaryIndexOperationTracker.java | 196 --
.../context/TransactionSubsystemProvider.java | 34 -
.../common/dataflow/AsterixLSMIndexUtil.java | 40 -
...erixLSMInsertDeleteOperatorNodePushable.java | 123 -
...rtedIndexInsertDeleteOperatorDescriptor.java | 63 -
...ixLSMTreeInsertDeleteOperatorDescriptor.java | 82 -
.../IAsterixApplicationContextInfo.java | 47 -
.../common/exceptions/ACIDException.java | 61 -
.../common/exceptions/AsterixException.java | 34 -
.../exceptions/AsterixRuntimeException.java | 33 -
.../common/exceptions/FrameDataException.java | 34 -
.../common/exceptions/TypeException.java | 39 -
.../common/feeds/BasicMonitoredBuffer.java | 70 -
.../asterix/common/feeds/CollectionRuntime.java | 88 -
.../feeds/ComputeSideMonitoredBuffer.java | 69 -
.../ics/asterix/common/feeds/DataBucket.java | 84 -
.../asterix/common/feeds/DataBucketPool.java | 106 -
.../common/feeds/DistributeFeedFrameWriter.java | 135 -
.../ics/asterix/common/feeds/FeedActivity.java | 115 -
.../feeds/FeedCollectRuntimeInputHandler.java | 57 -
.../common/feeds/FeedConnectJobInfo.java | 89 -
.../asterix/common/feeds/FeedConnectionId.java | 70 -
.../common/feeds/FeedConnectionRequest.java | 122 -
.../ics/asterix/common/feeds/FeedConstants.java | 67 -
.../common/feeds/FeedExceptionHandler.java | 104 -
.../asterix/common/feeds/FeedFrameCache.java | 167 -
.../common/feeds/FeedFrameCollector.java | 154 -
.../common/feeds/FeedFrameDiscarder.java | 63 -
.../asterix/common/feeds/FeedFrameHandlers.java | 302 --
.../asterix/common/feeds/FeedFrameSpiller.java | 172 -
.../common/feeds/FeedFrameTupleAccessor.java | 106 -
.../ics/asterix/common/feeds/FeedFrameUtil.java | 98 -
.../uci/ics/asterix/common/feeds/FeedId.java | 62 -
.../asterix/common/feeds/FeedIntakeInfo.java | 58 -
.../ics/asterix/common/feeds/FeedJobInfo.java | 82 -
.../ics/asterix/common/feeds/FeedJointKey.java | 75 -
.../asterix/common/feeds/FeedMemoryManager.java | 108 -
.../common/feeds/FeedMessageService.java | 140 -
.../common/feeds/FeedMetricCollector.java | 185 --
.../common/feeds/FeedPolicyAccessor.java | 164 -
.../ics/asterix/common/feeds/FeedRuntime.java | 70 -
.../ics/asterix/common/feeds/FeedRuntimeId.java | 76 -
.../common/feeds/FeedRuntimeInputHandler.java | 426 ---
.../common/feeds/FeedRuntimeManager.java | 77 -
.../asterix/common/feeds/FeedRuntimeReport.java | 19 -
.../common/feeds/FeedStorageStatistics.java | 23 -
.../common/feeds/FeedTupleCommitAckMessage.java | 93 -
.../feeds/FeedTupleCommitResponseMessage.java | 76 -
.../asterix/common/feeds/FrameCollection.java | 97 -
.../asterix/common/feeds/FrameDistributor.java | 359 --
.../common/feeds/FrameEventCallback.java | 98 -
.../common/feeds/IFramePostProcessor.java | 24 -
.../common/feeds/IFramePreprocessor.java | 22 -
.../asterix/common/feeds/IngestionRuntime.java | 71 -
.../common/feeds/IntakePartitionStatistics.java | 41 -
.../common/feeds/IntakeSideMonitoredBuffer.java | 70 -
.../asterix/common/feeds/MessageListener.java | 122 -
.../asterix/common/feeds/MessageReceiver.java | 107 -
.../asterix/common/feeds/MonitoredBuffer.java | 386 ---
.../common/feeds/MonitoredBufferTimerTasks.java | 290 --
.../uci/ics/asterix/common/feeds/NodeLoad.java | 58 -
.../asterix/common/feeds/NodeLoadReport.java | 95 -
.../common/feeds/NodeLoadReportService.java | 104 -
.../uci/ics/asterix/common/feeds/Series.java | 40 -
.../uci/ics/asterix/common/feeds/SeriesAvg.java | 43 -
.../ics/asterix/common/feeds/SeriesRate.java | 88 -
.../common/feeds/StorageFrameHandler.java | 114 -
.../feeds/StorageSideMonitoredBuffer.java | 203 --
.../common/feeds/SubscribableFeedRuntimeId.java | 48 -
.../common/feeds/SubscribableRuntime.java | 86 -
.../feeds/api/IAdapterRuntimeManager.java | 80 -
.../common/feeds/api/ICentralFeedManager.java | 30 -
.../common/feeds/api/IDatasourceAdapter.java | 43 -
.../common/feeds/api/IExceptionHandler.java | 39 -
.../asterix/common/feeds/api/IFeedAdapter.java | 56 -
.../feeds/api/IFeedConnectionManager.java | 71 -
.../common/feeds/api/IFeedFrameHandler.java | 35 -
.../asterix/common/feeds/api/IFeedJoint.java | 117 -
.../api/IFeedLifecycleEventSubscriber.java | 33 -
.../IFeedLifecycleIntakeEventSubscriber.java | 24 -
.../feeds/api/IFeedLifecycleListener.java | 52 -
.../common/feeds/api/IFeedLoadManager.java | 56 -
.../asterix/common/feeds/api/IFeedManager.java | 93 -
.../common/feeds/api/IFeedMemoryComponent.java | 54 -
.../common/feeds/api/IFeedMemoryManager.java | 54 -
.../asterix/common/feeds/api/IFeedMessage.java | 48 -
.../common/feeds/api/IFeedMessageService.java | 30 -
.../common/feeds/api/IFeedMetadataManager.java | 35 -
.../common/feeds/api/IFeedMetricCollector.java | 46 -
.../api/IFeedOperatorOutputSideHandler.java | 32 -
.../asterix/common/feeds/api/IFeedProvider.java | 22 -
.../asterix/common/feeds/api/IFeedRuntime.java | 58 -
.../asterix/common/feeds/api/IFeedService.java | 22 -
.../feeds/api/IFeedSubscriptionManager.java | 37 -
.../common/feeds/api/IFeedTrackingManager.java | 25 -
.../ics/asterix/common/feeds/api/IFeedWork.java | 24 -
.../feeds/api/IFeedWorkEventListener.java | 37 -
.../common/feeds/api/IFeedWorkManager.java | 21 -
.../common/feeds/api/IFrameEventCallback.java | 28 -
.../feeds/api/IIntakeProgressTracker.java | 25 -
.../common/feeds/api/IMessageReceiver.java | 24 -
.../common/feeds/api/ISubscribableRuntime.java | 57 -
.../common/feeds/api/ISubscriberRuntime.java | 26 -
.../common/feeds/api/ISubscriptionProvider.java | 25 -
.../feeds/api/ITupleTrackingFeedAdapter.java | 20 -
.../common/feeds/message/EndFeedMessage.java | 93 -
.../feeds/message/FeedCongestionMessage.java | 99 -
.../common/feeds/message/FeedMessage.java | 38 -
.../feeds/message/FeedMessageService.java | 143 -
.../common/feeds/message/FeedReportMessage.java | 96 -
.../message/FeedTupleCommitAckMessage.java | 95 -
.../message/FeedTupleCommitResponseMessage.java | 69 -
.../common/feeds/message/NodeReportMessage.java | 65 -
.../feeds/message/ScaleInReportMessage.java | 110 -
.../feeds/message/StorageReportFeedMessage.java | 125 -
.../message/ThrottlingEnabledFeedMessage.java | 82 -
.../common/functions/FunctionConstants.java | 21 -
.../common/functions/FunctionDescriptorTag.java | 23 -
.../common/functions/FunctionSignature.java | 79 -
.../AbstractLSMIOOperationCallback.java | 150 -
.../LSMBTreeIOOperationCallback.java | 59 -
.../LSMBTreeIOOperationCallbackFactory.java | 34 -
.../LSMBTreeWithBuddyIOOperationCallback.java | 54 -
...TreeWithBuddyIOOperationCallbackFactory.java | 33 -
.../LSMInvertedIndexIOOperationCallback.java | 57 -
...InvertedIndexIOOperationCallbackFactory.java | 34 -
.../LSMRTreeIOOperationCallback.java | 58 -
.../LSMRTreeIOOperationCallbackFactory.java | 34 -
.../common/parse/IAsterixTupleParser.java | 25 -
.../common/parse/IParseFileSplitsDecl.java | 29 -
.../common/parse/ITupleForwardPolicy.java | 44 -
.../common/parse/ITupleParserPolicy.java | 41 -
.../transactions/AbstractOperationCallback.java | 65 -
.../AbstractOperationCallbackFactory.java | 40 -
.../asterix/common/transactions/DatasetId.java | 50 -
.../IAsterixAppRuntimeContextProvider.java | 58 -
.../common/transactions/ILockHashTable.java | 35 -
.../common/transactions/ILockManager.java | 117 -
.../common/transactions/ILockMatrix.java | 44 -
.../common/transactions/ILogManager.java | 53 -
.../asterix/common/transactions/ILogPage.java | 23 -
.../asterix/common/transactions/ILogReader.java | 31 -
.../asterix/common/transactions/ILogRecord.java | 107 -
.../common/transactions/IRecoveryManager.java | 89 -
.../transactions/ITransactionContext.java | 51 -
.../transactions/ITransactionManager.java | 123 -
.../transactions/ITransactionSubsystem.java | 32 -
.../ics/asterix/common/transactions/JobId.java | 56 -
.../transactions/LogManagerProperties.java | 93 -
.../asterix/common/transactions/LogRecord.java | 476 ---
.../asterix/common/transactions/LogType.java | 50 -
.../common/transactions/MutableLong.java | 51 -
.../transactions/PrimaryKeyTupleReference.java | 50 -
.../ics/asterix/common/utils/ANameSchema.java | 25 -
.../asterix/common/utils/UTF8CharSequence.java | 89 -
.../asterix/test/base/AsterixTestHelper.java | 76 -
.../asterix/common/annotations/AutoDataGen.java | 34 +
.../annotations/DateBetweenYearsDataGen.java | 40 +
.../DatetimeAddRandHoursDataGen.java | 46 +
.../DatetimeBetweenYearsDataGen.java | 40 +
.../annotations/FieldIntervalDataGen.java | 53 +
.../common/annotations/FieldValFileDataGen.java | 36 +
.../FieldValFileSameIndexDataGen.java | 41 +
.../common/annotations/IRecordFieldDataGen.java | 32 +
.../annotations/IRecordTypeAnnotation.java | 23 +
.../annotations/InsertRandIntDataGen.java | 40 +
.../asterix/common/annotations/ListDataGen.java | 40 +
.../common/annotations/ListValFileDataGen.java | 48 +
.../annotations/RecordDataGenAnnotation.java | 43 +
...econdaryIndexSearchExpressionAnnotation.java | 42 +
.../asterix/common/annotations/TypeDataGen.java | 39 +
.../annotations/UndeclaredFieldsDataGen.java | 52 +
.../asterix/common/api/AsterixContextInfo.java | 40 +
.../common/api/AsterixThreadExecutor.java | 39 +
.../common/api/AsterixThreadFactory.java | 41 +
.../common/api/IAsterixAppRuntimeContext.java | 76 +
.../asterix/common/api/IAsterixContextInfo.java | 28 +
.../api/IAsterixRuntimeComponentsProvider.java | 61 +
.../common/api/IClusterEventsSubscriber.java | 47 +
.../common/api/IClusterManagementWork.java | 34 +
.../api/IClusterManagementWorkResponse.java | 41 +
.../common/api/ILocalResourceMetadata.java | 29 +
.../config/AbstractAsterixProperties.java | 23 +
.../config/AsterixCompilerProperties.java | 54 +
.../config/AsterixExternalProperties.java | 89 +
.../common/config/AsterixFeedProperties.java | 62 +
.../config/AsterixMetadataProperties.java | 53 +
.../config/AsterixPropertiesAccessor.java | 164 +
.../common/config/AsterixStorageProperties.java | 100 +
.../config/AsterixTransactionProperties.java | 113 +
.../asterix/common/config/DatasetConfig.java | 53 +
.../asterix/common/config/GlobalConfig.java | 68 +
.../config/IAsterixPropertiesProvider.java | 29 +
.../common/config/IPropertyInterpreter.java | 21 +
.../common/config/OptimizationConfUtil.java | 26 +
.../common/config/PropertyInterpreters.java | 94 +
.../common/context/AsterixFileMapManager.java | 87 +
.../AsterixVirtualBufferCacheProvider.java | 39 +
.../common/context/BaseOperationTracker.java | 64 +
.../context/CorrelatedPrefixMergePolicy.java | 126 +
.../CorrelatedPrefixMergePolicyFactory.java | 68 +
.../common/context/DatasetLifecycleManager.java | 603 ++++
.../context/ITransactionSubsystemProvider.java | 25 +
.../context/PrimaryIndexOperationTracker.java | 196 ++
.../context/TransactionSubsystemProvider.java | 34 +
.../common/dataflow/AsterixLSMIndexUtil.java | 40 +
...erixLSMInsertDeleteOperatorNodePushable.java | 123 +
...rtedIndexInsertDeleteOperatorDescriptor.java | 63 +
...ixLSMTreeInsertDeleteOperatorDescriptor.java | 82 +
.../IAsterixApplicationContextInfo.java | 47 +
.../common/exceptions/ACIDException.java | 61 +
.../common/exceptions/AsterixException.java | 34 +
.../exceptions/AsterixRuntimeException.java | 33 +
.../common/exceptions/FrameDataException.java | 34 +
.../common/exceptions/TypeException.java | 39 +
.../common/feeds/BasicMonitoredBuffer.java | 70 +
.../asterix/common/feeds/CollectionRuntime.java | 88 +
.../feeds/ComputeSideMonitoredBuffer.java | 69 +
.../apache/asterix/common/feeds/DataBucket.java | 84 +
.../asterix/common/feeds/DataBucketPool.java | 106 +
.../common/feeds/DistributeFeedFrameWriter.java | 135 +
.../asterix/common/feeds/FeedActivity.java | 115 +
.../feeds/FeedCollectRuntimeInputHandler.java | 57 +
.../common/feeds/FeedConnectJobInfo.java | 89 +
.../asterix/common/feeds/FeedConnectionId.java | 70 +
.../common/feeds/FeedConnectionRequest.java | 122 +
.../asterix/common/feeds/FeedConstants.java | 67 +
.../common/feeds/FeedExceptionHandler.java | 104 +
.../asterix/common/feeds/FeedFrameCache.java | 167 +
.../common/feeds/FeedFrameCollector.java | 154 +
.../common/feeds/FeedFrameDiscarder.java | 63 +
.../asterix/common/feeds/FeedFrameHandlers.java | 302 ++
.../asterix/common/feeds/FeedFrameSpiller.java | 172 +
.../common/feeds/FeedFrameTupleAccessor.java | 106 +
.../asterix/common/feeds/FeedFrameUtil.java | 98 +
.../org/apache/asterix/common/feeds/FeedId.java | 62 +
.../asterix/common/feeds/FeedIntakeInfo.java | 58 +
.../asterix/common/feeds/FeedJobInfo.java | 82 +
.../asterix/common/feeds/FeedJointKey.java | 75 +
.../asterix/common/feeds/FeedMemoryManager.java | 108 +
.../common/feeds/FeedMessageService.java | 140 +
.../common/feeds/FeedMetricCollector.java | 185 ++
.../common/feeds/FeedPolicyAccessor.java | 164 +
.../asterix/common/feeds/FeedRuntime.java | 70 +
.../asterix/common/feeds/FeedRuntimeId.java | 76 +
.../common/feeds/FeedRuntimeInputHandler.java | 426 +++
.../common/feeds/FeedRuntimeManager.java | 77 +
.../asterix/common/feeds/FeedRuntimeReport.java | 19 +
.../common/feeds/FeedStorageStatistics.java | 23 +
.../common/feeds/FeedTupleCommitAckMessage.java | 93 +
.../feeds/FeedTupleCommitResponseMessage.java | 76 +
.../asterix/common/feeds/FrameCollection.java | 97 +
.../asterix/common/feeds/FrameDistributor.java | 359 ++
.../common/feeds/FrameEventCallback.java | 98 +
.../common/feeds/IFramePostProcessor.java | 24 +
.../common/feeds/IFramePreprocessor.java | 22 +
.../asterix/common/feeds/IngestionRuntime.java | 71 +
.../common/feeds/IntakePartitionStatistics.java | 41 +
.../common/feeds/IntakeSideMonitoredBuffer.java | 70 +
.../asterix/common/feeds/MessageListener.java | 122 +
.../asterix/common/feeds/MessageReceiver.java | 107 +
.../asterix/common/feeds/MonitoredBuffer.java | 386 +++
.../common/feeds/MonitoredBufferTimerTasks.java | 290 ++
.../apache/asterix/common/feeds/NodeLoad.java | 58 +
.../asterix/common/feeds/NodeLoadReport.java | 95 +
.../common/feeds/NodeLoadReportService.java | 104 +
.../org/apache/asterix/common/feeds/Series.java | 40 +
.../apache/asterix/common/feeds/SeriesAvg.java | 43 +
.../apache/asterix/common/feeds/SeriesRate.java | 88 +
.../common/feeds/StorageFrameHandler.java | 114 +
.../feeds/StorageSideMonitoredBuffer.java | 203 ++
.../common/feeds/SubscribableFeedRuntimeId.java | 48 +
.../common/feeds/SubscribableRuntime.java | 86 +
.../feeds/api/IAdapterRuntimeManager.java | 80 +
.../common/feeds/api/ICentralFeedManager.java | 30 +
.../common/feeds/api/IDatasourceAdapter.java | 43 +
.../common/feeds/api/IExceptionHandler.java | 39 +
.../asterix/common/feeds/api/IFeedAdapter.java | 56 +
.../feeds/api/IFeedConnectionManager.java | 71 +
.../common/feeds/api/IFeedFrameHandler.java | 35 +
.../asterix/common/feeds/api/IFeedJoint.java | 117 +
.../api/IFeedLifecycleEventSubscriber.java | 33 +
.../IFeedLifecycleIntakeEventSubscriber.java | 24 +
.../feeds/api/IFeedLifecycleListener.java | 52 +
.../common/feeds/api/IFeedLoadManager.java | 56 +
.../asterix/common/feeds/api/IFeedManager.java | 93 +
.../common/feeds/api/IFeedMemoryComponent.java | 54 +
.../common/feeds/api/IFeedMemoryManager.java | 54 +
.../asterix/common/feeds/api/IFeedMessage.java | 48 +
.../common/feeds/api/IFeedMessageService.java | 30 +
.../common/feeds/api/IFeedMetadataManager.java | 35 +
.../common/feeds/api/IFeedMetricCollector.java | 46 +
.../api/IFeedOperatorOutputSideHandler.java | 32 +
.../asterix/common/feeds/api/IFeedProvider.java | 22 +
.../asterix/common/feeds/api/IFeedRuntime.java | 58 +
.../asterix/common/feeds/api/IFeedService.java | 22 +
.../feeds/api/IFeedSubscriptionManager.java | 37 +
.../common/feeds/api/IFeedTrackingManager.java | 25 +
.../asterix/common/feeds/api/IFeedWork.java | 24 +
.../feeds/api/IFeedWorkEventListener.java | 37 +
.../common/feeds/api/IFeedWorkManager.java | 21 +
.../common/feeds/api/IFrameEventCallback.java | 28 +
.../feeds/api/IIntakeProgressTracker.java | 25 +
.../common/feeds/api/IMessageReceiver.java | 24 +
.../common/feeds/api/ISubscribableRuntime.java | 57 +
.../common/feeds/api/ISubscriberRuntime.java | 26 +
.../common/feeds/api/ISubscriptionProvider.java | 25 +
.../feeds/api/ITupleTrackingFeedAdapter.java | 20 +
.../common/feeds/message/EndFeedMessage.java | 93 +
.../feeds/message/FeedCongestionMessage.java | 99 +
.../common/feeds/message/FeedMessage.java | 38 +
.../feeds/message/FeedMessageService.java | 143 +
.../common/feeds/message/FeedReportMessage.java | 96 +
.../message/FeedTupleCommitAckMessage.java | 95 +
.../message/FeedTupleCommitResponseMessage.java | 69 +
.../common/feeds/message/NodeReportMessage.java | 65 +
.../feeds/message/ScaleInReportMessage.java | 110 +
.../feeds/message/StorageReportFeedMessage.java | 125 +
.../message/ThrottlingEnabledFeedMessage.java | 82 +
.../common/functions/FunctionConstants.java | 21 +
.../common/functions/FunctionDescriptorTag.java | 23 +
.../common/functions/FunctionSignature.java | 79 +
.../AbstractLSMIOOperationCallback.java | 150 +
.../LSMBTreeIOOperationCallback.java | 59 +
.../LSMBTreeIOOperationCallbackFactory.java | 34 +
.../LSMBTreeWithBuddyIOOperationCallback.java | 54 +
...TreeWithBuddyIOOperationCallbackFactory.java | 33 +
.../LSMInvertedIndexIOOperationCallback.java | 57 +
...InvertedIndexIOOperationCallbackFactory.java | 34 +
.../LSMRTreeIOOperationCallback.java | 58 +
.../LSMRTreeIOOperationCallbackFactory.java | 34 +
.../common/parse/IAsterixTupleParser.java | 25 +
.../common/parse/IParseFileSplitsDecl.java | 29 +
.../common/parse/ITupleForwardPolicy.java | 44 +
.../common/parse/ITupleParserPolicy.java | 41 +
.../transactions/AbstractOperationCallback.java | 65 +
.../AbstractOperationCallbackFactory.java | 40 +
.../asterix/common/transactions/DatasetId.java | 50 +
.../IAsterixAppRuntimeContextProvider.java | 58 +
.../common/transactions/ILockHashTable.java | 35 +
.../common/transactions/ILockManager.java | 117 +
.../common/transactions/ILockMatrix.java | 44 +
.../common/transactions/ILogManager.java | 53 +
.../asterix/common/transactions/ILogPage.java | 23 +
.../asterix/common/transactions/ILogReader.java | 31 +
.../asterix/common/transactions/ILogRecord.java | 107 +
.../common/transactions/IRecoveryManager.java | 89 +
.../transactions/ITransactionContext.java | 51 +
.../transactions/ITransactionManager.java | 123 +
.../transactions/ITransactionSubsystem.java | 32 +
.../asterix/common/transactions/JobId.java | 56 +
.../transactions/LogManagerProperties.java | 93 +
.../asterix/common/transactions/LogRecord.java | 476 +++
.../asterix/common/transactions/LogType.java | 50 +
.../common/transactions/MutableLong.java | 51 +
.../transactions/PrimaryKeyTupleReference.java | 50 +
.../asterix/common/utils/ANameSchema.java | 25 +
.../asterix/common/utils/UTF8CharSequence.java | 89 +
.../asterix/test/base/AsterixTestHelper.java | 76 +
.../uci/ics/asterix/test/aql/TestHelper.java | 30 -
.../uci/ics/asterix/test/aql/TestsUtils.java | 530 ---
.../org/apache/asterix/test/aql/TestHelper.java | 30 +
.../org/apache/asterix/test/aql/TestsUtils.java | 530 +++
.../uci/ics/asterix/event/api/ClusterInfo.java | 26 -
.../edu/uci/ics/asterix/event/api/NodeInfo.java | 34 -
.../ics/asterix/event/driver/EventConfig.java | 36 -
.../ics/asterix/event/driver/EventDriver.java | 151 -
.../ics/asterix/event/error/EventException.java | 25 -
.../ics/asterix/event/error/OutputHandler.java | 89 -
.../asterix/event/error/VerificationUtil.java | 126 -
.../management/AsterixEventServiceClient.java | 229 --
.../event/management/DefaultOutputHandler.java | 26 -
.../asterix/event/management/ErrorHandler.java | 19 -
.../asterix/event/management/EventExecutor.java | 131 -
.../ics/asterix/event/management/EventTask.java | 154 -
.../event/management/EventTaskReport.java | 50 -
.../ics/asterix/event/management/EventUtil.java | 256 --
.../event/management/IOutputHandler.java | 22 -
.../event/management/IPatternListener.java | 24 -
.../event/management/OutputAnalysis.java | 34 -
.../asterix/event/management/Randomizer.java | 65 -
.../ics/asterix/event/management/ValueType.java | 95 -
.../asterix/event/model/AsterixInstance.java | 215 --
.../event/model/AsterixRuntimeState.java | 54 -
.../uci/ics/asterix/event/model/BackupInfo.java | 68 -
.../uci/ics/asterix/event/model/EventList.java | 34 -
.../ics/asterix/event/model/ProcessInfo.java | 54 -
.../event/service/AsterixEventService.java | 92 -
.../event/service/AsterixEventServiceUtil.java | 552 ----
.../asterix/event/service/ILookupService.java | 41 -
.../asterix/event/service/ServiceProvider.java | 30 -
.../asterix/event/service/ZooKeeperService.java | 247 --
.../asterix/event/util/AsterixConstants.java | 21 -
.../ics/asterix/event/util/PatternCreator.java | 645 ----
.../apache/asterix/event/api/ClusterInfo.java | 26 +
.../org/apache/asterix/event/api/NodeInfo.java | 34 +
.../asterix/event/driver/EventConfig.java | 36 +
.../asterix/event/driver/EventDriver.java | 151 +
.../asterix/event/error/EventException.java | 25 +
.../asterix/event/error/OutputHandler.java | 89 +
.../asterix/event/error/VerificationUtil.java | 126 +
.../management/AsterixEventServiceClient.java | 229 ++
.../event/management/DefaultOutputHandler.java | 26 +
.../asterix/event/management/ErrorHandler.java | 19 +
.../asterix/event/management/EventExecutor.java | 131 +
.../asterix/event/management/EventTask.java | 154 +
.../event/management/EventTaskReport.java | 50 +
.../asterix/event/management/EventUtil.java | 256 ++
.../event/management/IOutputHandler.java | 22 +
.../event/management/IPatternListener.java | 24 +
.../event/management/OutputAnalysis.java | 34 +
.../asterix/event/management/Randomizer.java | 65 +
.../asterix/event/management/ValueType.java | 95 +
.../asterix/event/model/AsterixInstance.java | 215 ++
.../event/model/AsterixRuntimeState.java | 54 +
.../apache/asterix/event/model/BackupInfo.java | 68 +
.../apache/asterix/event/model/EventList.java | 34 +
.../apache/asterix/event/model/ProcessInfo.java | 54 +
.../event/service/AsterixEventService.java | 92 +
.../event/service/AsterixEventServiceUtil.java | 552 ++++
.../asterix/event/service/ILookupService.java | 41 +
.../asterix/event/service/ServiceProvider.java | 30 +
.../asterix/event/service/ZooKeeperService.java | 247 ++
.../asterix/event/util/AsterixConstants.java | 21 +
.../asterix/event/util/PatternCreator.java | 645 ++++
.../adapter/factory/CNNFeedAdapterFactory.java | 153 -
.../adapter/factory/HDFSAdapterFactory.java | 342 --
.../factory/HDFSIndexingAdapterFactory.java | 208 --
.../adapter/factory/HiveAdapterFactory.java | 123 -
.../factory/NCFileSystemAdapterFactory.java | 164 -
.../PullBasedAzureTwitterAdapterFactory.java | 169 -
.../factory/PullBasedTwitterAdapterFactory.java | 116 -
.../factory/PushBasedTwitterAdapterFactory.java | 105 -
.../adapter/factory/RSSFeedAdapterFactory.java | 111 -
.../factory/StreamBasedAdapterFactory.java | 45 -
.../dataset/adapter/AzureTweetEntity.java | 47 -
.../adapter/AzureTweetMetadataEntity.java | 91 -
.../dataset/adapter/ClientBasedFeedAdapter.java | 150 -
.../external/dataset/adapter/FeedClient.java | 170 -
.../dataset/adapter/FileSystemBasedAdapter.java | 58 -
.../external/dataset/adapter/HDFSAdapter.java | 93 -
.../dataset/adapter/HDFSIndexingAdapter.java | 75 -
.../external/dataset/adapter/HiveAdapter.java | 45 -
.../external/dataset/adapter/IFeedClient.java | 42 -
.../dataset/adapter/IFeedClientFactory.java | 36 -
.../dataset/adapter/IPullBasedFeedClient.java | 42 -
.../dataset/adapter/NCFileSystemAdapter.java | 67 -
.../dataset/adapter/PullBasedAdapter.java | 157 -
.../adapter/PullBasedAzureFeedClient.java | 186 --
.../adapter/PullBasedAzureTwitterAdapter.java | 99 -
.../adapter/PullBasedTwitterAdapter.java | 76 -
.../adapter/PullBasedTwitterFeedClient.java | 101 -
.../adapter/PushBasedTwitterAdapter.java | 66 -
.../adapter/PushBasedTwitterFeedClient.java | 118 -
.../dataset/adapter/RSSFeedAdapter.java | 94 -
.../external/dataset/adapter/RSSFeedClient.java | 157 -
.../dataset/adapter/StreamBasedAdapter.java | 60 -
.../dataflow/AbstractIndexingTupleParser.java | 92 -
.../AdmOrDelimitedControlledTupleParser.java | 238 --
.../AdmOrDelimitedIndexingTupleParser.java | 101 -
.../dataflow/FileIndexTupleTranslator.java | 85 -
.../dataflow/HDFSIndexingParserFactory.java | 141 -
.../indexing/dataflow/HDFSLookupAdapter.java | 183 --
.../dataflow/HDFSLookupAdapterFactory.java | 178 -
.../dataflow/HDFSObjectTupleParser.java | 76 -
.../dataflow/HDFSObjectTupleParserFactory.java | 65 -
.../indexing/dataflow/HiveObjectParser.java | 420 ---
.../dataflow/IAsterixHDFSRecordParser.java | 51 -
.../dataflow/IControlledTupleParser.java | 40 -
.../dataflow/IControlledTupleParserFactory.java | 19 -
.../indexing/dataflow/IndexingScheduler.java | 347 --
.../dataflow/RCFileControlledTupleParser.java | 199 --
.../dataflow/RCFileIndexingTupleParser.java | 58 -
.../dataflow/SeqOrTxtControlledTupleParser.java | 187 --
.../dataflow/TextOrSeqIndexingTupleParser.java | 43 -
.../input/AbstractHDFSLookupInputStream.java | 114 -
.../indexing/input/AbstractHDFSReader.java | 103 -
.../input/GenericFileAwareRecordReader.java | 125 -
.../indexing/input/GenericRecordReader.java | 131 -
.../indexing/input/HDFSSeekableLineReader.java | 246 --
.../external/indexing/input/ILookupReader.java | 20 -
.../indexing/input/RCFileDataReader.java | 176 -
.../indexing/input/RCFileLookupReader.java | 103 -
.../input/SequenceFileLookupInputStream.java | 73 -
.../input/SequenceFileLookupReader.java | 106 -
.../input/TextFileLookupInputStream.java | 66 -
.../indexing/input/TextFileLookupReader.java | 93 -
.../indexing/input/TextualDataReader.java | 234 --
.../input/TextualFullScanDataReader.java | 205 --
...xternalDatasetIndexesOperatorDescriptor.java | 118 -
...alDatasetIndexesAbortOperatorDescriptor.java | 55 -
...lDatasetIndexesCommitOperatorDescriptor.java | 63 -
...DatasetIndexesRecoverOperatorDescriptor.java | 55 -
...ternalIndexBulkModifyOperatorDescriptor.java | 65 -
...rnalIndexBulkModifyOperatorNodePushable.java | 104 -
.../operators/IndexInfoOperatorDescriptor.java | 122 -
.../external/library/ExternalFunction.java | 110 -
.../ExternalFunctionDescriptorProvider.java | 65 -
.../library/ExternalFunctionProvider.java | 82 -
.../ExternalScalarFunctionEvaluatorFactory.java | 40 -
.../external/library/IExternalFunction.java | 23 -
.../library/IExternalScalarFunction.java | 21 -
.../external/library/IFunctionFactory.java | 21 -
.../external/library/IFunctionHelper.java | 36 -
.../external/library/IResultCollector.java | 41 -
.../external/library/JTypeObjectFactory.java | 146 -
.../external/library/JavaFunctionHelper.java | 181 --
.../external/library/ResultCollector.java | 147 -
.../library/RuntimeExternalFunctionUtil.java | 100 -
.../ics/asterix/external/library/TypeInfo.java | 63 -
.../external/library/java/IJListAccessor.java | 26 -
.../asterix/external/library/java/IJObject.java | 33 -
.../external/library/java/IJObjectAccessor.java | 25 -
.../external/library/java/IJRecordAccessor.java | 29 -
.../asterix/external/library/java/IJType.java | 25 -
.../external/library/java/JObjectAccessors.java | 584 ----
.../library/java/JObjectPointableVisitor.java | 89 -
.../external/library/java/JObjectUtil.java | 448 ---
.../asterix/external/library/java/JObjects.java | 1182 -------
.../asterix/external/library/java/JTypeTag.java | 27 -
.../ics/asterix/external/util/DNSResolver.java | 50 -
.../external/util/DNSResolverFactory.java | 29 -
.../ics/asterix/external/util/Datatypes.java | 35 -
.../asterix/external/util/INodeResolver.java | 33 -
.../external/util/INodeResolverFactory.java | 30 -
.../external/util/IdentitiyResolverFactory.java | 31 -
.../asterix/external/util/IdentityResolver.java | 28 -
.../asterix/external/util/TweetProcessor.java | 82 -
.../ics/asterix/external/util/TwitterUtil.java | 178 -
.../adapter/factory/CNNFeedAdapterFactory.java | 153 +
.../adapter/factory/HDFSAdapterFactory.java | 342 ++
.../factory/HDFSIndexingAdapterFactory.java | 208 ++
.../adapter/factory/HiveAdapterFactory.java | 123 +
.../factory/NCFileSystemAdapterFactory.java | 164 +
.../PullBasedAzureTwitterAdapterFactory.java | 169 +
.../factory/PullBasedTwitterAdapterFactory.java | 116 +
.../factory/PushBasedTwitterAdapterFactory.java | 105 +
.../adapter/factory/RSSFeedAdapterFactory.java | 111 +
.../factory/StreamBasedAdapterFactory.java | 45 +
.../dataset/adapter/AzureTweetEntity.java | 47 +
.../adapter/AzureTweetMetadataEntity.java | 91 +
.../dataset/adapter/ClientBasedFeedAdapter.java | 150 +
.../external/dataset/adapter/FeedClient.java | 170 +
.../dataset/adapter/FileSystemBasedAdapter.java | 58 +
.../external/dataset/adapter/HDFSAdapter.java | 93 +
.../dataset/adapter/HDFSIndexingAdapter.java | 75 +
.../external/dataset/adapter/HiveAdapter.java | 45 +
.../external/dataset/adapter/IFeedClient.java | 42 +
.../dataset/adapter/IFeedClientFactory.java | 36 +
.../dataset/adapter/IPullBasedFeedClient.java | 42 +
.../dataset/adapter/NCFileSystemAdapter.java | 67 +
.../dataset/adapter/PullBasedAdapter.java | 157 +
.../adapter/PullBasedAzureFeedClient.java | 186 ++
.../adapter/PullBasedAzureTwitterAdapter.java | 99 +
.../adapter/PullBasedTwitterAdapter.java | 76 +
.../adapter/PullBasedTwitterFeedClient.java | 101 +
.../adapter/PushBasedTwitterAdapter.java | 66 +
.../adapter/PushBasedTwitterFeedClient.java | 118 +
.../dataset/adapter/RSSFeedAdapter.java | 94 +
.../external/dataset/adapter/RSSFeedClient.java | 157 +
.../dataset/adapter/StreamBasedAdapter.java | 60 +
.../dataflow/AbstractIndexingTupleParser.java | 92 +
.../AdmOrDelimitedControlledTupleParser.java | 238 ++
.../AdmOrDelimitedIndexingTupleParser.java | 101 +
.../dataflow/FileIndexTupleTranslator.java | 85 +
.../dataflow/HDFSIndexingParserFactory.java | 141 +
.../indexing/dataflow/HDFSLookupAdapter.java | 183 ++
.../dataflow/HDFSLookupAdapterFactory.java | 178 +
.../dataflow/HDFSObjectTupleParser.java | 76 +
.../dataflow/HDFSObjectTupleParserFactory.java | 65 +
.../indexing/dataflow/HiveObjectParser.java | 420 +++
.../dataflow/IAsterixHDFSRecordParser.java | 51 +
.../dataflow/IControlledTupleParser.java | 40 +
.../dataflow/IControlledTupleParserFactory.java | 19 +
.../indexing/dataflow/IndexingScheduler.java | 347 ++
.../dataflow/RCFileControlledTupleParser.java | 199 ++
.../dataflow/RCFileIndexingTupleParser.java | 58 +
.../dataflow/SeqOrTxtControlledTupleParser.java | 187 ++
.../dataflow/TextOrSeqIndexingTupleParser.java | 43 +
.../input/AbstractHDFSLookupInputStream.java | 114 +
.../indexing/input/AbstractHDFSReader.java | 103 +
.../input/GenericFileAwareRecordReader.java | 125 +
.../indexing/input/GenericRecordReader.java | 131 +
.../indexing/input/HDFSSeekableLineReader.java | 246 ++
.../external/indexing/input/ILookupReader.java | 20 +
.../indexing/input/RCFileDataReader.java | 176 +
.../indexing/input/RCFileLookupReader.java | 103 +
.../input/SequenceFileLookupInputStream.java | 73 +
.../input/SequenceFileLookupReader.java | 106 +
.../input/TextFileLookupInputStream.java | 66 +
.../indexing/input/TextFileLookupReader.java | 93 +
.../indexing/input/TextualDataReader.java | 234 ++
.../input/TextualFullScanDataReader.java | 205 ++
...xternalDatasetIndexesOperatorDescriptor.java | 118 +
...alDatasetIndexesAbortOperatorDescriptor.java | 55 +
...lDatasetIndexesCommitOperatorDescriptor.java | 63 +
...DatasetIndexesRecoverOperatorDescriptor.java | 55 +
...ternalIndexBulkModifyOperatorDescriptor.java | 65 +
...rnalIndexBulkModifyOperatorNodePushable.java | 104 +
.../operators/IndexInfoOperatorDescriptor.java | 122 +
.../external/library/ExternalFunction.java | 110 +
.../ExternalFunctionDescriptorProvider.java | 65 +
.../library/ExternalFunctionProvider.java | 82 +
.../ExternalScalarFunctionEvaluatorFactory.java | 40 +
.../external/library/IExternalFunction.java | 23 +
.../library/IExternalScalarFunction.java | 21 +
.../external/library/IFunctionFactory.java | 21 +
.../external/library/IFunctionHelper.java | 36 +
.../external/library/IResultCollector.java | 41 +
.../external/library/JTypeObjectFactory.java | 146 +
.../external/library/JavaFunctionHelper.java | 181 ++
.../external/library/ResultCollector.java | 147 +
.../library/RuntimeExternalFunctionUtil.java | 100 +
.../asterix/external/library/TypeInfo.java | 63 +
.../external/library/java/IJListAccessor.java | 26 +
.../asterix/external/library/java/IJObject.java | 33 +
.../external/library/java/IJObjectAccessor.java | 25 +
.../external/library/java/IJRecordAccessor.java | 29 +
.../asterix/external/library/java/IJType.java | 25 +
.../external/library/java/JObjectAccessors.java | 584 ++++
.../library/java/JObjectPointableVisitor.java | 89 +
.../external/library/java/JObjectUtil.java | 448 +++
.../asterix/external/library/java/JObjects.java | 1182 +++++++
.../asterix/external/library/java/JTypeTag.java | 27 +
.../asterix/external/util/DNSResolver.java | 50 +
.../external/util/DNSResolverFactory.java | 29 +
.../apache/asterix/external/util/Datatypes.java | 35 +
.../asterix/external/util/INodeResolver.java | 33 +
.../external/util/INodeResolverFactory.java | 30 +
.../external/util/IdentitiyResolverFactory.java | 31 +
.../asterix/external/util/IdentityResolver.java | 28 +
.../asterix/external/util/TweetProcessor.java | 82 +
.../asterix/external/util/TwitterUtil.java | 178 +
.../external/library/AddHashTagsFactory.java | 27 -
.../external/library/AddHashTagsFunction.java | 76 -
.../library/AddHashTagsInPlaceFactory.java | 25 -
.../library/AddHashTagsInPlaceFunction.java | 54 -
.../external/library/AllTypesFactory.java | 27 -
.../external/library/AllTypesFunction.java | 108 -
.../external/library/CapitalFinderFactory.java | 27 -
.../external/library/CapitalFinderFunction.java | 55 -
.../external/library/EchoDelayFactory.java | 25 -
.../external/library/EchoDelayFunction.java | 46 -
.../external/library/ParseTweetFactory.java | 27 -
.../external/library/ParseTweetFunction.java | 60 -
.../asterix/external/library/SumFactory.java | 25 -
.../asterix/external/library/SumFunction.java | 43 -
.../external/library/UpperCaseFactory.java | 27 -
.../external/library/UpperCaseFunction.java | 58 -
.../library/adapter/TestTypedAdapter.java | 140 -
.../adapter/TestTypedAdapterFactory.java | 106 -
.../external/library/AddHashTagsFactory.java | 27 +
.../external/library/AddHashTagsFunction.java | 76 +
.../library/AddHashTagsInPlaceFactory.java | 25 +
.../library/AddHashTagsInPlaceFunction.java | 54 +
.../external/library/AllTypesFactory.java | 27 +
.../external/library/AllTypesFunction.java | 108 +
.../external/library/CapitalFinderFactory.java | 27 +
.../external/library/CapitalFinderFunction.java | 55 +
.../external/library/EchoDelayFactory.java | 25 +
.../external/library/EchoDelayFunction.java | 46 +
.../external/library/ParseTweetFactory.java | 27 +
.../external/library/ParseTweetFunction.java | 60 +
.../asterix/external/library/SumFactory.java | 25 +
.../asterix/external/library/SumFunction.java | 43 +
.../external/library/UpperCaseFactory.java | 27 +
.../external/library/UpperCaseFunction.java | 58 +
.../library/adapter/TestTypedAdapter.java | 140 +
.../adapter/TestTypedAdapterFactory.java | 106 +
.../asterix/fuzzyjoin/FuzzyFiltersJaccard.java | 104 -
.../fuzzyjoin/FuzzyJoinAppendLength.java | 60 -
.../ics/asterix/fuzzyjoin/FuzzyJoinConfig.java | 66 -
.../ics/asterix/fuzzyjoin/FuzzyJoinContext.java | 38 -
.../ics/asterix/fuzzyjoin/FuzzyJoinMemory.java | 317 --
.../asterix/fuzzyjoin/FuzzyJoinTokenize.java | 135 -
.../ics/asterix/fuzzyjoin/FuzzyJoinUtil.java | 87 -
.../edu/uci/ics/asterix/fuzzyjoin/IntArray.java | 80 -
.../edu/uci/ics/asterix/fuzzyjoin/IntPair.java | 96 -
.../fuzzyjoin/LittleEndianIntInputStream.java | 52 -
.../fuzzyjoin/LittleEndianIntOutputStream.java | 37 -
.../ics/asterix/fuzzyjoin/MutableInteger.java | 70 -
.../asterix/fuzzyjoin/RIDPairSimilarity.java | 57 -
.../uci/ics/asterix/fuzzyjoin/ResultJoin.java | 30 -
.../ics/asterix/fuzzyjoin/ResultSelfJoin.java | 31 -
.../fuzzyjoin/invertedlist/InvertedList.java | 27 -
.../invertedlist/InvertedListLengthFixed.java | 78 -
.../invertedlist/InvertedListLengthList.java | 107 -
.../invertedlist/InvertedListPlain.java | 49 -
.../fuzzyjoin/invertedlist/InvertedLists.java | 26 -
.../invertedlist/InvertedListsLengthFixed.java | 44 -
.../invertedlist/InvertedListsLengthList.java | 49 -
.../fuzzyjoin/recordgroup/RecordGroup.java | 36 -
.../recordgroup/RecordGroupFactory.java | 44 -
.../recordgroup/RecordGroupLengthCount.java | 111 -
.../recordgroup/RecordGroupLengthIdentity.java | 47 -
.../recordgroup/RecordGroupLengthRange.java | 75 -
.../recordgroup/RecordGroupSingle.java | 45 -
.../recordgroup/RecordGroupTokenFrequency.java | 47 -
.../RecordGroupTokenFrequencyMirror.java | 53 -
.../recordgroup/RecordGroupTokenIdentity.java | 47 -
.../similarity/IGenericSimilarityMetric.java | 32 -
.../fuzzyjoin/similarity/IListIterator.java | 38 -
.../fuzzyjoin/similarity/PartialIntersect.java | 42 -
.../fuzzyjoin/similarity/SimilarityFilters.java | 45 -
.../similarity/SimilarityFiltersFactory.java | 29 -
.../similarity/SimilarityFiltersJaccard.java | 297 --
.../fuzzyjoin/similarity/SimilarityMetric.java | 185 --
.../SimilarityMetricEditDistance.java | 324 --
.../similarity/SimilarityMetricFactory.java | 29 -
.../similarity/SimilarityMetricJaccard.java | 120 -
.../AbstractUTF8StringBinaryTokenizer.java | 77 -
.../fuzzyjoin/tokenizer/AbstractUTF8Token.java | 103 -
.../tokenizer/AbstractUTF8TokenFactory.java | 36 -
.../DelimitedUTF8StringBinaryTokenizer.java | 79 -
...limitedUTF8StringBinaryTokenizerFactory.java | 40 -
.../tokenizer/HashedUTF8NGramToken.java | 62 -
.../tokenizer/HashedUTF8NGramTokenFactory.java | 38 -
.../tokenizer/HashedUTF8WordToken.java | 84 -
.../tokenizer/HashedUTF8WordTokenFactory.java | 38 -
.../fuzzyjoin/tokenizer/IBinaryTokenizer.java | 30 -
.../tokenizer/IBinaryTokenizerFactory.java | 26 -
.../fuzzyjoin/tokenizer/INGramToken.java | 28 -
.../ics/asterix/fuzzyjoin/tokenizer/IToken.java | 39 -
.../fuzzyjoin/tokenizer/ITokenFactory.java | 26 -
.../fuzzyjoin/tokenizer/NGramTokenizer.java | 90 -
.../NGramUTF8StringBinaryTokenizer.java | 116 -
.../fuzzyjoin/tokenizer/StringUtils.java | 216 --
.../ics/asterix/fuzzyjoin/tokenizer/Token.java | 118 -
.../asterix/fuzzyjoin/tokenizer/Tokenizer.java | 27 -
.../fuzzyjoin/tokenizer/TokenizerBuffered.java | 30 -
.../tokenizer/TokenizerBufferedFactory.java | 33 -
.../fuzzyjoin/tokenizer/TokenizerFactory.java | 31 -
.../fuzzyjoin/tokenizer/UTF8NGramToken.java | 83 -
.../tokenizer/UTF8NGramTokenFactory.java | 39 -
.../fuzzyjoin/tokenizer/UTF8WordToken.java | 44 -
.../tokenizer/UTF8WordTokenFactory.java | 39 -
.../fuzzyjoin/tokenizer/WordTokenizer.java | 68 -
.../tokenizer/WordTokenizerBuffered.java | 92 -
.../fuzzyjoin/tokenorder/IntTokenCountRank.java | 28 -
.../tokenorder/IntTokenCountRankFrequency.java | 58 -
.../fuzzyjoin/tokenorder/IntTokenRank.java | 28 -
.../tokenorder/IntTokenRankFrequency.java | 54 -
.../asterix/fuzzyjoin/tokenorder/TokenLoad.java | 62 -
.../asterix/fuzzyjoin/tokenorder/TokenRank.java | 31 -
.../tokenorder/TokenRankBufferedFrequency.java | 75 -
.../tokenorder/TokenRankFrequency.java | 61 -
.../asterix/fuzzyjoin/FuzzyFiltersJaccard.java | 104 +
.../fuzzyjoin/FuzzyJoinAppendLength.java | 60 +
.../asterix/fuzzyjoin/FuzzyJoinConfig.java | 66 +
.../asterix/fuzzyjoin/FuzzyJoinContext.java | 38 +
.../asterix/fuzzyjoin/FuzzyJoinMemory.java | 317 ++
.../asterix/fuzzyjoin/FuzzyJoinTokenize.java | 135 +
.../apache/asterix/fuzzyjoin/FuzzyJoinUtil.java | 87 +
.../org/apache/asterix/fuzzyjoin/IntArray.java | 80 +
.../org/apache/asterix/fuzzyjoin/IntPair.java | 96 +
.../fuzzyjoin/LittleEndianIntInputStream.java | 52 +
.../fuzzyjoin/LittleEndianIntOutputStream.java | 37 +
.../asterix/fuzzyjoin/MutableInteger.java | 70 +
.../asterix/fuzzyjoin/RIDPairSimilarity.java | 57 +
.../apache/asterix/fuzzyjoin/ResultJoin.java | 30 +
.../asterix/fuzzyjoin/ResultSelfJoin.java | 31 +
.../fuzzyjoin/invertedlist/InvertedList.java | 27 +
.../invertedlist/InvertedListLengthFixed.java | 78 +
.../invertedlist/InvertedListLengthList.java | 107 +
.../invertedlist/InvertedListPlain.java | 49 +
.../fuzzyjoin/invertedlist/InvertedLists.java | 26 +
.../invertedlist/InvertedListsLengthFixed.java | 44 +
.../invertedlist/InvertedListsLengthList.java | 49 +
.../fuzzyjoin/recordgroup/RecordGroup.java | 36 +
.../recordgroup/RecordGroupFactory.java | 44 +
.../recordgroup/RecordGroupLengthCount.java | 111 +
.../recordgroup/RecordGroupLengthIdentity.java | 47 +
.../recordgroup/RecordGroupLengthRange.java | 75 +
.../recordgroup/RecordGroupSingle.java | 45 +
.../recordgroup/RecordGroupTokenFrequency.java | 47 +
.../RecordGroupTokenFrequencyMirror.java | 53 +
.../recordgroup/RecordGroupTokenIdentity.java | 47 +
.../similarity/IGenericSimilarityMetric.java | 32 +
.../fuzzyjoin/similarity/IListIterator.java | 38 +
.../fuzzyjoin/similarity/PartialIntersect.java | 42 +
.../fuzzyjoin/similarity/SimilarityFilters.java | 45 +
.../similarity/SimilarityFiltersFactory.java | 29 +
.../similarity/SimilarityFiltersJaccard.java | 297 ++
.../fuzzyjoin/similarity/SimilarityMetric.java | 185 ++
.../SimilarityMetricEditDistance.java | 324 ++
.../similarity/SimilarityMetricFactory.java | 29 +
.../similarity/SimilarityMetricJaccard.java | 120 +
.../AbstractUTF8StringBinaryTokenizer.java | 77 +
.../fuzzyjoin/tokenizer/AbstractUTF8Token.java | 103 +
.../tokenizer/AbstractUTF8TokenFactory.java | 36 +
.../DelimitedUTF8StringBinaryTokenizer.java | 79 +
...limitedUTF8StringBinaryTokenizerFactory.java | 40 +
.../tokenizer/HashedUTF8NGramToken.java | 62 +
.../tokenizer/HashedUTF8NGramTokenFactory.java | 38 +
.../tokenizer/HashedUTF8WordToken.java | 84 +
.../tokenizer/HashedUTF8WordTokenFactory.java | 38 +
.../fuzzyjoin/tokenizer/IBinaryTokenizer.java | 30 +
.../tokenizer/IBinaryTokenizerFactory.java | 26 +
.../fuzzyjoin/tokenizer/INGramToken.java | 28 +
.../asterix/fuzzyjoin/tokenizer/IToken.java | 39 +
.../fuzzyjoin/tokenizer/ITokenFactory.java | 26 +
.../fuzzyjoin/tokenizer/NGramTokenizer.java | 90 +
.../NGramUTF8StringBinaryTokenizer.java | 116 +
.../fuzzyjoin/tokenizer/StringUtils.java | 216 ++
.../asterix/fuzzyjoin/tokenizer/Token.java | 118 +
.../asterix/fuzzyjoin/tokenizer/Tokenizer.java | 27 +
.../fuzzyjoin/tokenizer/TokenizerBuffered.java | 30 +
.../tokenizer/TokenizerBufferedFactory.java | 33 +
.../fuzzyjoin/tokenizer/TokenizerFactory.java | 31 +
.../fuzzyjoin/tokenizer/UTF8NGramToken.java | 83 +
.../tokenizer/UTF8NGramTokenFactory.java | 39 +
.../fuzzyjoin/tokenizer/UTF8WordToken.java | 44 +
.../tokenizer/UTF8WordTokenFactory.java | 39 +
.../fuzzyjoin/tokenizer/WordTokenizer.java | 68 +
.../tokenizer/WordTokenizerBuffered.java | 92 +
.../fuzzyjoin/tokenorder/IntTokenCountRank.java | 28 +
.../tokenorder/IntTokenCountRankFrequency.java | 58 +
.../fuzzyjoin/tokenorder/IntTokenRank.java | 28 +
.../tokenorder/IntTokenRankFrequency.java | 54 +
.../asterix/fuzzyjoin/tokenorder/TokenLoad.java | 62 +
.../asterix/fuzzyjoin/tokenorder/TokenRank.java | 31 +
.../tokenorder/TokenRankBufferedFrequency.java | 75 +
.../tokenorder/TokenRankFrequency.java | 61 +
.../asterix/fuzzyjoin/tests/FuzzyJoinTest.java | 65 -
.../fuzzyjoin/tests/FuzzyJoinTestUtil.java | 63 -
.../fuzzyjoin/tests/NGramTokenizerTest.java | 239 --
.../fuzzyjoin/tests/WordTokenizerTest.java | 214 --
.../tests/dataset/AbstractDataset.java | 158 -
.../dataset/AbstractTokenizableDataset.java | 20 -
.../fuzzyjoin/tests/dataset/DBLPDataset.java | 36 -
.../tests/dataset/DBLPSmallDataset.java | 26 -
.../tests/dataset/IntArrayBagSmallDataset.java | 56 -
.../tests/dataset/IntArraySetSmallDataset.java | 56 -
.../fuzzyjoin/tests/dataset/PUBDataset.java | 41 -
.../tests/dataset/PUBSmallDataset.java | 26 -
.../tests/dataset/PublicationsDataset.java | 80 -
.../dataset/UsersVisitorsSmallDataset.java | 67 -
.../asterix/fuzzyjoin/tests/FuzzyJoinTest.java | 65 +
.../fuzzyjoin/tests/FuzzyJoinTestUtil.java | 63 +
.../fuzzyjoin/tests/NGramTokenizerTest.java | 239 ++
.../fuzzyjoin/tests/WordTokenizerTest.java | 214 ++
.../tests/dataset/AbstractDataset.java | 158 +
.../dataset/AbstractTokenizableDataset.java | 20 +
.../fuzzyjoin/tests/dataset/DBLPDataset.java | 36 +
.../tests/dataset/DBLPSmallDataset.java | 26 +
.../tests/dataset/IntArrayBagSmallDataset.java | 56 +
.../tests/dataset/IntArraySetSmallDataset.java | 56 +
.../fuzzyjoin/tests/dataset/PUBDataset.java | 41 +
.../tests/dataset/PUBSmallDataset.java | 26 +
.../tests/dataset/PublicationsDataset.java | 80 +
.../dataset/UsersVisitorsSmallDataset.java | 67 +
.../installer/command/AbstractCommand.java | 42 -
.../asterix/installer/command/AlterCommand.java | 72 -
.../installer/command/BackupCommand.java | 76 -
.../installer/command/CommandConfig.java | 19 -
.../installer/command/CommandHandler.java | 84 -
.../installer/command/ConfigureCommand.java | 120 -
.../installer/command/CreateCommand.java | 114 -
.../installer/command/DeleteCommand.java | 63 -
.../installer/command/DescribeCommand.java | 91 -
.../asterix/installer/command/HelpCommand.java | 105 -
.../ics/asterix/installer/command/ICommand.java | 41 -
.../installer/command/InstallCommand.java | 72 -
.../asterix/installer/command/LogCommand.java | 105 -
.../installer/command/RestoreCommand.java | 72 -
.../installer/command/ShutdownCommand.java | 45 -
.../asterix/installer/command/StartCommand.java | 76 -
.../installer/command/StartNodeCommand.java | 101 -
.../asterix/installer/command/StopCommand.java | 96 -
.../installer/command/StopNodeCommand.java | 108 -
.../installer/command/UninstallCommand.java | 74 -
.../installer/command/ValidateCommand.java | 266 --
.../installer/command/VersionCommand.java | 48 -
.../installer/driver/InstallerDriver.java | 129 -
.../asterix/installer/driver/InstallerUtil.java | 76 -
.../installer/error/InstallerException.java | 25 -
.../asterix/installer/error/OutputHandler.java | 89 -
.../installer/command/AbstractCommand.java | 42 +
.../asterix/installer/command/AlterCommand.java | 72 +
.../installer/command/BackupCommand.java | 76 +
.../installer/command/CommandConfig.java | 19 +
.../installer/command/CommandHandler.java | 84 +
.../installer/command/ConfigureCommand.java | 120 +
.../installer/command/CreateCommand.java | 114 +
.../installer/command/DeleteCommand.java | 63 +
.../installer/command/DescribeCommand.java | 91 +
.../asterix/installer/command/HelpCommand.java | 105 +
.../asterix/installer/command/ICommand.java | 41 +
.../installer/command/InstallCommand.java | 72 +
.../asterix/installer/command/LogCommand.java | 105 +
.../installer/command/RestoreCommand.java | 72 +
.../installer/command/ShutdownCommand.java | 45 +
.../asterix/installer/command/StartCommand.java | 76 +
.../installer/command/StartNodeCommand.java | 101 +
.../asterix/installer/command/StopCommand.java | 96 +
.../installer/command/StopNodeCommand.java | 108 +
.../installer/command/UninstallCommand.java | 74 +
.../installer/command/ValidateCommand.java | 266 ++
.../installer/command/VersionCommand.java | 48 +
.../installer/driver/InstallerDriver.java | 129 +
.../asterix/installer/driver/InstallerUtil.java | 76 +
.../installer/error/InstallerException.java | 25 +
.../asterix/installer/error/OutputHandler.java | 89 +
.../test/AsterixClusterLifeCycleIT.java | 187 --
.../test/AsterixExternalLibraryIT.java | 78 -
.../test/AsterixInstallerIntegrationUtil.java | 218 --
.../installer/test/AsterixLifecycleIT.java | 144 -
.../installer/transaction/DmlRecoveryIT.java | 130 -
.../installer/transaction/RecoveryIT.java | 112 -
.../test/AsterixClusterLifeCycleIT.java | 187 ++
.../test/AsterixExternalLibraryIT.java | 78 +
.../test/AsterixInstallerIntegrationUtil.java | 218 ++
.../installer/test/AsterixLifecycleIT.java | 144 +
.../installer/transaction/DmlRecoveryIT.java | 130 +
.../installer/transaction/RecoveryIT.java | 112 +
.../asterix/lexergenerator/LexerGenerator.java | 202 --
.../lexergenerator/LexerGeneratorMojo.java | 92 -
.../ics/asterix/lexergenerator/LexerNode.java | 248 --
.../lexergenerator/NodeChainFactory.java | 43 -
.../uci/ics/asterix/lexergenerator/Token.java | 70 -
.../ics/asterix/lexergenerator/TokenAux.java | 25 -
.../rulegenerators/RuleGenerator.java | 21 -
.../RuleGeneratorAnythingUntil.java | 31 -
.../RuleGeneratorCaseInsensitiveChar.java | 34 -
.../rulegenerators/RuleGeneratorChar.java | 31 -
.../RuleGeneratorCharOrNothing.java | 33 -
.../RuleGeneratorDigitSequence.java | 29 -
.../rulegenerators/RuleGeneratorNothing.java | 29 -
.../rulegenerators/RuleGeneratorSign.java | 30 -
.../RuleGeneratorSignOrNothing.java | 32 -
.../rulegenerators/RuleGeneratorString.java | 33 -
.../rulegenerators/RuleGeneratorToken.java | 31 -
.../ics/asterix/lexergenerator/rules/Rule.java | 29 -
.../lexergenerator/rules/RuleAnythingUntil.java | 64 -
.../asterix/lexergenerator/rules/RuleChar.java | 70 -
.../lexergenerator/rules/RuleDigitSequence.java | 57 -
.../lexergenerator/rules/RuleEpsilon.java | 54 -
.../lexergenerator/rules/RulePartial.java | 71 -
.../asterix/lexergenerator/LexerGenerator.java | 202 ++
.../lexergenerator/LexerGeneratorMojo.java | 92 +
.../asterix/lexergenerator/LexerNode.java | 248 ++
.../lexergenerator/NodeChainFactory.java | 43 +
.../apache/asterix/lexergenerator/Token.java | 70 +
.../apache/asterix/lexergenerator/TokenAux.java | 25 +
.../rulegenerators/RuleGenerator.java | 21 +
.../RuleGeneratorAnythingUntil.java | 31 +
.../RuleGeneratorCaseInsensitiveChar.java | 34 +
.../rulegenerators/RuleGeneratorChar.java | 31 +
.../RuleGeneratorCharOrNothing.java | 33 +
.../RuleGeneratorDigitSequence.java | 29 +
.../rulegenerators/RuleGeneratorNothing.java | 29 +
.../rulegenerators/RuleGeneratorSign.java | 30 +
.../RuleGeneratorSignOrNothing.java | 32 +
.../rulegenerators/RuleGeneratorString.java | 33 +
.../rulegenerators/RuleGeneratorToken.java | 31 +
.../asterix/lexergenerator/rules/Rule.java | 29 +
.../lexergenerator/rules/RuleAnythingUntil.java | 64 +
.../asterix/lexergenerator/rules/RuleChar.java | 70 +
.../lexergenerator/rules/RuleDigitSequence.java | 57 +
.../lexergenerator/rules/RuleEpsilon.java | 54 +
.../lexergenerator/rules/RulePartial.java | 71 +
.../ics/asterix/lexergenerator/Fixtures.java | 114 -
.../lexergenerator/LexerNodeAddRuleTest.java | 65 -
.../lexergenerator/LexerNodeAppendNodeTest.java | 95 -
.../lexergenerator/LexerNodeAppendRuleTest.java | 61 -
.../LexerNodeAuxFunctionsTest.java | 125 -
.../lexergenerator/LexerNodeCloneTest.java | 72 -
.../lexergenerator/LexerNodeMergeNodeTest.java | 102 -
.../apache/asterix/lexergenerator/Fixtures.java | 114 +
.../lexergenerator/LexerNodeAddRuleTest.java | 65 +
.../lexergenerator/LexerNodeAppendNodeTest.java | 95 +
.../lexergenerator/LexerNodeAppendRuleTest.java | 61 +
.../LexerNodeAuxFunctionsTest.java | 125 +
.../lexergenerator/LexerNodeCloneTest.java | 72 +
.../lexergenerator/LexerNodeMergeNodeTest.java | 102 +
.../recordmanagergenerator/Generator.java | 164 -
.../RecordManagerGeneratorMojo.java | 145 -
.../recordmanagergenerator/RecordType.java | 423 ---
.../recordmanagergenerator/Generator.java | 164 +
.../RecordManagerGeneratorMojo.java | 145 +
.../recordmanagergenerator/RecordType.java | 423 +++
.../ics/asterix/metadata/GarbageCollector.java | 39 -
.../ics/asterix/metadata/IDatasetDetails.java | 49 -
.../uci/ics/asterix/metadata/MetadataCache.java | 588 ----
.../ics/asterix/metadata/MetadataException.java | 38 -
.../ics/asterix/metadata/MetadataManager.java | 948 ------
.../uci/ics/asterix/metadata/MetadataNode.java | 1596 ---------
.../metadata/MetadataTransactionContext.java | 255 --
.../metadata/api/IAsterixStateProxy.java | 29 -
.../asterix/metadata/api/IClusterManager.java | 53 -
.../asterix/metadata/api/IMetadataEntity.java | 31 -
.../api/IMetadataEntityTupleTranslator.java | 54 -
.../asterix/metadata/api/IMetadataIndex.java | 83 -
.../asterix/metadata/api/IMetadataManager.java | 653 ----
.../ics/asterix/metadata/api/IMetadataNode.java | 745 -----
.../asterix/metadata/api/IValueExtractor.java | 46 -
.../metadata/bootstrap/AsterixStateProxy.java | 55 -
.../metadata/bootstrap/MetadataBootstrap.java | 543 ----
.../metadata/bootstrap/MetadataConstants.java | 29 -
.../metadata/bootstrap/MetadataIndex.java | 281 --
.../bootstrap/MetadataPrimaryIndexes.java | 137 -
.../metadata/bootstrap/MetadataRecordTypes.java | 568 ----
.../bootstrap/MetadataSecondaryIndexes.java | 64 -
.../cluster/AbstractClusterManagementWork.java | 54 -
.../asterix/metadata/cluster/AddNodeWork.java | 49 -
.../metadata/cluster/AddNodeWorkResponse.java | 41 -
.../cluster/ClusterManagementWorkResponse.java | 47 -
.../metadata/cluster/ClusterManager.java | 169 -
.../metadata/cluster/RemoveNodeWork.java | 50 -
.../cluster/RemoveNodeWorkResponse.java | 34 -
.../metadata/dataset/hints/DatasetHints.java | 128 -
.../asterix/metadata/dataset/hints/IHint.java | 42 -
.../AqlCompiledMetadataDeclarations.java | 272 --
.../metadata/declared/AqlDataSource.java | 205 --
.../ics/asterix/metadata/declared/AqlIndex.java | 54 -
.../declared/AqlLogicalPlanAndMetadataImpl.java | 60 -
.../declared/AqlMetadataImplConfig.java | 28 -
.../metadata/declared/AqlMetadataProvider.java | 2367 --------------
.../asterix/metadata/declared/AqlSourceId.java | 42 -
.../metadata/declared/DatasetDataSource.java | 120 -
.../metadata/declared/FeedDataSource.java | 124 -
.../declared/FieldExtractingAdapter.java | 166 -
.../declared/FieldExtractingAdapterFactory.java | 82 -
.../metadata/declared/FileSplitDataSink.java | 46 -
.../metadata/declared/FileSplitSinkId.java | 37 -
.../metadata/declared/LoadableDataSource.java | 138 -
.../metadata/declared/PKGeneratingAdapter.java | 180 -
.../declared/PKGeneratingAdapterFactory.java | 82 -
.../metadata/declared/ResultSetDataSink.java | 47 -
.../metadata/declared/ResultSetSinkId.java | 35 -
.../entities/AsterixBuiltinTypeMap.java | 83 -
.../metadata/entities/CompactionPolicy.java | 78 -
.../ics/asterix/metadata/entities/Dataset.java | 144 -
.../metadata/entities/DatasourceAdapter.java | 62 -
.../ics/asterix/metadata/entities/Datatype.java | 67 -
.../asterix/metadata/entities/Dataverse.java | 59 -
.../entities/ExternalDatasetDetails.java | 156 -
.../asterix/metadata/entities/ExternalFile.java | 140 -
.../uci/ics/asterix/metadata/entities/Feed.java | 112 -
.../asterix/metadata/entities/FeedPolicy.java | 95 -
.../ics/asterix/metadata/entities/Function.java | 93 -
.../ics/asterix/metadata/entities/Index.java | 247 --
.../entities/InternalDatasetDetails.java | 258 --
.../ics/asterix/metadata/entities/Library.java | 50 -
.../uci/ics/asterix/metadata/entities/Node.java | 48 -
.../asterix/metadata/entities/NodeGroup.java | 56 -
.../asterix/metadata/entities/PrimaryFeed.java | 76 -
.../metadata/entities/SecondaryFeed.java | 60 -
.../AbstractTupleTranslator.java | 66 -
.../CompactionPolicyTupleTranslator.java | 124 -
.../DatasetTupleTranslator.java | 403 ---
.../DatasourceAdapterTupleTranslator.java | 138 -
.../DatatypeTupleTranslator.java | 383 ---
.../DataverseTupleTranslator.java | 119 -
.../ExternalFileTupleTranslator.java | 179 -
.../FeedPolicyTupleTranslator.java | 200 --
.../FeedTupleTranslator.java | 313 --
.../FunctionTupleTranslator.java | 193 --
.../IndexTupleTranslator.java | 304 --
.../LibraryTupleTranslator.java | 120 -
.../NodeGroupTupleTranslator.java | 129 -
.../NodeTupleTranslator.java | 135 -
.../external/ExternalFileIndexAccessor.java | 143 -
.../ExternalLoopkupOperatorDiscriptor.java | 126 -
.../external/FilesIndexDescription.java | 96 -
.../metadata/external/IAdapterFactory.java | 94 -
.../metadata/external/IControlledAdapter.java | 61 -
.../external/IControlledAdapterFactory.java | 30 -
.../metadata/external/IndexingConstants.java | 203 --
.../feeds/AbstractDatasourceAdapter.java | 39 -
.../feeds/AbstractFeedDatasourceAdapter.java | 34 -
.../asterix/metadata/feeds/AdapterExecutor.java | 70 -
.../metadata/feeds/AdapterIdentifier.java | 62 -
.../metadata/feeds/AdapterRuntimeManager.java | 124 -
.../metadata/feeds/BuiltinFeedPolicies.java | 188 --
.../feeds/CollectTransformFeedFrameWriter.java | 116 -
.../asterix/metadata/feeds/EndFeedMessage.java | 38 -
.../ExternalDataScanOperatorDescriptor.java | 70 -
.../metadata/feeds/FeedActivityIdFactory.java | 36 -
.../feeds/FeedCollectOperatorDescriptor.java | 166 -
.../feeds/FeedCollectOperatorNodePushable.java | 204 --
.../metadata/feeds/FeedConnectionManager.java | 105 -
.../metadata/feeds/FeedFrameTupleDecorator.java | 104 -
.../feeds/FeedIntakeOperatorDescriptor.java | 131 -
.../feeds/FeedIntakeOperatorNodePushable.java | 209 --
.../feeds/FeedLifecycleEventSubscriber.java | 62 -
.../metadata/feeds/FeedManagerElectMessage.java | 61 -
.../ics/asterix/metadata/feeds/FeedMessage.java | 43 -
.../feeds/FeedMessageOperatorDescriptor.java | 49 -
.../feeds/FeedMessageOperatorNodePushable.java | 294 --
.../feeds/FeedMetaComputeNodePushable.java | 221 --
.../metadata/feeds/FeedMetaNodePushable.java | 184 --
.../feeds/FeedMetaOperatorDescriptor.java | 128 -
.../feeds/FeedMetaStoreNodePushable.java | 212 --
.../metadata/feeds/FeedPolicyEnforcer.java | 46 -
.../metadata/feeds/FeedSubscriptionManager.java | 72 -
.../ics/asterix/metadata/feeds/FeedUtil.java | 586 ----
.../asterix/metadata/feeds/FeedWorkManager.java | 46 -
.../metadata/feeds/IAdapterExecutor.java | 36 -
.../metadata/feeds/IFeedAdapterFactory.java | 26 -
.../asterix/metadata/feeds/IFeedMessage.java | 28 -
.../metadata/feeds/IPullBasedFeedAdapter.java | 30 -
.../metadata/feeds/ITypedAdapterFactory.java | 27 -
.../asterix/metadata/feeds/MessageListener.java | 134 -
.../metadata/feeds/PrepareStallMessage.java | 66 -
.../feeds/RemoteSocketMessageListener.java | 178 -
.../metadata/feeds/SocketMessageListener.java | 158 -
.../feeds/TerminateDataFlowMessage.java | 50 -
.../asterix/metadata/feeds/XAQLFeedMessage.java | 64 -
.../AsterixExternalScalarFunctionInfo.java | 38 -
.../functions/ExternalFunctionCompilerUtil.java | 223 --
.../functions/ExternalLibraryManager.java | 54 -
.../functions/MetadataBuiltinFunctions.java | 187 --
.../ics/asterix/metadata/utils/DatasetLock.java | 102 -
.../asterix/metadata/utils/DatasetUtils.java | 281 --
.../utils/ExternalDatasetAccessManager.java | 118 -
.../utils/ExternalDatasetsRegistry.java | 134 -
.../metadata/utils/MetadataLockManager.java | 595 ----
.../DatasetNameValueExtractor.java | 44 -
.../DatatypeNameValueExtractor.java | 64 -
.../MetadataEntityValueExtractor.java | 41 -
.../NestedDatatypeNameValueExtractor.java | 60 -
.../TupleCopyValueExtractor.java | 57 -
.../asterix/metadata/GarbageCollector.java | 39 +
.../asterix/metadata/IDatasetDetails.java | 49 +
.../apache/asterix/metadata/MetadataCache.java | 588 ++++
.../asterix/metadata/MetadataException.java | 38 +
.../asterix/metadata/MetadataManager.java | 948 ++++++
.../apache/asterix/metadata/MetadataNode.java | 1596 +++++++++
.../metadata/MetadataTransactionContext.java | 255 ++
.../metadata/api/IAsterixStateProxy.java | 29 +
.../asterix/metadata/api/IClusterManager.java | 53 +
.../asterix/metadata/api/IMetadataEntity.java | 31 +
.../api/IMetadataEntityTupleTranslator.java | 54 +
.../asterix/metadata/api/IMetadataIndex.java | 83 +
.../asterix/metadata/api/IMetadataManager.java | 653 ++++
.../asterix/metadata/api/IMetadataNode.java | 745 +++++
.../asterix/metadata/api/IValueExtractor.java | 46 +
.../metadata/bootstrap/AsterixStateProxy.java | 55 +
.../metadata/bootstrap/MetadataBootstrap.java | 543 ++++
.../metadata/bootstrap/MetadataConstants.java | 29 +
.../metadata/bootstrap/MetadataIndex.java | 281 ++
.../bootstrap/MetadataPrimaryIndexes.java | 137 +
.../metadata/bootstrap/MetadataRecordTypes.java | 568 ++++
.../bootstrap/MetadataSecondaryIndexes.java | 64 +
.../cluster/AbstractClusterManagementWork.java | 54 +
.../asterix/metadata/cluster/AddNodeWork.java | 49 +
.../metadata/cluster/AddNodeWorkResponse.java | 41 +
.../cluster/ClusterManagementWorkResponse.java | 47 +
.../metadata/cluster/ClusterManager.java | 169 +
.../metadata/cluster/RemoveNodeWork.java | 50 +
.../cluster/RemoveNodeWorkResponse.java | 34 +
.../metadata/dataset/hints/DatasetHints.java | 128 +
.../asterix/metadata/dataset/hints/IHint.java | 42 +
.../AqlCompiledMetadataDeclarations.java | 272 ++
.../metadata/declared/AqlDataSource.java | 205 ++
.../asterix/metadata/declared/AqlIndex.java | 54 +
.../declared/AqlLogicalPlanAndMetadataImpl.java | 60 +
.../declared/AqlMetadataImplConfig.java | 28 +
.../metadata/declared/AqlMetadataProvider.java | 2367 ++++++++++++++
.../asterix/metadata/declared/AqlSourceId.java | 42 +
.../metadata/declared/DatasetDataSource.java | 120 +
.../metadata/declared/FeedDataSource.java | 124 +
.../declared/FieldExtractingAdapter.java | 166 +
.../declared/FieldExtractingAdapterFactory.java | 82 +
.../metadata/declared/FileSplitDataSink.java | 46 +
.../metadata/declared/FileSplitSinkId.java | 37 +
.../metadata/declared/LoadableDataSource.java | 138 +
.../metadata/declared/PKGeneratingAdapter.java | 180 +
.../declared/PKGeneratingAdapterFactory.java | 82 +
.../metadata/declared/ResultSetDataSink.java | 47 +
.../metadata/declared/ResultSetSinkId.java | 35 +
.../entities/AsterixBuiltinTypeMap.java | 83 +
.../metadata/entities/CompactionPolicy.java | 78 +
.../asterix/metadata/entities/Dataset.java | 144 +
.../metadata/entities/DatasourceAdapter.java | 62 +
.../asterix/metadata/entities/Datatype.java | 67 +
.../asterix/metadata/entities/Dataverse.java | 59 +
.../entities/ExternalDatasetDetails.java | 156 +
.../asterix/metadata/entities/ExternalFile.java | 140 +
.../apache/asterix/metadata/entities/Feed.java | 112 +
.../asterix/metadata/entities/FeedPolicy.java | 95 +
.../asterix/metadata/entities/Function.java | 93 +
.../apache/asterix/metadata/entities/Index.java | 247 ++
.../entities/InternalDatasetDetails.java | 258 ++
.../asterix/metadata/entities/Library.java | 50 +
.../apache/asterix/metadata/entities/Node.java | 48 +
.../asterix/metadata/entities/NodeGroup.java | 56 +
.../asterix/metadata/entities/PrimaryFeed.java | 76 +
.../metadata/entities/SecondaryFeed.java | 60 +
.../AbstractTupleTranslator.java | 66 +
.../CompactionPolicyTupleTranslator.java | 124 +
.../DatasetTupleTranslator.java | 403 +++
.../DatasourceAdapterTupleTranslator.java | 138 +
.../DatatypeTupleTranslator.java | 383 +++
.../DataverseTupleTranslator.java | 119 +
.../ExternalFileTupleTranslator.java | 179 +
.../FeedPolicyTupleTranslator.java | 200 ++
.../FeedTupleTranslator.java | 313 ++
.../FunctionTupleTranslator.java | 193 ++
.../IndexTupleTranslator.java | 304 ++
.../LibraryTupleTranslator.java | 120 +
.../NodeGroupTupleTranslator.java | 129 +
.../NodeTupleTranslator.java | 135 +
.../external/ExternalFileIndexAccessor.java | 143 +
.../ExternalLoopkupOperatorDiscriptor.java | 126 +
.../external/FilesIndexDescription.java | 96 +
.../metadata/external/IAdapterFactory.java | 94 +
.../metadata/external/IControlledAdapter.java | 61 +
.../external/IControlledAdapterFactory.java | 30 +
.../metadata/external/IndexingConstants.java | 203 ++
.../feeds/AbstractDatasourceAdapter.java | 39 +
.../feeds/AbstractFeedDatasourceAdapter.java | 34 +
.../asterix/metadata/feeds/AdapterExecutor.java | 70 +
.../metadata/feeds/AdapterIdentifier.java | 62 +
.../metadata/feeds/AdapterRuntimeManager.java | 124 +
.../metadata/feeds/BuiltinFeedPolicies.java | 188 ++
.../feeds/CollectTransformFeedFrameWriter.java | 116 +
.../asterix/metadata/feeds/EndFeedMessage.java | 38 +
.../ExternalDataScanOperatorDescriptor.java | 70 +
.../metadata/feeds/FeedActivityIdFactory.java | 36 +
.../feeds/FeedCollectOperatorDescriptor.java | 166 +
.../feeds/FeedCollectOperatorNodePushable.java | 204 ++
.../metadata/feeds/FeedConnectionManager.java | 105 +
.../metadata/feeds/FeedFrameTupleDecorator.java | 104 +
.../feeds/FeedIntakeOperatorDescriptor.java | 131 +
.../feeds/FeedIntakeOperatorNodePushable.java | 209 ++
.../feeds/FeedLifecycleEventSubscriber.java | 62 +
.../metadata/feeds/FeedManagerElectMessage.java | 61 +
.../asterix/metadata/feeds/FeedMessage.java | 43 +
.../feeds/FeedMessageOperatorDescriptor.java | 49 +
.../feeds/FeedMessageOperatorNodePushable.java | 294 ++
.../feeds/FeedMetaComputeNodePushable.java | 221 ++
.../metadata/feeds/FeedMetaNodePushable.java | 184 ++
.../feeds/FeedMetaOperatorDescriptor.java | 128 +
.../feeds/FeedMetaStoreNodePushable.java | 212 ++
.../metadata/feeds/FeedPolicyEnforcer.java | 46 +
.../metadata/feeds/FeedSubscriptionManager.java | 72 +
.../apache/asterix/metadata/feeds/FeedUtil.java | 586 ++++
.../asterix/metadata/feeds/FeedWorkManager.java | 46 +
.../metadata/feeds/IAdapterExecutor.java | 36 +
.../metadata/feeds/IFeedAdapterFactory.java | 26 +
.../asterix/metadata/feeds/IFeedMessage.java | 28 +
.../metadata/feeds/IPullBasedFeedAdapter.java | 30 +
.../metadata/feeds/ITypedAdapterFactory.java | 27 +
.../asterix/metadata/feeds/MessageListener.java | 134 +
.../metadata/feeds/PrepareStallMessage.java | 66 +
.../feeds/RemoteSocketMessageListener.java | 178 +
.../metadata/feeds/SocketMessageListener.java | 158 +
.../feeds/TerminateDataFlowMessage.java | 50 +
.../asterix/metadata/feeds/XAQLFeedMessage.java | 64 +
.../AsterixExternalScalarFunctionInfo.java | 38 +
.../functions/ExternalFunctionCompilerUtil.java | 223 ++
.../functions/ExternalLibraryManager.java | 54 +
.../functions/MetadataBuiltinFunctions.java | 187 ++
.../asterix/metadata/utils/DatasetLock.java | 102 +
.../asterix/metadata/utils/DatasetUtils.java | 281 ++
.../utils/ExternalDatasetAccessManager.java | 118 +
.../utils/ExternalDatasetsRegistry.java | 134 +
.../metadata/utils/MetadataLockManager.java | 595 ++++
.../DatasetNameValueExtractor.java | 44 +
.../DatatypeNameValueExtractor.java | 64 +
.../MetadataEntityValueExtractor.java | 41 +
.../NestedDatatypeNameValueExtractor.java | 60 +
.../TupleCopyValueExtractor.java | 57 +
.../asterix/builders/AbstractListBuilder.java | 124 -
.../asterix/builders/AbvsBuilderFactory.java | 28 -
.../ics/asterix/builders/IARecordBuilder.java | 72 -
.../asterix/builders/IAsterixListBuilder.java | 43 -
.../asterix/builders/ListBuilderFactory.java | 30 -
.../asterix/builders/OrderedListBuilder.java | 35 -
.../uci/ics/asterix/builders/RecordBuilder.java | 289 --
.../asterix/builders/RecordBuilderFactory.java | 26 -
.../asterix/builders/UnorderedListBuilder.java | 24 -
.../dataflow/data/common/AListElementToken.java | 70 -
.../data/common/AListElementTokenFactory.java | 28 -
.../common/AOrderedListBinaryTokenizer.java | 88 -
.../AOrderedListBinaryTokenizerFactory.java | 34 -
.../common/AUnorderedListBinaryTokenizer.java | 36 -
.../AUnorderedListBinaryTokenizerFactory.java | 34 -
.../data/common/AqlExpressionTypeComputer.java | 97 -
.../AqlMergeAggregationExpressionFactory.java | 58 -
.../data/common/AqlNullableTypeComputer.java | 51 -
.../AqlPartialAggregationTypeComputer.java | 55 -
.../common/IBinaryTokenizerFactoryProvider.java | 25 -
.../dataflow/data/common/SerializationUtil.java | 31 -
.../data/nontagged/AqlNullWriterFactory.java | 49 -
.../dataflow/data/nontagged/Coordinate.java | 21 -
.../comparators/ABinaryComparator.java | 50 -
.../ACirclePartialBinaryComparatorFactory.java | 82 -
...ADurationPartialBinaryComparatorFactory.java | 59 -
...AIntervalPartialBinaryComparatorFactory.java | 61 -
.../ALinePartialBinaryComparatorFactory.java | 88 -
.../AObjectAscBinaryComparatorFactory.java | 313 --
.../AObjectDescBinaryComparatorFactory.java | 42 -
.../APoint3DPartialBinaryComparatorFactory.java | 71 -
.../APointPartialBinaryComparatorFactory.java | 61 -
.../APolygonPartialBinaryComparatorFactory.java | 84 -
...RectanglePartialBinaryComparatorFactory.java | 61 -
.../AUUIDPartialBinaryComparatorFactory.java | 46 -
.../BooleanBinaryComparatorFactory.java | 47 -
.../ListItemBinaryComparatorFactory.java | 176 -
.../LongBinaryComparatorFactory.java | 43 -
.../comparators/RawBinaryComparatorFactory.java | 47 -
.../AMurmurHash3BinaryHashFunctionFamily.java | 104 -
.../hash/AObjectBinaryHashFunctionFactory.java | 43 -
.../hash/BooleanBinaryHashFunctionFactory.java | 42 -
.../hash/DoubleBinaryHashFunctionFactory.java | 42 -
.../hash/ListItemBinaryHashFunctionFactory.java | 95 -
.../hash/LongBinaryHashFunctionFactory.java | 42 -
...AWrappedAscNormalizedKeyComputerFactory.java | 47 -
...WrappedDescNormalizedKeyComputerFactory.java | 47 -
.../printers/ABinaryBase64Printer.java | 147 -
.../nontagged/printers/ABinaryHexPrinter.java | 55 -
.../printers/ABinaryPrinterFactory.java | 31 -
.../nontagged/printers/ABooleanPrinter.java | 36 -
.../printers/ABooleanPrinterFactory.java | 30 -
.../data/nontagged/printers/ACirclePrinter.java | 42 -
.../printers/ACirclePrinterFactory.java | 30 -
.../data/nontagged/printers/ADatePrinter.java | 53 -
.../nontagged/printers/ADatePrinterFactory.java | 30 -
.../nontagged/printers/ADateTimePrinter.java | 53 -
.../printers/ADateTimePrinterFactory.java | 30 -
.../printers/ADayTimeDurationPrinter.java | 90 -
.../ADayTimeDurationPrinterFactory.java | 30 -
.../data/nontagged/printers/ADoublePrinter.java | 36 -
.../printers/ADoublePrinterFactory.java | 30 -
.../nontagged/printers/ADurationPrinter.java | 102 -
.../printers/ADurationPrinterFactory.java | 30 -
.../data/nontagged/printers/AFloatPrinter.java | 36 -
.../printers/AFloatPrinterFactory.java | 30 -
.../data/nontagged/printers/AInt16Printer.java | 63 -
.../printers/AInt16PrinterFactory.java | 30 -
.../data/nontagged/printers/AInt32Printer.java | 62 -
.../printers/AInt32PrinterFactory.java | 30 -
.../data/nontagged/printers/AInt64Printer.java | 43 -
.../printers/AInt64PrinterFactory.java | 30 -
.../data/nontagged/printers/AInt8Printer.java | 63 -
.../nontagged/printers/AInt8PrinterFactory.java | 30 -
.../nontagged/printers/AIntervalPrinter.java | 70 -
.../printers/AIntervalPrinterFactory.java | 30 -
.../data/nontagged/printers/ALinePrinter.java | 44 -
.../nontagged/printers/ALinePrinterFactory.java | 30 -
.../data/nontagged/printers/ANullPrinter.java | 35 -
.../nontagged/printers/ANullPrinterFactory.java | 30 -
.../printers/ANullableFieldPrinterFactory.java | 62 -
.../data/nontagged/printers/AObjectPrinter.java | 173 -
.../printers/AObjectPrinterFactory.java | 30 -
.../printers/AOrderedlistPrinterFactory.java | 69 -
.../nontagged/printers/APoint3DPrinter.java | 42 -
.../printers/APoint3DPrinterFactory.java | 30 -
.../data/nontagged/printers/APointPrinter.java | 40 -
.../printers/APointPrinterFactory.java | 30 -
.../nontagged/printers/APolygonPrinter.java | 49 -
.../printers/APolygonPrinterFactory.java | 30 -
.../printers/ARecordPrinterFactory.java | 69 -
.../nontagged/printers/ARectanglePrinter.java | 44 -
.../printers/ARectanglePrinterFactory.java | 30 -
.../data/nontagged/printers/AStringPrinter.java | 41 -
.../printers/AStringPrinterFactory.java | 30 -
.../data/nontagged/printers/ATimePrinter.java | 53 -
.../nontagged/printers/ATimePrinterFactory.java | 30 -
.../data/nontagged/printers/AUUIDPrinter.java | 44 -
.../nontagged/printers/AUUIDPrinterFactory.java | 32 -
.../printers/AUnionPrinterFactory.java | 72 -
.../printers/AUnorderedlistPrinterFactory.java | 69 -
.../printers/AYearMonthDurationPrinter.java | 75 -
.../AYearMonthDurationPrinterFactory.java | 33 -
.../data/nontagged/printers/PrintTools.java | 155 -
.../printers/ShortWithoutTypeInfoPrinter.java | 43 -
.../ShortWithoutTypeInfoPrinterFactory.java | 30 -
.../nontagged/printers/csv/ABooleanPrinter.java | 36 -
.../printers/csv/ABooleanPrinterFactory.java | 30 -
.../nontagged/printers/csv/ACirclePrinter.java | 36 -
.../printers/csv/ACirclePrinterFactory.java | 30 -
.../nontagged/printers/csv/ADatePrinter.java | 36 -
.../printers/csv/ADatePrinterFactory.java | 30 -
.../printers/csv/ADateTimePrinter.java | 36 -
.../printers/csv/ADateTimePrinterFactory.java | 30 -
.../printers/csv/ADayTimeDurationPrinter.java | 39 -
.../csv/ADayTimeDurationPrinterFactory.java | 30 -
.../nontagged/printers/csv/ADoublePrinter.java | 36 -
.../printers/csv/ADoublePrinterFactory.java | 30 -
.../printers/csv/ADurationPrinter.java | 38 -
.../printers/csv/ADurationPrinterFactory.java | 30 -
.../nontagged/printers/csv/AFloatPrinter.java | 36 -
.../printers/csv/AFloatPrinterFactory.java | 30 -
.../nontagged/printers/csv/AInt16Printer.java | 36 -
.../printers/csv/AInt16PrinterFactory.java | 30 -
.../nontagged/printers/csv/AInt32Printer.java | 37 -
.../printers/csv/AInt32PrinterFactory.java | 30 -
.../nontagged/printers/csv/AInt64Printer.java | 35 -
.../printers/csv/AInt64PrinterFactory.java | 30 -
.../nontagged/printers/csv/AInt8Printer.java | 37 -
.../printers/csv/AInt8PrinterFactory.java | 30 -
.../printers/csv/AIntervalPrinter.java | 40 -
.../printers/csv/AIntervalPrinterFactory.java | 30 -
.../nontagged/printers/csv/ALinePrinter.java | 36 -
.../printers/csv/ALinePrinterFactory.java | 30 -
.../nontagged/printers/csv/ANullPrinter.java | 35 -
.../printers/csv/ANullPrinterFactory.java | 30 -
.../csv/ANullableFieldPrinterFactory.java | 63 -
.../nontagged/printers/csv/AObjectPrinter.java | 151 -
.../printers/csv/AObjectPrinterFactory.java | 30 -
.../nontagged/printers/csv/APoint3DPrinter.java | 36 -
.../printers/csv/APoint3DPrinterFactory.java | 30 -
.../nontagged/printers/csv/APointPrinter.java | 36 -
.../printers/csv/APointPrinterFactory.java | 30 -
.../nontagged/printers/csv/APolygonPrinter.java | 37 -
.../printers/csv/APolygonPrinterFactory.java | 30 -
.../printers/csv/ARecordPrinterFactory.java | 69 -
.../printers/csv/ARectanglePrinter.java | 36 -
.../printers/csv/ARectanglePrinterFactory.java | 30 -
.../nontagged/printers/csv/AStringPrinter.java | 41 -
.../printers/csv/AStringPrinterFactory.java | 30 -
.../nontagged/printers/csv/ATimePrinter.java | 38 -
.../printers/csv/ATimePrinterFactory.java | 30 -
.../printers/csv/AUnionPrinterFactory.java | 72 -
.../printers/csv/AYearMonthDurationPrinter.java | 44 -
.../csv/AYearMonthDurationPrinterFactory.java | 33 -
.../printers/json/ABooleanPrinter.java | 36 -
.../printers/json/ABooleanPrinterFactory.java | 30 -
.../nontagged/printers/json/ACirclePrinter.java | 42 -
.../printers/json/ACirclePrinterFactory.java | 30 -
.../nontagged/printers/json/ADatePrinter.java | 41 -
.../printers/json/ADatePrinterFactory.java | 30 -
.../printers/json/ADateTimePrinter.java | 40 -
.../printers/json/ADateTimePrinterFactory.java | 30 -
.../printers/json/ADayTimeDurationPrinter.java | 41 -
.../json/ADayTimeDurationPrinterFactory.java | 30 -
.../nontagged/printers/json/ADoublePrinter.java | 36 -
.../printers/json/ADoublePrinterFactory.java | 30 -
.../printers/json/ADurationPrinter.java | 45 -
.../printers/json/ADurationPrinterFactory.java | 30 -
.../nontagged/printers/json/AFloatPrinter.java | 36 -
.../printers/json/AFloatPrinterFactory.java | 30 -
.../nontagged/printers/json/AInt16Printer.java | 39 -
.../printers/json/AInt16PrinterFactory.java | 30 -
.../nontagged/printers/json/AInt32Printer.java | 40 -
.../printers/json/AInt32PrinterFactory.java | 30 -
.../nontagged/printers/json/AInt64Printer.java | 37 -
.../printers/json/AInt64PrinterFactory.java | 30 -
.../nontagged/printers/json/AInt8Printer.java | 40 -
.../printers/json/AInt8PrinterFactory.java | 30 -
.../printers/json/AIntervalPrinter.java | 67 -
.../printers/json/AIntervalPrinterFactory.java | 30 -
.../nontagged/printers/json/ALinePrinter.java | 45 -
.../printers/json/ALinePrinterFactory.java | 30 -
.../nontagged/printers/json/ANullPrinter.java | 35 -
.../printers/json/ANullPrinterFactory.java | 30 -
.../json/ANullableFieldPrinterFactory.java | 63 -
.../nontagged/printers/json/AObjectPrinter.java | 167 -
.../printers/json/AObjectPrinterFactory.java | 30 -
.../json/AOrderedlistPrinterFactory.java | 69 -
.../printers/json/APoint3DPrinter.java | 42 -
.../printers/json/APoint3DPrinterFactory.java | 30 -
.../nontagged/printers/json/APointPrinter.java | 40 -
.../printers/json/APointPrinterFactory.java | 30 -
.../printers/json/APolygonPrinter.java | 56 -
.../printers/json/APolygonPrinterFactory.java | 30 -
.../printers/json/ARecordPrinterFactory.java | 69 -
.../printers/json/ARectanglePrinter.java | 45 -
.../printers/json/ARectanglePrinterFactory.java | 30 -
.../nontagged/printers/json/AStringPrinter.java | 41 -
.../printers/json/AStringPrinterFactory.java | 30 -
.../nontagged/printers/json/ATimePrinter.java | 41 -
.../printers/json/ATimePrinterFactory.java | 30 -
.../printers/json/AUnionPrinterFactory.java | 72 -
.../json/AUnorderedlistPrinterFactory.java | 69 -
.../json/AYearMonthDurationPrinter.java | 47 -
.../json/AYearMonthDurationPrinterFactory.java | 33 -
.../serde/ABinarySerializerDeserializer.java | 55 -
.../serde/ABooleanSerializerDeserializer.java | 60 -
.../serde/ACircleSerializerDeserializer.java | 93 -
.../serde/ADateSerializerDeserializer.java | 82 -
.../serde/ADateTimeSerializerDeserializer.java | 95 -
.../ADayTimeDurationSerializerDeserializer.java | 72 -
.../serde/ADoubleSerializerDeserializer.java | 60 -
.../serde/ADurationSerializerDeserializer.java | 100 -
.../serde/AFloatSerializerDeserializer.java | 54 -
.../serde/AInt16SerializerDeserializer.java | 57 -
.../serde/AInt32SerializerDeserializer.java | 49 -
.../serde/AInt64SerializerDeserializer.java | 60 -
.../serde/AInt8SerializerDeserializer.java | 53 -
.../serde/AIntervalSerializerDeserializer.java | 263 --
.../serde/ALineSerializerDeserializer.java | 106 -
.../serde/ANullSerializerDeserializer.java | 42 -
.../serde/AObjectSerializerDeserializer.java | 264 --
.../AOrderedListSerializerDeserializer.java | 172 -
.../serde/APoint3DSerializerDeserializer.java | 101 -
.../serde/APointSerializerDeserializer.java | 93 -
.../serde/APolygonSerializerDeserializer.java | 94 -
.../serde/ARecordSerializerDeserializer.java | 341 --
.../serde/ARectangleSerializerDeserializer.java | 117 -
.../serde/AStringSerializerDeserializer.java | 52 -
.../serde/ATimeSerializerDeserializer.java | 81 -
.../serde/ATypeSerializerDeserializer.java | 43 -
.../serde/AUUIDSerializerDeserializer.java | 51 -
.../AUUIDStringSerializerDeserializer.java | 56 -
.../AUnorderedListSerializerDeserializer.java | 160 -
...YearMonthDurationSerializerDeserializer.java | 73 -
.../serde/SerializerDeserializerUtil.java | 76 -
.../AqlPrimitiveValueProviderFactory.java | 66 -
.../ics/asterix/formats/base/IDataFormat.java | 93 -
.../AqlBinaryBooleanInspectorImpl.java | 50 -
.../AqlBinaryComparatorFactoryProvider.java | 222 --
.../AqlBinaryHashFunctionFactoryProvider.java | 62 -
.../AqlBinaryHashFunctionFamilyProvider.java | 44 -
.../nontagged/AqlBinaryIntegerInspector.java | 41 -
.../AqlBinaryTokenizerFactoryProvider.java | 89 -
.../nontagged/AqlCSVPrinterFactoryProvider.java | 145 -
.../AqlJSONPrinterFactoryProvider.java | 150 -
.../AqlLinearizeComparatorFactoryProvider.java | 99 -
...AqlNormalizedKeyComputerFactoryProvider.java | 99 -
.../AqlPredicateEvaluatorFactoryProvider.java | 78 -
.../nontagged/AqlPrinterFactoryProvider.java | 151 -
.../AqlSerializerDeserializerProvider.java | 215 --
.../formats/nontagged/AqlTypeTraitProvider.java | 101 -
.../NGramUTF8StringBinaryTokenizerFactory.java | 47 -
.../nontagged/UTF8StringLowercasePointable.java | 102 -
.../edu/uci/ics/asterix/om/base/ABinary.java | 137 -
.../edu/uci/ics/asterix/om/base/ABitArray.java | 149 -
.../edu/uci/ics/asterix/om/base/ABoolean.java | 86 -
.../edu/uci/ics/asterix/om/base/ACircle.java | 91 -
.../ics/asterix/om/base/ACollectionCursor.java | 70 -
.../java/edu/uci/ics/asterix/om/base/ADate.java | 102 -
.../edu/uci/ics/asterix/om/base/ADateTime.java | 133 -
.../ics/asterix/om/base/ADayTimeDuration.java | 94 -
.../edu/uci/ics/asterix/om/base/ADouble.java | 84 -
.../edu/uci/ics/asterix/om/base/ADuration.java | 126 -
.../edu/uci/ics/asterix/om/base/AFloat.java | 84 -
.../edu/uci/ics/asterix/om/base/AInt16.java | 74 -
.../edu/uci/ics/asterix/om/base/AInt32.java | 99 -
.../edu/uci/ics/asterix/om/base/AInt64.java | 73 -
.../java/edu/uci/ics/asterix/om/base/AInt8.java | 73 -
.../edu/uci/ics/asterix/om/base/AInterval.java | 159 -
.../java/edu/uci/ics/asterix/om/base/ALine.java | 84 -
.../uci/ics/asterix/om/base/AMutableBinary.java | 30 -
.../uci/ics/asterix/om/base/AMutableCircle.java | 28 -
.../uci/ics/asterix/om/base/AMutableDate.java | 27 -
.../ics/asterix/om/base/AMutableDateTime.java | 27 -
.../om/base/AMutableDayTimeDuration.java | 27 -
.../uci/ics/asterix/om/base/AMutableDouble.java | 27 -
.../ics/asterix/om/base/AMutableDuration.java | 28 -
.../uci/ics/asterix/om/base/AMutableFloat.java | 27 -
.../uci/ics/asterix/om/base/AMutableInt16.java | 27 -
.../uci/ics/asterix/om/base/AMutableInt32.java | 27 -
.../uci/ics/asterix/om/base/AMutableInt64.java | 27 -
.../uci/ics/asterix/om/base/AMutableInt8.java | 27 -
.../ics/asterix/om/base/AMutableInterval.java | 34 -
.../uci/ics/asterix/om/base/AMutableLine.java | 28 -
.../asterix/om/base/AMutableOrderedList.java | 39 -
.../uci/ics/asterix/om/base/AMutablePoint.java | 28 -
.../ics/asterix/om/base/AMutablePoint3D.java | 29 -
.../ics/asterix/om/base/AMutablePolygon.java | 27 -
.../uci/ics/asterix/om/base/AMutableRecord.java | 29 -
.../ics/asterix/om/base/AMutableRectangle.java | 28 -
.../uci/ics/asterix/om/base/AMutableString.java | 26 -
.../uci/ics/asterix/om/base/AMutableTime.java | 27 -
.../uci/ics/asterix/om/base/AMutableUUID.java | 60 -
.../asterix/om/base/AMutableUnorderedList.java | 38 -
.../om/base/AMutableYearMonthDuration.java | 27 -
.../java/edu/uci/ics/asterix/om/base/ANull.java | 67 -
.../uci/ics/asterix/om/base/AOrderedList.java | 137 -
.../edu/uci/ics/asterix/om/base/APoint.java | 84 -
.../edu/uci/ics/asterix/om/base/APoint3D.java | 91 -
.../edu/uci/ics/asterix/om/base/APolygon.java | 105 -
.../edu/uci/ics/asterix/om/base/ARecord.java | 109 -
.../edu/uci/ics/asterix/om/base/ARectangle.java | 84 -
.../edu/uci/ics/asterix/om/base/AString.java | 82 -
.../java/edu/uci/ics/asterix/om/base/ATime.java | 118 -
.../java/edu/uci/ics/asterix/om/base/AUUID.java | 170 -
.../uci/ics/asterix/om/base/AUnorderedList.java | 127 -
.../ics/asterix/om/base/AYearMonthDuration.java | 102 -
.../uci/ics/asterix/om/base/IACollection.java | 22 -
.../edu/uci/ics/asterix/om/base/IACursor.java | 33 -
.../edu/uci/ics/asterix/om/base/IAObject.java | 33 -
.../edu/uci/ics/asterix/om/base/InMemUtils.java | 61 -
.../asterix/om/base/ShortWithoutTypeInfo.java | 97 -
.../om/base/temporal/ADateParserFactory.java | 340 --
.../base/temporal/ADateTimeParserFactory.java | 70 -
.../base/temporal/ADurationParserFactory.java | 277 --
.../om/base/temporal/ATimeParserFactory.java | 513 ---
.../AsterixTemporalTypeParseException.java | 35 -
.../om/base/temporal/DateTimeFormatUtils.java | 971 ------
.../temporal/DurationArithmeticOperations.java | 90 -
.../base/temporal/GregorianCalendarSystem.java | 729 -----
.../om/base/temporal/ICalendarSystem.java | 61 -
.../om/constants/AsterixConstantValue.java | 71 -
.../functions/AbstractFunctionDescriptor.java | 66 -
.../om/functions/AsterixBuiltinFunctions.java | 1398 --------
.../functions/AsterixExternalFunctionInfo.java | 89 -
.../asterix/om/functions/AsterixFunction.java | 58 -
.../om/functions/AsterixFunctionIdentifier.java | 44 -
.../om/functions/AsterixFunctionInfo.java | 75 -
.../om/functions/FunctionInfoRepository.java | 44 -
.../om/functions/FunctionManagerHolder.java | 27 -
.../om/functions/IExternalFunctionInfo.java | 39 -
.../om/functions/IFunctionDescriptor.java | 47 -
.../functions/IFunctionDescriptorFactory.java | 26 -
.../asterix/om/functions/IFunctionManager.java | 27 -
.../ics/asterix/om/io/AsterixIOException.java | 26 -
.../edu/uci/ics/asterix/om/io/IALocation.java | 19 -
.../edu/uci/ics/asterix/om/io/IAOMReader.java | 29 -
.../asterix/om/io/IAOMReaderWriterFactory.java | 21 -
.../edu/uci/ics/asterix/om/io/IAOMWriter.java | 30 -
.../om/pointables/AFlatValuePointable.java | 81 -
.../om/pointables/AListVisitablePointable.java | 181 --
.../pointables/ARecordVisitablePointable.java | 285 --
.../pointables/AbstractVisitablePointable.java | 58 -
.../om/pointables/PointableAllocator.java | 128 -
.../pointables/base/DefaultOpenFieldType.java | 66 -
.../om/pointables/base/IVisitablePointable.java | 29 -
.../om/pointables/cast/ACastVisitor.java | 140 -
.../asterix/om/pointables/cast/AListCaster.java | 106 -
.../om/pointables/cast/ARecordCaster.java | 367 ---
.../pointables/nonvisitor/AListPointable.java | 195 --
.../pointables/nonvisitor/ARecordPointable.java | 336 --
.../om/pointables/printer/AListPrinter.java | 85 -
.../om/pointables/printer/APrintVisitor.java | 215 --
.../om/pointables/printer/ARecordPrinter.java | 88 -
.../pointables/printer/csv/APrintVisitor.java | 202 --
.../pointables/printer/csv/ARecordPrinter.java | 77 -
.../pointables/printer/json/AListPrinter.java | 82 -
.../pointables/printer/json/APrintVisitor.java | 210 --
.../pointables/printer/json/ARecordPrinter.java | 88 -
.../visitor/IVisitablePointableVisitor.java | 35 -
.../typecomputer/base/IResultTypeComputer.java | 28 -
.../base/TypeComputerUtilities.java | 120 -
.../typecomputer/impl/ABinaryTypeComputer.java | 37 -
.../typecomputer/impl/ABooleanTypeComputer.java | 38 -
.../typecomputer/impl/ACircleTypeComputer.java | 38 -
.../impl/ADateTimeTypeComputer.java | 38 -
.../om/typecomputer/impl/ADateTypeComputer.java | 38 -
.../typecomputer/impl/ADoubleTypeComputer.java | 38 -
.../typecomputer/impl/AFloatTypeComputer.java | 37 -
.../typecomputer/impl/AInt32TypeComputer.java | 38 -
.../typecomputer/impl/AInt64TypeComputer.java | 38 -
.../impl/AIntervalTypeComputer.java | 41 -
.../om/typecomputer/impl/ALineTypeComputer.java | 38 -
.../om/typecomputer/impl/ANullTypeComputer.java | 38 -
.../typecomputer/impl/APoint3DTypeComputer.java | 38 -
.../typecomputer/impl/APointTypeComputer.java | 38 -
.../typecomputer/impl/APolygonTypeComputer.java | 38 -
.../impl/ARectangleTypeComputer.java | 38 -
.../typecomputer/impl/AStringTypeComputer.java | 38 -
.../om/typecomputer/impl/ATimeTypeComputer.java | 38 -
.../om/typecomputer/impl/AUUIDTypeComputer.java | 41 -
.../impl/AbstractBinaryStringTypeComputer.java | 55 -
.../impl/AbstractQuadStringTypeComputer.java | 62 -
.../impl/AbstractTripleStringTypeComputer.java | 58 -
.../om/typecomputer/impl/AnyTypeComputer.java | 38 -
...BinaryBooleanOrNullFunctionTypeComputer.java | 57 -
.../BinaryStringBoolOrNullTypeComputer.java | 38 -
.../BinaryStringStringOrNullTypeComputer.java | 40 -
.../impl/CastListResultTypeComputer.java | 42 -
.../impl/CastRecordResultTypeComputer.java | 36 -
.../impl/ClosedRecordConstructorResultType.java | 79 -
.../impl/CollectionToSequenceTypeComputer.java | 65 -
.../impl/ConcatNonNullTypeComputer.java | 58 -
.../impl/FieldAccessByIndexResultType.java | 74 -
.../impl/FieldAccessNestedResultType.java | 91 -
.../impl/FlowRecordResultTypeComputer.java | 41 -
.../om/typecomputer/impl/GetItemResultType.java | 50 -
.../GetOverlappingInvervalTypeComputer.java | 39 -
.../impl/InjectFailureTypeComputer.java | 53 -
.../NonTaggedCollectionMemberResultType.java | 51 -
.../NonTaggedFieldAccessByNameResultType.java | 100 -
.../impl/NonTaggedGetItemResultType.java | 53 -
.../impl/NonTaggedLocalAvgTypeComputer.java | 44 -
.../impl/NonTaggedMinMaxAggTypeComputer.java | 102 -
...onTaggedNumericAddSubMulDivTypeComputer.java | 339 --
.../impl/NonTaggedNumericAggTypeComputer.java | 84 -
...ggedNumericRoundHalfToEven2TypeComputer.java | 111 -
...nTaggedNumericUnaryFunctionTypeComputer.java | 88 -
.../impl/NonTaggedSwitchCaseComputer.java | 63 -
.../impl/NonTaggedUnaryMinusTypeComputer.java | 44 -
.../typecomputer/impl/NotNullTypeComputer.java | 72 -
.../impl/NumericAddSubMulTypeDescriptor.java | 79 -
.../impl/OpenRecordConstructorResultType.java | 83 -
.../impl/OptionalABinaryTypeComputer.java | 44 -
.../impl/OptionalABooleanTypeComputer.java | 44 -
.../impl/OptionalACircleTypeComputer.java | 44 -
.../impl/OptionalADateTimeTypeComputer.java | 44 -
.../impl/OptionalADateTypeComputer.java | 44 -
.../OptionalADayTimeDurationTypeComputer.java | 48 -
.../impl/OptionalADoubleTypeComputer.java | 43 -
.../impl/OptionalADurationTypeComputer.java | 44 -
.../impl/OptionalAFloatTypeComputer.java | 44 -
.../impl/OptionalAInt16TypeComputer.java | 44 -
.../impl/OptionalAInt32TypeComputer.java | 44 -
.../impl/OptionalAInt64TypeComputer.java | 44 -
.../impl/OptionalAInt8TypeComputer.java | 44 -
.../impl/OptionalAIntervalTypeComputer.java | 44 -
.../impl/OptionalALineTypeComputer.java | 44 -
.../impl/OptionalAPoint3DTypeComputer.java | 44 -
.../impl/OptionalAPointTypeComputer.java | 44 -
.../impl/OptionalAPolygonTypeComputer.java | 44 -
.../impl/OptionalARectangleTypeComputer.java | 44 -
.../impl/OptionalAStringTypeComputer.java | 44 -
.../OptionalATemporalInstanceTypeComputer.java | 50 -
.../impl/OptionalATimeTypeComputer.java | 44 -
.../OptionalAYearMonthDurationTypeComputer.java | 48 -
.../impl/OrderedListConstructorResultType.java | 65 -
.../impl/OrderedListOfAInt32TypeComputer.java | 38 -
.../impl/OrderedListOfAInt64TypeComputer.java | 38 -
.../OrderedListOfAIntervalTypeComputer.java | 39 -
.../impl/OrderedListOfAPointTypeComputer.java | 38 -
.../impl/OrderedListOfAStringTypeComputer.java | 38 -
.../impl/OrderedListOfAnyTypeComputer.java | 38 -
.../QuadStringStringOrNullTypeComputer.java | 40 -
.../impl/RecordConstructorResultType.java | 84 -
.../impl/RecordMergeTypeComputer.java | 168 -
.../ScalarVersionOfAggregateResultType.java | 57 -
.../impl/SubsetCollectionTypeComputer.java | 71 -
.../impl/Substring2TypeComputer.java | 70 -
.../impl/SubstringTypeComputer.java | 85 -
.../TripleStringBoolOrNullTypeComputer.java | 39 -
.../TripleStringStringOrNullTypeComputer.java | 38 -
.../impl/TypeCompatibilityChecker.java | 76 -
.../UnaryBinaryInt64OrNullTypeComputer.java | 63 -
.../UnaryBooleanOrNullFunctionTypeComputer.java | 56 -
.../UnaryStringInt64OrNullTypeComputer.java | 74 -
.../impl/UnaryStringOrNullTypeComputer.java | 65 -
.../UnorderedListConstructorResultType.java | 65 -
.../ics/asterix/om/types/AOrderedListType.java | 80 -
.../uci/ics/asterix/om/types/ARecordType.java | 625 ----
.../edu/uci/ics/asterix/om/types/ATypeTag.java | 103 -
.../uci/ics/asterix/om/types/AUnionType.java | 161 -
.../asterix/om/types/AUnorderedListType.java | 80 -
.../om/types/AbstractCollectionType.java | 65 -
.../asterix/om/types/AbstractComplexType.java | 44 -
.../uci/ics/asterix/om/types/BuiltinType.java | 904 ------
.../ics/asterix/om/types/EnumDeserializer.java | 36 -
.../edu/uci/ics/asterix/om/types/IAType.java | 29 -
.../ics/asterix/om/types/IEnumSerializer.java | 23 -
.../uci/ics/asterix/om/types/TypeHelper.java | 83 -
.../uci/ics/asterix/om/types/TypeHierarchy.java | 40 -
.../uci/ics/asterix/om/types/TypeSignature.java | 56 -
.../uci/ics/asterix/om/types/TypeTagUtil.java | 83 -
.../om/types/hierachy/ATypeHierarchy.java | 804 -----
.../AbstractIntegerTypeConvertComputer.java | 141 -
.../DoubleToFloatTypeConvertComputer.java | 44 -
.../DoubleToInt16TypeConvertComputer.java | 46 -
.../DoubleToInt32TypeConvertComputer.java | 46 -
.../DoubleToInt64TypeConvertComputer.java | 46 -
.../DoubleToInt8TypeConvertComputer.java | 46 -
.../FloatToDoubleTypeConvertComputer.java | 39 -
.../FloatToInt16TypeConvertComputer.java | 46 -
.../FloatToInt32TypeConvertComputer.java | 46 -
.../FloatToInt64TypeConvertComputer.java | 46 -
.../FloatToInt8TypeConvertComputer.java | 46 -
.../om/types/hierachy/ITypeConvertComputer.java | 25 -
.../IntegerToDoubleTypeConvertComputer.java | 71 -
.../IntegerToFloatTypeConvertComputer.java | 71 -
.../IntegerToInt16TypeConvertComputer.java | 35 -
.../IntegerToInt32TypeConvertComputer.java | 34 -
.../IntegerToInt64TypeConvertComputer.java | 34 -
.../IntegerToInt8TypeConvertComputer.java | 35 -
.../asterix/om/util/AsterixAppContextInfo.java | 126 -
.../om/util/AsterixClusterProperties.java | 182 --
.../ics/asterix/om/util/AsterixRuntimeUtil.java | 52 -
.../om/util/JSONDeserializerForTypes.java | 91 -
.../asterix/om/util/NonTaggedFormatUtil.java | 235 --
.../util/ResettableByteArrayOutputStream.java | 28 -
.../om/util/container/IObjectFactory.java | 30 -
.../asterix/om/util/container/IObjectPool.java | 36 -
.../om/util/container/ListObjectPool.java | 81 -
.../uci/ics/asterix/om/visitors/IOMVisitor.java | 110 -
.../om/visitors/OMPrintToStringVisitor.java | 296 --
.../asterix/builders/AbstractListBuilder.java | 124 +
.../asterix/builders/AbvsBuilderFactory.java | 28 +
.../asterix/builders/IARecordBuilder.java | 72 +
.../asterix/builders/IAsterixListBuilder.java | 43 +
.../asterix/builders/ListBuilderFactory.java | 30 +
.../asterix/builders/OrderedListBuilder.java | 35 +
.../apache/asterix/builders/RecordBuilder.java | 289 ++
.../asterix/builders/RecordBuilderFactory.java | 26 +
.../asterix/builders/UnorderedListBuilder.java | 24 +
.../dataflow/data/common/AListElementToken.java | 70 +
.../data/common/AListElementTokenFactory.java | 28 +
.../common/AOrderedListBinaryTokenizer.java | 88 +
.../AOrderedListBinaryTokenizerFactory.java | 34 +
.../common/AUnorderedListBinaryTokenizer.java | 36 +
.../AUnorderedListBinaryTokenizerFactory.java | 34 +
.../data/common/AqlExpressionTypeComputer.java | 97 +
.../AqlMergeAggregationExpressionFactory.java | 58 +
.../data/common/AqlNullableTypeComputer.java | 51 +
.../AqlPartialAggregationTypeComputer.java | 55 +
.../common/IBinaryTokenizerFactoryProvider.java | 25 +
.../dataflow/data/common/SerializationUtil.java | 31 +
.../data/nontagged/AqlNullWriterFactory.java | 49 +
.../dataflow/data/nontagged/Coordinate.java | 21 +
.../comparators/ABinaryComparator.java | 50 +
.../ACirclePartialBinaryComparatorFactory.java | 82 +
...ADurationPartialBinaryComparatorFactory.java | 59 +
...AIntervalPartialBinaryComparatorFactory.java | 61 +
.../ALinePartialBinaryComparatorFactory.java | 88 +
.../AObjectAscBinaryComparatorFactory.java | 313 ++
.../AObjectDescBinaryComparatorFactory.java | 42 +
.../APoint3DPartialBinaryComparatorFactory.java | 71 +
.../APointPartialBinaryComparatorFactory.java | 61 +
.../APolygonPartialBinaryComparatorFactory.java | 84 +
...RectanglePartialBinaryComparatorFactory.java | 61 +
.../AUUIDPartialBinaryComparatorFactory.java | 46 +
.../BooleanBinaryComparatorFactory.java | 47 +
.../ListItemBinaryComparatorFactory.java | 176 +
.../LongBinaryComparatorFactory.java | 43 +
.../comparators/RawBinaryComparatorFactory.java | 47 +
.../AMurmurHash3BinaryHashFunctionFamily.java | 104 +
.../hash/AObjectBinaryHashFunctionFactory.java | 43 +
.../hash/BooleanBinaryHashFunctionFactory.java | 42 +
.../hash/DoubleBinaryHashFunctionFactory.java | 42 +
.../hash/ListItemBinaryHashFunctionFactory.java | 95 +
.../hash/LongBinaryHashFunctionFactory.java | 42 +
...AWrappedAscNormalizedKeyComputerFactory.java | 47 +
...WrappedDescNormalizedKeyComputerFactory.java | 47 +
.../printers/ABinaryBase64Printer.java | 147 +
.../nontagged/printers/ABinaryHexPrinter.java | 55 +
.../printers/ABinaryPrinterFactory.java | 31 +
.../nontagged/printers/ABooleanPrinter.java | 36 +
.../printers/ABooleanPrinterFactory.java | 30 +
.../data/nontagged/printers/ACirclePrinter.java | 42 +
.../printers/ACirclePrinterFactory.java | 30 +
.../data/nontagged/printers/ADatePrinter.java | 53 +
.../nontagged/printers/ADatePrinterFactory.java | 30 +
.../nontagged/printers/ADateTimePrinter.java | 53 +
.../printers/ADateTimePrinterFactory.java | 30 +
.../printers/ADayTimeDurationPrinter.java | 90 +
.../ADayTimeDurationPrinterFactory.java | 30 +
.../data/nontagged/printers/ADoublePrinter.java | 36 +
.../printers/ADoublePrinterFactory.java | 30 +
.../nontagged/printers/ADurationPrinter.java | 102 +
.../printers/ADurationPrinterFactory.java | 30 +
.../data/nontagged/printers/AFloatPrinter.java | 36 +
.../printers/AFloatPrinterFactory.java | 30 +
.../data/nontagged/printers/AInt16Printer.java | 63 +
.../printers/AInt16PrinterFactory.java | 30 +
.../data/nontagged/printers/AInt32Printer.java | 62 +
.../printers/AInt32PrinterFactory.java | 30 +
.../data/nontagged/printers/AInt64Printer.java | 43 +
.../printers/AInt64PrinterFactory.java | 30 +
.../data/nontagged/printers/AInt8Printer.java | 63 +
.../nontagged/printers/AInt8PrinterFactory.java | 30 +
.../nontagged/printers/AIntervalPrinter.java | 70 +
.../printers/AIntervalPrinterFactory.java | 30 +
.../data/nontagged/printers/ALinePrinter.java | 44 +
.../nontagged/printers/ALinePrinterFactory.java | 30 +
.../data/nontagged/printers/ANullPrinter.java | 35 +
.../nontagged/printers/ANullPrinterFactory.java | 30 +
.../printers/ANullableFieldPrinterFactory.java | 62 +
.../data/nontagged/printers/AObjectPrinter.java | 173 +
.../printers/AObjectPrinterFactory.java | 30 +
.../printers/AOrderedlistPrinterFactory.java | 69 +
.../nontagged/printers/APoint3DPrinter.java | 42 +
.../printers/APoint3DPrinterFactory.java | 30 +
.../data/nontagged/printers/APointPrinter.java | 40 +
.../printers/APointPrinterFactory.java | 30 +
.../nontagged/printers/APolygonPrinter.java | 49 +
.../printers/APolygonPrinterFactory.java | 30 +
.../printers/ARecordPrinterFactory.java | 69 +
.../nontagged/printers/ARectanglePrinter.java | 44 +
.../printers/ARectanglePrinterFactory.java | 30 +
.../data/nontagged/printers/AStringPrinter.java | 41 +
.../printers/AStringPrinterFactory.java | 30 +
.../data/nontagged/printers/ATimePrinter.java | 53 +
.../nontagged/printers/ATimePrinterFactory.java | 30 +
.../data/nontagged/printers/AUUIDPrinter.java | 44 +
.../nontagged/printers/AUUIDPrinterFactory.java | 32 +
.../printers/AUnionPrinterFactory.java | 72 +
.../printers/AUnorderedlistPrinterFactory.java | 69 +
.../printers/AYearMonthDurationPrinter.java | 75 +
.../AYearMonthDurationPrinterFactory.java | 33 +
.../data/nontagged/printers/PrintTools.java | 155 +
.../printers/ShortWithoutTypeInfoPrinter.java | 43 +
.../ShortWithoutTypeInfoPrinterFactory.java | 30 +
.../nontagged/printers/csv/ABooleanPrinter.java | 36 +
.../printers/csv/ABooleanPrinterFactory.java | 30 +
.../nontagged/printers/csv/ACirclePrinter.java | 36 +
.../printers/csv/ACirclePrinterFactory.java | 30 +
.../nontagged/printers/csv/ADatePrinter.java | 36 +
.../printers/csv/ADatePrinterFactory.java | 30 +
.../printers/csv/ADateTimePrinter.java | 36 +
.../printers/csv/ADateTimePrinterFactory.java | 30 +
.../printers/csv/ADayTimeDurationPrinter.java | 39 +
.../csv/ADayTimeDurationPrinterFactory.java | 30 +
.../nontagged/printers/csv/ADoublePrinter.java | 36 +
.../printers/csv/ADoublePrinterFactory.java | 30 +
.../printers/csv/ADurationPrinter.java | 38 +
.../printers/csv/ADurationPrinterFactory.java | 30 +
.../nontagged/printers/csv/AFloatPrinter.java | 36 +
.../printers/csv/AFloatPrinterFactory.java | 30 +
.../nontagged/printers/csv/AInt16Printer.java | 36 +
.../printers/csv/AInt16PrinterFactory.java | 30 +
.../nontagged/printers/csv/AInt32Printer.java | 37 +
.../printers/csv/AInt32PrinterFactory.java | 30 +
.../nontagged/printers/csv/AInt64Printer.java | 35 +
.../printers/csv/AInt64PrinterFactory.java | 30 +
.../nontagged/printers/csv/AInt8Printer.java | 37 +
.../printers/csv/AInt8PrinterFactory.java | 30 +
.../printers/csv/AIntervalPrinter.java | 40 +
.../printers/csv/AIntervalPrinterFactory.java | 30 +
.../nontagged/printers/csv/ALinePrinter.java | 36 +
.../printers/csv/ALinePrinterFactory.java | 30 +
.../nontagged/printers/csv/ANullPrinter.java | 35 +
.../printers/csv/ANullPrinterFactory.java | 30 +
.../csv/ANullableFieldPrinterFactory.java | 63 +
.../nontagged/printers/csv/AObjectPrinter.java | 151 +
.../printers/csv/AObjectPrinterFactory.java | 30 +
.../nontagged/printers/csv/APoint3DPrinter.java | 36 +
.../printers/csv/APoint3DPrinterFactory.java | 30 +
.../nontagged/printers/csv/APointPrinter.java | 36 +
.../printers/csv/APointPrinterFactory.java | 30 +
.../nontagged/printers/csv/APolygonPrinter.java | 37 +
.../printers/csv/APolygonPrinterFactory.java | 30 +
.../printers/csv/ARecordPrinterFactory.java | 69 +
.../printers/csv/ARectanglePrinter.java | 36 +
.../printers/csv/ARectanglePrinterFactory.java | 30 +
.../nontagged/printers/csv/AStringPrinter.java | 41 +
.../printers/csv/AStringPrinterFactory.java | 30 +
.../nontagged/printers/csv/ATimePrinter.java | 38 +
.../printers/csv/ATimePrinterFactory.java | 30 +
.../printers/csv/AUnionPrinterFactory.java | 72 +
.../printers/csv/AYearMonthDurationPrinter.java | 44 +
.../csv/AYearMonthDurationPrinterFactory.java | 33 +
.../printers/json/ABooleanPrinter.java | 36 +
.../printers/json/ABooleanPrinterFactory.java | 30 +
.../nontagged/printers/json/ACirclePrinter.java | 42 +
.../printers/json/ACirclePrinterFactory.java | 30 +
.../nontagged/printers/json/ADatePrinter.java | 41 +
.../printers/json/ADatePrinterFactory.java | 30 +
.../printers/json/ADateTimePrinter.java | 40 +
.../printers/json/ADateTimePrinterFactory.java | 30 +
.../printers/json/ADayTimeDurationPrinter.java | 41 +
.../json/ADayTimeDurationPrinterFactory.java | 30 +
.../nontagged/printers/json/ADoublePrinter.java | 36 +
.../printers/json/ADoublePrinterFactory.java | 30 +
.../printers/json/ADurationPrinter.java | 45 +
.../printers/json/ADurationPrinterFactory.java | 30 +
.../nontagged/printers/json/AFloatPrinter.java | 36 +
.../printers/json/AFloatPrinterFactory.java | 30 +
.../nontagged/printers/json/AInt16Printer.java | 39 +
.../printers/json/AInt16PrinterFactory.java | 30 +
.../nontagged/printers/json/AInt32Printer.java | 40 +
.../printers/json/AInt32PrinterFactory.java | 30 +
.../nontagged/printers/json/AInt64Printer.java | 37 +
.../printers/json/AInt64PrinterFactory.java | 30 +
.../nontagged/printers/json/AInt8Printer.java | 40 +
.../printers/json/AInt8PrinterFactory.java | 30 +
.../printers/json/AIntervalPrinter.java | 67 +
.../printers/json/AIntervalPrinterFactory.java | 30 +
.../nontagged/printers/json/ALinePrinter.java | 45 +
.../printers/json/ALinePrinterFactory.java | 30 +
.../nontagged/printers/json/ANullPrinter.java | 35 +
.../printers/json/ANullPrinterFactory.java | 30 +
.../json/ANullableFieldPrinterFactory.java | 63 +
.../nontagged/printers/json/AObjectPrinter.java | 167 +
.../printers/json/AObjectPrinterFactory.java | 30 +
.../json/AOrderedlistPrinterFactory.java | 69 +
.../printers/json/APoint3DPrinter.java | 42 +
.../printers/json/APoint3DPrinterFactory.java | 30 +
.../nontagged/printers/json/APointPrinter.java | 40 +
.../printers/json/APointPrinterFactory.java | 30 +
.../printers/json/APolygonPrinter.java | 56 +
.../printers/json/APolygonPrinterFactory.java | 30 +
.../printers/json/ARecordPrinterFactory.java | 69 +
.../printers/json/ARectanglePrinter.java | 45 +
.../printers/json/ARectanglePrinterFactory.java | 30 +
.../nontagged/printers/json/AStringPrinter.java | 41 +
.../printers/json/AStringPrinterFactory.java | 30 +
.../nontagged/printers/json/ATimePrinter.java | 41 +
.../printers/json/ATimePrinterFactory.java | 30 +
.../printers/json/AUnionPrinterFactory.java | 72 +
.../json/AUnorderedlistPrinterFactory.java | 69 +
.../json/AYearMonthDurationPrinter.java | 47 +
.../json/AYearMonthDurationPrinterFactory.java | 33 +
.../serde/ABinarySerializerDeserializer.java | 55 +
.../serde/ABooleanSerializerDeserializer.java | 60 +
.../serde/ACircleSerializerDeserializer.java | 93 +
.../serde/ADateSerializerDeserializer.java | 82 +
.../serde/ADateTimeSerializerDeserializer.java | 95 +
.../ADayTimeDurationSerializerDeserializer.java | 72 +
.../serde/ADoubleSerializerDeserializer.java | 60 +
.../serde/ADurationSerializerDeserializer.java | 100 +
.../serde/AFloatSerializerDeserializer.java | 54 +
.../serde/AInt16SerializerDeserializer.java | 57 +
.../serde/AInt32SerializerDeserializer.java | 49 +
.../serde/AInt64SerializerDeserializer.java | 60 +
.../serde/AInt8SerializerDeserializer.java | 53 +
.../serde/AIntervalSerializerDeserializer.java | 263 ++
.../serde/ALineSerializerDeserializer.java | 106 +
.../serde/ANullSerializerDeserializer.java | 42 +
.../serde/AObjectSerializerDeserializer.java | 264 ++
.../AOrderedListSerializerDeserializer.java | 172 +
.../serde/APoint3DSerializerDeserializer.java | 101 +
.../serde/APointSerializerDeserializer.java | 93 +
.../serde/APolygonSerializerDeserializer.java | 94 +
.../serde/ARecordSerializerDeserializer.java | 341 ++
.../serde/ARectangleSerializerDeserializer.java | 117 +
.../serde/AStringSerializerDeserializer.java | 52 +
.../serde/ATimeSerializerDeserializer.java | 81 +
.../serde/ATypeSerializerDeserializer.java | 43 +
.../serde/AUUIDSerializerDeserializer.java | 51 +
.../AUUIDStringSerializerDeserializer.java | 56 +
.../AUnorderedListSerializerDeserializer.java | 160 +
...YearMonthDurationSerializerDeserializer.java | 73 +
.../serde/SerializerDeserializerUtil.java | 76 +
.../AqlPrimitiveValueProviderFactory.java | 66 +
.../asterix/formats/base/IDataFormat.java | 93 +
.../AqlBinaryBooleanInspectorImpl.java | 50 +
.../AqlBinaryComparatorFactoryProvider.java | 222 ++
.../AqlBinaryHashFunctionFactoryProvider.java | 62 +
.../AqlBinaryHashFunctionFamilyProvider.java | 44 +
.../nontagged/AqlBinaryIntegerInspector.java | 41 +
.../AqlBinaryTokenizerFactoryProvider.java | 89 +
.../nontagged/AqlCSVPrinterFactoryProvider.java | 145 +
.../AqlJSONPrinterFactoryProvider.java | 150 +
.../AqlLinearizeComparatorFactoryProvider.java | 99 +
...AqlNormalizedKeyComputerFactoryProvider.java | 99 +
.../AqlPredicateEvaluatorFactoryProvider.java | 78 +
.../nontagged/AqlPrinterFactoryProvider.java | 151 +
.../AqlSerializerDeserializerProvider.java | 215 ++
.../formats/nontagged/AqlTypeTraitProvider.java | 101 +
.../NGramUTF8StringBinaryTokenizerFactory.java | 47 +
.../nontagged/UTF8StringLowercasePointable.java | 102 +
.../org/apache/asterix/om/base/ABinary.java | 137 +
.../org/apache/asterix/om/base/ABitArray.java | 149 +
.../org/apache/asterix/om/base/ABoolean.java | 86 +
.../org/apache/asterix/om/base/ACircle.java | 91 +
.../asterix/om/base/ACollectionCursor.java | 70 +
.../java/org/apache/asterix/om/base/ADate.java | 102 +
.../org/apache/asterix/om/base/ADateTime.java | 133 +
.../asterix/om/base/ADayTimeDuration.java | 94 +
.../org/apache/asterix/om/base/ADouble.java | 84 +
.../org/apache/asterix/om/base/ADuration.java | 126 +
.../java/org/apache/asterix/om/base/AFloat.java | 84 +
.../java/org/apache/asterix/om/base/AInt16.java | 74 +
.../java/org/apache/asterix/om/base/AInt32.java | 99 +
.../java/org/apache/asterix/om/base/AInt64.java | 73 +
.../java/org/apache/asterix/om/base/AInt8.java | 73 +
.../org/apache/asterix/om/base/AInterval.java | 159 +
.../java/org/apache/asterix/om/base/ALine.java | 84 +
.../apache/asterix/om/base/AMutableBinary.java | 30 +
.../apache/asterix/om/base/AMutableCircle.java | 28 +
.../apache/asterix/om/base/AMutableDate.java | 27 +
.../asterix/om/base/AMutableDateTime.java | 27 +
.../om/base/AMutableDayTimeDuration.java | 27 +
.../apache/asterix/om/base/AMutableDouble.java | 27 +
.../asterix/om/base/AMutableDuration.java | 28 +
.../apache/asterix/om/base/AMutableFloat.java | 27 +
.../apache/asterix/om/base/AMutableInt16.java | 27 +
.../apache/asterix/om/base/AMutableInt32.java | 27 +
.../apache/asterix/om/base/AMutableInt64.java | 27 +
.../apache/asterix/om/base/AMutableInt8.java | 27 +
.../asterix/om/base/AMutableInterval.java | 34 +
.../apache/asterix/om/base/AMutableLine.java | 28 +
.../asterix/om/base/AMutableOrderedList.java | 39 +
.../apache/asterix/om/base/AMutablePoint.java | 28 +
.../apache/asterix/om/base/AMutablePoint3D.java | 29 +
.../apache/asterix/om/base/AMutablePolygon.java | 27 +
.../apache/asterix/om/base/AMutableRecord.java | 29 +
.../asterix/om/base/AMutableRectangle.java | 28 +
.../apache/asterix/om/base/AMutableString.java | 26 +
.../apache/asterix/om/base/AMutableTime.java | 27 +
.../apache/asterix/om/base/AMutableUUID.java | 60 +
.../asterix/om/base/AMutableUnorderedList.java | 38 +
.../om/base/AMutableYearMonthDuration.java | 27 +
.../java/org/apache/asterix/om/base/ANull.java | 67 +
.../apache/asterix/om/base/AOrderedList.java | 137 +
.../java/org/apache/asterix/om/base/APoint.java | 84 +
.../org/apache/asterix/om/base/APoint3D.java | 91 +
.../org/apache/asterix/om/base/APolygon.java | 105 +
.../org/apache/asterix/om/base/ARecord.java | 109 +
.../org/apache/asterix/om/base/ARectangle.java | 84 +
.../org/apache/asterix/om/base/AString.java | 82 +
.../java/org/apache/asterix/om/base/ATime.java | 118 +
.../java/org/apache/asterix/om/base/AUUID.java | 170 +
.../apache/asterix/om/base/AUnorderedList.java | 127 +
.../asterix/om/base/AYearMonthDuration.java | 102 +
.../apache/asterix/om/base/IACollection.java | 22 +
.../org/apache/asterix/om/base/IACursor.java | 33 +
.../org/apache/asterix/om/base/IAObject.java | 33 +
.../org/apache/asterix/om/base/InMemUtils.java | 61 +
.../asterix/om/base/ShortWithoutTypeInfo.java | 97 +
.../om/base/temporal/ADateParserFactory.java | 340 ++
.../base/temporal/ADateTimeParserFactory.java | 70 +
.../base/temporal/ADurationParserFactory.java | 277 ++
.../om/base/temporal/ATimeParserFactory.java | 513 +++
.../AsterixTemporalTypeParseException.java | 35 +
.../om/base/temporal/DateTimeFormatUtils.java | 971 ++++++
.../temporal/DurationArithmeticOperations.java | 90 +
.../base/temporal/GregorianCalendarSystem.java | 729 +++++
.../om/base/temporal/ICalendarSystem.java | 61 +
.../om/constants/AsterixConstantValue.java | 71 +
.../functions/AbstractFunctionDescriptor.java | 66 +
.../om/functions/AsterixBuiltinFunctions.java | 1398 ++++++++
.../functions/AsterixExternalFunctionInfo.java | 89 +
.../asterix/om/functions/AsterixFunction.java | 58 +
.../om/functions/AsterixFunctionIdentifier.java | 44 +
.../om/functions/AsterixFunctionInfo.java | 75 +
.../om/functions/FunctionInfoRepository.java | 44 +
.../om/functions/FunctionManagerHolder.java | 27 +
.../om/functions/IExternalFunctionInfo.java | 39 +
.../om/functions/IFunctionDescriptor.java | 47 +
.../functions/IFunctionDescriptorFactory.java | 26 +
.../asterix/om/functions/IFunctionManager.java | 27 +
.../asterix/om/io/AsterixIOException.java | 26 +
.../org/apache/asterix/om/io/IALocation.java | 19 +
.../org/apache/asterix/om/io/IAOMReader.java | 29 +
.../asterix/om/io/IAOMReaderWriterFactory.java | 21 +
.../org/apache/asterix/om/io/IAOMWriter.java | 30 +
.../om/pointables/AFlatValuePointable.java | 81 +
.../om/pointables/AListVisitablePointable.java | 181 ++
.../pointables/ARecordVisitablePointable.java | 285 ++
.../pointables/AbstractVisitablePointable.java | 58 +
.../om/pointables/PointableAllocator.java | 128 +
.../pointables/base/DefaultOpenFieldType.java | 66 +
.../om/pointables/base/IVisitablePointable.java | 29 +
.../om/pointables/cast/ACastVisitor.java | 140 +
.../asterix/om/pointables/cast/AListCaster.java | 106 +
.../om/pointables/cast/ARecordCaster.java | 367 +++
.../pointables/nonvisitor/AListPointable.java | 195 ++
.../pointables/nonvisitor/ARecordPointable.java | 336 ++
.../om/pointables/printer/AListPrinter.java | 85 +
.../om/pointables/printer/APrintVisitor.java | 215 ++
.../om/pointables/printer/ARecordPrinter.java | 88 +
.../pointables/printer/csv/APrintVisitor.java | 202 ++
.../pointables/printer/csv/ARecordPrinter.java | 77 +
.../pointables/printer/json/AListPrinter.java | 82 +
.../pointables/printer/json/APrintVisitor.java | 210 ++
.../pointables/printer/json/ARecordPrinter.java | 88 +
.../visitor/IVisitablePointableVisitor.java | 35 +
.../typecomputer/base/IResultTypeComputer.java | 28 +
.../base/TypeComputerUtilities.java | 120 +
.../typecomputer/impl/ABinaryTypeComputer.java | 37 +
.../typecomputer/impl/ABooleanTypeComputer.java | 38 +
.../typecomputer/impl/ACircleTypeComputer.java | 38 +
.../impl/ADateTimeTypeComputer.java | 38 +
.../om/typecomputer/impl/ADateTypeComputer.java | 38 +
.../typecomputer/impl/ADoubleTypeComputer.java | 38 +
.../typecomputer/impl/AFloatTypeComputer.java | 37 +
.../typecomputer/impl/AInt32TypeComputer.java | 38 +
.../typecomputer/impl/AInt64TypeComputer.java | 38 +
.../impl/AIntervalTypeComputer.java | 41 +
.../om/typecomputer/impl/ALineTypeComputer.java | 38 +
.../om/typecomputer/impl/ANullTypeComputer.java | 38 +
.../typecomputer/impl/APoint3DTypeComputer.java | 38 +
.../typecomputer/impl/APointTypeComputer.java | 38 +
.../typecomputer/impl/APolygonTypeComputer.java | 38 +
.../impl/ARectangleTypeComputer.java | 38 +
.../typecomputer/impl/AStringTypeComputer.java | 38 +
.../om/typecomputer/impl/ATimeTypeComputer.java | 38 +
.../om/typecomputer/impl/AUUIDTypeComputer.java | 41 +
.../impl/AbstractBinaryStringTypeComputer.java | 55 +
.../impl/AbstractQuadStringTypeComputer.java | 62 +
.../impl/AbstractTripleStringTypeComputer.java | 58 +
.../om/typecomputer/impl/AnyTypeComputer.java | 38 +
...BinaryBooleanOrNullFunctionTypeComputer.java | 57 +
.../BinaryStringBoolOrNullTypeComputer.java | 38 +
.../BinaryStringStringOrNullTypeComputer.java | 40 +
.../impl/CastListResultTypeComputer.java | 42 +
.../impl/CastRecordResultTypeComputer.java | 36 +
.../impl/ClosedRecordConstructorResultType.java | 79 +
.../impl/CollectionToSequenceTypeComputer.java | 65 +
.../impl/ConcatNonNullTypeComputer.java | 58 +
.../impl/FieldAccessByIndexResultType.java | 74 +
.../impl/FieldAccessNestedResultType.java | 91 +
.../impl/FlowRecordResultTypeComputer.java | 41 +
.../om/typecomputer/impl/GetItemResultType.java | 50 +
.../GetOverlappingInvervalTypeComputer.java | 39 +
.../impl/InjectFailureTypeComputer.java | 53 +
.../NonTaggedCollectionMemberResultType.java | 51 +
.../NonTaggedFieldAccessByNameResultType.java | 100 +
.../impl/NonTaggedGetItemResultType.java | 53 +
.../impl/NonTaggedLocalAvgTypeComputer.java | 44 +
.../impl/NonTaggedMinMaxAggTypeComputer.java | 102 +
...onTaggedNumericAddSubMulDivTypeComputer.java | 339 ++
.../impl/NonTaggedNumericAggTypeComputer.java | 84 +
...ggedNumericRoundHalfToEven2TypeComputer.java | 111 +
...nTaggedNumericUnaryFunctionTypeComputer.java | 88 +
.../impl/NonTaggedSwitchCaseComputer.java | 63 +
.../impl/NonTaggedUnaryMinusTypeComputer.java | 44 +
.../typecomputer/impl/NotNullTypeComputer.java | 72 +
.../impl/NumericAddSubMulTypeDescriptor.java | 79 +
.../impl/OpenRecordConstructorResultType.java | 83 +
.../impl/OptionalABinaryTypeComputer.java | 44 +
.../impl/OptionalABooleanTypeComputer.java | 44 +
.../impl/OptionalACircleTypeComputer.java | 44 +
.../impl/OptionalADateTimeTypeComputer.java | 44 +
.../impl/OptionalADateTypeComputer.java | 44 +
.../OptionalADayTimeDurationTypeComputer.java | 48 +
.../impl/OptionalADoubleTypeComputer.java | 43 +
.../impl/OptionalADurationTypeComputer.java | 44 +
.../impl/OptionalAFloatTypeComputer.java | 44 +
.../impl/OptionalAInt16TypeComputer.java | 44 +
.../impl/OptionalAInt32TypeComputer.java | 44 +
.../impl/OptionalAInt64TypeComputer.java | 44 +
.../impl/OptionalAInt8TypeComputer.java | 44 +
.../impl/OptionalAIntervalTypeComputer.java | 44 +
.../impl/OptionalALineTypeComputer.java | 44 +
.../impl/OptionalAPoint3DTypeComputer.java | 44 +
.../impl/OptionalAPointTypeComputer.java | 44 +
.../impl/OptionalAPolygonTypeComputer.java | 44 +
.../impl/OptionalARectangleTypeComputer.java | 44 +
.../impl/OptionalAStringTypeComputer.java | 44 +
.../OptionalATemporalInstanceTypeComputer.java | 50 +
.../impl/OptionalATimeTypeComputer.java | 44 +
.../OptionalAYearMonthDurationTypeComputer.java | 48 +
.../impl/OrderedListConstructorResultType.java | 65 +
.../impl/OrderedListOfAInt32TypeComputer.java | 38 +
.../impl/OrderedListOfAInt64TypeComputer.java | 38 +
.../OrderedListOfAIntervalTypeComputer.java | 39 +
.../impl/OrderedListOfAPointTypeComputer.java | 38 +
.../impl/OrderedListOfAStringTypeComputer.java | 38 +
.../impl/OrderedListOfAnyTypeComputer.java | 38 +
.../QuadStringStringOrNullTypeComputer.java | 40 +
.../impl/RecordConstructorResultType.java | 84 +
.../impl/RecordMergeTypeComputer.java | 168 +
.../ScalarVersionOfAggregateResultType.java | 57 +
.../impl/SubsetCollectionTypeComputer.java | 71 +
.../impl/Substring2TypeComputer.java | 70 +
.../impl/SubstringTypeComputer.java | 85 +
.../TripleStringBoolOrNullTypeComputer.java | 39 +
.../TripleStringStringOrNullTypeComputer.java | 38 +
.../impl/TypeCompatibilityChecker.java | 76 +
.../UnaryBinaryInt64OrNullTypeComputer.java | 63 +
.../UnaryBooleanOrNullFunctionTypeComputer.java | 56 +
.../UnaryStringInt64OrNullTypeComputer.java | 74 +
.../impl/UnaryStringOrNullTypeComputer.java | 65 +
.../UnorderedListConstructorResultType.java | 65 +
.../asterix/om/types/AOrderedListType.java | 80 +
.../apache/asterix/om/types/ARecordType.java | 625 ++++
.../org/apache/asterix/om/types/ATypeTag.java | 103 +
.../org/apache/asterix/om/types/AUnionType.java | 161 +
.../asterix/om/types/AUnorderedListType.java | 80 +
.../om/types/AbstractCollectionType.java | 65 +
.../asterix/om/types/AbstractComplexType.java | 44 +
.../apache/asterix/om/types/BuiltinType.java | 904 ++++++
.../asterix/om/types/EnumDeserializer.java | 36 +
.../org/apache/asterix/om/types/IAType.java | 29 +
.../asterix/om/types/IEnumSerializer.java | 23 +
.../org/apache/asterix/om/types/TypeHelper.java | 83 +
.../apache/asterix/om/types/TypeHierarchy.java | 40 +
.../apache/asterix/om/types/TypeSignature.java | 56 +
.../apache/asterix/om/types/TypeTagUtil.java | 83 +
.../om/types/hierachy/ATypeHierarchy.java | 804 +++++
.../AbstractIntegerTypeConvertComputer.java | 141 +
.../DoubleToFloatTypeConvertComputer.java | 44 +
.../DoubleToInt16TypeConvertComputer.java | 46 +
.../DoubleToInt32TypeConvertComputer.java | 46 +
.../DoubleToInt64TypeConvertComputer.java | 46 +
.../DoubleToInt8TypeConvertComputer.java | 46 +
.../FloatToDoubleTypeConvertComputer.java | 39 +
.../FloatToInt16TypeConvertComputer.java | 46 +
.../FloatToInt32TypeConvertComputer.java | 46 +
.../FloatToInt64TypeConvertComputer.java | 46 +
.../FloatToInt8TypeConvertComputer.java | 46 +
.../om/types/hierachy/ITypeConvertComputer.java | 25 +
.../IntegerToDoubleTypeConvertComputer.java | 71 +
.../IntegerToFloatTypeConvertComputer.java | 71 +
.../IntegerToInt16TypeConvertComputer.java | 35 +
.../IntegerToInt32TypeConvertComputer.java | 34 +
.../IntegerToInt64TypeConvertComputer.java | 34 +
.../IntegerToInt8TypeConvertComputer.java | 35 +
.../asterix/om/util/AsterixAppContextInfo.java | 126 +
.../om/util/AsterixClusterProperties.java | 182 ++
.../asterix/om/util/AsterixRuntimeUtil.java | 52 +
.../om/util/JSONDeserializerForTypes.java | 91 +
.../asterix/om/util/NonTaggedFormatUtil.java | 235 ++
.../util/ResettableByteArrayOutputStream.java | 28 +
.../om/util/container/IObjectFactory.java | 30 +
.../asterix/om/util/container/IObjectPool.java | 36 +
.../om/util/container/ListObjectPool.java | 81 +
.../apache/asterix/om/visitors/IOMVisitor.java | 110 +
.../om/visitors/OMPrintToStringVisitor.java | 296 ++
.../nontagged/printers/ABinaryPrinterTest.java | 66 -
.../om/util/JSONDeserializerForTypesTest.java | 72 -
.../nontagged/printers/ABinaryPrinterTest.java | 66 +
.../om/util/JSONDeserializerForTypesTest.java | 72 +
...tractAggregateFunctionDynamicDescriptor.java | 27 -
...zableAggregateFunctionDynamicDescriptor.java | 28 -
.../base/SingleFieldFrameTupleReference.java | 61 -
.../collections/ListifyAggregateDescriptor.java | 53 -
.../ListifyAggregateFunctionEvalFactory.java | 86 -
.../AbstractScalarAggregateDescriptor.java | 62 -
.../scalar/GenericScalarAggregateFunction.java | 56 -
.../scalar/ScalarAvgAggregateDescriptor.java | 36 -
.../scalar/ScalarCountAggregateDescriptor.java | 36 -
.../scalar/ScalarMaxAggregateDescriptor.java | 36 -
.../scalar/ScalarMinAggregateDescriptor.java | 36 -
.../scalar/ScalarSqlAvgAggregateDescriptor.java | 36 -
.../ScalarSqlCountAggregateDescriptor.java | 36 -
.../scalar/ScalarSqlMaxAggregateDescriptor.java | 36 -
.../scalar/ScalarSqlMinAggregateDescriptor.java | 36 -
.../scalar/ScalarSqlSumAggregateDescriptor.java | 36 -
.../scalar/ScalarSumAggregateDescriptor.java | 36 -
...bstractSerializableAvgAggregateFunction.java | 278 --
...tractSerializableCountAggregateFunction.java | 106 -
...bstractSerializableSumAggregateFunction.java | 221 --
.../serializable/std/BufferSerDeUtil.java | 81 -
.../std/SerializableAvgAggregateDescriptor.java | 54 -
.../std/SerializableAvgAggregateFunction.java | 56 -
.../SerializableCountAggregateDescriptor.java | 57 -
.../std/SerializableCountAggregateFunction.java | 27 -
...erializableGlobalAvgAggregateDescriptor.java | 55 -
.../SerializableGlobalAvgAggregateFunction.java | 57 -
...alizableGlobalSqlAvgAggregateDescriptor.java | 55 -
...rializableGlobalSqlAvgAggregateFunction.java | 49 -
...zableIntermediateAvgAggregateDescriptor.java | 55 -
...lizableIntermediateAvgAggregateFunction.java | 57 -
...leIntermediateSqlAvgAggregateDescriptor.java | 55 -
...ableIntermediateSqlAvgAggregateFunction.java | 49 -
...SerializableLocalAvgAggregateDescriptor.java | 54 -
.../SerializableLocalAvgAggregateFunction.java | 57 -
...ializableLocalSqlAvgAggregateDescriptor.java | 54 -
...erializableLocalSqlAvgAggregateFunction.java | 49 -
...ializableLocalSqlSumAggregateDescriptor.java | 53 -
...SerializableLocalSumAggregateDescriptor.java | 53 -
.../SerializableSqlAvgAggregateDescriptor.java | 52 -
.../SerializableSqlAvgAggregateFunction.java | 48 -
...SerializableSqlCountAggregateDescriptor.java | 57 -
.../SerializableSqlCountAggregateFunction.java | 31 -
.../SerializableSqlSumAggregateDescriptor.java | 53 -
.../SerializableSqlSumAggregateFunction.java | 62 -
.../std/SerializableSumAggregateDescriptor.java | 53 -
.../std/SerializableSumAggregateFunction.java | 70 -
.../std/AbstractAvgAggregateFunction.java | 257 --
.../std/AbstractCountAggregateFunction.java | 88 -
.../std/AbstractMinMaxAggregateFunction.java | 191 --
.../std/AbstractSumAggregateFunction.java | 211 --
.../aggregates/std/AvgAggregateDescriptor.java | 57 -
.../aggregates/std/AvgAggregateFunction.java | 55 -
.../std/CountAggregateDescriptor.java | 59 -
.../aggregates/std/CountAggregateFunction.java | 34 -
.../std/GlobalAvgAggregateDescriptor.java | 58 -
.../std/GlobalAvgAggregateFunction.java | 56 -
.../std/GlobalSqlAvgAggregateDescriptor.java | 58 -
.../std/GlobalSqlAvgAggregateFunction.java | 48 -
.../std/IntermediateAvgAggregateDescriptor.java | 58 -
.../std/IntermediateAvgAggregateFunction.java | 56 -
.../IntermediateSqlAvgAggregateDescriptor.java | 57 -
.../IntermediateSqlAvgAggregateFunction.java | 47 -
.../std/LocalAvgAggregateDescriptor.java | 56 -
.../std/LocalAvgAggregateFunction.java | 56 -
.../std/LocalMaxAggregateDescriptor.java | 57 -
.../std/LocalMinAggregateDescriptor.java | 56 -
.../std/LocalSqlAvgAggregateDescriptor.java | 56 -
.../std/LocalSqlAvgAggregateFunction.java | 49 -
.../std/LocalSqlMaxAggregateDescriptor.java | 57 -
.../std/LocalSqlMinAggregateDescriptor.java | 56 -
.../std/LocalSqlSumAggregateDescriptor.java | 56 -
.../std/LocalSumAggregateDescriptor.java | 56 -
.../aggregates/std/MaxAggregateDescriptor.java | 55 -
.../aggregates/std/MinAggregateDescriptor.java | 55 -
.../aggregates/std/MinMaxAggregateFunction.java | 59 -
.../std/SqlAvgAggregateDescriptor.java | 57 -
.../aggregates/std/SqlAvgAggregateFunction.java | 47 -
.../std/SqlCountAggregateDescriptor.java | 59 -
.../std/SqlCountAggregateFunction.java | 34 -
.../std/SqlMaxAggregateDescriptor.java | 55 -
.../std/SqlMinAggregateDescriptor.java | 55 -
.../std/SqlMinMaxAggregateFunction.java | 53 -
.../std/SqlSumAggregateDescriptor.java | 55 -
.../aggregates/std/SqlSumAggregateFunction.java | 61 -
.../aggregates/std/SumAggregateDescriptor.java | 55 -
.../aggregates/std/SumAggregateFunction.java | 67 -
.../stream/EmptyStreamAggregateDescriptor.java | 103 -
.../NonEmptyStreamAggregateDescriptor.java | 101 -
.../runtime/base/AsterixTupleFilter.java | 44 -
.../runtime/base/AsterixTupleFilterFactory.java | 43 -
.../accessors/CircleCenterAccessor.java | 117 -
.../accessors/CircleRadiusAccessor.java | 112 -
.../accessors/LineRectanglePolygonAccessor.java | 181 --
.../accessors/PointXCoordinateAccessor.java | 113 -
.../accessors/PointYCoordinateAccessor.java | 113 -
.../accessors/TemporalDayAccessor.java | 154 -
.../accessors/TemporalHourAccessor.java | 152 -
.../accessors/TemporalIntervalEndAccessor.java | 142 -
.../TemporalIntervalEndDateAccessor.java | 128 -
.../TemporalIntervalEndDatetimeAccessor.java | 127 -
.../TemporalIntervalEndTimeAccessor.java | 127 -
.../TemporalIntervalStartAccessor.java | 142 -
.../TemporalIntervalStartDateAccessor.java | 127 -
.../TemporalIntervalStartDatetimeAccessor.java | 127 -
.../TemporalIntervalStartTimeAccessor.java | 126 -
.../accessors/TemporalMillisecondAccessor.java | 153 -
.../accessors/TemporalMinuteAccessor.java | 153 -
.../accessors/TemporalMonthAccessor.java | 155 -
.../accessors/TemporalSecondAccessor.java | 153 -
.../accessors/TemporalYearAccessor.java | 166 -
...AbstractScalarFunctionDynamicDescriptor.java | 29 -
.../common/AbstractAsterixListIterator.java | 157 -
.../common/AccessibleByteArrayEval.java | 68 -
.../evaluators/common/AsterixListAccessor.java | 109 -
.../common/AsterixOrderedListIterator.java | 36 -
.../common/AsterixUnorderedListIterator.java | 36 -
.../ClosedRecordConstructorEvalFactory.java | 97 -
.../evaluators/common/CreateMBREvalFactory.java | 332 --
.../runtime/evaluators/common/DoubleArray.java | 75 -
.../common/EditDistanceCheckEvaluator.java | 107 -
.../common/EditDistanceContainsEvaluator.java | 58 -
.../common/EditDistanceEvaluator.java | 161 -
.../evaluators/common/FunctionManagerImpl.java | 65 -
.../evaluators/common/GramTokensEvaluator.java | 94 -
.../common/SimilarityFiltersCache.java | 53 -
.../common/SimilarityJaccardCheckEvaluator.java | 129 -
.../common/SimilarityJaccardEvaluator.java | 282 --
.../SimilarityJaccardPrefixEvaluator.java | 284 --
.../SimilarityJaccardSortedCheckEvaluator.java | 42 -
.../SimilarityJaccardSortedEvaluator.java | 42 -
.../runtime/evaluators/common/SpatialUtils.java | 175 -
.../evaluators/common/WordTokensEvaluator.java | 65 -
.../AbstractComparisonEvaluator.java | 557 ----
.../comparisons/ComparisonEvalFactory.java | 379 ---
...BinaryBase64StringConstructorDescriptor.java | 49 -
.../ABinaryHexStringConstructorDescriptor.java | 110 -
.../ABooleanConstructorDescriptor.java | 111 -
.../ACircleConstructorDescriptor.java | 107 -
.../ADateConstructorDescriptor.java | 133 -
.../ADateTimeConstructorDescriptor.java | 129 -
.../ADayTimeDurationConstructorDescriptor.java | 114 -
.../ADoubleConstructorDescriptor.java | 217 --
.../ADurationConstructorDescriptor.java | 109 -
.../AFloatConstructorDescriptor.java | 219 --
.../AInt16ConstructorDescriptor.java | 126 -
.../AInt32ConstructorDescriptor.java | 125 -
.../AInt64ConstructorDescriptor.java | 127 -
.../AInt8ConstructorDescriptor.java | 126 -
.../AIntervalFromDateConstructorDescriptor.java | 150 -
...tervalFromDateTimeConstructorDescriptor.java | 173 -
.../AIntervalFromTimeConstructorDescriptor.java | 163 -
...ervalStartFromDateConstructorDescriptor.java | 180 -
...lStartFromDateTimeConstructorDescriptor.java | 193 --
...ervalStartFromTimeConstructorDescriptor.java | 191 --
.../ALineConstructorDescriptor.java | 110 -
.../ANullConstructorDescriptor.java | 98 -
.../APoint3DConstructorDescriptor.java | 106 -
.../APointConstructorDescriptor.java | 102 -
.../APolygonConstructorDescriptor.java | 103 -
.../ARectangleConstructorDescriptor.java | 117 -
.../AStringConstructorDescriptor.java | 176 -
.../ATimeConstructorDescriptor.java | 121 -
.../AUUIDFromStringConstructorDescriptor.java | 217 --
...AYearMonthDurationConstructorDescriptor.java | 114 -
.../ClosedRecordConstructorDescriptor.java | 52 -
.../OpenRecordConstructorDescriptor.java | 113 -
.../functions/AbstractBinaryStringBoolEval.java | 132 -
.../AbstractNumericArithmeticEval.java | 526 ---
.../functions/AbstractQuadStringStringEval.java | 157 -
.../functions/AbstractStringContainsEval.java | 99 -
.../functions/AbstractTripleStringBoolEval.java | 139 -
.../AbstractTripleStringStringEval.java | 171 -
.../evaluators/functions/AndDescriptor.java | 110 -
.../AnyCollectionMemberDescriptor.java | 149 -
.../evaluators/functions/BinaryHashMap.java | 288 --
.../functions/CastListDescriptor.java | 104 -
.../functions/CastRecordDescriptor.java | 98 -
.../functions/CodePointToStringDescriptor.java | 177 -
.../evaluators/functions/CodepointIterator.java | 101 -
.../functions/ContainsDescriptor.java | 95 -
.../CountHashedGramTokensDescriptor.java | 61 -
.../CountHashedWordTokensDescriptor.java | 61 -
.../functions/CreateCircleDescriptor.java | 117 -
.../functions/CreateLineDescriptor.java | 120 -
.../functions/CreateMBRDescriptor.java | 45 -
.../functions/CreatePointDescriptor.java | 117 -
.../functions/CreatePolygonDescriptor.java | 140 -
.../functions/CreateRectangleDescriptor.java | 125 -
.../functions/CreateUUIDDescriptor.java | 78 -
.../functions/EditDistanceCheckDescriptor.java | 53 -
.../EditDistanceContainsDescriptor.java | 53 -
.../functions/EditDistanceDescriptor.java | 54 -
.../functions/EditDistanceListIsFilterable.java | 144 -
.../EditDistanceStringIsFilterable.java | 167 -
.../functions/EmbedTypeDescriptor.java | 71 -
.../functions/EndsWithDescriptor.java | 91 -
.../functions/FlowRecordDescriptor.java | 89 -
.../evaluators/functions/FuzzyEqDescriptor.java | 45 -
.../evaluators/functions/GetItemDescriptor.java | 159 -
.../functions/GramTokensDescriptor.java | 61 -
.../functions/HashedGramTokensDescriptor.java | 61 -
.../functions/HashedWordTokensDescriptor.java | 61 -
.../functions/InjectFailureDescriptor.java | 93 -
.../evaluators/functions/IsNullDescriptor.java | 82 -
.../functions/IsSystemNullDescriptor.java | 82 -
.../evaluators/functions/LenDescriptor.java | 124 -
.../evaluators/functions/LikeDescriptor.java | 200 --
.../evaluators/functions/NotDescriptor.java | 101 -
.../evaluators/functions/NotNullDescriptor.java | 88 -
.../functions/NumericAbsDescriptor.java | 159 -
.../functions/NumericAddDescriptor.java | 64 -
.../functions/NumericCaretDescriptor.java | 76 -
.../functions/NumericCeilingDescriptor.java | 160 -
.../functions/NumericDivideDescriptor.java | 60 -
.../functions/NumericFloorDescriptor.java | 159 -
.../functions/NumericModuloDescriptor.java | 195 --
.../functions/NumericMultiplyDescriptor.java | 72 -
.../functions/NumericRoundDescriptor.java | 161 -
.../NumericRoundHalfToEven2Descriptor.java | 198 --
.../NumericRoundHalfToEvenDescriptor.java | 162 -
.../functions/NumericSubDescriptor.java | 77 -
.../functions/NumericSubtractDescriptor.java | 193 --
.../functions/NumericUnaryMinusDescriptor.java | 149 -
.../evaluators/functions/OrDescriptor.java | 113 -
.../OrderedListConstructorDescriptor.java | 139 -
.../functions/PrefixLenDescriptor.java | 138 -
.../functions/PrefixLenJaccardDescriptor.java | 127 -
.../evaluators/functions/RegExpDescriptor.java | 168 -
.../functions/SimilarityDescriptor.java | 282 --
.../SimilarityJaccardCheckDescriptor.java | 53 -
.../functions/SimilarityJaccardDescriptor.java | 54 -
.../SimilarityJaccardPrefixCheckDescriptor.java | 107 -
.../SimilarityJaccardPrefixDescriptor.java | 54 -
.../SimilarityJaccardSortedCheckDescriptor.java | 54 -
.../SimilarityJaccardSortedDescriptor.java | 55 -
.../functions/SpatialAreaDescriptor.java | 143 -
.../functions/SpatialCellDescriptor.java | 156 -
.../functions/SpatialDistanceDescriptor.java | 126 -
.../functions/SpatialIntersectDescriptor.java | 1108 -------
.../functions/StartsWithDescriptor.java | 84 -
.../functions/StringConcatDescriptor.java | 139 -
.../functions/StringEndWithDescrtiptor.java | 88 -
.../functions/StringEqualDescriptor.java | 83 -
.../functions/StringEvaluatorUtils.java | 49 -
.../functions/StringJoinDescriptor.java | 138 -
.../functions/StringLengthDescriptor.java | 103 -
.../functions/StringLowerCaseDescriptor.java | 112 -
.../functions/StringMatchesDescriptor.java | 122 -
.../StringMatchesWithFlagDescriptor.java | 150 -
.../functions/StringReplaceDescriptor.java | 152 -
.../StringReplaceWithFlagsDescriptor.java | 174 -
.../functions/StringStartWithDescrtiptor.java | 83 -
.../functions/StringToCodePointDescriptor.java | 146 -
.../functions/StringUpperCaseDescriptor.java | 112 -
.../functions/Substring2Descriptor.java | 122 -
.../functions/SubstringAfterDescriptor.java | 128 -
.../functions/SubstringBeforeDescriptor.java | 125 -
.../functions/SubstringDescriptor.java | 182 --
.../functions/SwitchCaseDescriptor.java | 120 -
.../UnorderedListConstructorDescriptor.java | 138 -
.../functions/WordTokensDescriptor.java | 61 -
.../functions/binary/AbstractCopyEvaluator.java | 105 -
.../binary/BinaryConcatDescriptor.java | 107 -
.../binary/BinaryLengthDescriptor.java | 82 -
.../functions/binary/FindBinaryDescriptor.java | 147 -
.../binary/FindBinaryFromDescriptor.java | 70 -
.../functions/binary/ParseBinaryDescriptor.java | 124 -
.../functions/binary/PrintBinaryDescriptor.java | 106 -
.../binary/SubBinaryFromDescriptor.java | 57 -
.../binary/SubBinaryFromToDescriptor.java | 128 -
.../records/FieldAccessByIndexDescriptor.java | 50 -
.../records/FieldAccessByIndexEvalFactory.java | 137 -
.../records/FieldAccessByNameDescriptor.java | 43 -
.../records/FieldAccessByNameEvalFactory.java | 111 -
.../records/FieldAccessNestedDescriptor.java | 54 -
.../records/FieldAccessNestedEvalFactory.java | 68 -
.../functions/records/FieldAccessUtil.java | 193 --
.../records/GetRecordFieldValueDescriptor.java | 50 -
.../records/GetRecordFieldValueEvalFactory.java | 98 -
.../records/GetRecordFieldsDescriptor.java | 50 -
.../records/GetRecordFieldsEvalFactory.java | 101 -
.../functions/records/RecordFieldsUtil.java | 314 --
.../records/RecordMergeDescriptor.java | 257 --
.../AbstractIntervalLogicFuncDescriptor.java | 122 -
.../AdjustDateTimeForTimeZoneDescriptor.java | 146 -
.../AdjustTimeForTimeZoneDescriptor.java | 146 -
.../CalendarDuartionFromDateDescriptor.java | 236 --
.../CalendarDurationFromDateTimeDescriptor.java | 250 --
.../temporal/CurrentDateDescriptor.java | 87 -
.../temporal/CurrentDateTimeDescriptor.java | 91 -
.../temporal/CurrentTimeDescriptor.java | 93 -
.../temporal/DateFromDatetimeDescriptor.java | 123 -
.../DateFromUnixTimeInDaysDescriptor.java | 105 -
.../DatetimeFromDateAndTimeDescriptor.java | 141 -
.../DatetimeFromUnixTimeInMsDescriptor.java | 135 -
.../DatetimeFromUnixTimeInSecsDescriptor.java | 136 -
.../functions/temporal/DayOfWeekDescriptor.java | 150 -
.../DayTimeDurationComparatorDescriptor.java | 149 -
.../temporal/DurationEqualDescriptor.java | 130 -
.../DurationFromIntervalDescriptor.java | 126 -
.../DurationFromMillisecondsDescriptor.java | 135 -
.../temporal/DurationFromMonthsDescriptor.java | 112 -
.../temporal/GetDayTimeDurationDescriptor.java | 121 -
.../GetOverlappingIntervalDescriptor.java | 143 -
.../GetYearMonthDurationDescriptor.java | 121 -
.../temporal/IntervalAfterDescriptor.java | 51 -
.../temporal/IntervalBeforeDescriptor.java | 48 -
.../temporal/IntervalBinDescriptor.java | 282 --
.../temporal/IntervalCoveredByDescriptor.java | 51 -
.../temporal/IntervalCoversDescriptor.java | 51 -
.../temporal/IntervalEndedByDescriptor.java | 51 -
.../temporal/IntervalEndsDecriptor.java | 51 -
.../functions/temporal/IntervalLogic.java | 161 -
.../temporal/IntervalMeetsDescriptor.java | 51 -
.../temporal/IntervalMetByDescriptor.java | 51 -
.../IntervalOverlappedByDescriptor.java | 51 -
.../temporal/IntervalOverlapsDescriptor.java | 51 -
.../temporal/IntervalStartedByDescriptor.java | 51 -
.../temporal/IntervalStartsDescriptor.java | 51 -
...llisecondsFromDayTimeDurationDescriptor.java | 121 -
.../MonthsFromYearMonthDurationDescriptor.java | 122 -
.../temporal/OverlapBinsDescriptor.java | 338 --
.../functions/temporal/OverlapDescriptor.java | 51 -
.../functions/temporal/ParseDateDescriptor.java | 168 -
.../temporal/ParseDateTimeDescriptor.java | 162 -
.../functions/temporal/ParseTimeDescriptor.java | 162 -
.../functions/temporal/PrintDateDescriptor.java | 135 -
.../temporal/PrintDateTimeDescriptor.java | 132 -
.../functions/temporal/PrintTimeDescriptor.java | 133 -
.../temporal/TimeFromDatetimeDescriptor.java | 128 -
.../TimeFromUnixTimeInMsDescriptor.java | 110 -
.../YearMonthDurationComparatorDecriptor.java | 149 -
.../ExternalBTreeSearchOperatorDescriptor.java | 56 -
...ExternalBTreeSearchOperatorNodePushable.java | 87 -
.../ExternalRTreeSearchOperatorDescriptor.java | 53 -
...ExternalRTreeSearchOperatorNodePushable.java | 86 -
.../asterix/runtime/formats/FormatUtils.java | 23 -
.../runtime/formats/NonTaggedDataFormat.java | 1201 -------
.../job/listener/JobEventListenerFactory.java | 73 -
.../runtime/operators/file/ADMDataParser.java | 1099 -------
.../operators/file/AbstractDataParser.java | 351 --
.../operators/file/AbstractTupleParser.java | 77 -
.../file/AsterixTupleParserFactory.java | 268 --
.../file/CounterTimerTupleForwardPolicy.java | 154 -
.../operators/file/DelimitedDataParser.java | 172 -
.../file/FrameFullTupleForwardPolicy.java | 72 -
.../runtime/operators/file/IDataParser.java | 55 -
.../file/RateContolledParserPolicy.java | 93 -
.../file/RateControlledTupleForwardPolicy.java | 84 -
.../std/FlushDatasetOperatorDescriptor.java | 89 -
.../std/NoTupleSourceRuntimeFactory.java | 45 -
...nningAggregateFunctionDynamicDescriptor.java | 26 -
.../std/TidRunningAggregateDescriptor.java | 95 -
...tractUnnestingFunctionDynamicDescriptor.java | 26 -
.../unnestingfunctions/std/RangeDescriptor.java | 116 -
.../std/ScanCollectionDescriptor.java | 120 -
.../std/SubsetCollectionDescriptor.java | 162 -
...tractAggregateFunctionDynamicDescriptor.java | 27 +
...zableAggregateFunctionDynamicDescriptor.java | 28 +
.../base/SingleFieldFrameTupleReference.java | 61 +
.../collections/ListifyAggregateDescriptor.java | 53 +
.../ListifyAggregateFunctionEvalFactory.java | 86 +
.../AbstractScalarAggregateDescriptor.java | 62 +
.../scalar/GenericScalarAggregateFunction.java | 56 +
.../scalar/ScalarAvgAggregateDescriptor.java | 36 +
.../scalar/ScalarCountAggregateDescriptor.java | 36 +
.../scalar/ScalarMaxAggregateDescriptor.java | 36 +
.../scalar/ScalarMinAggregateDescriptor.java | 36 +
.../scalar/ScalarSqlAvgAggregateDescriptor.java | 36 +
.../ScalarSqlCountAggregateDescriptor.java | 36 +
.../scalar/ScalarSqlMaxAggregateDescriptor.java | 36 +
.../scalar/ScalarSqlMinAggregateDescriptor.java | 36 +
.../scalar/ScalarSqlSumAggregateDescriptor.java | 36 +
.../scalar/ScalarSumAggregateDescriptor.java | 36 +
...bstractSerializableAvgAggregateFunction.java | 278 ++
...tractSerializableCountAggregateFunction.java | 106 +
...bstractSerializableSumAggregateFunction.java | 221 ++
.../serializable/std/BufferSerDeUtil.java | 81 +
.../std/SerializableAvgAggregateDescriptor.java | 54 +
.../std/SerializableAvgAggregateFunction.java | 56 +
.../SerializableCountAggregateDescriptor.java | 57 +
.../std/SerializableCountAggregateFunction.java | 27 +
...erializableGlobalAvgAggregateDescriptor.java | 55 +
.../SerializableGlobalAvgAggregateFunction.java | 57 +
...alizableGlobalSqlAvgAggregateDescriptor.java | 55 +
...rializableGlobalSqlAvgAggregateFunction.java | 49 +
...zableIntermediateAvgAggregateDescriptor.java | 55 +
...lizableIntermediateAvgAggregateFunction.java | 57 +
...leIntermediateSqlAvgAggregateDescriptor.java | 55 +
...ableIntermediateSqlAvgAggregateFunction.java | 49 +
...SerializableLocalAvgAggregateDescriptor.java | 54 +
.../SerializableLocalAvgAggregateFunction.java | 57 +
...ializableLocalSqlAvgAggregateDescriptor.java | 54 +
...erializableLocalSqlAvgAggregateFunction.java | 49 +
...ializableLocalSqlSumAggregateDescriptor.java | 53 +
...SerializableLocalSumAggregateDescriptor.java | 53 +
.../SerializableSqlAvgAggregateDescriptor.java | 52 +
.../SerializableSqlAvgAggregateFunction.java | 48 +
...SerializableSqlCountAggregateDescriptor.java | 57 +
.../SerializableSqlCountAggregateFunction.java | 31 +
.../SerializableSqlSumAggregateDescriptor.java | 53 +
.../SerializableSqlSumAggregateFunction.java | 62 +
.../std/SerializableSumAggregateDescriptor.java | 53 +
.../std/SerializableSumAggregateFunction.java | 70 +
.../std/AbstractAvgAggregateFunction.java | 257 ++
.../std/AbstractCountAggregateFunction.java | 88 +
.../std/AbstractMinMaxAggregateFunction.java | 191 ++
.../std/AbstractSumAggregateFunction.java | 211 ++
.../aggregates/std/AvgAggregateDescriptor.java | 57 +
.../aggregates/std/AvgAggregateFunction.java | 55 +
.../std/CountAggregateDescriptor.java | 59 +
.../aggregates/std/CountAggregateFunction.java | 34 +
.../std/GlobalAvgAggregateDescriptor.java | 58 +
.../std/GlobalAvgAggregateFunction.java | 56 +
.../std/GlobalSqlAvgAggregateDescriptor.java | 58 +
.../std/GlobalSqlAvgAggregateFunction.java | 48 +
.../std/IntermediateAvgAggregateDescriptor.java | 58 +
.../std/IntermediateAvgAggregateFunction.java | 56 +
.../IntermediateSqlAvgAggregateDescriptor.java | 57 +
.../IntermediateSqlAvgAggregateFunction.java | 47 +
.../std/LocalAvgAggregateDescriptor.java | 56 +
.../std/LocalAvgAggregateFunction.java | 56 +
.../std/LocalMaxAggregateDescriptor.java | 57 +
.../std/LocalMinAggregateDescriptor.java | 56 +
.../std/LocalSqlAvgAggregateDescriptor.java | 56 +
.../std/LocalSqlAvgAggregateFunction.java | 49 +
.../std/LocalSqlMaxAggregateDescriptor.java | 57 +
.../std/LocalSqlMinAggregateDescriptor.java | 56 +
.../std/LocalSqlSumAggregateDescriptor.java | 56 +
.../std/LocalSumAggregateDescriptor.java | 56 +
.../aggregates/std/MaxAggregateDescriptor.java | 55 +
.../aggregates/std/MinAggregateDescriptor.java | 55 +
.../aggregates/std/MinMaxAggregateFunction.java | 59 +
.../std/SqlAvgAggregateDescriptor.java | 57 +
.../aggregates/std/SqlAvgAggregateFunction.java | 47 +
.../std/SqlCountAggregateDescriptor.java | 59 +
.../std/SqlCountAggregateFunction.java | 34 +
.../std/SqlMaxAggregateDescriptor.java | 55 +
.../std/SqlMinAggregateDescriptor.java | 55 +
.../std/SqlMinMaxAggregateFunction.java | 53 +
.../std/SqlSumAggregateDescriptor.java | 55 +
.../aggregates/std/SqlSumAggregateFunction.java | 61 +
.../aggregates/std/SumAggregateDescriptor.java | 55 +
.../aggregates/std/SumAggregateFunction.java | 67 +
.../stream/EmptyStreamAggregateDescriptor.java | 103 +
.../NonEmptyStreamAggregateDescriptor.java | 101 +
.../runtime/base/AsterixTupleFilter.java | 44 +
.../runtime/base/AsterixTupleFilterFactory.java | 43 +
.../accessors/CircleCenterAccessor.java | 117 +
.../accessors/CircleRadiusAccessor.java | 112 +
.../accessors/LineRectanglePolygonAccessor.java | 181 ++
.../accessors/PointXCoordinateAccessor.java | 113 +
.../accessors/PointYCoordinateAccessor.java | 113 +
.../accessors/TemporalDayAccessor.java | 154 +
.../accessors/TemporalHourAccessor.java | 152 +
.../accessors/TemporalIntervalEndAccessor.java | 142 +
.../TemporalIntervalEndDateAccessor.java | 128 +
.../TemporalIntervalEndDatetimeAccessor.java | 127 +
.../TemporalIntervalEndTimeAccessor.java | 127 +
.../TemporalIntervalStartAccessor.java | 142 +
.../TemporalIntervalStartDateAccessor.java | 127 +
.../TemporalIntervalStartDatetimeAccessor.java | 127 +
.../TemporalIntervalStartTimeAccessor.java | 126 +
.../accessors/TemporalMillisecondAccessor.java | 153 +
.../accessors/TemporalMinuteAccessor.java | 153 +
.../accessors/TemporalMonthAccessor.java | 155 +
.../accessors/TemporalSecondAccessor.java | 153 +
.../accessors/TemporalYearAccessor.java | 166 +
...AbstractScalarFunctionDynamicDescriptor.java | 29 +
.../common/AbstractAsterixListIterator.java | 157 +
.../common/AccessibleByteArrayEval.java | 68 +
.../evaluators/common/AsterixListAccessor.java | 109 +
.../common/AsterixOrderedListIterator.java | 36 +
.../common/AsterixUnorderedListIterator.java | 36 +
.../ClosedRecordConstructorEvalFactory.java | 97 +
.../evaluators/common/CreateMBREvalFactory.java | 332 ++
.../runtime/evaluators/common/DoubleArray.java | 75 +
.../common/EditDistanceCheckEvaluator.java | 107 +
.../common/EditDistanceContainsEvaluator.java | 58 +
.../common/EditDistanceEvaluator.java | 161 +
.../evaluators/common/FunctionManagerImpl.java | 65 +
.../evaluators/common/GramTokensEvaluator.java | 94 +
.../common/SimilarityFiltersCache.java | 53 +
.../common/SimilarityJaccardCheckEvaluator.java | 129 +
.../common/SimilarityJaccardEvaluator.java | 282 ++
.../SimilarityJaccardPrefixEvaluator.java | 284 ++
.../SimilarityJaccardSortedCheckEvaluator.java | 42 +
.../SimilarityJaccardSortedEvaluator.java | 42 +
.../runtime/evaluators/common/SpatialUtils.java | 175 +
.../evaluators/common/WordTokensEvaluator.java | 65 +
.../AbstractComparisonEvaluator.java | 557 ++++
.../comparisons/ComparisonEvalFactory.java | 379 +++
...BinaryBase64StringConstructorDescriptor.java | 49 +
.../ABinaryHexStringConstructorDescriptor.java | 110 +
.../ABooleanConstructorDescriptor.java | 111 +
.../ACircleConstructorDescriptor.java | 107 +
.../ADateConstructorDescriptor.java | 133 +
.../ADateTimeConstructorDescriptor.java | 129 +
.../ADayTimeDurationConstructorDescriptor.java | 114 +
.../ADoubleConstructorDescriptor.java | 217 ++
.../ADurationConstructorDescriptor.java | 109 +
.../AFloatConstructorDescriptor.java | 219 ++
.../AInt16ConstructorDescriptor.java | 126 +
.../AInt32ConstructorDescriptor.java | 125 +
.../AInt64ConstructorDescriptor.java | 127 +
.../AInt8ConstructorDescriptor.java | 126 +
.../AIntervalFromDateConstructorDescriptor.java | 150 +
...tervalFromDateTimeConstructorDescriptor.java | 173 +
.../AIntervalFromTimeConstructorDescriptor.java | 163 +
...ervalStartFromDateConstructorDescriptor.java | 180 +
...lStartFromDateTimeConstructorDescriptor.java | 193 ++
...ervalStartFromTimeConstructorDescriptor.java | 191 ++
.../ALineConstructorDescriptor.java | 110 +
.../ANullConstructorDescriptor.java | 98 +
.../APoint3DConstructorDescriptor.java | 106 +
.../APointConstructorDescriptor.java | 102 +
.../APolygonConstructorDescriptor.java | 103 +
.../ARectangleConstructorDescriptor.java | 117 +
.../AStringConstructorDescriptor.java | 176 +
.../ATimeConstructorDescriptor.java | 121 +
.../AUUIDFromStringConstructorDescriptor.java | 217 ++
...AYearMonthDurationConstructorDescriptor.java | 114 +
.../ClosedRecordConstructorDescriptor.java | 52 +
.../OpenRecordConstructorDescriptor.java | 113 +
.../functions/AbstractBinaryStringBoolEval.java | 132 +
.../AbstractNumericArithmeticEval.java | 526 +++
.../functions/AbstractQuadStringStringEval.java | 157 +
.../functions/AbstractStringContainsEval.java | 99 +
.../functions/AbstractTripleStringBoolEval.java | 139 +
.../AbstractTripleStringStringEval.java | 171 +
.../evaluators/functions/AndDescriptor.java | 110 +
.../AnyCollectionMemberDescriptor.java | 149 +
.../evaluators/functions/BinaryHashMap.java | 288 ++
.../functions/CastListDescriptor.java | 104 +
.../functions/CastRecordDescriptor.java | 98 +
.../functions/CodePointToStringDescriptor.java | 177 +
.../evaluators/functions/CodepointIterator.java | 101 +
.../functions/ContainsDescriptor.java | 95 +
.../CountHashedGramTokensDescriptor.java | 61 +
.../CountHashedWordTokensDescriptor.java | 61 +
.../functions/CreateCircleDescriptor.java | 117 +
.../functions/CreateLineDescriptor.java | 120 +
.../functions/CreateMBRDescriptor.java | 45 +
.../functions/CreatePointDescriptor.java | 117 +
.../functions/CreatePolygonDescriptor.java | 140 +
.../functions/CreateRectangleDescriptor.java | 125 +
.../functions/CreateUUIDDescriptor.java | 78 +
.../functions/EditDistanceCheckDescriptor.java | 53 +
.../EditDistanceContainsDescriptor.java | 53 +
.../functions/EditDistanceDescriptor.java | 54 +
.../functions/EditDistanceListIsFilterable.java | 144 +
.../EditDistanceStringIsFilterable.java | 167 +
.../functions/EmbedTypeDescriptor.java | 71 +
.../functions/EndsWithDescriptor.java | 91 +
.../functions/FlowRecordDescriptor.java | 89 +
.../evaluators/functions/FuzzyEqDescriptor.java | 45 +
.../evaluators/functions/GetItemDescriptor.java | 159 +
.../functions/GramTokensDescriptor.java | 61 +
.../functions/HashedGramTokensDescriptor.java | 61 +
.../functions/HashedWordTokensDescriptor.java | 61 +
.../functions/InjectFailureDescriptor.java | 93 +
.../evaluators/functions/IsNullDescriptor.java | 82 +
.../functions/IsSystemNullDescriptor.java | 82 +
.../evaluators/functions/LenDescriptor.java | 124 +
.../evaluators/functions/LikeDescriptor.java | 200 ++
.../evaluators/functions/NotDescriptor.java | 101 +
.../evaluators/functions/NotNullDescriptor.java | 88 +
.../functions/NumericAbsDescriptor.java | 159 +
.../functions/NumericAddDescriptor.java | 64 +
.../functions/NumericCaretDescriptor.java | 76 +
.../functions/NumericCeilingDescriptor.java | 160 +
.../functions/NumericDivideDescriptor.java | 60 +
.../functions/NumericFloorDescriptor.java | 159 +
.../functions/NumericModuloDescriptor.java | 195 ++
.../functions/NumericMultiplyDescriptor.java | 72 +
.../functions/NumericRoundDescriptor.java | 161 +
.../NumericRoundHalfToEven2Descriptor.java | 198 ++
.../NumericRoundHalfToEvenDescriptor.java | 162 +
.../functions/NumericSubDescriptor.java | 77 +
.../functions/NumericSubtractDescriptor.java | 193 ++
.../functions/NumericUnaryMinusDescriptor.java | 149 +
.../evaluators/functions/OrDescriptor.java | 113 +
.../OrderedListConstructorDescriptor.java | 139 +
.../functions/PrefixLenDescriptor.java | 138 +
.../functions/PrefixLenJaccardDescriptor.java | 127 +
.../evaluators/functions/RegExpDescriptor.java | 168 +
.../functions/SimilarityDescriptor.java | 282 ++
.../SimilarityJaccardCheckDescriptor.java | 53 +
.../functions/SimilarityJaccardDescriptor.java | 54 +
.../SimilarityJaccardPrefixCheckDescriptor.java | 107 +
.../SimilarityJaccardPrefixDescriptor.java | 54 +
.../SimilarityJaccardSortedCheckDescriptor.java | 54 +
.../SimilarityJaccardSortedDescriptor.java | 55 +
.../functions/SpatialAreaDescriptor.java | 143 +
.../functions/SpatialCellDescriptor.java | 156 +
.../functions/SpatialDistanceDescriptor.java | 126 +
.../functions/SpatialIntersectDescriptor.java | 1108 +++++++
.../functions/StartsWithDescriptor.java | 84 +
.../functions/StringConcatDescriptor.java | 139 +
.../functions/StringEndWithDescrtiptor.java | 88 +
.../functions/StringEqualDescriptor.java | 83 +
.../functions/StringEvaluatorUtils.java | 49 +
.../functions/StringJoinDescriptor.java | 138 +
.../functions/StringLengthDescriptor.java | 103 +
.../functions/StringLowerCaseDescriptor.java | 112 +
.../functions/StringMatchesDescriptor.java | 122 +
.../StringMatchesWithFlagDescriptor.java | 150 +
.../functions/StringReplaceDescriptor.java | 152 +
.../StringReplaceWithFlagsDescriptor.java | 174 +
.../functions/StringStartWithDescrtiptor.java | 83 +
.../functions/StringToCodePointDescriptor.java | 146 +
.../functions/StringUpperCaseDescriptor.java | 112 +
.../functions/Substring2Descriptor.java | 122 +
.../functions/SubstringAfterDescriptor.java | 128 +
.../functions/SubstringBeforeDescriptor.java | 125 +
.../functions/SubstringDescriptor.java | 182 ++
.../functions/SwitchCaseDescriptor.java | 120 +
.../UnorderedListConstructorDescriptor.java | 138 +
.../functions/WordTokensDescriptor.java | 61 +
.../functions/binary/AbstractCopyEvaluator.java | 105 +
.../binary/BinaryConcatDescriptor.java | 107 +
.../binary/BinaryLengthDescriptor.java | 82 +
.../functions/binary/FindBinaryDescriptor.java | 147 +
.../binary/FindBinaryFromDescriptor.java | 70 +
.../functions/binary/ParseBinaryDescriptor.java | 124 +
.../functions/binary/PrintBinaryDescriptor.java | 106 +
.../binary/SubBinaryFromDescriptor.java | 57 +
.../binary/SubBinaryFromToDescriptor.java | 128 +
.../records/FieldAccessByIndexDescriptor.java | 50 +
.../records/FieldAccessByIndexEvalFactory.java | 137 +
.../records/FieldAccessByNameDescriptor.java | 43 +
.../records/FieldAccessByNameEvalFactory.java | 111 +
.../records/FieldAccessNestedDescriptor.java | 54 +
.../records/FieldAccessNestedEvalFactory.java | 68 +
.../functions/records/FieldAccessUtil.java | 193 ++
.../records/GetRecordFieldValueDescriptor.java | 50 +
.../records/GetRecordFieldValueEvalFactory.java | 98 +
.../records/GetRecordFieldsDescriptor.java | 50 +
.../records/GetRecordFieldsEvalFactory.java | 101 +
.../functions/records/RecordFieldsUtil.java | 314 ++
.../records/RecordMergeDescriptor.java | 257 ++
.../AbstractIntervalLogicFuncDescriptor.java | 122 +
.../AdjustDateTimeForTimeZoneDescriptor.java | 146 +
.../AdjustTimeForTimeZoneDescriptor.java | 146 +
.../CalendarDuartionFromDateDescriptor.java | 236 ++
.../CalendarDurationFromDateTimeDescriptor.java | 250 ++
.../temporal/CurrentDateDescriptor.java | 87 +
.../temporal/CurrentDateTimeDescriptor.java | 91 +
.../temporal/CurrentTimeDescriptor.java | 93 +
.../temporal/DateFromDatetimeDescriptor.java | 123 +
.../DateFromUnixTimeInDaysDescriptor.java | 105 +
.../DatetimeFromDateAndTimeDescriptor.java | 141 +
.../DatetimeFromUnixTimeInMsDescriptor.java | 135 +
.../DatetimeFromUnixTimeInSecsDescriptor.java | 136 +
.../functions/temporal/DayOfWeekDescriptor.java | 150 +
.../DayTimeDurationComparatorDescriptor.java | 149 +
.../temporal/DurationEqualDescriptor.java | 130 +
.../DurationFromIntervalDescriptor.java | 126 +
.../DurationFromMillisecondsDescriptor.java | 135 +
.../temporal/DurationFromMonthsDescriptor.java | 112 +
.../temporal/GetDayTimeDurationDescriptor.java | 121 +
.../GetOverlappingIntervalDescriptor.java | 143 +
.../GetYearMonthDurationDescriptor.java | 121 +
.../temporal/IntervalAfterDescriptor.java | 51 +
.../temporal/IntervalBeforeDescriptor.java | 48 +
.../temporal/IntervalBinDescriptor.java | 282 ++
.../temporal/IntervalCoveredByDescriptor.java | 51 +
.../temporal/IntervalCoversDescriptor.java | 51 +
.../temporal/IntervalEndedByDescriptor.java | 51 +
.../temporal/IntervalEndsDecriptor.java | 51 +
.../functions/temporal/IntervalLogic.java | 161 +
.../temporal/IntervalMeetsDescriptor.java | 51 +
.../temporal/IntervalMetByDescriptor.java | 51 +
.../IntervalOverlappedByDescriptor.java | 51 +
.../temporal/IntervalOverlapsDescriptor.java | 51 +
.../temporal/IntervalStartedByDescriptor.java | 51 +
.../temporal/IntervalStartsDescriptor.java | 51 +
...llisecondsFromDayTimeDurationDescriptor.java | 121 +
.../MonthsFromYearMonthDurationDescriptor.java | 122 +
.../temporal/OverlapBinsDescriptor.java | 338 ++
.../functions/temporal/OverlapDescriptor.java | 51 +
.../functions/temporal/ParseDateDescriptor.java | 168 +
.../temporal/ParseDateTimeDescriptor.java | 162 +
.../functions/temporal/ParseTimeDescriptor.java | 162 +
.../functions/temporal/PrintDateDescriptor.java | 135 +
.../temporal/PrintDateTimeDescriptor.java | 132 +
.../functions/temporal/PrintTimeDescriptor.java | 133 +
.../temporal/TimeFromDatetimeDescriptor.java | 128 +
.../TimeFromUnixTimeInMsDescriptor.java | 110 +
.../YearMonthDurationComparatorDecriptor.java | 149 +
.../ExternalBTreeSearchOperatorDescriptor.java | 56 +
...ExternalBTreeSearchOperatorNodePushable.java | 87 +
.../ExternalRTreeSearchOperatorDescriptor.java | 53 +
...ExternalRTreeSearchOperatorNodePushable.java | 86 +
.../asterix/runtime/formats/FormatUtils.java | 23 +
.../runtime/formats/NonTaggedDataFormat.java | 1201 +++++++
.../job/listener/JobEventListenerFactory.java | 73 +
.../runtime/operators/file/ADMDataParser.java | 1099 +++++++
.../operators/file/AbstractDataParser.java | 351 ++
.../operators/file/AbstractTupleParser.java | 77 +
.../file/AsterixTupleParserFactory.java | 268 ++
.../file/CounterTimerTupleForwardPolicy.java | 154 +
.../operators/file/DelimitedDataParser.java | 172 +
.../file/FrameFullTupleForwardPolicy.java | 72 +
.../runtime/operators/file/IDataParser.java | 55 +
.../file/RateContolledParserPolicy.java | 93 +
.../file/RateControlledTupleForwardPolicy.java | 84 +
.../std/FlushDatasetOperatorDescriptor.java | 89 +
.../std/NoTupleSourceRuntimeFactory.java | 45 +
...nningAggregateFunctionDynamicDescriptor.java | 26 +
.../std/TidRunningAggregateDescriptor.java | 95 +
...tractUnnestingFunctionDynamicDescriptor.java | 26 +
.../unnestingfunctions/std/RangeDescriptor.java | 116 +
.../std/ScanCollectionDescriptor.java | 120 +
.../std/SubsetCollectionDescriptor.java | 162 +
.../testframework/context/TestCaseContext.java | 229 --
.../testframework/context/TestFileContext.java | 58 -
.../testframework/xml/TestSuiteParser.java | 29 -
.../testframework/context/TestCaseContext.java | 229 ++
.../testframework/context/TestFileContext.java | 58 +
.../testframework/xml/TestSuiteParser.java | 29 +
.../asterix/tools/datagen/AdgClientDriver.java | 48 -
.../ics/asterix/tools/datagen/AdmDataGen.java | 1015 ------
.../asterix/tools/datagen/CustOrdDataGen.java | 472 ---
.../ics/asterix/tools/datagen/EventDataGen.java | 233 --
.../tools/external/data/DataGenerator.java | 1184 -------
.../ExternalFilesIndexOperatorDescriptor.java | 161 -
.../tools/external/data/GULongIDGenerator.java | 46 -
.../external/data/GenericSocketFeedAdapter.java | 119 -
.../data/GenericSocketFeedAdapterFactory.java | 168 -
.../RateControlledFileSystemBasedAdapter.java | 65 -
...ControlledFileSystemBasedAdapterFactory.java | 127 -
.../external/data/SocketClientAdapter.java | 110 -
.../data/SocketClientAdapterFactory.java | 89 -
.../tools/external/data/TweetGenerator.java | 152 -
.../data/TwitterFirehoseFeedAdapter.java | 189 --
.../data/TwitterFirehoseFeedAdapterFactory.java | 120 -
.../ics/asterix/tools/tbltoadm/TblToAdm.java | 93 -
.../tools/translator/ADGenDmlTranslator.java | 87 -
.../asterix/tools/datagen/AdgClientDriver.java | 48 +
.../asterix/tools/datagen/AdmDataGen.java | 1015 ++++++
.../asterix/tools/datagen/CustOrdDataGen.java | 472 +++
.../asterix/tools/datagen/EventDataGen.java | 233 ++
.../tools/external/data/DataGenerator.java | 1184 +++++++
.../ExternalFilesIndexOperatorDescriptor.java | 161 +
.../tools/external/data/GULongIDGenerator.java | 46 +
.../external/data/GenericSocketFeedAdapter.java | 119 +
.../data/GenericSocketFeedAdapterFactory.java | 168 +
.../RateControlledFileSystemBasedAdapter.java | 65 +
...ControlledFileSystemBasedAdapterFactory.java | 127 +
.../external/data/SocketClientAdapter.java | 110 +
.../data/SocketClientAdapterFactory.java | 89 +
.../tools/external/data/TweetGenerator.java | 152 +
.../data/TwitterFirehoseFeedAdapter.java | 189 ++
.../data/TwitterFirehoseFeedAdapterFactory.java | 120 +
.../apache/asterix/tools/tbltoadm/TblToAdm.java | 93 +
.../tools/translator/ADGenDmlTranslator.java | 87 +
.../ics/asterix/tools/test/AdmDataGenTest.java | 211 --
.../asterix/tools/test/AdmDataGenTest.java | 211 ++
...tractIndexModificationOperationCallback.java | 72 -
...maryIndexInstantSearchOperationCallback.java | 72 -
...exInstantSearchOperationCallbackFactory.java | 52 -
...imaryIndexModificationOperationCallback.java | 60 -
...dexModificationOperationCallbackFactory.java | 71 -
.../PrimaryIndexOperationTrackerProvider.java | 41 -
.../PrimaryIndexSearchOperationCallback.java | 64 -
...maryIndexSearchOperationCallbackFactory.java | 52 -
...ndaryIndexModificationOperationCallback.java | 58 -
...dexModificationOperationCallbackFactory.java | 68 -
.../SecondaryIndexOperationTrackerProvider.java | 41 -
.../SecondaryIndexSearchOperationCallback.java | 53 -
...daryIndexSearchOperationCallbackFactory.java | 32 -
...tasetIndexModificationOperationCallback.java | 51 -
...dexModificationOperationCallbackFactory.java | 67 -
...dexModificationOperationCallbackFactory.java | 67 -
.../AbstractLSMLocalResourceMetadata.java | 41 -
.../ExternalBTreeLocalResourceMetadata.java | 63 -
...rnalBTreeWithBuddyLocalResourceMetadata.java | 75 -
.../ExternalRTreeLocalResourceMetadata.java | 79 -
.../resource/LSMBTreeLocalResourceMetadata.java | 85 -
.../LSMInvertedIndexLocalResourceMetadata.java | 123 -
.../resource/LSMRTreeLocalResourceMetadata.java | 101 -
.../PersistentLocalResourceFactory.java | 35 -
.../PersistentLocalResourceFactoryProvider.java | 36 -
.../PersistentLocalResourceRepository.java | 322 --
...ersistentLocalResourceRepositoryFactory.java | 33 -
.../service/locking/ConcurrentLockManager.java | 1231 -------
.../service/locking/DatasetLockInfo.java | 532 ---
.../service/locking/DeadlockDetector.java | 251 --
.../service/locking/DummyLockManager.java | 89 -
.../service/locking/EntityInfoManager.java | 726 -----
.../service/locking/EntityLockInfoManager.java | 823 -----
.../service/locking/ILockHashTable.java | 35 -
.../management/service/locking/ILockMatrix.java | 44 -
.../management/service/locking/Job.json | 24 -
.../management/service/locking/JobInfo.java | 330 --
.../management/service/locking/LockManager.java | 2285 -------------
.../LockManagerDeterministicUnitTest.java | 662 ----
.../locking/LockManagerRandomUnitTest.java | 633 ----
.../service/locking/LockManagerStats.java | 71 -
.../locking/LockMgrLatchHandlerException.java | 32 -
.../management/service/locking/LockRequestFile | 11 -
.../service/locking/LockRequestTracker.java | 71 -
.../management/service/locking/LockWaiter.java | 145 -
.../service/locking/LockWaiterManager.java | 399 ---
.../service/locking/PrimitiveIntHashMap.java | 591 ----
.../management/service/locking/Request.json | 34 -
.../management/service/locking/Resource.json | 37 -
.../locking/TestRuntimeContextProvider.java | 139 -
.../service/locking/TimeOutDetector.java | 97 -
.../management/service/logging/LogManager.java | 517 ---
.../management/service/logging/LogPage.java | 281 --
.../service/logging/LogPageReader.java | 46 -
.../management/service/logging/LogReader.java | 189 --
.../service/recovery/CheckpointObject.java | 68 -
.../service/recovery/CheckpointThread.java | 93 -
.../service/recovery/RecoveryManager.java | 851 -----
.../AsterixRuntimeComponentsProvider.java | 75 -
.../service/transaction/DatasetIdFactory.java | 39 -
.../transaction/FieldsHashValueGenerator.java | 37 -
.../service/transaction/JobIdFactory.java | 34 -
.../service/transaction/MutableResourceId.java | 44 -
.../service/transaction/TransactionContext.java | 236 --
.../TransactionManagementConstants.java | 63 -
.../service/transaction/TransactionManager.java | 202 --
.../transaction/TransactionSubsystem.java | 91 -
.../TransactionSubsystemProvider.java | 35 -
...tractIndexModificationOperationCallback.java | 72 +
...maryIndexInstantSearchOperationCallback.java | 72 +
...exInstantSearchOperationCallbackFactory.java | 52 +
...imaryIndexModificationOperationCallback.java | 60 +
...dexModificationOperationCallbackFactory.java | 71 +
.../PrimaryIndexOperationTrackerProvider.java | 41 +
.../PrimaryIndexSearchOperationCallback.java | 64 +
...maryIndexSearchOperationCallbackFactory.java | 52 +
...ndaryIndexModificationOperationCallback.java | 58 +
...dexModificationOperationCallbackFactory.java | 68 +
.../SecondaryIndexOperationTrackerProvider.java | 41 +
.../SecondaryIndexSearchOperationCallback.java | 53 +
...daryIndexSearchOperationCallbackFactory.java | 32 +
...tasetIndexModificationOperationCallback.java | 51 +
...dexModificationOperationCallbackFactory.java | 67 +
...dexModificationOperationCallbackFactory.java | 67 +
.../AbstractLSMLocalResourceMetadata.java | 41 +
.../ExternalBTreeLocalResourceMetadata.java | 63 +
...rnalBTreeWithBuddyLocalResourceMetadata.java | 75 +
.../ExternalRTreeLocalResourceMetadata.java | 79 +
.../resource/LSMBTreeLocalResourceMetadata.java | 85 +
.../LSMInvertedIndexLocalResourceMetadata.java | 123 +
.../resource/LSMRTreeLocalResourceMetadata.java | 101 +
.../PersistentLocalResourceFactory.java | 35 +
.../PersistentLocalResourceFactoryProvider.java | 36 +
.../PersistentLocalResourceRepository.java | 322 ++
...ersistentLocalResourceRepositoryFactory.java | 33 +
.../service/locking/ConcurrentLockManager.java | 1231 +++++++
.../service/locking/DatasetLockInfo.java | 532 +++
.../service/locking/DeadlockDetector.java | 251 ++
.../service/locking/DummyLockManager.java | 89 +
.../service/locking/EntityInfoManager.java | 726 +++++
.../service/locking/EntityLockInfoManager.java | 823 +++++
.../service/locking/ILockHashTable.java | 35 +
.../management/service/locking/ILockMatrix.java | 44 +
.../management/service/locking/Job.json | 24 +
.../management/service/locking/JobInfo.java | 330 ++
.../management/service/locking/LockManager.java | 2285 +++++++++++++
.../LockManagerDeterministicUnitTest.java | 662 ++++
.../locking/LockManagerRandomUnitTest.java | 633 ++++
.../service/locking/LockManagerStats.java | 71 +
.../locking/LockMgrLatchHandlerException.java | 32 +
.../management/service/locking/LockRequestFile | 11 +
.../service/locking/LockRequestTracker.java | 71 +
.../management/service/locking/LockWaiter.java | 145 +
.../service/locking/LockWaiterManager.java | 399 +++
.../service/locking/PrimitiveIntHashMap.java | 591 ++++
.../management/service/locking/Request.json | 34 +
.../management/service/locking/Resource.json | 37 +
.../locking/TestRuntimeContextProvider.java | 139 +
.../service/locking/TimeOutDetector.java | 97 +
.../management/service/logging/LogManager.java | 517 +++
.../management/service/logging/LogPage.java | 281 ++
.../service/logging/LogPageReader.java | 46 +
.../management/service/logging/LogReader.java | 189 ++
.../service/recovery/CheckpointObject.java | 68 +
.../service/recovery/CheckpointThread.java | 93 +
.../service/recovery/RecoveryManager.java | 851 +++++
.../AsterixRuntimeComponentsProvider.java | 75 +
.../service/transaction/DatasetIdFactory.java | 39 +
.../transaction/FieldsHashValueGenerator.java | 37 +
.../service/transaction/JobIdFactory.java | 34 +
.../service/transaction/MutableResourceId.java | 44 +
.../service/transaction/TransactionContext.java | 236 ++
.../TransactionManagementConstants.java | 63 +
.../service/transaction/TransactionManager.java | 202 ++
.../transaction/TransactionSubsystem.java | 91 +
.../TransactionSubsystemProvider.java | 35 +
.../edu/uci/ics/asterix/aoya/AConstants.java | 116 -
.../asterix/aoya/AsterixApplicationMaster.java | 1288 --------
.../uci/ics/asterix/aoya/AsterixYARNClient.java | 1387 --------
.../java/edu/uci/ics/asterix/aoya/Deleter.java | 45 -
.../edu/uci/ics/asterix/aoya/HDFSBackup.java | 108 -
.../java/edu/uci/ics/asterix/aoya/Utils.java | 476 ---
.../org/apache/asterix/aoya/AConstants.java | 116 +
.../asterix/aoya/AsterixApplicationMaster.java | 1288 ++++++++
.../apache/asterix/aoya/AsterixYARNClient.java | 1387 ++++++++
.../java/org/apache/asterix/aoya/Deleter.java | 45 +
.../org/apache/asterix/aoya/HDFSBackup.java | 108 +
.../java/org/apache/asterix/aoya/Utils.java | 476 +++
.../aoya/test/AsterixYARNInstanceUtil.java | 121 -
.../aoya/test/AsterixYARNLibraryTestIT.java | 104 -
.../aoya/test/AsterixYARNLifecycleIT.java | 162 -
.../uci/ics/asterix/aoya/test/YARNCluster.java | 99 -
.../aoya/test/AsterixYARNInstanceUtil.java | 121 +
.../aoya/test/AsterixYARNLibraryTestIT.java | 104 +
.../aoya/test/AsterixYARNLifecycleIT.java | 162 +
.../apache/asterix/aoya/test/YARNCluster.java | 99 +
3796 files changed, 219326 insertions(+), 219326 deletions(-)
----------------------------------------------------------------------