asterixdb-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ima...@apache.org
Subject [51/51] [partial] incubator-asterixdb-hyracks git commit: Change Java package from edu.uci.ics to org.apache
Date Tue, 25 Aug 2015 16:42:55 GMT
Change Java package from edu.uci.ics to org.apache

Change-Id: I99172d856e88954b00cf7cfb24d33bb400f53994
Reviewed-on: https://asterix-gerrit.ics.uci.edu/308
Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Reviewed-by: Till Westmann <tillw@apache.org>


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

Branch: refs/heads/master
Commit: e915e8c4612664ac07063b8441b5ae4832fefa14
Parents: 9939b48
Author: Ian Maxon <imaxon@apache.org>
Authored: Wed Jul 1 17:03:31 2015 -0700
Committer: Ian Maxon <imaxon@apache.org>
Committed: Sat Aug 22 12:56:42 2015 -0700

----------------------------------------------------------------------
 algebricks/algebricks-common/pom.xml            |   4 +-
 .../AlgebricksAbsolutePartitionConstraint.java  |   2 +-
 .../AlgebricksCountPartitionConstraint.java     |   2 +-
 .../AlgebricksPartitionConstraint.java          |   2 +-
 .../AlgebricksPartitionConstraintHelper.java    |   8 +-
 .../common/exceptions/AlgebricksException.java  |   2 +-
 .../exceptions/NotImplementedException.java     |   2 +-
 .../algebricks/common/utils/ListSet.java        |   2 +-
 .../hyracks/algebricks/common/utils/Pair.java   |   2 +-
 .../hyracks/algebricks/common/utils/Triple.java |   2 +-
 algebricks/algebricks-compiler/pom.xml          |   6 +-
 .../api/AbstractCompilerFactoryBuilder.java     |  46 +++---
 .../api/HeuristicCompilerFactoryBuilder.java    |  38 ++---
 .../algebricks/compiler/api/ICompiler.java      |   8 +-
 .../compiler/api/ICompilerFactory.java          |   6 +-
 .../PrioritizedRuleController.java              |  10 +-
 .../SequentialFixpointRuleController.java       |  10 +-
 .../SequentialOnceRuleController.java           |  10 +-
 algebricks/algebricks-core/pom.xml              |  12 +-
 .../algebricks/core/algebra/base/Counter.java   |   2 +-
 .../core/algebra/base/EquivalenceClass.java     |   4 +-
 .../core/algebra/base/IHyracksJobBuilder.java   |  16 +--
 .../core/algebra/base/ILogicalExpression.java   |   8 +-
 .../core/algebra/base/ILogicalOperator.java     |  24 ++--
 .../core/algebra/base/ILogicalPlan.java         |   2 +-
 .../algebra/base/ILogicalPlanAndMetadata.java   |   6 +-
 .../core/algebra/base/IOptimizationContext.java |  24 ++--
 .../core/algebra/base/IPhysicalOperator.java    |  14 +-
 .../core/algebra/base/LogicalExpressionTag.java |   2 +-
 .../core/algebra/base/LogicalOperatorTag.java   |   2 +-
 .../core/algebra/base/LogicalVariable.java      |   2 +-
 .../core/algebra/base/OperatorAnnotations.java  |   2 +-
 .../core/algebra/base/PhysicalOperatorTag.java  |   2 +-
 .../AbstractFunctionCallExpression.java         |  18 +--
 .../expressions/AbstractLogicalExpression.java  |  10 +-
 .../AggregateFunctionCallExpression.java        |  10 +-
 .../BroadcastExpressionAnnotation.java          |   2 +-
 .../algebra/expressions/ConstantExpression.java |  12 +-
 .../ExpressionAnnotationNoCopyImpl.java         |   2 +-
 .../expressions/IAlgebricksConstantValue.java   |   2 +-
 .../expressions/IExpressionAnnotation.java      |   2 +-
 .../IExpressionEvalSizeComputer.java            |   6 +-
 .../expressions/IExpressionRuntimeProvider.java |  20 +--
 .../expressions/IExpressionTypeComputer.java    |   8 +-
 .../expressions/ILogicalExpressionJobGen.java   |  22 +--
 .../IMergeAggregationExpressionFactory.java     |  10 +-
 .../expressions/INullableTypeComputer.java      |   4 +-
 .../IPartialAggregationTypeComputer.java        |   8 +-
 .../IVariableEvalSizeEnvironment.java           |   4 +-
 .../expressions/IVariableTypeEnvironment.java   |   8 +-
 .../IndexedNLJoinExpressionAnnotation.java      |   2 +-
 ...obGenToExpressionRuntimeProviderAdapter.java |  54 +++----
 .../ScalarFunctionCallExpression.java           |  10 +-
 .../StatefulFunctionCallExpression.java         |  14 +-
 .../UnnestingFunctionCallExpression.java        |  10 +-
 .../VariableReferenceExpression.java            |  12 +-
 .../algebra/functions/AbstractFunctionInfo.java |   2 +-
 .../functions/AlgebricksBuiltinFunctions.java   |   2 +-
 .../algebra/functions/FunctionIdentifier.java   |   2 +-
 .../core/algebra/functions/IFunctionInfo.java   |   2 +-
 .../core/algebra/metadata/IDataSink.java        |   4 +-
 .../core/algebra/metadata/IDataSource.java      |   6 +-
 .../core/algebra/metadata/IDataSourceIndex.java |   2 +-
 .../metadata/IDataSourcePropertiesProvider.java |   6 +-
 .../algebra/metadata/IMetadataProvider.java     |  32 ++---
 .../logical/AbstractAssignOperator.java         |  10 +-
 .../logical/AbstractBinaryJoinOperator.java     |  14 +-
 .../logical/AbstractDataSourceOperator.java     |   8 +-
 .../AbstractExtensibleLogicalOperator.java      |   8 +-
 .../logical/AbstractLogicalOperator.java        |  34 ++---
 .../AbstractOperatorWithNestedPlans.java        |   8 +-
 .../operators/logical/AbstractScanOperator.java |   8 +-
 .../logical/AbstractUnnestOperator.java         |  10 +-
 .../operators/logical/AggregateOperator.java    |  20 +--
 .../operators/logical/AssignOperator.java       |  26 ++--
 .../logical/DataSourceScanOperator.java         |  22 +--
 .../operators/logical/DistinctOperator.java     |  24 ++--
 .../logical/DistributeResultOperator.java       |  22 +--
 .../logical/EmptyTupleSourceOperator.java       |  20 +--
 .../operators/logical/ExchangeOperator.java     |  20 +--
 .../operators/logical/ExtensionOperator.java    |  20 +--
 .../logical/ExternalDataLookupOperator.java     |  26 ++--
 .../operators/logical/GroupByOperator.java      |  38 ++---
 .../operators/logical/IOperatorExtension.java   |  12 +-
 .../operators/logical/IOperatorSchema.java      |   4 +-
 .../logical/IndexInsertDeleteOperator.java      |  26 ++--
 .../operators/logical/InnerJoinOperator.java    |  16 +--
 .../operators/logical/InsertDeleteOperator.java |  22 +--
 .../logical/LeftOuterJoinOperator.java          |  28 ++--
 .../operators/logical/LimitOperator.java        |  20 +--
 .../operators/logical/MaterializeOperator.java  |  18 +--
 .../logical/NestedTupleSourceOperator.java      |  26 ++--
 .../operators/logical/OrderOperator.java        |  24 ++--
 .../logical/PartitioningSplitOperator.java      |  22 +--
 .../operators/logical/ProjectOperator.java      |  20 +--
 .../operators/logical/ReplicateOperator.java    |  20 +--
 .../logical/RunningAggregateOperator.java       |  18 +--
 .../operators/logical/ScriptOperator.java       |  24 ++--
 .../operators/logical/SelectOperator.java       |  36 ++---
 .../algebra/operators/logical/SinkOperator.java |  30 ++--
 .../operators/logical/SubplanOperator.java      |  32 ++---
 .../operators/logical/TokenizeOperator.java     |  24 ++--
 .../operators/logical/UnionAllOperator.java     |  22 +--
 .../operators/logical/UnnestMapOperator.java    |  20 +--
 .../operators/logical/UnnestOperator.java       |  20 +--
 .../operators/logical/UpdateOperator.java       |  16 +--
 .../operators/logical/WriteOperator.java        |  22 +--
 .../operators/logical/WriteResultOperator.java  |  22 +--
 .../visitors/FDsAndEquivClassesVisitor.java     | 108 +++++++-------
 .../visitors/IsomorphismOperatorVisitor.java    |  94 ++++++-------
 .../logical/visitors/IsomorphismUtilities.java  |  10 +-
 .../IsomorphismVariableMappingVisitor.java      |  88 ++++++------
 .../visitors/LogicalPropertiesVisitor.java      |  90 ++++++------
 .../visitors/OperatorDeepCopyVisitor.java       |  88 ++++++------
 .../visitors/ProducedVariableVisitor.java       |  82 +++++------
 .../logical/visitors/SchemaVariableVisitor.java |  84 +++++------
 .../visitors/SubstituteVariableVisitor.java     |  94 ++++++-------
 .../logical/visitors/UsedVariableVisitor.java   |  98 ++++++-------
 .../logical/visitors/VariableUtilities.java     |  14 +-
 .../physical/AbstractExchangePOperator.java     |  20 +--
 .../physical/AbstractHashJoinPOperator.java     |  38 ++---
 .../physical/AbstractJoinPOperator.java         |   8 +-
 .../physical/AbstractPhysicalOperator.java      |  50 +++----
 .../AbstractPreclusteredGroupByPOperator.java   |  58 ++++----
 ...gatePropertiesForUsedVariablesPOperator.java |  12 +-
 .../physical/AbstractScanPOperator.java         |   8 +-
 .../physical/AbstractStableSortPOperator.java   |  38 ++---
 .../operators/physical/AggregatePOperator.java  |  48 +++----
 .../operators/physical/AssignPOperator.java     |  38 ++---
 .../operators/physical/BroadcastPOperator.java  |  38 ++---
 .../operators/physical/BulkloadPOperator.java   |  50 +++----
 .../physical/DataSourceScanPOperator.java       |  34 ++---
 .../physical/DistributeResultPOperator.java     |  56 ++++----
 .../physical/EmptyTupleSourcePOperator.java     |  32 ++---
 .../physical/ExternalGroupByPOperator.java      |  88 ++++++------
 .../HashPartitionExchangePOperator.java         |  50 +++----
 .../HashPartitionMergeExchangePOperator.java    |  72 +++++-----
 .../physical/HybridHashJoinPOperator.java       |  66 ++++-----
 .../physical/InMemoryHashJoinPOperator.java     |  52 +++----
 .../physical/InMemoryStableSortPOperator.java   |  38 ++---
 .../physical/IndexBulkloadPOperator.java        |  60 ++++----
 .../physical/IndexInsertDeletePOperator.java    |  52 +++----
 .../physical/InsertDeletePOperator.java         |  50 +++----
 .../physical/MaterializePOperator.java          |  32 ++---
 .../MicroPreclusteredGroupByPOperator.java      |  42 +++---
 .../operators/physical/NLJoinPOperator.java     |  78 +++++------
 .../physical/NestedTupleSourcePOperator.java    |  38 ++---
 .../physical/OneToOneExchangePOperator.java     |  32 ++---
 .../physical/PreSortedDistinctByPOperator.java  |  60 ++++----
 .../physical/PreclusteredGroupByPOperator.java  |  48 +++----
 .../physical/RandomMergeExchangePOperator.java  |  32 ++---
 .../physical/RandomPartitionPOperator.java      |  42 +++---
 .../physical/RangePartitionMergePOperator.java  |  70 +++++-----
 .../physical/RangePartitionPOperator.java       |  60 ++++----
 .../operators/physical/ReplicatePOperator.java  |  36 ++---
 .../physical/RunningAggregatePOperator.java     |  42 +++---
 .../operators/physical/SinkPOperator.java       |  42 +++---
 .../operators/physical/SinkWritePOperator.java  |  54 +++----
 .../physical/SortGroupByPOperator.java          |  82 +++++------
 .../physical/SortMergeExchangePOperator.java    |  64 ++++-----
 .../operators/physical/StableSortPOperator.java |  42 +++---
 .../physical/StreamLimitPOperator.java          |  44 +++---
 .../physical/StreamProjectPOperator.java        |  30 ++--
 .../physical/StreamSelectPOperator.java         |  32 ++---
 .../StringStreamingScriptPOperator.java         |  34 ++---
 .../operators/physical/SubplanPOperator.java    |  42 +++---
 .../operators/physical/TokenizePOperator.java   |  48 +++----
 .../operators/physical/UnionAllPOperator.java   |  44 +++---
 .../operators/physical/UnnestPOperator.java     |  42 +++---
 .../physical/WriteResultPOperator.java          |  42 +++---
 .../core/algebra/plan/ALogicalPlanImpl.java     |   6 +-
 .../LogicalExpressionPrettyPrintVisitor.java    |  18 +--
 .../LogicalOperatorPrettyPrintVisitor.java      |  86 ++++++------
 .../core/algebra/prettyprint/PlanPlotter.java   |  10 +-
 .../algebra/prettyprint/PlanPrettyPrinter.java  |  14 +-
 .../properties/AbstractGroupingProperty.java    |   8 +-
 .../BroadcastPartitioningProperty.java          |   6 +-
 .../properties/DefaultNodeGroupDomain.java      |   2 +-
 .../algebra/properties/FileSplitDomain.java     |   4 +-
 .../FilteredVariablePropagationPolicy.java      |   6 +-
 .../properties/FunctionalDependency.java        |   4 +-
 .../properties/ILocalStructuralProperty.java    |   4 +-
 .../properties/ILogicalPropertiesVector.java    |   2 +-
 .../core/algebra/properties/INodeDomain.java    |   2 +-
 .../properties/IPartitioningProperty.java       |   6 +-
 .../IPartitioningRequirementsCoordinator.java   |  18 +--
 .../properties/IPhysicalPropertiesVector.java   |   6 +-
 .../algebra/properties/IPropertiesComputer.java |   4 +-
 .../algebra/properties/IStructuralProperty.java |   4 +-
 .../properties/LocalGroupingProperty.java       |   6 +-
 .../algebra/properties/LocalOrderProperty.java  |  10 +-
 .../properties/LogicalPropertiesVectorImpl.java |   2 +-
 .../core/algebra/properties/OrderColumn.java    |   6 +-
 .../properties/OrderedPartitionedProperty.java  |   6 +-
 .../properties/PhysicalRequirements.java        |   2 +-
 .../core/algebra/properties/PropertiesUtil.java |  10 +-
 .../properties/RandomPartitioningProperty.java  |   6 +-
 .../algebra/properties/ResultSetDomain.java     |   2 +-
 .../properties/StructuralPropertiesVector.java  |   6 +-
 .../properties/TypePropagationPolicy.java       |  12 +-
 .../UnorderedPartitionedProperty.java           |   6 +-
 .../UnpartitionedPropertyComputer.java          |   4 +-
 .../properties/VariablePropagationPolicy.java   |   8 +-
 .../algebra/scripting/IScriptDescription.java   |   6 +-
 .../StringStreamingScriptDescription.java       |  10 +-
 .../algebra/typing/AbstractTypeEnvironment.java |  14 +-
 .../core/algebra/typing/ITypeEnvPointer.java    |   4 +-
 .../core/algebra/typing/ITypingContext.java     |  12 +-
 .../typing/NonPropagatingTypeEnvironment.java   |  10 +-
 .../algebra/typing/OpRefTypeEnvPointer.java     |   6 +-
 .../PropagateOperatorInputsTypeEnvironment.java |  14 +-
 .../typing/PropagatingTypeEnvironment.java      |  14 +-
 .../algebra/util/OperatorManipulationUtil.java  |  36 ++---
 .../algebra/util/OperatorPropertiesUtil.java    |  34 ++---
 .../visitors/AbstractConstVarFunVisitor.java    |  14 +-
 .../ILogicalExpressionReferenceTransform.java   |   6 +-
 .../visitors/ILogicalExpressionVisitor.java     |  16 +--
 .../visitors/ILogicalOperatorVisitor.java       |  70 +++++-----
 .../core/config/AlgebricksConfig.java           |   4 +-
 .../algebricks/core/config/SysoutFormatter.java |   2 +-
 .../impl/ConnectorPolicyAssignmentPolicy.java   |  14 +-
 .../algebricks/core/jobgen/impl/JobBuilder.java |  36 ++---
 .../core/jobgen/impl/JobGenContext.java         |  52 +++----
 .../core/jobgen/impl/JobGenHelper.java          |  40 +++---
 .../core/jobgen/impl/OperatorSchemaImpl.java    |   6 +-
 .../core/jobgen/impl/PlanCompiler.java          |  22 +--
 .../rewriter/base/AbstractRuleController.java   |  20 +--
 .../base/AlgebricksOptimizationContext.java     |  32 ++---
 .../core/rewriter/base/HeuristicOptimizer.java  |  22 +--
 .../rewriter/base/IAlgebraicRewriteRule.java    |   8 +-
 .../base/IOptimizationContextFactory.java       |  12 +-
 .../base/PhysicalOptimizationConfig.java        |   2 +-
 .../algebricks/core/utils/Substitution.java     |   2 +-
 algebricks/algebricks-data/pom.xml              |   6 +-
 .../hyracks/algebricks/data/IAWriter.java       |   6 +-
 .../algebricks/data/IAWriterFactory.java        |   4 +-
 .../data/IBinaryBooleanInspector.java           |   2 +-
 .../data/IBinaryBooleanInspectorFactory.java    |   4 +-
 .../data/IBinaryComparatorFactoryProvider.java  |   6 +-
 .../IBinaryHashFunctionFactoryProvider.java     |   6 +-
 .../data/IBinaryHashFunctionFamilyProvider.java |   6 +-
 .../data/IBinaryIntegerInspector.java           |   4 +-
 .../data/IBinaryIntegerInspectorFactory.java    |   4 +-
 .../ILinearizeComparatorFactoryProvider.java    |   6 +-
 .../INormalizedKeyComputerFactoryProvider.java  |   4 +-
 .../hyracks/algebricks/data/IPrinter.java       |   4 +-
 .../algebricks/data/IPrinterFactory.java        |   2 +-
 .../data/IPrinterFactoryProvider.java           |   4 +-
 .../data/IResultSerializerFactoryProvider.java  |   4 +-
 .../data/ISerializerDeserializerProvider.java   |   6 +-
 .../algebricks/data/ITypeTraitProvider.java     |   4 +-
 .../data/impl/BinaryBooleanInspectorImpl.java   |   8 +-
 .../data/impl/BinaryIntegerInspectorImpl.java   |  10 +-
 .../data/impl/IntegerPrinterFactory.java        |  12 +-
 .../data/impl/NoopNullWriterFactory.java        |   8 +-
 .../data/impl/UTF8StringPrinterFactory.java     |  10 +-
 .../algebricks/data/utils/WriteValueTools.java  |   4 +-
 .../algebricks-examples/piglet-example/pom.xml  |   4 +-
 .../algebricks/examples/piglet/ast/ASTNode.java |   2 +-
 .../examples/piglet/ast/AssignmentNode.java     |   2 +-
 .../examples/piglet/ast/DumpNode.java           |   2 +-
 .../examples/piglet/ast/ExpressionNode.java     |   2 +-
 .../piglet/ast/FieldAccessExpressionNode.java   |   2 +-
 .../examples/piglet/ast/FilterNode.java         |   2 +-
 .../examples/piglet/ast/FunctionTag.java        |   2 +-
 .../piglet/ast/LiteralExpressionNode.java       |   4 +-
 .../examples/piglet/ast/LoadNode.java           |   4 +-
 .../examples/piglet/ast/RelationNode.java       |   2 +-
 .../ast/ScalarFunctionExpressionNode.java       |   2 +-
 .../examples/piglet/compiler/ConstantValue.java |   6 +-
 .../piglet/compiler/PigletCompiler.java         | 114 +++++++--------
 .../compiler/PigletPrinterFactoryProvider.java  |  20 +--
 .../piglet/exceptions/PigletException.java      |   2 +-
 .../piglet/metadata/FileSplitUtils.java         |   6 +-
 .../piglet/metadata/PigletFileDataSink.java     |  12 +-
 .../piglet/metadata/PigletFileDataSource.java   |  22 +--
 .../piglet/metadata/PigletFunction.java         |   6 +-
 .../piglet/metadata/PigletMetadataProvider.java |  78 +++++------
 .../piglet/rewriter/PigletRewriteRuleset.java   |  50 +++----
 .../piglet/runtime/PigletExpressionJobGen.java  |  56 ++++----
 .../IPigletFunctionEvaluatorFactoryBuilder.java |   6 +-
 .../IntegerEqFunctionEvaluatorFactory.java      |  18 +--
 .../functions/PigletFunctionRegistry.java       |  10 +-
 .../examples/piglet/types/BagType.java          |   2 +-
 .../examples/piglet/types/CharArrayType.java    |   2 +-
 .../examples/piglet/types/DoubleType.java       |   2 +-
 .../examples/piglet/types/FloatType.java        |   2 +-
 .../examples/piglet/types/IntegerType.java      |   2 +-
 .../examples/piglet/types/LongType.java         |   2 +-
 .../examples/piglet/types/MapType.java          |   2 +-
 .../examples/piglet/types/Schema.java           |   4 +-
 .../examples/piglet/types/TupleType.java        |   2 +-
 .../algebricks/examples/piglet/types/Type.java  |   2 +-
 .../src/main/javacc/PigletParser.jj             |   8 +-
 .../examples/piglet/test/PigletTest.java        |   2 +-
 .../examples/piglet/test/PigletTestCase.java    |   8 +-
 algebricks/algebricks-examples/pom.xml          |   2 +-
 algebricks/algebricks-rewriter/pom.xml          |   4 +-
 .../rules/AbstractDecorrelationRule.java        |  32 ++---
 .../rewriter/rules/AbstractExtractExprRule.java |  18 +--
 .../rules/AbstractIntroduceCombinerRule.java    |  32 ++---
 .../AbstractIntroduceGroupByCombinerRule.java   |  42 +++---
 .../rules/BreakSelectIntoConjunctsRule.java     |  18 +--
 .../rules/ComplexJoinInferenceRule.java         |  36 ++---
 .../rules/ComplexUnnestToProductRule.java       |  28 ++--
 .../rewriter/rules/ConsolidateAssignsRule.java  |  20 +--
 .../rewriter/rules/ConsolidateSelectsRule.java  |  26 ++--
 .../rewriter/rules/CopyLimitDownRule.java       |  32 ++---
 .../rules/EliminateGroupByEmptyKeyRule.java     |  20 +--
 .../rewriter/rules/EliminateSubplanRule.java    |  28 ++--
 ...inateSubplanWithInputCardinalityOneRule.java |  26 ++--
 .../rules/EnforceOrderByAfterSubplan.java       |  24 ++--
 .../rules/EnforceStructuralPropertiesRule.java  | 128 ++++++++---------
 .../rules/ExtractCommonExpressionsRule.java     |  42 +++---
 .../rules/ExtractCommonOperatorsRule.java       |  44 +++---
 .../ExtractFunctionsFromJoinConditionRule.java  |  34 ++---
 .../rules/ExtractGbyExpressionsRule.java        |  24 ++--
 .../FactorRedundantGroupAndDecorVarsRule.java   |  28 ++--
 .../rewriter/rules/InferTypesRule.java          |  10 +-
 .../rules/InlineAssignIntoAggregateRule.java    |  36 ++---
 .../InlineSingleReferenceVariablesRule.java     |  14 +-
 .../rewriter/rules/InlineVariablesRule.java     |  38 ++---
 .../rewriter/rules/InsertOuterJoinRule.java     |  24 ++--
 .../rules/InsertProjectBeforeUnionRule.java     |  26 ++--
 .../rules/IntroHashPartitionMergeExchange.java  |  22 +--
 .../rules/IntroJoinInsideSubplanRule.java       |  30 ++--
 .../rules/IntroduceAggregateCombinerRule.java   |  18 +--
 .../rules/IntroduceGroupByCombinerRule.java     |   8 +-
 .../rules/IntroduceGroupByForSubplanRule.java   |  68 ++++-----
 .../rewriter/rules/IntroduceProjectsRule.java   |  24 ++--
 .../rules/IsolateHyracksOperatorsRule.java      |  26 ++--
 ...oveFreeVariableOperatorOutOfSubplanRule.java |  25 ++--
 .../rewriter/rules/NestedSubplanToJoinRule.java |  30 ++--
 .../rewriter/rules/PullSelectOutOfEqJoin.java   |  32 ++---
 .../rules/PushAssignBelowUnionAllRule.java      |  26 ++--
 .../rules/PushAssignDownThroughProductRule.java |  22 +--
 .../rewriter/rules/PushFunctionsBelowJoin.java  |  34 ++---
 .../rewriter/rules/PushGroupByIntoSortRule.java |  32 ++---
 .../PushMapOperatorDownThroughProductRule.java  |  22 +--
 ...hNestedOrderByUnderPreSortedGroupByRule.java |  38 ++---
 .../rewriter/rules/PushProjectDownRule.java     |  30 ++--
 .../PushProjectIntoDataSourceScanRule.java      |  18 +--
 .../rewriter/rules/PushSelectDownRule.java      |  22 +--
 .../rewriter/rules/PushSelectIntoJoinRule.java  |  36 ++---
 .../rules/PushSubplanIntoGroupByRule.java       |  32 ++---
 ...planWithAggregateDownThroughProductRule.java |  26 ++--
 .../rules/PushUnnestDownThroughProductRule.java |  22 +--
 .../rules/PushUnnestDownThroughUnionRule.java   |  26 ++--
 .../rewriter/rules/ReinferAllTypesRule.java     |  16 +--
 .../rules/RemoveRedundantGroupByDecorVars.java  |  26 ++--
 .../rules/RemoveRedundantProjectionRule.java    |  20 +--
 .../rules/RemoveRedundantVariablesRule.java     |  44 +++---
 .../RemoveUnusedAssignAndAggregateRule.java     |  36 ++---
 .../SetAlgebricksPhysicalOperatorsRule.java     | 124 ++++++++--------
 .../rewriter/rules/SetExecutionModeRule.java    |  14 +-
 .../rules/SimpleUnnestToProductRule.java        |  30 ++--
 .../rewriter/rules/SubplanOutOfGroupRule.java   |  26 ++--
 .../algebricks/rewriter/util/JoinUtils.java     |  46 +++---
 .../util/PhysicalOptimizationsUtil.java         |  22 +--
 algebricks/algebricks-runtime/pom.xml           |  12 +-
 .../TupleCountAggregateFunctionFactory.java     |  16 +--
 ...pleCountRunningAggregateFunctionFactory.java |  14 +-
 .../runtime/base/AlgebricksPipeline.java        |   4 +-
 .../runtime/base/IAggregateEvaluator.java       |   8 +-
 .../base/IAggregateEvaluatorFactory.java        |   6 +-
 .../runtime/base/ICopyAggregateFunction.java    |   6 +-
 .../base/ICopyAggregateFunctionFactory.java     |   6 +-
 .../algebricks/runtime/base/ICopyEvaluator.java |   6 +-
 .../runtime/base/ICopyEvaluatorFactory.java     |   6 +-
 .../base/ICopyRunningAggregateFunction.java     |   6 +-
 .../ICopyRunningAggregateFunctionFactory.java   |   6 +-
 .../ICopySerializableAggregateFunction.java     |   6 +-
 ...opySerializableAggregateFunctionFactory.java |   4 +-
 .../runtime/base/ICopyUnnestingFunction.java    |   6 +-
 .../base/ICopyUnnestingFunctionFactory.java     |   6 +-
 .../algebricks/runtime/base/IPushRuntime.java   |   6 +-
 .../runtime/base/IPushRuntimeFactory.java       |   8 +-
 .../base/IRunningAggregateEvaluator.java        |   8 +-
 .../base/IRunningAggregateEvaluatorFactory.java |   4 +-
 .../runtime/base/IScalarEvaluator.java          |   8 +-
 .../runtime/base/IScalarEvaluatorFactory.java   |   6 +-
 .../runtime/base/IUnnestingEvaluator.java       |   8 +-
 .../base/IUnnestingEvaluatorFactory.java        |   6 +-
 .../runtime/base/IUnnestingPositionWriter.java  |   2 +-
 .../evaluators/ColumnAccessEvalFactory.java     |  12 +-
 .../runtime/evaluators/ConstantEvalFactory.java |  12 +-
 .../evaluators/ConstantEvaluatorFactory.java    |  14 +-
 .../evaluators/TupleFieldEvaluatorFactory.java  |  14 +-
 .../aggreg/AggregateRuntimeFactory.java         |  24 ++--
 ...estedPlansAccumulatingAggregatorFactory.java |  32 ++---
 .../NestedPlansRunningAggregatorFactory.java    |  40 +++---
 ...SerializableAggregatorDescriptorFactory.java |  26 ++--
 ...AlgebricksAccumulatingAggregatorFactory.java |  32 ++---
 ...eInputOneOutputOneFieldFramePushRuntime.java |  22 +--
 ...actOneInputOneOutputOneFramePushRuntime.java |  26 ++--
 .../AbstractOneInputOneOutputPushRuntime.java   |   4 +-
 ...AbstractOneInputOneOutputRuntimeFactory.java |  12 +-
 .../base/AbstractOneInputPushRuntime.java       |  10 +-
 .../base/AbstractOneInputSinkPushRuntime.java   |   8 +-
 .../base/AbstractOneInputSourcePushRuntime.java |   6 +-
 .../operators/base/SinkRuntimeFactory.java      |  12 +-
 .../MicroPreClusteredGroupRuntimeFactory.java   |  26 ++--
 .../meta/AlgebricksMetaOperatorDescriptor.java  |  28 ++--
 .../operators/meta/PipelineAssembler.java       |  16 +--
 .../operators/meta/SubplanRuntimeFactory.java   |  34 ++---
 .../sort/InMemorySortRuntimeFactory.java        |  28 ++--
 .../operators/std/AssignRuntimeFactory.java     |  26 ++--
 .../std/EmptyTupleSourceRuntimeFactory.java     |  20 +--
 .../std/NestedTupleSourceRuntimeFactory.java    |  12 +-
 .../PartitioningSplitOperatorDescriptor.java    |  44 +++---
 .../operators/std/PrinterRuntimeFactory.java    |  16 +--
 .../std/RunningAggregateRuntimeFactory.java     |  26 ++--
 .../operators/std/SinkWriterRuntime.java        |  16 +--
 .../operators/std/SinkWriterRuntimeFactory.java |  18 +--
 .../std/StreamLimitRuntimeFactory.java          |  24 ++--
 .../std/StreamProjectRuntimeFactory.java        |  12 +-
 .../std/StreamSelectRuntimeFactory.java         |  32 ++---
 .../std/StringStreamingRuntimeFactory.java      |  20 +--
 .../operators/std/UnnestRuntimeFactory.java     |  34 ++---
 .../ResultSerializerFactoryProvider.java        |  22 +--
 .../writers/PrinterBasedWriterFactory.java      |  16 +--
 .../writers/SerializedDataWriterFactory.java    |  14 +-
 algebricks/algebricks-tests/pom.xml             |  12 +-
 .../tests/pushruntime/IntArrayUnnester.java     |  16 +--
 .../pushruntime/IntegerAddEvalFactory.java      |  22 +--
 .../pushruntime/IntegerConstantEvalFactory.java |  22 +--
 .../pushruntime/IntegerEqualsEvalFactory.java   |  22 +--
 .../IntegerGreaterThanEvalFactory.java          |  22 +--
 .../tests/script/IdentityStreamingScript.java   |   2 +-
 .../tests/pushruntime/PushRuntimeTest.java      | 140 +++++++++----------
 .../algebricks/tests/tools/WriteValueTest.java  |   6 +-
 .../util/AlgebricksHyracksIntegrationUtil.java  |  22 +--
 algebricks/pom.xml                              |   4 +-
 hyracks/hyracks-api/pom.xml                     |   4 +-
 .../api/application/IApplicationContext.java    |   6 +-
 .../api/application/ICCApplicationContext.java  |   6 +-
 .../application/ICCApplicationEntryPoint.java   |   2 +-
 .../application/IClusterLifecycleListener.java  |   2 +-
 .../api/application/INCApplicationContext.java  |   8 +-
 .../application/INCApplicationEntryPoint.java   |   2 +-
 .../api/application/IStateDumpHandler.java      |   2 +-
 .../hyracks/api/channels/IInputChannel.java     |   6 +-
 .../api/channels/IInputChannelMonitor.java      |   2 +-
 .../api/client/ClusterControllerInfo.java       |   2 +-
 .../client/HyracksClientInterfaceFunctions.java |  12 +-
 .../HyracksClientInterfaceRemoteProxy.java      |  22 +--
 .../hyracks/api/client/HyracksConnection.java   |  34 ++---
 .../api/client/IHyracksClientConnection.java    |  20 +--
 .../api/client/IHyracksClientInterface.java     |  16 +--
 .../hyracks/api/client/NodeControllerInfo.java  |   4 +-
 .../apache/hyracks/api/client/NodeStatus.java   |   2 +-
 .../impl/ActivityClusterGraphBuilder.java       |  18 +--
 .../impl/IConnectorDescriptorVisitor.java       |   6 +-
 .../client/impl/IOperatorDescriptorVisitor.java |   6 +-
 .../client/impl/JobActivityGraphBuilder.java    |  20 +--
 ...ionActivityClusterGraphGeneratorFactory.java |  30 ++--
 .../hyracks/api/client/impl/PlanUtils.java      |  12 +-
 .../apache/hyracks/api/comm/FixedSizeFrame.java |   4 +-
 .../apache/hyracks/api/comm/FrameConstants.java |   2 +-
 .../apache/hyracks/api/comm/FrameHelper.java    |   2 +-
 .../org/apache/hyracks/api/comm/IFrame.java     |   4 +-
 .../apache/hyracks/api/comm/IFrameAppender.java |   4 +-
 .../hyracks/api/comm/IFrameFieldAppender.java   |   4 +-
 .../apache/hyracks/api/comm/IFrameReader.java   |   4 +-
 .../hyracks/api/comm/IFrameTupleAccessor.java   |   2 +-
 .../hyracks/api/comm/IFrameTupleAppender.java   |   4 +-
 .../apache/hyracks/api/comm/IFrameWriter.java   |   4 +-
 .../hyracks/api/comm/IPartitionCollector.java   |  10 +-
 .../api/comm/IPartitionWriterFactory.java       |   4 +-
 .../apache/hyracks/api/comm/NetworkAddress.java |   4 +-
 .../hyracks/api/comm/NoShrinkVSizeFrame.java    |   6 +-
 .../hyracks/api/comm/PartitionChannel.java      |   6 +-
 .../org/apache/hyracks/api/comm/VSizeFrame.java |   6 +-
 .../hyracks/api/constraints/Constraint.java     |   6 +-
 .../api/constraints/IConstraintAcceptor.java    |   2 +-
 .../constraints/PartitionConstraintHelper.java  |  12 +-
 .../expressions/ConstantExpression.java         |   2 +-
 .../expressions/ConstraintExpression.java       |   2 +-
 .../expressions/LValueConstraintExpression.java |   2 +-
 .../expressions/PartitionCountExpression.java   |   4 +-
 .../PartitionLocationExpression.java            |   4 +-
 .../apache/hyracks/api/context/ICCContext.java  |   6 +-
 .../api/context/IHyracksCommonContext.java      |   4 +-
 .../api/context/IHyracksFrameMgrContext.java    |   4 +-
 .../api/context/IHyracksJobletContext.java      |  12 +-
 .../api/context/IHyracksRootContext.java        |   6 +-
 .../api/context/IHyracksTaskContext.java        |  16 +--
 .../apache/hyracks/api/dataflow/ActivityId.java |   4 +-
 .../api/dataflow/ConnectorDescriptorId.java     |   4 +-
 .../apache/hyracks/api/dataflow/IActivity.java  |   8 +-
 .../api/dataflow/IActivityGraphBuilder.java     |   2 +-
 .../api/dataflow/IConnectorDescriptor.java      |  20 +--
 .../hyracks/api/dataflow/IDataReader.java       |   4 +-
 .../hyracks/api/dataflow/IDataWriter.java       |   4 +-
 .../api/dataflow/IOpenableDataReader.java       |   4 +-
 .../api/dataflow/IOpenableDataWriter.java       |   4 +-
 .../api/dataflow/IOperatorDescriptor.java       |   8 +-
 .../api/dataflow/IOperatorNodePullable.java     |   2 +-
 .../api/dataflow/IOperatorNodePushable.java     |   8 +-
 .../api/dataflow/OperatorDescriptorId.java      |   4 +-
 .../api/dataflow/OperatorInstanceId.java        |   2 +-
 .../hyracks/api/dataflow/TaskAttemptId.java     |   4 +-
 .../org/apache/hyracks/api/dataflow/TaskId.java |   4 +-
 .../connectors/ConnectorPolicyFactory.java      |   2 +-
 .../dataflow/connectors/IConnectorPolicy.java   |   2 +-
 .../IConnectorPolicyAssignmentPolicy.java       |   4 +-
 .../connectors/PipeliningConnectorPolicy.java   |   2 +-
 ...SideMaterializedBlockingConnectorPolicy.java |   2 +-
 ...deMaterializedPipeliningConnectorPolicy.java |   2 +-
 ...SideMaterializedBlockingConnectorPolicy.java |   2 +-
 ...deMaterializedPipeliningConnectorPolicy.java |   2 +-
 ...SideMaterializedBlockingConnectorPolicy.java |   2 +-
 .../api/dataflow/state/IStateObject.java        |   4 +-
 .../value/BinaryComparatorConstant.java         |   2 +-
 .../api/dataflow/value/IBinaryComparator.java   |   4 +-
 .../value/IBinaryComparatorFactory.java         |   2 +-
 .../api/dataflow/value/IBinaryHashFunction.java |   4 +-
 .../value/IBinaryHashFunctionFactory.java       |   2 +-
 .../value/IBinaryHashFunctionFamily.java        |   2 +-
 .../hyracks/api/dataflow/value/IComparator.java |   2 +-
 .../api/dataflow/value/IComparatorFactory.java  |   2 +-
 .../api/dataflow/value/IHashFunction.java       |   4 +-
 .../dataflow/value/IHashFunctionFactory.java    |   2 +-
 .../dataflow/value/ILinearizeComparator.java    |   2 +-
 .../value/ILinearizeComparatorFactory.java      |   2 +-
 .../dataflow/value/INormalizedKeyComputer.java  |   2 +-
 .../value/INormalizedKeyComputerFactory.java    |   2 +-
 .../hyracks/api/dataflow/value/INullWriter.java |   4 +-
 .../api/dataflow/value/INullWriterFactory.java  |   2 +-
 .../api/dataflow/value/IPredicateEvaluator.java |   4 +-
 .../value/IPredicateEvaluatorFactory.java       |   2 +-
 .../IPredicateEvaluatorFactoryProvider.java     |   2 +-
 .../value/IRecordDescriptorProvider.java        |   4 +-
 .../api/dataflow/value/IResultSerializer.java   |   6 +-
 .../value/IResultSerializerFactory.java         |   2 +-
 .../dataflow/value/ISerializerDeserializer.java |   4 +-
 .../dataflow/value/ITuplePairComparator.java    |   6 +-
 .../value/ITuplePairComparatorFactory.java      |   4 +-
 .../dataflow/value/ITuplePartitionComputer.java |   6 +-
 .../value/ITuplePartitionComputerFactory.java   |   2 +-
 .../value/ITuplePartitionComputerFamily.java    |   2 +-
 .../hyracks/api/dataflow/value/ITypeTraits.java |   2 +-
 .../api/dataflow/value/JSONSerializable.java    |   2 +-
 .../api/dataflow/value/RecordDescriptor.java    |   2 +-
 .../api/dataset/DatasetDirectoryRecord.java     |   4 +-
 .../hyracks/api/dataset/DatasetJobRecord.java   |   2 +-
 .../dataset/IDatasetInputChannelMonitor.java    |   4 +-
 .../hyracks/api/dataset/IDatasetManager.java    |   4 +-
 .../api/dataset/IDatasetPartitionManager.java   |  12 +-
 .../api/dataset/IDatasetStateRecord.java        |   2 +-
 .../hyracks/api/dataset/IHyracksDataset.java    |   6 +-
 ...yracksDatasetDirectoryServiceConnection.java |   6 +-
 ...HyracksDatasetDirectoryServiceInterface.java |   6 +-
 .../api/dataset/IHyracksDatasetReader.java      |   8 +-
 .../apache/hyracks/api/dataset/ResultSetId.java |   2 +-
 .../hyracks/api/dataset/ResultSetMetaData.java  |   2 +-
 .../hyracks/api/deployment/DeploymentId.java    |   4 +-
 .../api/exceptions/HyracksDataException.java    |   2 +-
 .../api/exceptions/HyracksException.java        |   2 +-
 .../apache/hyracks/api/io/FileReference.java    |   2 +-
 .../org/apache/hyracks/api/io/IFileHandle.java  |   2 +-
 .../org/apache/hyracks/api/io/IIOFuture.java    |   4 +-
 .../org/apache/hyracks/api/io/IIOManager.java   |   4 +-
 .../apache/hyracks/api/io/IODeviceHandle.java   |   2 +-
 .../hyracks/api/io/IWorkspaceFileFactory.java   |   4 +-
 .../org/apache/hyracks/api/io/IWritable.java    |   2 +-
 .../apache/hyracks/api/job/ActivityCluster.java |  14 +-
 .../hyracks/api/job/ActivityClusterGraph.java   |  10 +-
 .../hyracks/api/job/ActivityClusterId.java      |   2 +-
 .../api/job/IActivityClusterGraphGenerator.java |   4 +-
 .../IActivityClusterGraphGeneratorFactory.java  |   6 +-
 .../api/job/IConnectorDescriptorRegistry.java   |   6 +-
 .../hyracks/api/job/IGlobalJobDataFactory.java  |   4 +-
 .../hyracks/api/job/IJobLifecycleListener.java  |   4 +-
 .../api/job/IJobSerializerDeserializer.java     |   4 +-
 .../IJobSerializerDeserializerContainer.java    |   4 +-
 .../hyracks/api/job/IJobletEventListener.java   |   2 +-
 .../api/job/IJobletEventListenerFactory.java    |   4 +-
 .../api/job/IOperatorDescriptorRegistry.java    |   6 +-
 .../hyracks/api/job/IOperatorEnvironment.java   |   4 +-
 .../hyracks/api/job/JobActivityGraph.java       |  12 +-
 .../org/apache/hyracks/api/job/JobFlag.java     |   2 +-
 .../java/org/apache/hyracks/api/job/JobId.java  |   4 +-
 .../org/apache/hyracks/api/job/JobInfo.java     |   4 +-
 .../api/job/JobSerializerDeserializer.java      |   6 +-
 .../job/JobSerializerDeserializerContainer.java |   4 +-
 .../hyracks/api/job/JobSpecification.java       |  24 ++--
 .../org/apache/hyracks/api/job/JobStatus.java   |   2 +-
 .../api/job/profiling/counters/ICounter.java    |   2 +-
 .../job/profiling/counters/ICounterContext.java |   2 +-
 .../api/lifecycle/ILifeCycleComponent.java      |   2 +-
 .../lifecycle/ILifeCycleComponentManager.java   |   2 +-
 .../lifecycle/LifeCycleComponentManager.java    |   2 +-
 .../apache/hyracks/api/messages/IMessage.java   |   2 +-
 .../hyracks/api/messages/IMessageBroker.java    |   2 +-
 .../hyracks/api/partitions/IPartition.java      |   8 +-
 .../hyracks/api/partitions/PartitionId.java     |   8 +-
 .../api/partitions/ResultSetPartitionId.java    |   6 +-
 .../api/replication/IIOReplicationManager.java  |   4 +-
 .../api/replication/IReplicationJob.java        |   2 +-
 .../impl/AbstractReplicationJob.java            |   4 +-
 .../hyracks/api/resources/IDeallocatable.java   |   2 +-
 .../api/resources/IDeallocatableRegistry.java   |   2 +-
 .../api/resources/memory/IMemoryManager.java    |   2 +-
 .../rewriter/ActivityClusterGraphRewriter.java  |  22 +--
 .../OneToOneConnectedActivityCluster.java       |  10 +-
 .../api/rewriter/runtime/SuperActivity.java     |  26 ++--
 .../SuperActivityOperatorNodePushable.java      |  20 +--
 .../hyracks/api/topology/ClusterTopology.java   |   2 +-
 .../hyracks/api/topology/NetworkEndpoint.java   |   2 +-
 .../hyracks/api/topology/NetworkSwitch.java     |   2 +-
 .../hyracks/api/topology/NetworkTerminal.java   |   2 +-
 .../api/topology/TopologyDefinitionParser.java  |   4 +-
 .../api/util/JavaSerializationUtils.java        |   2 +-
 hyracks/hyracks-client/pom.xml                  |  14 +-
 .../client/dataset/DatasetClientContext.java    |   8 +-
 .../hyracks/client/dataset/HyracksDataset.java  |  22 +--
 ...yracksDatasetDirectoryServiceConnection.java |  24 ++--
 ...setDirectoryServiceInterfaceRemoteProxy.java |  20 +--
 .../client/dataset/HyracksDatasetReader.java    |  36 ++---
 .../client/net/ClientNetworkManager.java        |  14 +-
 .../hyracks/client/stats/AggregateCounter.java  |   4 +-
 .../apache/hyracks/client/stats/Counters.java   |   2 +-
 .../client/stats/IClusterCounterContext.java    |   6 +-
 .../client/stats/impl/ClientCounterContext.java |  12 +-
 .../client/stats/ClientCounterContextTest.java  |   6 +-
 .../hyracks/client/stats/HyracksUtils.java      |  20 +--
 hyracks/hyracks-comm/pom.xml                    |   6 +-
 .../channels/DatasetNetworkInputChannel.java    |  20 +--
 .../channels/IChannelConnectionFactory.java     |   6 +-
 .../comm/channels/NetworkInputChannel.java      |  18 +--
 .../comm/channels/NetworkOutputChannel.java     |  10 +-
 .../comm/channels/ReadBufferFactory.java        |   6 +-
 .../hyracks-control/hyracks-control-cc/pom.xml  |   4 +-
 .../org/apache/hyracks/control/cc/CCDriver.java |   4 +-
 .../control/cc/ClusterControllerService.java    | 136 +++++++++---------
 .../hyracks/control/cc/NodeControllerState.java |  18 +--
 .../HyracksAdminConsoleApplication.java         |   6 +-
 .../cc/adminconsole/pages/AbstractPage.java     |   4 +-
 .../cc/adminconsole/pages/IndexPage.java        |  10 +-
 .../cc/adminconsole/pages/JobDetailsPage.java   |  16 +--
 .../cc/adminconsole/pages/NodeDetailsPage.java  |   2 +-
 .../cc/application/CCApplicationContext.java    |  22 +--
 .../cc/dataset/DatasetDirectoryService.java     |  28 ++--
 .../cc/dataset/IDatasetDirectoryService.java    |  20 +--
 .../control/cc/job/ActivityClusterPlan.java     |   4 +-
 .../hyracks/control/cc/job/ActivityPlan.java    |   4 +-
 .../cc/job/IJobStatusConditionVariable.java     |   2 +-
 .../apache/hyracks/control/cc/job/JobRun.java   |  44 +++---
 .../org/apache/hyracks/control/cc/job/Task.java |   4 +-
 .../hyracks/control/cc/job/TaskAttempt.java     |   4 +-
 .../hyracks/control/cc/job/TaskCluster.java     |   6 +-
 .../control/cc/job/TaskClusterAttempt.java      |   4 +-
 .../hyracks/control/cc/job/TaskClusterId.java   |   4 +-
 .../cc/partitions/PartitionMatchMaker.java      |  12 +-
 .../control/cc/partitions/PartitionUtils.java   |  16 +--
 .../cc/scheduler/ActivityClusterPlanner.java    |  42 +++---
 .../cc/scheduler/ActivityPartitionDetails.java  |   2 +-
 .../control/cc/scheduler/JobScheduler.java      |  66 ++++-----
 .../cc/scheduler/PartitionConstraintSolver.java |  10 +-
 .../cc/scheduler/RankedRunnableTaskCluster.java |   4 +-
 .../control/cc/scheduler/Runnability.java       |   2 +-
 .../cc/web/ApplicationInstallationHandler.java  |   6 +-
 .../control/cc/web/JobsRESTAPIFunction.java     |  14 +-
 .../control/cc/web/NodesRESTAPIFunction.java    |  10 +-
 .../cc/web/StateDumpRESTAPIFunction.java        |  10 +-
 .../hyracks/control/cc/web/WebServer.java       |  10 +-
 .../cc/web/util/IJSONOutputFunction.java        |   2 +-
 .../cc/web/util/JSONOutputRequestHandler.java   |   2 +-
 .../hyracks/control/cc/web/util/JSONUtils.java  |   2 +-
 .../control/cc/web/util/RoutingHandler.java     |   2 +-
 .../control/cc/work/AbstractHeartbeatWork.java  |  10 +-
 .../cc/work/AbstractTaskLifecycleWork.java      |  26 ++--
 .../control/cc/work/ApplicationMessageWork.java |  12 +-
 .../control/cc/work/CliDeployBinaryWork.java    |  16 +--
 .../control/cc/work/CliUnDeployBinaryWork.java  |  16 +--
 .../control/cc/work/ClusterShutdownWork.java    |  14 +-
 .../control/cc/work/GatherStateDumpsWork.java   |   8 +-
 .../work/GetActivityClusterGraphJSONWork.java   |  10 +-
 .../GetDatasetDirectoryServiceInfoWork.java     |  10 +-
 .../cc/work/GetIpAddressNodeNameMapWork.java    |   6 +-
 .../hyracks/control/cc/work/GetJobInfoWork.java |  14 +-
 .../control/cc/work/GetJobRunJSONWork.java      |  10 +-
 .../control/cc/work/GetJobStatusWork.java       |  14 +-
 .../cc/work/GetJobSummariesJSONWork.java        |   8 +-
 .../cc/work/GetNodeControllersInfoWork.java     |  14 +-
 .../control/cc/work/GetNodeDetailsJSONWork.java |   8 +-
 .../cc/work/GetNodeSummariesJSONWork.java       |   8 +-
 .../work/GetResultPartitionLocationsWork.java   |  18 +--
 .../control/cc/work/GetResultStatusWork.java    |  18 +--
 .../hyracks/control/cc/work/JobCleanupWork.java |  20 +--
 .../hyracks/control/cc/work/JobStartWork.java   |  26 ++--
 .../cc/work/JobletCleanupNotificationWork.java  |  14 +-
 .../control/cc/work/NodeHeartbeatWork.java      |   6 +-
 .../control/cc/work/NotifyDeployBinaryWork.java |  10 +-
 .../control/cc/work/NotifyShutdownWork.java     |  14 +-
 .../cc/work/NotifyStateDumpResponse.java        |   6 +-
 .../control/cc/work/RegisterNodeWork.java       |  20 +--
 .../work/RegisterPartitionAvailibilityWork.java |  18 +--
 .../cc/work/RegisterPartitionRequestWork.java   |  18 +--
 .../RegisterResultPartitionLocationWork.java    |  12 +-
 .../control/cc/work/RemoveDeadNodesWork.java    |  12 +-
 .../control/cc/work/ReportProfilesWork.java     |  12 +-
 .../work/ReportResultPartitionFailureWork.java  |  10 +-
 ...eportResultPartitionWriteCompletionWork.java |  10 +-
 .../control/cc/work/TaskCompleteWork.java       |  20 +--
 .../control/cc/work/TaskFailureWork.java        |  14 +-
 .../control/cc/work/UnregisterNodeWork.java     |   8 +-
 .../cc/work/WaitForJobCompletionWork.java       |  12 +-
 .../cc/adminconsole/pages/AbstractPage.html     |  32 -----
 .../cc/adminconsole/pages/IndexPage.html        |  57 --------
 .../cc/adminconsole/pages/JobDetailsPage.html   |  27 ----
 .../cc/adminconsole/pages/NodeDetailsPage.html  |  82 -----------
 .../cc/adminconsole/pages/AbstractPage.html     |  32 +++++
 .../cc/adminconsole/pages/IndexPage.html        |  57 ++++++++
 .../cc/adminconsole/pages/JobDetailsPage.html   |  27 ++++
 .../cc/adminconsole/pages/NodeDetailsPage.html  |  82 +++++++++++
 .../hyracks-control-common/pom.xml              |   4 +-
 .../control/common/AbstractRemoteService.java   |   4 +-
 .../common/application/ApplicationContext.java  |  12 +-
 .../common/application/ApplicationStatus.java   |   2 +-
 .../control/common/base/IClusterController.java |  26 ++--
 .../control/common/base/INodeController.java    |  22 +--
 .../control/common/context/ServerContext.java   |   2 +-
 .../control/common/controllers/CCConfig.java    |   2 +-
 .../control/common/controllers/NCConfig.java    |   2 +-
 .../common/controllers/NodeParameters.java      |   4 +-
 .../common/controllers/NodeRegistration.java    |   6 +-
 .../common/dataset/ResultStateSweeper.java      |   6 +-
 .../ClassLoaderJobSerializerDeserializer.java   |   8 +-
 .../common/deployment/DeploymentRun.java        |   2 +-
 .../common/deployment/DeploymentStatus.java     |   2 +-
 .../common/deployment/DeploymentUtils.java      |  16 +--
 .../IDeploymentStatusConditionVariable.java     |   2 +-
 .../control/common/heartbeat/HeartbeatData.java |   2 +-
 .../common/heartbeat/HeartbeatSchema.java       |   2 +-
 .../control/common/ipc/CCNCFunctions.java       |  56 ++++----
 .../ipc/ClusterControllerRemoteProxy.java       |  30 ++--
 .../common/ipc/NodeControllerRemoteProxy.java   |  26 ++--
 .../control/common/job/PartitionDescriptor.java |   6 +-
 .../control/common/job/PartitionRequest.java    |   6 +-
 .../control/common/job/PartitionState.java      |   2 +-
 .../common/job/TaskAttemptDescriptor.java       |   8 +-
 .../common/job/profiling/counters/Counter.java  |   4 +-
 .../counters/MultiResolutionEventProfiler.java  |   4 +-
 .../job/profiling/om/AbstractProfile.java       |   4 +-
 .../common/job/profiling/om/JobProfile.java     |   4 +-
 .../common/job/profiling/om/JobletProfile.java  |   4 +-
 .../job/profiling/om/PartitionProfile.java      |   8 +-
 .../common/job/profiling/om/TaskProfile.java    |   8 +-
 .../hyracks/control/common/logs/LogFile.java    |   2 +-
 .../control/common/service/AbstractService.java |   2 +-
 .../control/common/service/IService.java        |   2 +-
 .../IShutdownStatusConditionVariable.java       |   2 +-
 .../control/common/shutdown/ShutdownRun.java    |   2 +-
 .../control/common/utils/ExceptionUtils.java    |   4 +-
 .../control/common/work/AbstractWork.java       |   2 +-
 .../control/common/work/FutureValue.java        |   2 +-
 .../control/common/work/IPCResponder.java       |   6 +-
 .../control/common/work/IResultCallback.java    |   2 +-
 .../control/common/work/SynchronizableWork.java |   2 +-
 .../hyracks/control/common/work/WorkQueue.java  |   4 +-
 .../hyracks-control/hyracks-control-nc/pom.xml  |   8 +-
 .../org/apache/hyracks/control/nc/Joblet.java   |  70 +++++-----
 .../org/apache/hyracks/control/nc/NCDriver.java |   4 +-
 .../control/nc/NodeControllerService.java       | 100 ++++++-------
 .../org/apache/hyracks/control/nc/Task.java     |  66 ++++-----
 .../nc/application/NCApplicationContext.java    |  18 +--
 .../nc/dataset/DatasetMemoryManager.java        |   6 +-
 .../nc/dataset/DatasetPartitionManager.java     |  28 ++--
 .../nc/dataset/DatasetPartitionReader.java      |   8 +-
 .../nc/dataset/DatasetPartitionWriter.java      |  20 +--
 .../apache/hyracks/control/nc/dataset/Page.java |   2 +-
 .../hyracks/control/nc/dataset/ResultState.java |  18 +--
 .../hyracks/control/nc/io/FileHandle.java       |   8 +-
 .../apache/hyracks/control/nc/io/IOManager.java |  16 +--
 .../control/nc/io/WorkspaceFileFactory.java     |  12 +-
 .../control/nc/io/profiling/IIOCounter.java     |   2 +-
 .../nc/io/profiling/IOCounterDefault.java       |   2 +-
 .../nc/io/profiling/IOCounterFactory.java       |   2 +-
 .../control/nc/io/profiling/IOCounterLinux.java |   2 +-
 .../control/nc/io/profiling/IOCounterOSX.java   |   2 +-
 .../control/nc/net/DatasetNetworkManager.java   |  30 ++--
 .../hyracks/control/nc/net/NetworkManager.java  |  32 ++---
 .../nc/partitions/MaterializedPartition.java    |  18 +--
 .../MaterializedPartitionInputChannel.java      |  16 +--
 .../partitions/MaterializedPartitionWriter.java |  22 +--
 .../MaterializingPipelinedPartition.java        |  24 ++--
 .../control/nc/partitions/PartitionManager.java |  30 ++--
 .../nc/partitions/PipelinedPartition.java       |  16 +--
 .../ReceiveSideMaterializingCollector.java      |  26 ++--
 .../ConnectorReceiverProfilingFrameReader.java  |  14 +-
 .../ConnectorSenderProfilingFrameWriter.java    |  12 +-
 .../ProfilingPartitionWriterFactory.java        |  20 +--
 .../resources/DefaultDeallocatableRegistry.java |   6 +-
 .../nc/resources/memory/FrameManager.java       |  10 +-
 .../nc/resources/memory/MemoryManager.java      |   4 +-
 .../control/nc/runtime/RootHyracksContext.java  |  10 +-
 .../hyracks/control/nc/work/AbortTasksWork.java |  16 +--
 .../control/nc/work/ApplicationMessageWork.java |  14 +-
 .../control/nc/work/BuildJobProfilesWork.java   |  16 +--
 .../control/nc/work/CleanupJobletWork.java      |  14 +-
 .../control/nc/work/DeployBinaryWork.java       |  14 +-
 .../control/nc/work/NotifyTaskCompleteWork.java |  10 +-
 .../control/nc/work/NotifyTaskFailureWork.java  |  12 +-
 .../work/ReportPartitionAvailabilityWork.java   |  18 +--
 .../hyracks/control/nc/work/ShutdownWork.java   |  14 +-
 .../hyracks/control/nc/work/StartTasksWork.java |  76 +++++-----
 .../hyracks/control/nc/work/StateDumpWork.java  |   6 +-
 .../control/nc/work/UnDeployBinaryWork.java     |  14 +-
 hyracks/hyracks-control/pom.xml                 |   2 +-
 hyracks/hyracks-data/hyracks-data-std/pom.xml   |   4 +-
 .../std/accessors/MurmurHash3BinaryHash.java    |   2 +-
 .../MurmurHash3BinaryHashFunctionFamily.java    |   6 +-
 .../PointableBinaryComparatorFactory.java       |  12 +-
 .../PointableBinaryHashFunctionFactory.java     |  12 +-
 .../UTF8StringBinaryHashFunctionFamily.java     |   8 +-
 .../std/algorithms/BinarySearchAlgorithm.java   |   6 +-
 .../hyracks/data/std/api/AbstractPointable.java |   2 +-
 .../hyracks/data/std/api/IComparable.java       |   2 +-
 .../data/std/api/IDataOutputProvider.java       |   2 +-
 .../apache/hyracks/data/std/api/IHashable.java  |   2 +-
 .../data/std/api/IMutableValueStorage.java      |   2 +-
 .../apache/hyracks/data/std/api/INumeric.java   |   2 +-
 .../apache/hyracks/data/std/api/IPointable.java |   2 +-
 .../hyracks/data/std/api/IPointableFactory.java |   4 +-
 .../hyracks/data/std/api/IValueReference.java   |   2 +-
 .../collections/api/IValueReferenceVector.java  |   2 +-
 .../data/std/primitive/BooleanPointable.java    |  14 +-
 .../data/std/primitive/ByteArrayPointable.java  |   6 +-
 .../data/std/primitive/BytePointable.java       |  18 +--
 .../data/std/primitive/DoublePointable.java     |  18 +--
 .../data/std/primitive/FloatPointable.java      |  18 +--
 .../data/std/primitive/IntegerPointable.java    |  18 +--
 .../data/std/primitive/LongPointable.java       |  18 +--
 .../std/primitive/RawUTF8StringPointable.java   |  16 +--
 .../data/std/primitive/ShortPointable.java      |  18 +--
 .../data/std/primitive/UTF8StringPointable.java |  16 +--
 .../data/std/primitive/UTF8StringWriter.java    |   2 +-
 .../data/std/primitive/VoidPointable.java       |  10 +-
 .../data/std/util/ArrayBackedValueStorage.java  |   6 +-
 .../util/ByteArrayAccessibleOutputStream.java   |   2 +-
 .../hyracks/data/std/util/GrowableArray.java    |   6 +-
 .../std/primitive/ByteArrayPointableTest.java   |   2 +-
 hyracks/hyracks-data/pom.xml                    |   2 +-
 hyracks/hyracks-dataflow-common/pom.xml         |   8 +-
 .../common/comm/io/AbstractFrameAppender.java   |  16 +--
 .../common/comm/io/ArrayTupleBuilder.java       |  14 +-
 .../common/comm/io/ArrayTupleReference.java     |   4 +-
 .../common/comm/io/FrameDeserializer.java       |  10 +-
 .../comm/io/FrameDeserializingDataReader.java   |  16 +--
 .../comm/io/FrameDeserializingDataWriter.java   |  12 +-
 .../common/comm/io/FrameFixedFieldAppender.java |  16 +--
 .../comm/io/FrameFixedFieldTupleAppender.java   |  16 +--
 .../common/comm/io/FrameOutputStream.java       |  10 +-
 .../common/comm/io/FrameTupleAccessor.java      |  16 +--
 .../common/comm/io/FrameTupleAppender.java      |  14 +-
 .../comm/io/FrameTupleAppenderAccessor.java     |  18 +--
 .../comm/io/FrameTupleAppenderWrapper.java      |  16 +--
 .../comm/io/FrameTuplePairComparator.java       |   6 +-
 .../comm/io/ResultFrameTupleAccessor.java       |   4 +-
 .../common/comm/io/SerializingDataWriter.java   |  16 +--
 .../common/comm/util/ByteBufferInputStream.java |   2 +-
 .../dataflow/common/comm/util/FrameUtils.java   |  12 +-
 .../FrameTupleFieldValueReference.java          |   6 +-
 .../data/accessors/FrameTupleReference.java     |   4 +-
 .../data/accessors/IFrameTupleReference.java    |   4 +-
 .../common/data/accessors/ITupleReference.java  |   2 +-
 .../BooleanSerializerDeserializer.java          |   6 +-
 .../ByteArraySerializerDeserializer.java        |   8 +-
 .../DoubleSerializerDeserializer.java           |   6 +-
 .../FloatSerializerDeserializer.java            |   6 +-
 .../IntArraySerializerDeserializer.java         |   6 +-
 .../Integer64SerializerDeserializer.java        |   6 +-
 .../IntegerSerializerDeserializer.java          |   6 +-
 .../ShortSerializerDeserializer.java            |   6 +-
 .../UTF8StringSerializerDeserializer.java       |   6 +-
 .../ByteArrayNormalizedKeyComputerFactory.java  |   8 +-
 .../DoubleNormalizedKeyComputerFactory.java     |  10 +-
 .../FloatNormalizedKeyComputerFactory.java      |  10 +-
 .../Integer64NormalizedKeyComputerFactory.java  |  10 +-
 .../IntegerNormalizedKeyComputerFactory.java    |  10 +-
 .../UTF8StringNormalizedKeyComputerFactory.java |   8 +-
 .../parsers/ByteArrayBase64ParserFactory.java   |   6 +-
 .../data/parsers/ByteArrayHexParserFactory.java |   6 +-
 .../data/parsers/DoubleParserFactory.java       |   4 +-
 .../common/data/parsers/FloatParserFactory.java |   4 +-
 .../common/data/parsers/IValueParser.java       |   4 +-
 .../data/parsers/IValueParserFactory.java       |   2 +-
 .../data/parsers/IntegerParserFactory.java      |   4 +-
 .../common/data/parsers/LongParserFactory.java  |   4 +-
 .../data/parsers/UTF8StringParserFactory.java   |   4 +-
 .../FieldHashPartitionComputerFactory.java      |  14 +-
 .../FieldHashPartitionComputerFamily.java       |  14 +-
 .../RandomPartitionComputerFactory.java         |  10 +-
 .../partition/RepartitionComputerFactory.java   |  10 +-
 .../partition/RepartitionComputerFamily.java    |  10 +-
 .../FieldRangePartitionComputerFactory.java     |  14 +-
 .../common/data/partition/range/IRangeMap.java  |   4 +-
 .../common/data/partition/range/RangeMap.java   |   6 +-
 .../dataflow/common/data/util/StringUtils.java  |   2 +-
 .../dataflow/common/io/RunFileReader.java       |  16 +--
 .../dataflow/common/io/RunFileWriter.java       |  12 +-
 .../dataflow/common/util/IntSerDeUtils.java     |   2 +-
 .../dataflow/common/util/ReflectionUtils.java   |   2 +-
 .../dataflow/common/util/SerdeUtils.java        |  40 +++---
 .../dataflow/common/util/TupleUtils.java        |  16 +--
 .../FrameFixedFieldTupleAppenderTest.java       |  32 ++---
 .../ByteArraySerializerDeserializerTest.java    |   4 +-
 ...teArrayNormalizedKeyComputerFactoryTest.java |   8 +-
 .../ByteArrayBase64ParserFactoryTest.java       |   8 +-
 .../parsers/ByteArrayHexParserFactoryTest.java  |   4 +-
 hyracks/hyracks-dataflow-hadoop/pom.xml         |  10 +-
 .../AbstractHadoopOperatorDescriptor.java       |  14 +-
 .../hadoop/HadoopMapperOperatorDescriptor.java  |  34 ++---
 .../hadoop/HadoopReadOperatorDescriptor.java    |  34 ++---
 .../hadoop/HadoopReducerOperatorDescriptor.java |  42 +++---
 .../hadoop/HadoopWriteOperatorDescriptor.java   |  16 +--
 .../hadoop/data/AbstractClassBasedDelegate.java |   2 +-
 ...HadoopHashTuplePartitionComputerFactory.java |  14 +-
 ...artitionerTuplePartitionComputerFactory.java |  14 +-
 ...artitionerTuplePartitionComputerFactory.java |  14 +-
 .../hadoop/data/KeyBinaryComparatorFactory.java |   8 +-
 .../hadoop/data/KeyComparatorFactory.java       |   8 +-
 .../data/RawComparingComparatorFactory.java     |   8 +-
 ...ritableComparingBinaryComparatorFactory.java |   8 +-
 .../dataflow/hadoop/mapreduce/HadoopHelper.java |  24 ++--
 .../dataflow/hadoop/mapreduce/HadoopTools.java  |   2 +-
 ...hPartitioningShuffleConnectorDescriptor.java |  28 ++--
 .../hadoop/mapreduce/IInputSplitProvider.java   |   4 +-
 .../mapreduce/IInputSplitProviderFactory.java   |   4 +-
 .../hadoop/mapreduce/InputFileSplit.java        |   2 +-
 .../dataflow/hadoop/mapreduce/KVIterator.java   |   8 +-
 .../mapreduce/MapperOperatorDescriptor.java     |  40 +++---
 .../hadoop/mapreduce/MarshalledWritable.java    |   2 +-
 .../dataflow/hadoop/mapreduce/ReduceWriter.java |  26 ++--
 .../mapreduce/ReducerOperatorDescriptor.java    |  20 +--
 .../hadoop/mapreduce/ShuffleFrameReader.java    |  42 +++---
 .../util/ClasspathBasedHadoopClassFactory.java  |   2 +-
 .../dataflow/hadoop/util/DatatypeHelper.java    |   8 +-
 .../hadoop/util/DuplicateKeyMapper.java         |   8 +-
 .../hadoop/util/IHadoopClassFactory.java        |   2 +-
 .../dataflow/hadoop/util/InputSplitsProxy.java  |   2 +-
 .../dataflow/hadoop/util/MRContextUtil.java     |   4 +-
 .../util/PreappendLongWritableMapper.java       |   8 +-
 hyracks/hyracks-dataflow-std/pom.xml            |   8 +-
 .../dataflow/std/base/AbstractActivityNode.java |   6 +-
 .../std/base/AbstractConnectorDescriptor.java   |  14 +-
 .../base/AbstractMToNConnectorDescriptor.java   |   4 +-
 .../std/base/AbstractOperatorDescriptor.java    |  14 +-
 .../std/base/AbstractOperatorNodePushable.java  |   4 +-
 ...bstractSingleActivityOperatorDescriptor.java |  10 +-
 .../dataflow/std/base/AbstractStateObject.java  |   6 +-
 .../AbstractUnaryInputOperatorNodePushable.java |   8 +-
 ...tractUnaryInputSinkOperatorNodePushable.java |   6 +-
 ...aryInputUnaryOutputOperatorNodePushable.java |   4 +-
 ...AbstractUnaryOutputOperatorNodePushable.java |   8 +-
 ...ctUnaryOutputSourceOperatorNodePushable.java |   4 +-
 .../std/base/IOpenableDataWriterOperator.java   |   4 +-
 .../collectors/AbstractPartitionCollector.java  |  10 +-
 .../std/collectors/IPartitionAcceptor.java      |   6 +-
 .../std/collectors/IPartitionBatchManager.java  |   6 +-
 .../std/collectors/InputChannelFrameReader.java |  16 +--
 .../NonDeterministicChannelReader.java          |  10 +-
 .../collectors/NonDeterministicFrameReader.java |  12 +-
 .../NonDeterministicPartitionBatchManager.java  |  10 +-
 .../std/collectors/PartitionCollector.java      |  16 +--
 .../std/collectors/SortMergeFrameReader.java    |  20 +--
 .../connectors/GlobalHashingLocalityMap.java    |   6 +-
 .../std/connectors/HashtableLocalityMap.java    |   6 +-
 .../dataflow/std/connectors/ILocalityMap.java   |   2 +-
 ...wareMToNPartitioningConnectorDescriptor.java |  40 +++---
 .../LocalityAwarePartitionDataWriter.java       |  32 ++---
 .../MToNPartitioningConnectorDescriptor.java    |  26 ++--
 ...NPartitioningMergingConnectorDescriptor.java |  38 ++---
 .../MToNReplicatingConnectorDescriptor.java     |  24 ++--
 .../connectors/OneToOneConnectorDescriptor.java |  36 ++---
 .../std/connectors/PartitionDataWriter.java     |  22 +--
 ...tDeserializedFileScanOperatorDescriptor.java |  22 +--
 .../AbstractFileWriteOperatorDescriptor.java    |  22 +--
 .../std/file/ConstantFileSplitProvider.java     |   2 +-
 .../file/DelimitedDataTupleParserFactory.java   |  22 +--
 .../file/FieldCursorForDelimitedDataParser.java |   2 +-
 .../std/file/FileRemoveOperatorDescriptor.java  |  20 +--
 .../std/file/FileScanOperatorDescriptor.java    |  18 +--
 .../hyracks/dataflow/std/file/FileSplit.java    |   4 +-
 .../file/FrameFileWriterOperatorDescriptor.java |  16 +--
 .../dataflow/std/file/IFileSplitProvider.java   |   2 +-
 .../dataflow/std/file/IRecordReader.java        |   2 +-
 .../dataflow/std/file/IRecordWriter.java        |   2 +-
 .../hyracks/dataflow/std/file/ITupleParser.java |   6 +-
 .../dataflow/std/file/ITupleParserFactory.java  |   6 +-
 .../file/LineFileWriteOperatorDescriptor.java   |   4 +-
 .../file/PlainFileWriterOperatorDescriptor.java |  28 ++--
 .../file/RecordFileScanOperatorDescriptor.java  |   6 +-
 .../hyracks/dataflow/std/file/RecordWriter.java |   4 +-
 ...AccumulatingAggregatorDescriptorFactory.java |  12 +-
 .../AbstractRunningAggregatorDescriptor.java    |  12 +-
 .../dataflow/std/group/AggregateState.java      |   2 +-
 .../DeserializedPreclusteredGroupOperator.java  |  12 +-
 .../std/group/FrameToolsForGroupers.java        |   8 +-
 .../std/group/HashSpillableTableFactory.java    |  54 +++----
 .../std/group/IAggregatorDescriptor.java        |   8 +-
 .../std/group/IAggregatorDescriptorFactory.java |  10 +-
 .../std/group/IFieldAggregateDescriptor.java    |   6 +-
 .../group/IFieldAggregateDescriptorFactory.java |   8 +-
 .../dataflow/std/group/IGroupAggregator.java    |   8 +-
 .../dataflow/std/group/ISpillableTable.java     |  10 +-
 .../std/group/ISpillableTableFactory.java       |  12 +-
 .../AvgFieldGroupAggregatorFactory.java         |  28 ++--
 .../AvgFieldMergeAggregatorFactory.java         |  28 ++--
 .../CountFieldAggregatorFactory.java            |  28 ++--
 .../FloatSumFieldAggregatorFactory.java         |  22 +--
 .../IntSumFieldAggregatorFactory.java           |  28 ++--
 .../MinMaxStringFieldAggregatorFactory.java     |  30 ++--
 .../MultiFieldsAggregatorFactory.java           |  32 ++---
 .../ExternalGroupBuildOperatorNodePushable.java |  28 ++--
 .../ExternalGroupMergeOperatorNodePushable.java |  52 +++----
 .../ExternalGroupOperatorDescriptor.java        |  38 ++---
 .../std/group/external/ExternalGroupState.java  |  10 +-
 .../std/group/hash/GroupingHashTable.java       |  40 +++---
 .../HashGroupBuildOperatorNodePushable.java     |  18 +--
 .../group/hash/HashGroupOperatorDescriptor.java |  34 ++---
 .../HashGroupOutputOperatorNodePushable.java    |   8 +-
 .../dataflow/std/group/hash/HashGroupState.java |   6 +-
 .../PreclusteredGroupOperatorDescriptor.java    |  20 +--
 .../PreclusteredGroupOperatorNodePushable.java  |  16 +--
 .../preclustered/PreclusteredGroupWriter.java   |  32 ++---
 .../sort/ExternalSortGroupByRunGenerator.java   |  30 ++--
 .../sort/ExternalSortGroupByRunMerger.java      |  28 ++--
 .../sort/SortGroupByOperatorDescriptor.java     |  38 ++---
 .../join/GraceHashJoinOperatorDescriptor.java   |  34 ++---
 .../join/GraceHashJoinOperatorNodePushable.java |  46 +++---
 ...hJoinPartitionBuildOperatorNodePushable.java |  32 ++---
 .../std/join/GraceHashJoinPartitionState.java   |   8 +-
 .../join/HybridHashJoinOperatorDescriptor.java  |  76 +++++-----
 .../dataflow/std/join/InMemoryHashJoin.java     |  30 ++--
 .../InMemoryHashJoinOperatorDescriptor.java     |  60 ++++----
 .../dataflow/std/join/JoinComparator.java       |  10 +-
 .../std/join/JoinComparatorFactory.java         |  10 +-
 .../dataflow/std/join/NestedLoopJoin.java       |  32 ++---
 .../join/NestedLoopJoinOperatorDescriptor.java  |  48 +++----
 .../std/join/OptimizedHybridHashJoin.java       |  42 +++---
 ...timizedHybridHashJoinOperatorDescriptor.java |  74 +++++-----
 .../DeserializedMapperOperatorDescriptor.java   |  22 +--
 .../dataflow/std/map/IDeserializedMapper.java   |   6 +-
 .../std/map/IDeserializedMapperFactory.java     |   4 +-
 ...eflectionBasedDeserializedMapperFactory.java |   4 +-
 .../map/SamplerDeserializedMapperFactory.java   |   6 +-
 .../ConstantTupleSourceOperatorDescriptor.java  |  16 +--
 ...ConstantTupleSourceOperatorNodePushable.java |  12 +-
 .../std/misc/IdentityOperatorDescriptor.java    |  18 +--
 .../std/misc/LimitOperatorDescriptor.java       |  26 ++--
 .../std/misc/MaterializerTaskState.java         |  24 ++--
 .../misc/MaterializingOperatorDescriptor.java   |  36 ++---
 .../std/misc/NullSinkOperatorDescriptor.java    |  16 +--
 .../std/misc/PrinterOperatorDescriptor.java     |  22 +--
 .../std/misc/SinkOperatorDescriptor.java        |  19 +--
 .../std/misc/SplitOperatorDescriptor.java       |  34 ++---
 .../std/misc/SplitVectorOperatorDescriptor.java |  34 ++---
 .../result/ResultWriterOperatorDescriptor.java  |  38 ++---
 .../dataflow/std/sort/AbstractFrameSorter.java  |  32 ++---
 .../std/sort/AbstractSortRunGenerator.java      |   8 +-
 .../sort/AbstractSorterOperatorDescriptor.java  |  42 +++---
 .../hyracks/dataflow/std/sort/Algorithm.java    |   2 +-
 .../sort/ExternalSortOperatorDescriptor.java    |  16 +--
 .../std/sort/ExternalSortRunGenerator.java      |  34 ++---
 .../std/sort/ExternalSortRunMerger.java         |  28 ++--
 .../dataflow/std/sort/FrameSorterMergeSort.java |  18 +--
 .../dataflow/std/sort/FrameSorterQuickSort.java |  16 +--
 .../dataflow/std/sort/HeapSortRunGenerator.java |  30 ++--
 .../std/sort/HybridTopKSortRunGenerator.java    |  22 +--
 .../hyracks/dataflow/std/sort/IFrameSorter.java |   4 +-
 .../dataflow/std/sort/IRunGenerator.java        |   4 +-
 .../hyracks/dataflow/std/sort/ISorter.java      |   6 +-
 .../hyracks/dataflow/std/sort/ITupleSorter.java |   6 +-
 .../sort/InMemorySortOperatorDescriptor.java    |  44 +++---
 .../std/sort/RunAndMaxFrameSizePair.java        |   4 +-
 .../std/sort/RunMergingFrameReader.java         |  26 ++--
 .../std/sort/TopKSorterOperatorDescriptor.java  |  12 +-
 .../dataflow/std/sort/TupleSorterHeapSort.java  |  38 ++---
 .../sort/buffermanager/EnumFreeSlotPolicy.java  |   2 +-
 .../FrameFreeSlotBiggestFirst.java              |   8 +-
 .../buffermanager/FrameFreeSlotLastFit.java     |   2 +-
 .../buffermanager/FrameFreeSlotSmallestFit.java |   2 +-
 .../sort/buffermanager/IFrameBufferManager.java |   6 +-
 .../buffermanager/IFrameFreeSlotPolicy.java     |   2 +-
 .../std/sort/buffermanager/IFramePool.java      |   4 +-
 .../buffermanager/ITupleBufferAccessor.java     |   4 +-
 .../sort/buffermanager/ITupleBufferManager.java |  10 +-
 .../VariableFrameMemoryManager.java             |  12 +-
 .../sort/buffermanager/VariableFramePool.java   |   6 +-
 .../VariableTupleMemoryManager.java             |  14 +-
 .../sort/util/DeletableFrameTupleAppender.java  |  12 +-
 .../std/sort/util/GroupFrameAccessor.java       |  10 +-
 .../dataflow/std/sort/util/GroupVSizeFrame.java |  10 +-
 .../IAppendDeletableFrameTupleAccessor.java     |   8 +-
 .../dataflow/std/structures/AbstractHeap.java   |   4 +-
 .../hyracks/dataflow/std/structures/IHeap.java  |   2 +-
 .../dataflow/std/structures/IMaxHeap.java       |   2 +-
 .../dataflow/std/structures/IMinHeap.java       |   2 +-
 .../dataflow/std/structures/IMinMaxHeap.java    |   2 +-
 .../dataflow/std/structures/IResetable.java     |   2 +-
 .../std/structures/IResetableComparable.java    |   2 +-
 .../structures/IResetableComparableFactory.java |   2 +-
 .../std/structures/ISerializableTable.java      |   4 +-
 .../dataflow/std/structures/MaxHeap.java        |   2 +-
 .../dataflow/std/structures/MinHeap.java        |   2 +-
 .../dataflow/std/structures/MinMaxHeap.java     |   2 +-
 .../std/structures/SerializableHashTable.java   |   6 +-
 .../dataflow/std/structures/TuplePointer.java   |   2 +-
 .../std/union/UnionAllOperatorDescriptor.java   |  26 ++--
 .../util/DeserializedOperatorNodePushable.java  |  18 +--
 .../hyracks/dataflow/std/util/MathUtil.java     |   2 +-
 .../dataflow/std/util/ReferenceEntry.java       |   8 +-
 .../std/util/ReferencedPriorityQueue.java       |   6 +-
 .../dataflow/std/util/SelectionTree.java        |   2 +-
 .../std/util/StringSerializationUtils.java      |   2 +-
 .../hyracks/dataflow/std/sort/Utility.java      |   2 +-
 .../dataflow/std/sort/buffermanager/Common.java |   4 +-
 .../FrameFreeSlotBestFitUsingTreeMapTest.java   |   2 +-
 .../FrameFreeSlotBiggestFirstTest.java          |   2 +-
 .../buffermanager/FrameFreeSlotLastFitTest.java |   2 +-
 .../buffermanager/VariableFramePoolTest.java    |  12 +-
 .../VariableFramesMemoryManagerTest.java        |  26 ++--
 .../VariableTupleMemoryManagerTest.java         |  26 ++--
 .../util/DeletableFrameTupleAppenderTest.java   |  18 +--
 .../std/structures/AbstracHeapTest.java         |   2 +-
 .../dataflow/std/structures/MaxHeapTest.java    |   2 +-
 .../dataflow/std/structures/MinHeapTest.java    |   2 +-
 .../dataflow/std/structures/MinMaxHeapTest.java |   2 +-
 .../std/test/util/SelectionTreeTest.java        |   6 +-
 .../hyracks/dataflow/std/util/MathTest.java     |   2 +-
 hyracks/hyracks-dist/pom.xml                    |   2 +-
 hyracks/hyracks-documentation/pom.xml           |   2 +-
 .../user-guide/sec-concepts-applications.apt    |   2 +-
 .../btree-example/btreeclient/pom.xml           |  12 +-
 .../btree/client/InsertPipelineExample.java     |  66 ++++-----
 .../examples/btree/client/JobHelper.java        |  16 +--
 .../client/PrimaryIndexBulkLoadExample.java     |  64 ++++-----
 .../btree/client/PrimaryIndexSearchExample.java |  56 ++++----
 .../client/SecondaryIndexBulkLoadExample.java   |  54 +++----
 .../client/SecondaryIndexSearchExample.java     |  56 ++++----
 .../btree-example/btreehelper/pom.xml           |  12 +-
 .../btree/helper/DataGenOperatorDescriptor.java |  28 ++--
 .../helper/IndexLifecycleManagerProvider.java   |   8 +-
 .../btree/helper/NCApplicationEntryPoint.java   |   6 +-
 .../examples/btree/helper/RuntimeContext.java   |  42 +++---
 .../btree/helper/StorageManagerInterface.java   |  16 +--
 .../btree-example/btreeserver/pom.xml           |  14 +-
 hyracks/hyracks-examples/btree-example/pom.xml  |   4 +-
 .../hadoopcompatclient/pom.xml                  |  10 +-
 .../compat/client/WordCountCompatibility.java   |   4 +-
 .../hadoopcompathelper/pom.xml                  |   8 +-
 .../hyracks/examples/wordcount/WordCount.java   |   2 +-
 .../job/wordcount/wordcount.job                 |   6 +-
 .../hadoopcompatserver/pom.xml                  |  18 +--
 .../compat/test/WordCountCompatibilityIT.java   |   4 +-
 .../hadoop-compat-example/pom.xml               |   6 +-
 .../hyracks-integration-tests/pom.xml           |  26 ++--
 .../am/btree/AbstractBTreeOperatorTest.java     |  80 +++++------
 .../tests/am/btree/BTreeOperatorTestHelper.java |   8 +-
 .../BTreePrimaryIndexScanOperatorTest.java      |  34 ++---
 .../BTreePrimaryIndexSearchOperatorTest.java    |  34 ++---
 .../BTreePrimaryIndexStatsOperatorTest.java     |  24 ++--
 .../BTreeSecondaryIndexInsertOperatorTest.java  |  34 ++---
 .../BTreeSecondaryIndexSearchOperatorTest.java  |  34 ++---
 .../BTreeSecondaryIndexUpsertOperatorTest.java  |  34 ++---
 .../am/common/ITreeIndexOperatorTestHelper.java |   2 +-
 .../am/common/LSMTreeOperatorTestHelper.java    |  10 +-
 .../tests/am/common/TreeOperatorTestHelper.java |   2 +-
 .../lsm/btree/LSMBTreeOperatorTestHelper.java   |  18 +--
 .../LSMBTreePrimaryIndexScanOperatorTest.java   |  12 +-
 .../LSMBTreePrimaryIndexSearchOperatorTest.java |  12 +-
 ...SMBTreeSecondaryIndexInsertOperatorTest.java |  12 +-
 ...SMBTreeSecondaryIndexSearchOperatorTest.java |  12 +-
 .../lsm/rtree/LSMRTreeOperatorTestHelper.java   |  26 ++--
 ...SMRTreeSecondaryIndexInsertOperatorTest.java |  20 +--
 ...SMRTreeSecondaryIndexSearchOperatorTest.java |  20 +--
 ...eWithAntiMatterTuplesOperatorTestHelper.java |  26 ++--
 ...rTuplesSecondaryIndexInsertOperatorTest.java |  20 +--
 ...rTuplesSecondaryIndexSearchOperatorTest.java |  20 +--
 .../am/rtree/AbstractRTreeOperatorTest.java     | 100 ++++++-------
 .../tests/am/rtree/RTreeOperatorTestHelper.java |  14 +-
 .../RTreeSecondaryIndexInsertOperatorTest.java  |  46 +++---
 .../RTreeSecondaryIndexScanOperatorTest.java    |  42 +++---
 .../RTreeSecondaryIndexSearchOperatorTest.java  |  46 +++---
 .../RTreeSecondaryIndexStatsOperatorTest.java   |  32 ++---
 .../comm/SerializationDeserializationTest.java  |  36 ++---
 .../integration/AbstractIntegrationTest.java    |  38 ++---
 .../AbstractMultiNCIntegrationTest.java         |  38 ++---
 .../tests/integration/AggregationTest.java      |  90 ++++++------
 .../tests/integration/CountOfCountsTest.java    |  72 +++++-----
 .../integration/LocalityAwareConnectorTest.java |  80 +++++------
 .../integration/OptimizedSortMergeTest.java     |  60 ++++----
 .../tests/integration/ScanPrintTest.java        |  56 ++++----
 .../tests/integration/SortMergeTest.java        |  58 ++++----
 .../tests/integration/SplitOperatorTest.java    |  36 ++---
 ...TPCHCustomerOptimizedHybridHashJoinTest.java |  52 +++----
 .../TPCHCustomerOrderHashJoinTest.java          |  68 ++++-----
 .../TPCHCustomerOrderNestedLoopJoinTest.java    |  66 ++++-----
 .../hyracks/tests/integration/UnionTest.java    |  40 +++---
 .../integration/VSizeFrameSortMergeTest.java    |  52 +++----
 .../tests/unit/AbstractRunGeneratorTest.java    |  48 +++----
 .../unit/ExternalSortRunGeneratorTest.java      |  12 +-
 .../tests/unit/HeapSortRunGeneratorTest.java    |  10 +-
 .../tests/unit/HybridSortRunGenerator.java      |  10 +-
 .../tests/unit/RunMergingFrameReaderTest.java   |  56 ++++----
 .../tests/unit/TopKRunGeneratorTest.java        |  34 ++---
 .../tests/util/NoopNullWriterFactory.java       |   8 +-
 .../util/ResultSerializerFactoryProvider.java   |  14 +-
 .../hyracks-shutdown-test/pom.xml               |  18 +--
 .../shutdown/test/ClusterShutdownIT.java        |   8 +-
 hyracks/hyracks-examples/pom.xml                |   2 +-
 hyracks/hyracks-examples/text-example/pom.xml   |   2 +-
 .../text-example/textclient/pom.xml             |  10 +-
 .../text/client/ExternalGroupClient.java        |  92 ++++++------
 .../examples/text/client/WordCountMain.java     |  74 +++++-----
 .../text-example/texthelper/pom.xml             |   8 +-
 .../examples/text/WordTupleParserFactory.java   |  24 ++--
 .../text-example/textserver/pom.xml             |  18 +--
 .../hyracks/examples/text/test/WordCountIT.java |   4 +-
 hyracks/hyracks-examples/tpch-example/pom.xml   |   2 +-
 .../tpch-example/tpchclient/pom.xml             |   8 +-
 .../hyracks/examples/tpch/client/Common.java    |  22 +--
 .../hyracks/examples/tpch/client/Join.java      |  88 ++++++------
 .../hyracks/examples/tpch/client/Sort.java      |  62 ++++----
 .../tpch-example/tpchserver/pom.xml             |  16 +--
 hyracks/hyracks-hadoop-compat/pom.xml           |   6 +-
 .../hadoop/compat/client/HyracksClient.java     |  16 +--
 .../hadoop/compat/client/HyracksRunningJob.java |  10 +-
 .../compat/driver/CompatibilityLayer.java       |  20 +--
 .../hadoop/compat/util/CompatibilityConfig.java |   2 +-
 .../compat/util/ConfigurationConstants.java     |   2 +-
 .../hadoop/compat/util/DCacheHandler.java       |   2 +-
 .../hadoop/compat/util/HadoopAdapter.java       |  50 +++----
 .../hyracks/hadoop/compat/util/Utilities.java   |   2 +-
 hyracks/hyracks-hdfs/hyracks-hdfs-1.x/pom.xml   |   4 +-
 .../org/apache/hyracks/hdfs/ContextFactory.java |   4 +-
 .../hyracks/hdfs/MiniDFSClusterFactory.java     |   4 +-
 hyracks/hyracks-hdfs/hyracks-hdfs-2.x/pom.xml   |   4 +-
 .../org/apache/hyracks/hdfs/ContextFactory.java |   4 +-
 .../hyracks/hdfs/MiniDFSClusterFactory.java     |   4 +-
 hyracks/hyracks-hdfs/hyracks-hdfs-core/pom.xml  |  26 ++--
 .../hyracks/hdfs/api/IKeyValueParser.java       |   6 +-
 .../hdfs/api/IKeyValueParserFactory.java        |   6 +-
 .../apache/hyracks/hdfs/api/INcCollection.java  |   2 +-
 .../hyracks/hdfs/api/INcCollectionBuilder.java  |   4 +-
 .../apache/hyracks/hdfs/api/ITupleWriter.java   |   6 +-
 .../hyracks/hdfs/api/ITupleWriterFactory.java   |   6 +-
 .../hyracks/hdfs/dataflow/ConfFactory.java      |   4 +-
 .../dataflow/HDFSReadOperatorDescriptor.java    |  24 ++--
 .../dataflow/HDFSWriteOperatorDescriptor.java   |  28 ++--
 .../hdfs/dataflow/InputSplitsFactory.java       |   4 +-
 .../hdfs/lib/RawBinaryComparatorFactory.java    |   6 +-
 .../hdfs/lib/RawBinaryHashFunctionFactory.java  |   6 +-
 .../hdfs/lib/TextKeyValueParserFactory.java     |  20 +--
 .../hdfs/lib/TextTupleWriterFactory.java        |  12 +-
 .../IPProximityNcCollectionBuilder.java         |   8 +-
 .../scheduler/RackAwareNcCollectionBuilder.java |  10 +-
 .../hyracks/hdfs/scheduler/Scheduler.java       |  18 +--
 .../hyracks/hdfs2/dataflow/ConfFactory.java     |   4 +-
 .../hdfs2/dataflow/FileSplitsFactory.java       |   4 +-
 .../dataflow/HDFSReadOperatorDescriptor.java    |  26 ++--
 .../dataflow/HDFSWriteOperatorDescriptor.java   |  28 ++--
 .../hyracks/hdfs2/scheduler/Scheduler.java      |  22 +--
 .../hdfs2/scheduler/WrappedFileSplit.java       |   2 +-
 .../hyracks/hdfs/dataflow/DataflowTest.java     |  46 +++---
 .../hyracks/hdfs/scheduler/SchedulerTest.java   |  12 +-
 .../apache/hyracks/hdfs/utils/HyracksUtils.java |  20 +--
 .../apache/hyracks/hdfs/utils/TestUtils.java    |   2 +-
 .../hyracks/hdfs2/dataflow/DataflowTest.java    |  48 +++----
 .../hyracks/hdfs2/scheduler/SchedulerTest.java  |   8 +-
 hyracks/hyracks-hdfs/pom.xml                    |   2 +-
 hyracks/hyracks-ipc/pom.xml                     |   2 +-
 .../org/apache/hyracks/ipc/api/IIPCHandle.java  |   4 +-
 .../java/org/apache/hyracks/ipc/api/IIPCI.java  |   2 +-
 .../hyracks/ipc/api/IPCPerformanceCounters.java |   2 +-
 .../ipc/api/IPayloadSerializerDeserializer.java |   2 +-
 .../hyracks/ipc/api/IResponseCallback.java      |   2 +-
 .../apache/hyracks/ipc/api/RPCInterface.java    |   4 +-
 .../hyracks/ipc/exceptions/IPCException.java    |   2 +-
 .../apache/hyracks/ipc/impl/HandleState.java    |   2 +-
 .../hyracks/ipc/impl/IPCConnectionManager.java  |   2 +-
 .../org/apache/hyracks/ipc/impl/IPCHandle.java  |   6 +-
 .../org/apache/hyracks/ipc/impl/IPCSystem.java  |  12 +-
 ...ationBasedPayloadSerializerDeserializer.java |   4 +-
 .../org/apache/hyracks/ipc/impl/Message.java    |   4 +-
 .../org/apache/hyracks/ipc/tests/IPCTest.java   |  14 +-
 .../hyracks-virtualcluster-maven-plugin/pom.xml |   2 +-
 .../maven/plugin/AbstractHyracksMojo.java       |   2 +-
 .../maven/plugin/AbstractHyracksServerMojo.java |   2 +-
 .../maven/plugin/HyracksCCStartMojo.java        |   2 +-
 .../maven/plugin/HyracksNCStartMojo.java        |   2 +-
 .../maven/plugin/HyracksServiceRegistry.java    |   2 +-
 .../maven/plugin/HyracksStopServicesMojo.java   |   2 +-
 hyracks/hyracks-maven-plugins/pom.xml           |   2 +-
 hyracks/hyracks-net/pom.xml                     |   2 +-
 .../hyracks/net/buffers/IBufferAcceptor.java    |   2 +-
 .../net/buffers/ICloseableBufferAcceptor.java   |   2 +-
 .../hyracks/net/exceptions/NetException.java    |   2 +-
 .../protocols/muxdemux/ChannelControlBlock.java |   8 +-
 .../net/protocols/muxdemux/ChannelSet.java      |   4 +-
 .../net/protocols/muxdemux/IBufferFactory.java  |   2 +-
 .../muxdemux/IChannelOpenListener.java          |   2 +-
 .../muxdemux/IChannelReadInterface.java         |   6 +-
 .../muxdemux/IChannelWriteInterface.java        |   6 +-
 .../net/protocols/muxdemux/IEventCounter.java   |   2 +-
 .../muxdemux/MultiplexedConnection.java         |   8 +-
 .../net/protocols/muxdemux/MuxDemux.java        |  10 +-
 .../net/protocols/muxdemux/MuxDemuxCommand.java |   4 +-
 .../muxdemux/MuxDemuxPerformanceCounters.java   |   2 +-
 .../tcp/ITCPConnectionEventListener.java        |   4 +-
 .../protocols/tcp/ITCPConnectionListener.java   |   2 +-
 .../net/protocols/tcp/TCPConnection.java        |   2 +-
 .../hyracks/net/protocols/tcp/TCPEndpoint.java  |   2 +-
 .../org/apache/hyracks/net/tests/NetTest.java   |  14 +-
 hyracks/hyracks-server/docs/README              |   2 +-
 hyracks/hyracks-server/pom.xml                  |  12 +-
 .../server/drivers/VirtualClusterDriver.java    |  10 +-
 .../server/process/HyracksCCProcess.java        |   6 +-
 .../server/process/HyracksNCProcess.java        |   6 +-
 .../server/process/HyracksServerProcess.java    |   2 +-
 hyracks/hyracks-storage-am-bloomfilter/pom.xml  |   4 +-
 .../am/bloomfilter/impls/BloomCalculations.java |   2 +-
 .../am/bloomfilter/impls/BloomFilter.java       |  20 +--
 .../bloomfilter/impls/BloomFilterFactory.java   |  10 +-
 .../impls/BloomFilterSpecification.java         |   2 +-
 .../am/bloomfilter/impls/MurmurHash128Bit.java  |   4 +-
 hyracks/hyracks-storage-am-btree/pom.xml        |  10 +-
 .../storage/am/btree/api/IBTreeFrame.java       |  12 +-
 .../am/btree/api/IBTreeInteriorFrame.java       |   6 +-
 .../storage/am/btree/api/IBTreeLeafFrame.java   |  18 +--
 .../am/btree/api/IPrefixSlotManager.java        |  18 +--
 .../storage/am/btree/api/ITupleAcceptor.java    |   4 +-
 .../compressors/FieldPrefixCompressor.java      |  24 ++--
 .../am/btree/dataflow/BTreeDataflowHelper.java  |  20 +--
 .../dataflow/BTreeDataflowHelperFactory.java    |  10 +-
 .../dataflow/BTreeSearchOperatorDescriptor.java |  34 ++---
 .../BTreeSearchOperatorNodePushable.java        |  22 +--
 .../BTreeUpdateSearchOperatorDescriptor.java    |  28 ++--
 .../BTreeUpdateSearchOperatorNodePushable.java  |  24 ++--
 .../am/btree/exceptions/BTreeException.java     |   4 +-
 .../exceptions/BTreeNotUpdateableException.java |   2 +-
 .../frames/BTreeFieldPrefixNSMLeafFrame.java    |  52 +++----
 .../BTreeFieldPrefixNSMLeafFrameFactory.java    |   8 +-
 .../am/btree/frames/BTreeLeafFrameType.java     |   2 +-
 .../am/btree/frames/BTreeNSMInteriorFrame.java  |  38 ++---
 .../frames/BTreeNSMInteriorFrameFactory.java    |   8 +-
 .../am/btree/frames/BTreeNSMLeafFrame.java      |  32 ++---
 .../btree/frames/BTreeNSMLeafFrameFactory.java  |   8 +-
 .../am/btree/frames/OrderedSlotManager.java     |  16 +--
 .../hyracks/storage/am/btree/impls/BTree.java   |  92 ++++++------
 .../btree/impls/BTreeCountingSearchCursor.java  |  38 ++---
 .../am/btree/impls/BTreeCursorInitialState.java |  12 +-
 .../storage/am/btree/impls/BTreeOpContext.java  |  44 +++---
 .../am/btree/impls/BTreeRangeSearchCursor.java  |  42 +++---
 .../storage/am/btree/impls/BTreeSplitKey.java   |   6 +-
 .../impls/FieldPrefixPrefixTupleReference.java  |  12 +-
 .../am/btree/impls/FieldPrefixSlotManager.java  |  20 +--
 .../btree/impls/FieldPrefixTupleReference.java  |  10 +-
 .../storage/am/btree/impls/NodeFrontier.java    |   6 +-
 .../storage/am/btree/impls/RangePredicate.java  |   8 +-
 .../btree/impls/UnconditionalTupleAcceptor.java |   6 +-
 .../storage/am/btree/util/BTreeUtils.java       |  44 +++---
 hyracks/hyracks-storage-am-common/pom.xml       |  10 +-
 .../am/common/api/ICursorInitialState.java      |   6 +-
 .../storage/am/common/api/IFreePageManager.java |   4 +-
 .../am/common/api/IFreePageManagerFactory.java  |   2 +-
 .../hyracks/storage/am/common/api/IIndex.java   |   6 +-
 .../storage/am/common/api/IIndexAccessor.java   |   6 +-
 .../storage/am/common/api/IIndexBulkLoader.java |   6 +-
 .../storage/am/common/api/IIndexCursor.java     |   6 +-
 .../am/common/api/IIndexDataflowHelper.java     |   8 +-
 .../am/common/api/IIndexLifecycleManager.java   |   4 +-
 .../api/IIndexLifecycleManagerProvider.java     |   4 +-
 .../am/common/api/IIndexOperationContext.java   |   6 +-
 .../api/IModificationOperationCallback.java     |   6 +-
 .../IModificationOperationCallbackFactory.java  |   6 +-
 .../am/common/api/IPrimitiveValueProvider.java  |   2 +-
 .../api/IPrimitiveValueProviderFactory.java     |   2 +-
 .../am/common/api/ISearchOperationCallback.java |   6 +-
 .../api/ISearchOperationCallbackFactory.java    |   6 +-
 .../storage/am/common/api/ISearchPredicate.java |   4 +-
 .../storage/am/common/api/ISlotManager.java     |  12 +-
 .../storage/am/common/api/ISplitKey.java        |   2 +-
 .../storage/am/common/api/ITreeIndex.java       |   4 +-
 .../am/common/api/ITreeIndexAccessor.java       |   4 +-
 .../storage/am/common/api/ITreeIndexCursor.java |   8 +-
 .../storage/am/common/api/ITreeIndexFrame.java  |  12 +-
 .../common/api/ITreeIndexFrameCompressor.java   |   4 +-
 .../am/common/api/ITreeIndexFrameFactory.java   |   2 +-
 .../am/common/api/ITreeIndexMetaDataFrame.java  |   4 +-
 .../api/ITreeIndexMetaDataFrameFactory.java     |   2 +-
 .../am/common/api/ITreeIndexTupleReference.java |   4 +-
 .../am/common/api/ITreeIndexTupleWriter.java    |   4 +-
 .../api/ITreeIndexTupleWriterFactory.java       |   2 +-
 .../storage/am/common/api/ITupleFilter.java     |   4 +-
 .../am/common/api/ITupleFilterFactory.java      |   4 +-
 .../storage/am/common/api/ITupleUpdater.java    |   4 +-
 .../am/common/api/ITupleUpdaterFactory.java     |   2 +-
 .../am/common/api/ITwoPCIndexBulkLoader.java    |   6 +-
 .../am/common/api/IVirtualFreePageManager.java  |   2 +-
 .../storage/am/common/api/IndexException.java   |   2 +-
 .../am/common/api/TreeIndexException.java       |   2 +-
 .../am/common/api/UnsortedInputException.java   |   2 +-
 .../PointablePrimitiveValueProviderFactory.java |  14 +-
 .../AbstractIndexOperatorDescriptor.java        |  26 ++--
 .../AbstractTreeIndexOperatorDescriptor.java    |  26 ++--
 .../dataflow/IIndexDataflowHelperFactory.java   |   6 +-
 .../dataflow/IIndexOperatorDescriptor.java      |  24 ++--
 .../dataflow/ITreeIndexOperatorDescriptor.java  |   8 +-
 .../IndexBulkLoadOperatorNodePushable.java      |  26 ++--
 .../IndexCreateOperatorNodePushable.java        |  16 +--
 .../am/common/dataflow/IndexDataflowHelper.java |  24 ++--
 .../dataflow/IndexDropOperatorDescriptor.java   |  26 ++--
 .../dataflow/IndexDropOperatorNodePushable.java |  16 +--
 ...xInsertUpdateDeleteOperatorNodePushable.java |  44 +++---
 .../common/dataflow/IndexLifecycleManager.java  |  10 +-
 .../am/common/dataflow/IndexRegistry.java       |   2 +-
 .../IndexSearchOperatorNodePushable.java        |  44 +++---
 .../TreeIndexBulkLoadOperatorDescriptor.java    |  26 ++--
 .../TreeIndexCreateOperatorDescriptor.java      |  26 ++--
 .../dataflow/TreeIndexDataflowHelper.java       |  12 +-
 ...reeIndexDiskOrderScanOperatorDescriptor.java |  26 ++--
 ...eIndexDiskOrderScanOperatorNodePushable.java |  30 ++--
 ...dexInsertUpdateDeleteOperatorDescriptor.java |  32 ++---
 .../TreeIndexStatsOperatorDescriptor.java       |  32 ++---
 .../TreeIndexStatsOperatorNodePushable.java     |  28 ++--
 .../am/common/datagen/DataGenThread.java        |   4 +-
 .../storage/am/common/datagen/DataGenUtils.java |  12 +-
 .../DocumentStringFieldValueGenerator.java      |   2 +-
 .../datagen/DoubleFieldValueGenerator.java      |   2 +-
 .../datagen/FloatFieldValueGenerator.java       |   2 +-
 .../am/common/datagen/IFieldValueGenerator.java |   2 +-
 .../datagen/IntegerFieldValueGenerator.java     |   2 +-
 .../datagen/PersonNameFieldValueGenerator.java  |   2 +-
 .../am/common/datagen/ProbabilityHelper.java    |   2 +-
 .../SortedDoubleFieldValueGenerator.java        |   2 +-
 .../datagen/SortedFloatFieldValueGenerator.java |   2 +-
 .../SortedIntegerFieldValueGenerator.java       |   2 +-
 .../datagen/StringFieldValueGenerator.java      |   2 +-
 .../storage/am/common/datagen/TupleBatch.java   |   6 +-
 .../am/common/datagen/TupleGenerator.java       |  10 +-
 .../TreeIndexDuplicateKeyException.java         |   4 +-
 .../TreeIndexNonExistentKeyException.java       |   4 +-
 .../am/common/frames/AbstractSlotManager.java   |   6 +-
 .../am/common/frames/FrameOpSpaceStatus.java    |   2 +-
 .../am/common/frames/LIFOMetaDataFrame.java     |   6 +-
 .../common/frames/LIFOMetaDataFrameFactory.java |   6 +-
 .../am/common/frames/TreeIndexNSMFrame.java     |  16 +--
 .../freepage/LinkedListFreePageManager.java     |  18 +--
 .../LinkedListFreePageManagerFactory.java       |  10 +-
 .../common/impls/AbstractSearchPredicate.java   |   6 +-
 .../am/common/impls/AbstractTreeIndex.java      |  40 +++---
 .../am/common/impls/NoOpOperationCallback.java  |  10 +-
 .../impls/NoOpOperationCallbackFactory.java     |  12 +-
 .../storage/am/common/impls/NodeFrontier.java   |   6 +-
 .../impls/TreeIndexDiskOrderScanCursor.java     |  22 +--
 .../am/common/ophelpers/DoubleArrayList.java    |   2 +-
 .../am/common/ophelpers/FindTupleMode.java      |   2 +-
 .../ophelpers/FindTupleNoExactMatchPolicy.java  |   2 +-
 .../storage/am/common/ophelpers/IndexOp.java    |   2 +-
 .../am/common/ophelpers/IndexOperation.java     |   2 +-
 .../am/common/ophelpers/IntArrayList.java       |   2 +-
 .../am/common/ophelpers/LongArrayList.java      |   2 +-
 .../am/common/ophelpers/MultiComparator.java    |  10 +-
 .../am/common/ophelpers/SingleComparator.java   |   8 +-
 .../am/common/ophelpers/SlotOffTupleOff.java    |   2 +-
 .../tuples/ConcatenatingTupleReference.java     |   4 +-
 .../am/common/tuples/DualTupleReference.java    |   4 +-
 .../tuples/PermutingFrameTupleReference.java    |   6 +-
 .../common/tuples/PermutingTupleReference.java  |   4 +-
 .../am/common/tuples/SimpleTupleReference.java  |   6 +-
 .../am/common/tuples/SimpleTupleWriter.java     |   8 +-
 .../common/tuples/SimpleTupleWriterFactory.java |   6 +-
 .../common/tuples/TypeAwareTupleReference.java  |   8 +-
 .../am/common/tuples/TypeAwareTupleWriter.java  |  10 +-
 .../tuples/TypeAwareTupleWriterFactory.java     |   8 +-
 .../common/tuples/VarLenIntEncoderDecoder.java  |   2 +-
 .../storage/am/common/util/HashMultiSet.java    |   2 +-
 .../am/common/util/IndexFileNameUtil.java       |   2 +-
 .../common/util/TreeIndexBufferCacheWarmup.java |  18 +--
 .../storage/am/common/util/TreeIndexStats.java  |   8 +-
 .../am/common/util/TreeIndexStatsGatherer.java  |  16 +--
 .../storage/am/common/util/TreeIndexUtils.java  |  12 +-
 hyracks/hyracks-storage-am-lsm-btree/pom.xml    |   8 +-
 .../dataflow/ExternalBTreeDataflowHelper.java   |  26 ++--
 .../ExternalBTreeDataflowHelperFactory.java     |  18 +--
 .../ExternalBTreeWithBuddyDataflowHelper.java   |  24 ++--
 ...rnalBTreeWithBuddyDataflowHelperFactory.java |  18 +--
 .../btree/dataflow/LSMBTreeDataflowHelper.java  |  30 ++--
 .../dataflow/LSMBTreeDataflowHelperFactory.java |  24 ++--
 .../impls/AntimatterAwareTupleAcceptor.java     |   8 +-
 .../am/lsm/btree/impls/ExternalBTree.java       |  86 ++++++------
 .../lsm/btree/impls/ExternalBTreeOpContext.java |  22 +--
 .../lsm/btree/impls/ExternalBTreeWithBuddy.java |  98 ++++++-------
 .../impls/ExternalBTreeWithBuddyOpContext.java  |  18 +--
 .../storage/am/lsm/btree/impls/LSMBTree.java    | 118 ++++++++--------
 .../btree/impls/LSMBTreeCursorInitialState.java |  18 +--
 .../lsm/btree/impls/LSMBTreeDiskComponent.java  |  12 +-
 .../impls/LSMBTreeDiskComponentFactory.java     |  22 +--
 .../am/lsm/btree/impls/LSMBTreeFileManager.java |  18 +--
 .../lsm/btree/impls/LSMBTreeFlushOperation.java |  18 +--
 .../btree/impls/LSMBTreeMemoryComponent.java    |  12 +-
 .../lsm/btree/impls/LSMBTreeMergeOperation.java |  20 +--
 .../am/lsm/btree/impls/LSMBTreeOpContext.java   |  30 ++--
 .../btree/impls/LSMBTreePointSearchCursor.java  |  46 +++---
 .../btree/impls/LSMBTreeRangeSearchCursor.java  |  42 +++---
 .../lsm/btree/impls/LSMBTreeSearchCursor.java   |  24 ++--
 .../impls/LSMBTreeWithBuddyAbstractCursor.java  |  42 +++---
 .../LSMBTreeWithBuddyCursorInitialState.java    |  16 +--
 .../impls/LSMBTreeWithBuddyDiskComponent.java   |  10 +-
 .../LSMBTreeWithBuddyDiskComponentFactory.java  |  20 +--
 .../impls/LSMBTreeWithBuddyFileManager.java     |  18 +--
 .../impls/LSMBTreeWithBuddyMemoryComponent.java |  10 +-
 .../impls/LSMBTreeWithBuddyMergeOperation.java  |  20 +--
 .../impls/LSMBTreeWithBuddySearchCursor.java    |  16 +--
 .../impls/LSMBTreeWithBuddySortedCursor.java    |  16 +--
 .../btree/impls/LSMBuddyBTreeMergeCursor.java   |  32 ++---
 .../btree/tuples/LSMBTreeCopyTupleWriter.java   |   6 +-
 .../tuples/LSMBTreeCopyTupleWriterFactory.java  |   8 +-
 .../LSMBTreeRefrencingTupleWriterFactory.java   |  10 +-
 .../btree/tuples/LSMBTreeTupleReference.java    |  10 +-
 .../lsm/btree/tuples/LSMBTreeTupleWriter.java   |  10 +-
 .../tuples/LSMBTreeTupleWriterFactory.java      |   8 +-
 .../am/lsm/btree/util/LSMBTreeUtils.java        |  70 +++++-----
 hyracks/hyracks-storage-am-lsm-common/pom.xml   |   8 +-
 .../am/lsm/common/api/ILSMComponent.java        |   6 +-
 .../am/lsm/common/api/ILSMComponentFactory.java |  10 +-
 .../am/lsm/common/api/ILSMComponentFilter.java  |  10 +-
 .../common/api/ILSMComponentFilterFactory.java  |   2 +-
 .../common/api/ILSMComponentFilterFrame.java    |   6 +-
 .../api/ILSMComponentFilterFrameFactory.java    |   2 +-
 .../common/api/ILSMComponentFilterManager.java  |   8 +-
 .../storage/am/lsm/common/api/ILSMHarness.java  |  13 +-
 .../am/lsm/common/api/ILSMIOOperation.java      |   8 +-
 .../lsm/common/api/ILSMIOOperationCallback.java |   6 +-
 .../api/ILSMIOOperationCallbackFactory.java     |   2 +-
 .../api/ILSMIOOperationCallbackProvider.java    |   2 +-
 .../common/api/ILSMIOOperationScheduler.java    |   4 +-
 .../api/ILSMIOOperationSchedulerProvider.java   |   4 +-
 .../storage/am/lsm/common/api/ILSMIndex.java    |  12 +-
 .../am/lsm/common/api/ILSMIndexAccessor.java    |  10 +-
 .../common/api/ILSMIndexAccessorInternal.java   |   8 +-
 .../am/lsm/common/api/ILSMIndexFileManager.java |   8 +-
 .../am/lsm/common/api/ILSMIndexInternal.java    |  20 +--
 .../common/api/ILSMIndexOperationContext.java   |  10 +-
 .../lsm/common/api/ILSMIndexReplicationJob.java |   6 +-
 .../am/lsm/common/api/ILSMMergePolicy.java      |   6 +-
 .../lsm/common/api/ILSMMergePolicyFactory.java  |   6 +-
 .../am/lsm/common/api/ILSMOperationTracker.java |  12 +-
 .../api/ILSMOperationTrackerProvider.java       |   4 +-
 .../lsm/common/api/ILSMTreeTupleReference.java  |   4 +-
 .../storage/am/lsm/common/api/ITwoPCIndex.java  |  12 +-
 .../am/lsm/common/api/IVirtualBufferCache.java  |   8 +-
 .../common/api/IVirtualBufferCacheProvider.java |   4 +-
 .../AbstractLSMIndexDataflowHelper.java         |  22 +--
 .../AbstractLSMIndexDataflowHelperFactory.java  |  18 +--
 .../LSMIndexCompactOperatorNodePushable.java    |  24 ++--
 ...xInsertUpdateDeleteOperatorNodePushable.java |  20 +--
 .../LSMTreeIndexCompactOperatorDescriptor.java  |  30 ++--
 ...dexInsertUpdateDeleteOperatorDescriptor.java |  36 ++---
 .../common/frames/LSMComponentFilterFrame.java  |  12 +-
 .../frames/LSMComponentFilterFrameFactory.java  |   8 +-
 .../common/freepage/VirtualFreePageManager.java |  10 +-
 .../impls/AbortRecoverLSMIndexFileManager.java  |   4 +-
 .../common/impls/AbstractDiskLSMComponent.java  |   6 +-
 .../lsm/common/impls/AbstractLSMComponent.java  |   6 +-
 .../am/lsm/common/impls/AbstractLSMIndex.java   |  44 +++---
 .../impls/AbstractLSMIndexFileManager.java      |  22 +--
 .../impls/AbstractMemoryLSMComponent.java       |   8 +-
 .../lsm/common/impls/AsynchronousScheduler.java |  10 +-
 .../am/lsm/common/impls/BTreeFactory.java       |  18 +--
 .../BlockingIOOperationCallbackWrapper.java     |   8 +-
 .../BloomFilterAwareBTreePointSearchCursor.java |  10 +-
 .../lsm/common/impls/ConstantMergePolicy.java   |  18 +--
 .../impls/ConstantMergePolicyFactory.java       |  10 +-
 .../lsm/common/impls/ExternalIndexHarness.java  |  32 ++---
 .../am/lsm/common/impls/IndexFactory.java       |  14 +-
 .../impls/LSMComponentFileReferences.java       |   4 +-
 .../am/lsm/common/impls/LSMComponentFilter.java |  16 +--
 .../common/impls/LSMComponentFilterFactory.java |  10 +-
 .../common/impls/LSMComponentFilterManager.java |  26 ++--
 .../am/lsm/common/impls/LSMComponentState.java  |   2 +-
 .../storage/am/lsm/common/impls/LSMHarness.java |  40 +++---
 .../am/lsm/common/impls/LSMIOOperationTask.java |   4 +-
 .../common/impls/LSMIndexReplicationJob.java    |  10 +-
 .../lsm/common/impls/LSMIndexSearchCursor.java  |  26 ++--
 .../am/lsm/common/impls/LSMOperationType.java   |   2 +-
 .../lsm/common/impls/LSMTreeIndexAccessor.java  |  26 ++--
 .../impls/MultitenantVirtualBufferCache.java    |  15 +-
 .../am/lsm/common/impls/NoMergePolicy.java      |  10 +-
 .../lsm/common/impls/NoMergePolicyFactory.java  |  10 +-
 .../common/impls/NoOpIOOperationCallback.java   |  14 +-
 .../impls/NoOpOperationTrackerProvider.java     |  16 +--
 .../am/lsm/common/impls/PrefixMergePolicy.java  |  18 +--
 .../common/impls/PrefixMergePolicyFactory.java  |  10 +-
 .../lsm/common/impls/SynchronousScheduler.java  |  10 +-
 .../impls/SynchronousSchedulerProvider.java     |   8 +-
 .../ThreadCountingOperationTrackerProvider.java |   8 +-
 .../lsm/common/impls/ThreadCountingTracker.java |  18 +--
 .../am/lsm/common/impls/TreeIndexFactory.java   |  14 +-
 .../am/lsm/common/impls/VirtualBufferCache.java |  20 +--
 .../pom.xml                                     |   6 +-
 .../lsm/invertedindex/api/IInvertedIndex.java   |  16 +--
 .../api/IInvertedIndexAccessor.java             |  14 +-
 .../api/IInvertedIndexFileNameMapper.java       |   2 +-
 .../api/IInvertedIndexOperatorDescriptor.java   |  10 +-
 .../api/IInvertedIndexSearchModifier.java       |   2 +-
 .../IInvertedIndexSearchModifierFactory.java    |   2 +-
 .../api/IInvertedIndexSearcher.java             |  16 +--
 .../invertedindex/api/IInvertedListBuilder.java |   4 +-
 .../api/IInvertedListBuilderFactory.java        |   2 +-
 .../invertedindex/api/IInvertedListCursor.java  |  12 +-
 .../lsm/invertedindex/api/IObjectFactory.java   |   2 +-
 .../api/IPartitionedInvertedIndex.java          |  10 +-
 ...tractLSMInvertedIndexOperatorDescriptor.java |  34 ++---
 .../BinaryTokenizerOperatorDescriptor.java      |  18 +--
 .../BinaryTokenizerOperatorNodePushable.java    |  26 ++--
 ...InvertedIndexBulkLoadOperatorDescriptor.java |  32 ++---
 .../LSMInvertedIndexCompactOperator.java        |  32 ++---
 ...SMInvertedIndexCreateOperatorDescriptor.java |  32 ++---
 .../LSMInvertedIndexDataflowHelper.java         |  38 ++---
 .../LSMInvertedIndexDataflowHelperFactory.java  |  24 ++--
 ...InvertedIndexInsertUpdateDeleteOperator.java |  38 ++---
 ...SMInvertedIndexSearchOperatorDescriptor.java |  40 +++---
 ...InvertedIndexSearchOperatorNodePushable.java |  22 +--
 ...rtitionedLSMInvertedIndexDataflowHelper.java |  38 ++---
 ...edLSMInvertedIndexDataflowHelperFactory.java |  24 ++--
 .../exceptions/InvertedIndexException.java      |   4 +-
 .../OccurrenceThresholdPanicException.java      |   2 +-
 .../invertedindex/impls/LSMInvertedIndex.java   | 128 ++++++++---------
 .../impls/LSMInvertedIndexAccessor.java         |  30 ++--
 ...nvertedIndexDeletedKeysBTreeMergeCursor.java |  22 +--
 .../impls/LSMInvertedIndexDiskComponent.java    |  16 +--
 .../LSMInvertedIndexDiskComponentFactory.java   |  24 ++--
 .../impls/LSMInvertedIndexFileManager.java      |  18 +--
 .../impls/LSMInvertedIndexFlushOperation.java   |  18 +--
 .../impls/LSMInvertedIndexMemoryComponent.java  |  16 +--
 .../impls/LSMInvertedIndexMergeOperation.java   |  22 +--
 .../impls/LSMInvertedIndexOpContext.java        |  26 ++--
 .../LSMInvertedIndexRangeSearchCursor.java      |  34 ++---
 ...ertedIndexRangeSearchCursorInitialState.java |  22 +--
 .../impls/LSMInvertedIndexSearchCursor.java     |  36 ++---
 ...SMInvertedIndexSearchCursorInitialState.java |  24 ++--
 .../impls/PartitionedLSMInvertedIndex.java      |  44 +++---
 .../inmemory/InMemoryInvertedIndex.java         |  54 +++----
 .../inmemory/InMemoryInvertedIndexAccessor.java |  42 +++---
 .../InMemoryInvertedIndexOpContext.java         |  24 ++--
 .../inmemory/InMemoryInvertedListCursor.java    |  36 ++---
 .../PartitionedInMemoryInvertedIndex.java       |  46 +++---
 ...artitionedInMemoryInvertedIndexAccessor.java |  10 +-
 ...rtitionedInMemoryInvertedIndexOpContext.java |  12 +-
 .../FixedSizeElementInvertedListBuilder.java    |   8 +-
 ...edSizeElementInvertedListBuilderFactory.java |   8 +-
 .../FixedSizeElementInvertedListCursor.java     |  20 +--
 .../ondisk/FixedSizeFrameTupleAccessor.java     |   8 +-
 .../ondisk/FixedSizeFrameTupleAppender.java     |   6 +-
 .../ondisk/FixedSizeTupleReference.java         |   6 +-
 .../ondisk/OnDiskInvertedIndex.java             |  84 +++++------
 .../ondisk/OnDiskInvertedIndexFactory.java      |  24 ++--
 .../ondisk/OnDiskInvertedIndexOpContext.java    |  20 +--
 .../OnDiskInvertedIndexRangeSearchCursor.java   |  32 ++---
 .../ondisk/OnDiskInvertedIndexSearchCursor.java |  18 +--
 .../ondisk/PartitionedOnDiskInvertedIndex.java  |  42 +++---
 .../PartitionedOnDiskInvertedIndexFactory.java  |  22 +--
 .../search/AbstractTOccurrenceSearcher.java     |  50 +++----
 .../invertedindex/search/ArrayListFactory.java  |   4 +-
 .../ConjunctiveEditDistanceSearchModifier.java  |   2 +-
 ...nctiveEditDistanceSearchModifierFactory.java |   6 +-
 ...njunctiveListEditDistanceSearchModifier.java |   2 +-
 ...veListEditDistanceSearchModifierFactory.java |   6 +-
 .../search/ConjunctiveSearchModifier.java       |   4 +-
 .../ConjunctiveSearchModifierFactory.java       |   6 +-
 .../search/EditDistanceSearchModifier.java      |   4 +-
 .../EditDistanceSearchModifierFactory.java      |   6 +-
 .../search/InvertedIndexSearchPredicate.java    |  12 +-
 .../search/InvertedListCursorFactory.java       |   8 +-
 .../search/InvertedListMerger.java              |  24 ++--
 .../search/InvertedListPartitions.java          |   8 +-
 .../search/JaccardSearchModifier.java           |   4 +-
 .../search/JaccardSearchModifierFactory.java    |   6 +-
 .../search/ListEditDistanceSearchModifier.java  |   4 +-
 .../ListEditDistanceSearchModifierFactory.java  |   6 +-
 .../search/PartitionedTOccurrenceSearcher.java  |  32 ++---
 .../lsm/invertedindex/search/SearchResult.java  |  18 +--
 .../search/TOccurrenceSearcher.java             |  20 +--
 .../AbstractUTF8StringBinaryTokenizer.java      |   4 +-
 .../tokenizers/AbstractUTF8Token.java           |   6 +-
 .../tokenizers/AbstractUTF8TokenFactory.java    |   2 +-
 .../DelimitedUTF8StringBinaryTokenizer.java     |   4 +-
 ...limitedUTF8StringBinaryTokenizerFactory.java |   2 +-
 .../tokenizers/HashedUTF8NGramToken.java        |   6 +-
 .../tokenizers/HashedUTF8NGramTokenFactory.java |   2 +-
 .../tokenizers/HashedUTF8WordToken.java         |   6 +-
 .../tokenizers/HashedUTF8WordTokenFactory.java  |   2 +-
 .../tokenizers/IBinaryTokenizer.java            |   2 +-
 .../tokenizers/IBinaryTokenizerFactory.java     |   2 +-
 .../invertedindex/tokenizers/INGramToken.java   |   2 +-
 .../am/lsm/invertedindex/tokenizers/IToken.java |   4 +-
 .../invertedindex/tokenizers/ITokenFactory.java |   2 +-
 .../lsm/invertedindex/tokenizers/IntArray.java  |   2 +-
 .../NGramUTF8StringBinaryTokenizer.java         |   4 +-
 .../NGramUTF8StringBinaryTokenizerFactory.java  |   2 +-
 .../tokenizers/UTF8NGramToken.java              |   8 +-
 .../tokenizers/UTF8NGramTokenFactory.java       |   2 +-
 .../invertedindex/tokenizers/UTF8WordToken.java |   8 +-
 .../tokenizers/UTF8WordTokenFactory.java        |   2 +-
 .../InvertedIndexTokenizingTupleIterator.java   |  14 +-
 .../invertedindex/util/InvertedIndexUtils.java  |  82 +++++------
 .../am/lsm/invertedindex/util/ObjectCache.java  |   4 +-
 ...nedInvertedIndexTokenizingTupleIterator.java |  10 +-
 hyracks/hyracks-storage-am-lsm-rtree/pom.xml    |   8 +-
 .../AbstractLSMRTreeDataflowHelper.java         |  42 +++---
 .../dataflow/ExternalRTreeDataflowHelper.java   |  44 +++---
 .../ExternalRTreeDataflowHelperFactory.java     |  24 ++--
 .../rtree/dataflow/LSMRTreeDataflowHelper.java  |  42 +++---
 .../dataflow/LSMRTreeDataflowHelperFactory.java |  30 ++--
 ...RTreeWithAntiMatterTuplesDataflowHelper.java |  42 +++---
 ...thAntiMatterTuplesDataflowHelperFactory.java |  30 ++--
 .../am/lsm/rtree/impls/AbstractLSMRTree.java    |  82 +++++------
 .../am/lsm/rtree/impls/ExternalRTree.java       |  84 +++++------
 .../lsm/rtree/impls/ExternalRTreeOpContext.java |  18 +--
 .../storage/am/lsm/rtree/impls/LSMRTree.java    | 104 +++++++-------
 .../lsm/rtree/impls/LSMRTreeAbstractCursor.java |  50 +++----
 .../rtree/impls/LSMRTreeCursorInitialState.java |  18 +--
 .../LSMRTreeDeletedKeysBTreeMergeCursor.java    |  32 ++---
 .../lsm/rtree/impls/LSMRTreeDiskComponent.java  |  14 +-
 .../impls/LSMRTreeDiskComponentFactory.java     |  24 ++--
 .../am/lsm/rtree/impls/LSMRTreeFileManager.java |  18 +--
 .../lsm/rtree/impls/LSMRTreeFlushOperation.java |  18 +--
 .../rtree/impls/LSMRTreeMemoryComponent.java    |  16 +--
 .../lsm/rtree/impls/LSMRTreeMergeOperation.java |  20 +--
 .../am/lsm/rtree/impls/LSMRTreeOpContext.java   |  36 ++---
 .../lsm/rtree/impls/LSMRTreeSearchCursor.java   |  16 +--
 .../lsm/rtree/impls/LSMRTreeSortedCursor.java   |  20 +--
 .../impls/LSMRTreeWithAntiMatterTuples.java     |  86 ++++++------
 ...ithAntiMatterTuplesDiskComponentFactory.java |  18 +--
 ...LSMRTreeWithAntiMatterTuplesFileManager.java |  12 +-
 ...LSMRTreeWithAntiMatterTuplesFlushCursor.java |  22 +--
 ...SMRTreeWithAntiMatterTuplesSearchCursor.java |  46 +++---
 .../am/lsm/rtree/impls/RTreeFactory.java        |  20 +--
 .../am/lsm/rtree/impls/TreeTupleSorter.java     |  28 ++--
 .../rtree/tuples/LSMRTreeCopyTupleWriter.java   |   6 +-
 .../tuples/LSMRTreeCopyTupleWriterFactory.java  |   8 +-
 .../rtree/tuples/LSMRTreeTupleReference.java    |   8 +-
 .../lsm/rtree/tuples/LSMRTreeTupleWriter.java   |  10 +-
 .../tuples/LSMRTreeTupleWriterFactory.java      |   8 +-
 .../tuples/LSMTypeAwareTupleWriterFactory.java  |  12 +-
 .../am/lsm/rtree/utils/LSMRTreeUtils.java       |  94 ++++++-------
 hyracks/hyracks-storage-am-rtree/pom.xml        |   8 +-
 ...IGenericPrimitiveSerializerDeserializer.java |   4 +-
 .../storage/am/rtree/api/IRTreeFrame.java       |   6 +-
 .../am/rtree/api/IRTreeInteriorFrame.java       |  12 +-
 .../storage/am/rtree/api/IRTreeLeafFrame.java   |   8 +-
 .../storage/am/rtree/api/IRTreePolicy.java      |  16 +--
 .../am/rtree/dataflow/RTreeDataflowHelper.java  |  20 +--
 .../dataflow/RTreeDataflowHelperFactory.java    |  14 +-
 .../dataflow/RTreeSearchOperatorDescriptor.java |  34 ++---
 .../RTreeSearchOperatorNodePushable.java        |  22 +--
 .../am/rtree/frames/RStarTreePolicy.java        |  38 ++---
 .../am/rtree/frames/RTreeComputationUtils.java  |  10 +-
 .../storage/am/rtree/frames/RTreeNSMFrame.java  |  28 ++--
 .../am/rtree/frames/RTreeNSMInteriorFrame.java  |  32 ++---
 .../frames/RTreeNSMInteriorFrameFactory.java    |  12 +-
 .../am/rtree/frames/RTreeNSMLeafFrame.java      |  18 +--
 .../rtree/frames/RTreeNSMLeafFrameFactory.java  |  12 +-
 .../storage/am/rtree/frames/RTreePolicy.java    |  34 ++---
 .../am/rtree/frames/RTreePolicyType.java        |   2 +-
 .../DoublePrimitiveValueProviderFactory.java    |   8 +-
 .../storage/am/rtree/impls/EntriesOrder.java    |   2 +-
 .../FloatPrimitiveValueProviderFactory.java     |   8 +-
 .../IntegerPrimitiveValueProviderFactory.java   |   8 +-
 .../storage/am/rtree/impls/PathList.java        |   6 +-
 .../hyracks/storage/am/rtree/impls/RTree.java   |  74 +++++-----
 .../am/rtree/impls/RTreeCursorInitialState.java |  10 +-
 .../storage/am/rtree/impls/RTreeOpContext.java  |  24 ++--
 .../am/rtree/impls/RTreeSearchCursor.java       |  28 ++--
 .../storage/am/rtree/impls/RTreeSplitKey.java   |   6 +-
 .../storage/am/rtree/impls/Rectangle.java       |   6 +-
 .../storage/am/rtree/impls/SearchPredicate.java |   8 +-
 .../storage/am/rtree/impls/TupleEntry.java      |   4 +-
 .../am/rtree/impls/TupleEntryArrayList.java     |   2 +-
 .../am/rtree/impls/UnorderedSlotManager.java    |  18 +--
 .../linearize/HilbertDoubleComparator.java      |  18 +--
 .../HilbertDoubleComparatorFactory.java         |   6 +-
 .../rtree/linearize/ZCurveDoubleComparator.java |  16 +--
 .../ZCurveDoubleComparatorFactory.java          |   6 +-
 .../am/rtree/linearize/ZCurveIntComparator.java |  12 +-
 .../linearize/ZCurveIntComparatorFactory.java   |   6 +-
 .../rtree/tuples/RTreeTypeAwareTupleWriter.java |   8 +-
 .../RTreeTypeAwareTupleWriterFactory.java       |   8 +-
 .../storage/am/rtree/util/RTreeUtils.java       |  44 +++---
 hyracks/hyracks-storage-common/pom.xml          |   4 +-
 .../common/IStorageManagerInterface.java        |  12 +-
 .../storage/common/buffercache/BufferCache.java |  18 +--
 .../storage/common/buffercache/CachedPage.java  |   2 +-
 .../ClockPageReplacementStrategy.java           |   2 +-
 .../common/buffercache/DebugBufferCache.java    |   8 +-
 .../buffercache/DelayPageCleanerPolicy.java     |   4 +-
 .../buffercache/DirectBufferAllocator.java      |   2 +-
 .../common/buffercache/HeapBufferAllocator.java |   2 +-
 .../common/buffercache/IBufferCache.java        |  10 +-
 .../buffercache/IBufferCacheInternal.java       |   2 +-
 .../buffercache/ICacheMemoryAllocator.java      |   2 +-
 .../storage/common/buffercache/ICachedPage.java |   2 +-
 .../common/buffercache/ICachedPageInternal.java |   2 +-
 .../common/buffercache/IPageCleanerPolicy.java  |   4 +-
 .../buffercache/IPageReplacementStrategy.java   |   2 +-
 .../storage/common/file/BufferedFileHandle.java |   4 +-
 .../storage/common/file/IFileMapManager.java    |   6 +-
 .../storage/common/file/IFileMapProvider.java   |   6 +-
 .../common/file/ILocalResourceFactory.java      |   2 +-
 .../file/ILocalResourceFactoryProvider.java     |   2 +-
 .../common/file/ILocalResourceRepository.java   |   4 +-
 .../file/ILocalResourceRepositoryFactory.java   |   4 +-
 .../storage/common/file/LocalResource.java      |   2 +-
 .../file/NoOpLocalResourceFactoryProvider.java  |   2 +-
 .../storage/common/file/ResourceIdFactory.java  |   2 +-
 .../common/file/ResourceIdFactoryProvider.java  |   4 +-
 .../common/file/TransientFileMapManager.java    |   6 +-
 .../file/TransientLocalResourceFactory.java     |   2 +-
 .../TransientLocalResourceFactoryProvider.java  |   2 +-
 .../file/TransientLocalResourceRepository.java  |   4 +-
 ...TransientLocalResourceRepositoryFactory.java |   4 +-
 .../hyracks/storage/common/sync/LatchType.java  |   2 +-
 hyracks/hyracks-test-support/pom.xml            |  12 +-
 ...stractModificationOperationCallbackTest.java |  20 +--
 .../am/btree/AbstractOperationCallbackTest.java |  12 +-
 .../AbstractSearchOperationCallbackTest.java    |  22 +--
 .../am/btree/OrderedIndexBulkLoadTest.java      |  12 +-
 .../am/btree/OrderedIndexDeleteTest.java        |  14 +-
 .../am/btree/OrderedIndexExamplesTest.java      |  54 +++----
 .../am/btree/OrderedIndexInsertTest.java        |  12 +-
 .../am/btree/OrderedIndexMultiThreadTest.java   |  30 ++--
 .../am/btree/OrderedIndexSortedInsertTest.java  |  12 +-
 .../am/btree/OrderedIndexTestContext.java       |  12 +-
 .../am/btree/OrderedIndexTestDriver.java        |  16 +--
 .../storage/am/btree/OrderedIndexTestUtils.java |  40 +++---
 .../am/btree/OrderedIndexUpdateTest.java        |  14 +-
 .../am/btree/OrderedIndexUpsertTest.java        |  12 +-
 .../am/common/AbstractIndexLifecycleTest.java   |   6 +-
 .../am/common/AbstractIndexTestWorker.java      |  20 +--
 .../hyracks/storage/am/common/CheckTuple.java   |   2 +-
 .../storage/am/common/IIndexTestContext.java    |  14 +-
 .../am/common/IIndexTestWorkerFactory.java      |   8 +-
 .../am/common/ITreeIndexTestContext.java        |  14 +-
 .../storage/am/common/ITreeIndexTestWorker.java |  10 +-
 .../am/common/IndexMultiThreadTestDriver.java   |  14 +-
 .../storage/am/common/IndexTestContext.java     |  14 +-
 .../am/common/TestOperationCallback.java        |  10 +-
 .../am/common/TestOperationSelector.java        |   4 +-
 .../storage/am/common/TestWorkloadConf.java     |   4 +-
 .../storage/am/common/TreeIndexTestUtils.java   |  26 ++--
 .../am/config/AccessMethodTestsConfig.java      |   2 +-
 .../am/rtree/AbstractRTreeBulkLoadTest.java     |  16 +--
 .../am/rtree/AbstractRTreeDeleteTest.java       |  16 +--
 .../am/rtree/AbstractRTreeExamplesTest.java     |  58 ++++----
 .../am/rtree/AbstractRTreeInsertTest.java       |  14 +-
 .../am/rtree/AbstractRTreeMultiThreadTest.java  |  42 +++---
 .../am/rtree/AbstractRTreeTestContext.java      |  12 +-
 .../am/rtree/AbstractRTreeTestDriver.java       |  24 ++--
 .../storage/am/rtree/RTreeCheckTuple.java       |   4 +-
 .../storage/am/rtree/RTreeTestUtils.java        |  32 ++---
 .../hyracks/test/support/CounterContext.java    |   8 +-
 .../TestIndexLifecycleManagerProvider.java      |   8 +-
 .../hyracks/test/support/TestJobletContext.java |  26 ++--
 .../test/support/TestNCApplicationContext.java  |  18 +--
 .../hyracks/test/support/TestRootContext.java   |  14 +-
 .../TestStorageManagerComponentHolder.java      |  44 +++---
 .../support/TestStorageManagerInterface.java    |  16 +--
 .../hyracks/test/support/TestTaskContext.java   |  30 ++--
 .../apache/hyracks/test/support/TestUtils.java  |  20 +--
 .../support/TestVirtualBufferCacheProvider.java |  12 +-
 .../hyracks-storage-am-bloomfilter-test/pom.xml |   6 +-
 .../storage/am/bloomfilter/BloomFilterTest.java |  28 ++--
 .../MurmurHashForITupleReferenceTest.java       |  20 +--
 .../util/AbstractBloomFilterTest.java           |   4 +-
 .../util/BloomFilterTestHarness.java            |  18 +--
 .../hyracks-storage-am-btree-test/pom.xml       |   6 +-
 .../storage/am/btree/BTreeBulkLoadTest.java     |  12 +-
 .../storage/am/btree/BTreeDeleteTest.java       |  12 +-
 .../storage/am/btree/BTreeExamplesTest.java     |  18 +--
 .../storage/am/btree/BTreeInsertTest.java       |  12 +-
 .../storage/am/btree/BTreeLifecycleTest.java    |  26 ++--
 .../BTreeModificationOperationCallbackTest.java |  10 +-
 .../storage/am/btree/BTreeSearchCursorTest.java |  64 ++++-----
 .../btree/BTreeSearchOperationCallbackTest.java |  10 +-
 .../storage/am/btree/BTreeSortedInsertTest.java |  12 +-
 .../storage/am/btree/BTreeStatsTest.java        |  78 +++++------
 .../storage/am/btree/BTreeUpdateSearchTest.java |  58 ++++----
 .../storage/am/btree/BTreeUpdateTest.java       |  12 +-
 .../storage/am/btree/BTreeUpsertTest.java       |  12 +-
 .../storage/am/btree/FieldPrefixNSMTest.java    |  58 ++++----
 .../storage/am/btree/StorageManagerTest.java    |  14 +-
 .../btree/multithread/BTreeMultiThreadTest.java |  28 ++--
 .../am/btree/multithread/BTreeTestWorker.java   |  36 ++---
 .../multithread/BTreeTestWorkerFactory.java     |  14 +-
 .../am/btree/util/AbstractBTreeTest.java        |   4 +-
 .../storage/am/btree/util/BTreeTestContext.java |  26 ++--
 .../storage/am/btree/util/BTreeTestHarness.java |  20 +--
 .../hyracks-storage-am-lsm-btree-test/pom.xml   |   8 +-
 .../am/lsm/btree/LSMBTreeBulkLoadTest.java      |  18 +--
 .../am/lsm/btree/LSMBTreeDeleteTest.java        |  18 +--
 .../am/lsm/btree/LSMBTreeExamplesTest.java      |  38 ++---
 .../am/lsm/btree/LSMBTreeInsertTest.java        |  18 +--
 .../am/lsm/btree/LSMBTreeLifecycleTest.java     |  24 ++--
 .../storage/am/lsm/btree/LSMBTreeMergeTest.java |  16 +--
 .../am/lsm/btree/LSMBTreeMergeTestDriver.java   |  26 ++--
 ...MBTreeModificationOperationCallbackTest.java |  22 +--
 .../am/lsm/btree/LSMBTreeMultiBulkLoadTest.java |  20 +--
 .../LSMBTreeSearchOperationCallbackTest.java    |  34 ++---
 .../am/lsm/btree/LSMBTreeUpdateTest.java        |  18 +--
 .../multithread/LSMBTreeMultiThreadTest.java    |  28 ++--
 .../btree/multithread/LSMBTreeTestWorker.java   |  40 +++---
 .../multithread/LSMBTreeTestWorkerFactory.java  |  14 +-
 .../am/lsm/btree/perf/BTreeBulkLoadRunner.java  |  16 +--
 .../am/lsm/btree/perf/BTreePageSizePerf.java    |  14 +-
 .../storage/am/lsm/btree/perf/BTreeRunner.java  |  22 +--
 .../btree/perf/ConcurrentSkipListRunner.java    |  20 +--
 .../am/lsm/btree/perf/IExperimentRunner.java    |   4 +-
 .../am/lsm/btree/perf/InMemoryBTreeRunner.java  |  44 +++---
 .../am/lsm/btree/perf/InMemorySortRunner.java   |  20 +--
 .../am/lsm/btree/perf/LSMTreeRunner.java        |  56 ++++----
 .../am/lsm/btree/perf/PerfExperiment.java       |  14 +-
 .../am/lsm/btree/tuples/LSMBTreeTuplesTest.java |  22 +--
 .../am/lsm/btree/util/LSMBTreeTestContext.java  |  36 ++---
 .../am/lsm/btree/util/LSMBTreeTestHarness.java  |  48 +++----
 .../hyracks-storage-am-lsm-common-test/pom.xml  |   6 +-
 .../am/lsm/common/DummyLSMIndexFileManager.java |  16 +--
 .../storage/am/lsm/common/DummyTreeFactory.java |  10 +-
 .../am/lsm/common/LSMIndexFileManagerTest.java  |  22 +--
 .../am/lsm/common/VirtualBufferCacheTest.java   |  14 +-
 .../lsm/common/VirtualFreePageManagerTest.java  |   6 +-
 .../pom.xml                                     |   8 +-
 .../LSMInvertedIndexBulkLoadTest.java           |   6 +-
 .../LSMInvertedIndexDeleteTest.java             |   6 +-
 .../LSMInvertedIndexInsertTest.java             |   6 +-
 .../LSMInvertedIndexMergeTest.java              |  26 ++--
 .../LSMInvertedIndexSearchTest.java             |   6 +-
 ...PartitionedLSMInvertedIndexBulkLoadTest.java |   6 +-
 .../PartitionedLSMInvertedIndexDeleteTest.java  |   6 +-
 .../PartitionedLSMInvertedIndexInsertTest.java  |   6 +-
 .../PartitionedLSMInvertedIndexMergeTest.java   |  26 ++--
 .../PartitionedLSMInvertedIndexSearchTest.java  |   6 +-
 .../common/AbstractInvertedIndexDeleteTest.java |  16 +--
 .../common/AbstractInvertedIndexLoadTest.java   |  14 +-
 .../common/AbstractInvertedIndexSearchTest.java |  24 ++--
 .../common/AbstractInvertedIndexTest.java       |  26 ++--
 .../common/LSMInvertedIndexTestHarness.java     |  48 +++----
 .../InMemoryInvertedIndexDeleteTest.java        |   6 +-
 .../InMemoryInvertedIndexInsertTest.java        |   6 +-
 .../InMemoryInvertedIndexSearchTest.java        |   6 +-
 ...titionedInMemoryInvertedIndexDeleteTest.java |   6 +-
 ...titionedInMemoryInvertedIndexInsertTest.java |   6 +-
 ...titionedInMemoryInvertedIndexSearchTest.java |   6 +-
 .../LSMInvertedIndexMultiThreadTest.java        |  28 ++--
 .../LSMInvertedIndexMultiThreadTestDriver.java  |  16 +--
 .../multithread/LSMInvertedIndexTestWorker.java |  42 +++---
 .../LSMInvertedIndexWorkerFactory.java          |  14 +-
 ...titionedLSMInvertedIndexMultiThreadTest.java |   4 +-
 .../ondisk/FixedSizeFrameTupleTest.java         |  12 +-
 .../ondisk/OnDiskInvertedIndexBulkLoadTest.java |   6 +-
 .../OnDiskInvertedIndexLifecycleTest.java       |  22 +--
 .../ondisk/OnDiskInvertedIndexSearchTest.java   |   6 +-
 ...titionedOnDiskInvertedIndexBulkLoadTest.java |   6 +-
 ...artitionedOnDiskInvertedIndexSearchTest.java |   6 +-
 .../tokenizers/NGramTokenizerTest.java          |   4 +-
 .../tokenizers/WordTokenizerTest.java           |   4 +-
 .../util/LSMInvertedIndexTestContext.java       |  36 ++---
 .../util/LSMInvertedIndexTestUtils.java         |  88 ++++++------
 .../hyracks-storage-am-lsm-rtree-test/pom.xml   |   6 +-
 .../lsm/rtree/AbstractLSMRTreeExamplesTest.java |  36 ++---
 .../am/lsm/rtree/LSMRTreeBulkLoadTest.java      |  22 +--
 .../am/lsm/rtree/LSMRTreeDeleteTest.java        |  22 +--
 .../am/lsm/rtree/LSMRTreeExamplesTest.java      |  22 +--
 .../am/lsm/rtree/LSMRTreeInsertTest.java        |  22 +--
 .../am/lsm/rtree/LSMRTreeLifecycleTest.java     |  32 ++---
 .../storage/am/lsm/rtree/LSMRTreeMergeTest.java |  20 +--
 .../am/lsm/rtree/LSMRTreeMergeTestDriver.java   |  28 ++--
 ...SMRTreeWithAntiMatterTuplesBulkLoadTest.java |  22 +--
 .../LSMRTreeWithAntiMatterTuplesDeleteTest.java |  22 +--
 ...SMRTreeWithAntiMatterTuplesExamplesTest.java |  22 +--
 .../LSMRTreeWithAntiMatterTuplesInsertTest.java |  22 +--
 ...MRTreeWithAntiMatterTuplesLifecycleTest.java |  32 ++---
 .../LSMRTreeWithAntiMatterTuplesMergeTest.java  |  20 +--
 .../multithread/AbstractLSMRTreeTestWorker.java |  26 ++--
 .../multithread/LSMRTreeMultiThreadTest.java    |  34 ++---
 .../rtree/multithread/LSMRTreeTestWorker.java   |  34 ++---
 .../multithread/LSMRTreeTestWorkerFactory.java  |  14 +-
 ...TreeWithAntiMatterTuplesMultiThreadTest.java |  34 ++---
 .../LSMRTreeWithAntiMatterTuplesTestWorker.java |  28 ++--
 ...eeWithAntiMatterTuplesTestWorkerFactory.java |  14 +-
 .../am/lsm/rtree/util/LSMRTreeTestContext.java  |  42 +++---
 .../am/lsm/rtree/util/LSMRTreeTestHarness.java  |  46 +++---
 ...LSMRTreeWithAntiMatterTuplesTestContext.java |  42 +++---
 .../hyracks-storage-am-rtree-test/pom.xml       |   6 +-
 .../storage/am/rtree/RTreeBulkLoadTest.java     |  16 +--
 .../storage/am/rtree/RTreeDeleteTest.java       |  16 +--
 .../storage/am/rtree/RTreeExamplesTest.java     |  20 +--
 .../storage/am/rtree/RTreeInsertTest.java       |  16 +--
 .../storage/am/rtree/RTreeLifecycleTest.java    |  32 ++---
 .../storage/am/rtree/RTreeSearchCursorTest.java |  70 +++++-----
 .../rtree/multithread/RTreeMultiThreadTest.java |  32 ++---
 .../am/rtree/multithread/RTreeTestWorker.java   |  32 ++---
 .../multithread/RTreeTestWorkerFactory.java     |  14 +-
 .../am/rtree/utils/AbstractRTreeTest.java       |   4 +-
 .../am/rtree/utils/RTreeTestContext.java        |  30 ++--
 .../am/rtree/utils/RTreeTestHarness.java        |  18 +--
 .../hyracks-storage-common-test/pom.xml         |   6 +-
 .../common/BufferCacheRegressionTest.java       |  26 ++--
 .../hyracks/storage/common/BufferCacheTest.java |  20 +--
 hyracks/hyracks-tests/pom.xml                   |   2 +-
 hyracks/hyracks-yarn/hyracks-yarn-am/pom.xml    |   6 +-
 .../yarn/am/HyracksYarnApplicationMaster.java   |  14 +-
 .../yarn/am/manifest/AbstractProcess.java       |   2 +-
 .../yarn/am/manifest/ClusterController.java     |   2 +-
 .../am/manifest/ContainerSpecification.java     |   2 +-
 .../yarn/am/manifest/HyracksCluster.java        |   2 +-
 .../yarn/am/manifest/ManifestParser.java        |   2 +-
 .../yarn/am/manifest/NodeController.java        |   2 +-
 .../hyracks-yarn/hyracks-yarn-client/pom.xml    |  10 +-
 .../yarn/client/KillHyracksApplication.java     |   4 +-
 .../yarn/client/LaunchHyracksApplication.java   |  10 +-
 .../hyracks-yarn/hyracks-yarn-common/pom.xml    |   2 +-
 .../common/protocols/amrm/AMRMConnection.java   |   2 +-
 .../protocols/clientrm/YarnApplication.java     |   2 +-
 .../clientrm/YarnClientRMConnection.java        |   2 +-
 .../common/resources/LocalResourceHelper.java   |   2 +-
 .../yarn/common/resources/ResourceHelper.java   |   2 +-
 hyracks/hyracks-yarn/pom.xml                    |   2 +-
 hyracks/pom.xml                                 |   4 +-
 pom.xml                                         |   5 +-
 2034 files changed, 16357 insertions(+), 16354 deletions(-)
----------------------------------------------------------------------



Mime
View raw message