asterixdb-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ti...@apache.org
Subject [5/5] incubator-asterixdb-hyracks git commit: remove end-of-line whitespace
Date Wed, 10 Feb 2016 01:06:56 GMT
remove end-of-line whitespace

Change-Id: If3542874d7f3a536a6fe524aba2fffaf6447a614
Reviewed-on: https://asterix-gerrit.ics.uci.edu/600
Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Reviewed-by: Yingyi Bu <buyingyi@gmail.com>


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/6464d723
Tree: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/tree/6464d723
Diff: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/diff/6464d723

Branch: refs/heads/master
Commit: 6464d723fdda15826f0cd7a5d27e48798e16f8d6
Parents: d960fd3
Author: Till Westmann <tillw@apache.org>
Authored: Tue Feb 9 16:03:14 2016 -0800
Committer: Till Westmann <tillw@apache.org>
Committed: Tue Feb 9 17:02:02 2016 -0800

----------------------------------------------------------------------
 .../api/AbstractCompilerFactoryBuilder.java     |  2 +-
 .../PrioritizedRuleController.java              |  8 +--
 .../SequentialFixpointRuleController.java       |  2 +-
 .../core/algebra/base/ILogicalOperator.java     |  6 +--
 .../core/algebra/base/LogicalVariable.java      |  4 +-
 .../AggregateFunctionCallExpression.java        |  8 +--
 .../algebra/metadata/IMetadataProvider.java     |  6 +--
 .../operators/logical/AssignOperator.java       |  6 +--
 .../operators/logical/ExtensionOperator.java    |  2 +-
 .../operators/logical/IOperatorExtension.java   |  4 +-
 .../logical/PartitioningSplitOperator.java      |  6 +--
 .../physical/InMemoryHashJoinPOperator.java     |  4 +-
 .../properties/ILocalStructuralProperty.java    |  4 +-
 .../properties/IPhysicalPropertiesVector.java   |  2 +-
 .../algebra/properties/LocalOrderProperty.java  |  2 +-
 .../core/algebra/properties/PropertiesUtil.java |  2 +-
 .../properties/StructuralPropertiesVector.java  |  4 +-
 .../properties/VariablePropagationPolicy.java   |  6 +--
 .../algebra/util/OperatorPropertiesUtil.java    |  6 +--
 .../base/PhysicalOptimizationConfig.java        | 14 +++---
 .../data/IResultSerializerFactoryProvider.java  |  2 +-
 .../examples/piglet/ast/LoadNode.java           |  4 +-
 .../algebricks/examples/piglet/types/Type.java  |  4 +-
 .../rules/ComplexUnnestToProductRule.java       |  2 +-
 .../rewriter/rules/ConsolidateSelectsRule.java  | 16 +++---
 .../rules/EliminateGroupByEmptyKeyRule.java     |  2 +-
 .../rules/EnforceOrderByAfterSubplan.java       |  2 +-
 .../rules/ExtractCommonExpressionsRule.java     |  4 +-
 .../ExtractFunctionsFromJoinConditionRule.java  |  6 +--
 .../InlineSingleReferenceVariablesRule.java     | 14 +++---
 .../rewriter/rules/IntroduceProjectsRule.java   |  4 +-
 .../rewriter/rules/PushFunctionsBelowJoin.java  | 10 ++--
 .../rules/RemoveRedundantGroupByDecorVars.java  |  4 +-
 .../rules/RemoveRedundantProjectionRule.java    |  6 +--
 .../rules/RemoveRedundantVariablesRule.java     |  4 +-
 .../RemoveUnusedAssignAndAggregateRule.java     |  2 +-
 .../rewriter/rules/SetExecutionModeRule.java    |  2 +-
 ...inateSubplanWithInputCardinalityOneRule.java |  8 +--
 ...oveFreeVariableOperatorOutOfSubplanRule.java |  8 +--
 .../subplan/PushSubplanIntoGroupByRule.java     |  6 +--
 .../ICopySerializableAggregateFunction.java     |  8 +--
 .../operators/std/AssignRuntimeFactory.java     |  4 +-
 .../api/application/IApplicationContext.java    |  6 +--
 .../api/application/ICCApplicationContext.java  | 12 ++---
 .../api/application/INCApplicationContext.java  | 18 +++----
 .../hyracks/api/client/HyracksConnection.java   |  6 +--
 .../api/client/IHyracksClientConnection.java    | 30 +++++------
 .../api/dataflow/IConnectorDescriptor.java      | 14 +++---
 .../hyracks/api/dataflow/IDataReader.java       |  8 +--
 .../hyracks/api/dataflow/IDataWriter.java       |  2 +-
 .../api/dataflow/IOperatorDescriptor.java       | 16 +++---
 .../api/dataflow/value/IPredicateEvaluator.java |  2 +-
 .../value/IPredicateEvaluatorFactory.java       |  2 +-
 .../IPredicateEvaluatorFactoryProvider.java     |  2 +-
 .../api/dataflow/value/IResultSerializer.java   |  4 +-
 .../value/IResultSerializerFactory.java         |  4 +-
 .../dataflow/value/ISerializerDeserializer.java |  6 +--
 .../api/dataflow/value/JSONSerializable.java    |  4 +-
 ...yracksDatasetDirectoryServiceConnection.java |  4 +-
 ...HyracksDatasetDirectoryServiceInterface.java |  4 +-
 .../hyracks/api/deployment/DeploymentId.java    |  2 +-
 .../api/job/IJobSerializerDeserializer.java     |  8 +--
 .../IJobSerializerDeserializerContainer.java    |  6 +--
 .../api/job/profiling/counters/ICounter.java    | 10 ++--
 .../job/profiling/counters/ICounterContext.java |  6 +--
 .../rewriter/ActivityClusterGraphRewriter.java  | 12 ++---
 .../OneToOneConnectedActivityCluster.java       | 14 +++---
 .../api/rewriter/runtime/SuperActivity.java     |  2 +-
 .../client/stats/IClusterCounterContext.java    |  2 +-
 .../client/stats/impl/ClientCounterContext.java |  6 +--
 .../control/cc/scheduler/JobScheduler.java      |  8 +--
 .../control/cc/work/CliDeployBinaryWork.java    |  2 +-
 .../control/cc/work/CliUnDeployBinaryWork.java  |  2 +-
 .../control/cc/work/NotifyDeployBinaryWork.java |  2 +-
 .../ClassLoaderJobSerializerDeserializer.java   |  2 +-
 .../common/deployment/DeploymentRun.java        |  4 +-
 .../common/deployment/DeploymentUtils.java      | 14 +++---
 .../IDeploymentStatusConditionVariable.java     |  4 +-
 .../control/common/shutdown/ShutdownRun.java    |  2 +-
 .../nc/io/profiling/IOCounterFactory.java       |  2 +-
 .../control/nc/work/DeployBinaryWork.java       |  2 +-
 .../hyracks/control/nc/work/StartTasksWork.java |  2 +-
 .../control/nc/work/UnDeployBinaryWork.java     |  2 +-
 .../std/algorithms/BinarySearchAlgorithm.java   |  8 +--
 .../hyracks/data/std/api/IPointableFactory.java |  4 +-
 .../collections/api/IValueReferenceVector.java  | 12 ++---
 .../data/std/util/ArrayBackedValueStorage.java  |  4 +-
 .../common/comm/io/ArrayTupleBuilder.java       | 16 +++---
 .../common/comm/io/ArrayTupleReference.java     |  6 +--
 .../FieldRangePartitionComputerFactory.java     |  4 +-
 .../dataflow/common/util/TupleUtils.java        |  2 +-
 .../base/AbstractMToNConnectorDescriptor.java   |  4 +-
 .../std/connectors/HashtableLocalityMap.java    |  4 +-
 ...wareMToNPartitioningConnectorDescriptor.java |  4 +-
 .../LocalityAwarePartitionDataWriter.java       |  8 +--
 .../file/PlainFileWriterOperatorDescriptor.java |  2 +-
 .../std/group/IAggregatorDescriptor.java        | 12 ++---
 .../std/group/IFieldAggregateDescriptor.java    | 14 +++---
 .../AvgFieldGroupAggregatorFactory.java         |  2 +-
 .../AvgFieldMergeAggregatorFactory.java         |  2 +-
 .../CountFieldAggregatorFactory.java            |  2 +-
 .../FloatSumFieldAggregatorFactory.java         | 26 +++++-----
 .../IntSumFieldAggregatorFactory.java           |  2 +-
 .../MinMaxStringFieldAggregatorFactory.java     |  2 +-
 .../MultiFieldsAggregatorFactory.java           |  2 +-
 .../ExternalGroupOperatorDescriptor.java        |  2 +-
 .../group/hash/HashGroupOperatorDescriptor.java |  4 +-
 .../join/GraceHashJoinOperatorDescriptor.java   |  4 +-
 .../btree/client/InsertPipelineExample.java     |  4 +-
 ...rTuplesSecondaryIndexSearchOperatorTest.java |  4 +-
 .../integration/LocalityAwareConnectorTest.java |  4 +-
 .../shutdown/test/ClusterShutdownIT.java        |  4 +-
 .../examples/text/client/WordCountMain.java     |  4 +-
 .../hyracks/hdfs/api/IKeyValueParser.java       |  6 +--
 .../hdfs/api/IKeyValueParserFactory.java        |  4 +-
 .../hyracks/hdfs/api/INcCollectionBuilder.java  |  2 +-
 .../apache/hyracks/hdfs/api/ITupleWriter.java   |  6 +--
 .../dataflow/HDFSReadOperatorDescriptor.java    |  2 +-
 .../dataflow/HDFSWriteOperatorDescriptor.java   |  2 +-
 .../hdfs/dataflow/InputSplitsFactory.java       |  4 +-
 .../hyracks/hdfs/scheduler/Scheduler.java       | 20 ++++----
 .../hdfs2/dataflow/FileSplitsFactory.java       |  4 +-
 .../dataflow/HDFSReadOperatorDescriptor.java    |  2 +-
 .../dataflow/HDFSWriteOperatorDescriptor.java   |  2 +-
 .../hyracks/hdfs2/scheduler/Scheduler.java      | 10 ++--
 .../hyracks/hdfs/dataflow/DataflowTest.java     |  6 +--
 .../hyracks/hdfs/scheduler/SchedulerTest.java   | 10 ++--
 .../hyracks/hdfs2/dataflow/DataflowTest.java    |  6 +--
 .../hyracks/hdfs2/scheduler/SchedulerTest.java  |  8 +--
 .../org/apache/hyracks/ipc/api/IIPCHandle.java  |  4 +-
 .../org/apache/hyracks/ipc/impl/IPCSystem.java  |  4 +-
 .../hyracks/net/buffers/IBufferAcceptor.java    |  6 +--
 .../net/buffers/ICloseableBufferAcceptor.java   |  6 +--
 .../protocols/muxdemux/ChannelControlBlock.java |  8 +--
 .../muxdemux/IChannelOpenListener.java          |  6 +--
 .../muxdemux/IChannelReadInterface.java         | 10 ++--
 .../muxdemux/IChannelWriteInterface.java        | 10 ++--
 .../muxdemux/MultiplexedConnection.java         |  6 +--
 .../net/protocols/muxdemux/MuxDemux.java        | 14 +++---
 .../am/bloomfilter/impls/BloomCalculations.java |  4 +-
 .../hyracks/storage/am/btree/impls/BTree.java   |  6 +--
 .../am/btree/impls/BTreeCursorInitialState.java |  2 +-
 .../hyracks/storage/am/common/api/IIndex.java   | 14 +++---
 .../storage/am/common/api/IIndexAccessor.java   | 16 +++---
 .../storage/am/common/api/IIndexBulkLoader.java |  4 +-
 .../am/common/api/IMetaDataPageManager.java     |  2 +-
 .../api/IModificationOperationCallback.java     |  1 +
 .../am/common/api/ITreeIndexAccessor.java       |  6 +--
 .../am/common/api/ITreeIndexMetaDataFrame.java  |  2 +-
 .../am/common/api/ITreeIndexTupleReference.java |  2 +-
 .../storage/am/common/api/ITupleUpdater.java    |  2 +-
 .../am/common/api/ITwoPCIndexBulkLoader.java    |  6 +--
 .../storage/am/common/api/IndexException.java   |  2 +-
 .../am/common/api/TreeIndexException.java       |  2 +-
 .../am/common/api/UnsortedInputException.java   |  6 +--
 .../dataflow/ITreeIndexOperatorDescriptor.java  |  6 +--
 .../am/common/dataflow/IndexDataflowHelper.java |  6 +--
 .../datagen/PersonNameFieldValueGenerator.java  |  6 +--
 .../SortedDoubleFieldValueGenerator.java        |  8 +--
 .../datagen/SortedFloatFieldValueGenerator.java |  6 +--
 .../SortedIntegerFieldValueGenerator.java       |  4 +-
 .../datagen/StringFieldValueGenerator.java      |  4 +-
 .../storage/am/common/datagen/TupleBatch.java   | 10 ++--
 .../am/common/datagen/TupleGenerator.java       | 14 +++---
 .../am/common/frames/AbstractSlotManager.java   |  6 +--
 .../am/common/impls/AbstractTreeIndex.java      |  4 +-
 .../am/common/ophelpers/LongArrayList.java      |  2 +-
 .../am/common/ophelpers/SlotOffTupleOff.java    |  4 +-
 .../tuples/ConcatenatingTupleReference.java     | 22 ++++-----
 .../common/tuples/PermutingTupleReference.java  |  4 +-
 .../storage/am/common/util/HashMultiSet.java    | 20 ++++----
 .../storage/am/common/util/TreeIndexUtils.java  |  4 +-
 .../am/lsm/btree/impls/ExternalBTree.java       |  2 +-
 .../impls/LSMBTreeWithBuddySearchCursor.java    | 12 ++---
 .../btree/tuples/LSMBTreeCopyTupleWriter.java   |  2 +-
 .../tuples/LSMBTreeCopyTupleWriterFactory.java  |  2 +-
 .../btree/tuples/LSMBTreeTupleReference.java    | 10 ++--
 .../tuples/LSMBTreeTupleWriterFactory.java      |  2 +-
 .../am/lsm/common/api/ILSMComponent.java        |  2 +-
 .../common/api/ILSMComponentFilterFrame.java    |  2 +-
 .../lsm/common/api/ILSMIOOperationCallback.java |  4 +-
 .../am/lsm/common/api/ILSMIndexAccessor.java    | 10 ++--
 .../common/api/ILSMIndexAccessorInternal.java   |  4 +-
 .../am/lsm/common/api/ILSMIndexFileManager.java |  6 +--
 .../am/lsm/common/api/ILSMIndexInternal.java    |  4 +-
 .../lsm/common/api/ILSMMergePolicyFactory.java  |  4 +-
 .../am/lsm/common/api/ILSMOperationTracker.java |  2 +-
 .../storage/am/lsm/common/api/ITwoPCIndex.java  | 16 +++---
 .../lsm/common/impls/AsynchronousScheduler.java |  4 +-
 .../impls/LSMComponentFileReferences.java       |  2 +-
 .../lsm/common/impls/LSMTreeIndexAccessor.java  |  4 +-
 .../impls/MultitenantVirtualBufferCache.java    |  8 +--
 .../impls/NoOpOperationTrackerProvider.java     |  2 +-
 .../am/lsm/common/impls/PrefixMergePolicy.java  |  2 +-
 .../am/lsm/common/impls/VirtualBufferCache.java |  2 +-
 .../lsm/invertedindex/api/IInvertedIndex.java   | 14 +++---
 .../api/IInvertedIndexOperatorDescriptor.java   | 10 ++--
 .../api/IInvertedIndexSearcher.java             |  2 +-
 .../invertedindex/api/IInvertedListCursor.java  |  2 +-
 .../exceptions/InvertedIndexException.java      |  4 +-
 .../invertedindex/impls/LSMInvertedIndex.java   |  2 +-
 .../InMemoryInvertedIndexOpContext.java         |  2 +-
 .../ondisk/OnDiskInvertedIndex.java             |  4 +-
 .../OnDiskInvertedIndexRangeSearchCursor.java   |  4 +-
 .../ondisk/OnDiskInvertedIndexSearchCursor.java |  6 +--
 .../PartitionedOnDiskInvertedIndexFactory.java  |  2 +-
 .../ConjunctiveEditDistanceSearchModifier.java  |  4 +-
 ...nctiveEditDistanceSearchModifierFactory.java |  4 +-
 ...njunctiveListEditDistanceSearchModifier.java |  2 +-
 .../search/ConjunctiveSearchModifier.java       |  2 +-
 .../EditDistanceSearchModifierFactory.java      |  4 +-
 .../search/ListEditDistanceSearchModifier.java  |  2 +-
 .../search/PartitionedTOccurrenceSearcher.java  |  4 +-
 .../lsm/invertedindex/search/SearchResult.java  |  8 +--
 .../am/lsm/rtree/impls/ExternalRTree.java       |  2 +-
 .../rtree/impls/LSMRTreeCursorInitialState.java |  4 +-
 .../lsm/rtree/impls/LSMRTreeSortedCursor.java   |  4 +-
 .../tuples/LSMTypeAwareTupleWriterFactory.java  |  2 +-
 .../hyracks/storage/am/rtree/impls/RTree.java   |  2 +-
 .../am/rtree/impls/RTreeSearchCursor.java       |  4 +-
 .../linearize/HilbertDoubleComparator.java      |  8 +--
 .../HilbertDoubleComparatorFactory.java         |  6 +--
 .../ZCurveDoubleComparatorFactory.java          |  6 +--
 .../linearize/ZCurveIntComparatorFactory.java   |  6 +--
 .../RTreeTypeAwareTupleWriterFactory.java       |  2 +-
 .../common/buffercache/DebugBufferCache.java    |  8 +--
 .../common/buffercache/FIFOLocalWriter.java     |  2 +-
 .../common/buffercache/IBufferCache.java        |  2 +-
 .../buffercache/ICacheMemoryAllocator.java      |  4 +-
 .../common/buffercache/IPageCleanerPolicy.java  | 10 ++--
 .../storage/common/file/IFileMapManager.java    | 12 ++---
 .../storage/common/file/IFileMapProvider.java   | 12 ++---
 .../TransientLocalResourceFactoryProvider.java  |  2 +-
 .../hyracks/storage/am/common/CheckTuple.java   | 16 +++---
 .../storage/am/common/IIndexTestContext.java    |  2 +-
 .../am/common/ITreeIndexTestContext.java        |  2 +-
 .../am/common/TestOperationSelector.java        | 12 ++---
 .../storage/am/common/TestWorkloadConf.java     |  4 +-
 .../storage/am/btree/BTreeInsertTest.java       |  8 +--
 .../storage/am/btree/BTreeUpsertTest.java       |  8 +--
 .../btree/multithread/BTreeMultiThreadTest.java |  2 +-
 .../am/btree/multithread/BTreeTestWorker.java   |  2 +-
 .../am/lsm/btree/perf/BTreePageSizePerf.java    | 12 ++---
 .../am/lsm/btree/perf/IExperimentRunner.java    |  8 +--
 .../am/lsm/btree/perf/PerfExperiment.java       |  2 +-
 .../am/lsm/btree/tuples/LSMBTreeTuplesTest.java | 52 ++++++++++----------
 .../InMemoryInvertedIndexDeleteTest.java        |  2 +-
 .../InMemoryInvertedIndexInsertTest.java        |  2 +-
 ...titionedInMemoryInvertedIndexDeleteTest.java |  2 +-
 .../ondisk/FixedSizeFrameTupleTest.java         |  2 +-
 .../util/LSMInvertedIndexTestContext.java       |  2 +-
 .../util/LSMInvertedIndexTestUtils.java         |  2 +-
 .../storage/am/rtree/RTreeDeleteTest.java       |  2 +-
 .../storage/am/rtree/RTreeInsertTest.java       |  2 +-
 .../hyracks/storage/common/BufferCacheTest.java |  6 +--
 .../yarn/am/manifest/ClusterController.java     |  4 +-
 256 files changed, 736 insertions(+), 735 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/api/AbstractCompilerFactoryBuilder.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/api/AbstractCompilerFactoryBuilder.java b/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/api/AbstractCompilerFactoryBuilder.java
index 616dfa9..d5fe6ed 100644
--- a/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/api/AbstractCompilerFactoryBuilder.java
+++ b/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/api/AbstractCompilerFactoryBuilder.java
@@ -116,7 +116,7 @@ public abstract class AbstractCompilerFactoryBuilder {
     public IBinaryComparatorFactoryProvider getComparatorFactoryProvider() {
         return comparatorFactoryProvider;
     }
-    
+
     public void setPredicateEvaluatorFactoryProvider(IPredicateEvaluatorFactoryProvider predEvaluatorFactoryProvider) {
         this.predEvaluatorFactoryProvider = predEvaluatorFactoryProvider;
     }

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/PrioritizedRuleController.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/PrioritizedRuleController.java b/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/PrioritizedRuleController.java
index 2f5acda..5a1b461 100644
--- a/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/PrioritizedRuleController.java
+++ b/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/PrioritizedRuleController.java
@@ -28,13 +28,13 @@ import org.apache.hyracks.algebricks.core.rewriter.base.AbstractRuleController;
 import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
 
 /**
- * 
+ *
  * Runs each rule until it produces no changes. Then the whole collection of
  * rules is run again until no change is made.
- * 
- * 
+ *
+ *
  * @author Nicola
- * 
+ *
  */
 
 public class PrioritizedRuleController extends AbstractRuleController {

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/SequentialFixpointRuleController.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/SequentialFixpointRuleController.java b/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/SequentialFixpointRuleController.java
index b6d6d61..61b75c9 100644
--- a/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/SequentialFixpointRuleController.java
+++ b/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/SequentialFixpointRuleController.java
@@ -30,7 +30,7 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
 /**
  * Runs rules sequentially (round-robin), until one iteration over all rules
  * produces no change.
- * 
+ *
  * @author Nicola
  */
 public class SequentialFixpointRuleController extends AbstractRuleController {

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalOperator.java
index 90c0de2..9d68fae 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalOperator.java
@@ -50,7 +50,7 @@ public interface ILogicalOperator {
     public List<LogicalVariable> getSchema();
 
     /*
-     * 
+     *
      * support for visitors
      */
 
@@ -73,7 +73,7 @@ public interface ILogicalOperator {
     /**
      * Get the variable propogation policy from this operator's input to its
      * output.
-     * 
+     *
      * @return The VariablePropogationPolicy.
      */
     public VariablePropagationPolicy getVariablePropagationPolicy();
@@ -103,4 +103,4 @@ public interface ILogicalOperator {
      * Indicates whether the expressions used by this operator must be variable reference expressions.
      */
     public boolean requiresVariableReferenceExpressions();
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalVariable.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalVariable.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalVariable.java
index 465d1a2..fc30ce2 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalVariable.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalVariable.java
@@ -20,7 +20,7 @@ package org.apache.hyracks.algebricks.core.algebra.base;
 
 /**
  * Represents a logical variable in an asterix logical plan.
- * 
+ *
  * @author Vinayak R. Borkar [vborkar@ics.uci.edu]
  */
 public final class LogicalVariable {
@@ -52,4 +52,4 @@ public final class LogicalVariable {
     public int hashCode() {
         return id;
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/AggregateFunctionCallExpression.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/AggregateFunctionCallExpression.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/AggregateFunctionCallExpression.java
index 11207e0..67f285d 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/AggregateFunctionCallExpression.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/AggregateFunctionCallExpression.java
@@ -28,17 +28,17 @@ import org.apache.hyracks.algebricks.core.algebra.functions.IFunctionInfo;
 import org.apache.hyracks.algebricks.core.algebra.visitors.ILogicalExpressionVisitor;
 
 /**
- * 
+ *
  * An aggregate function may be executed in a "two step" mode. First the
  * "step-one" aggregates are run and then the results are passed to the
  * "step-two" aggregators. The convention is the following:
- * 
+ *
  * 1. The step-one aggregate must be able to accept the same arguments as the
  * original aggregate function call.
- * 
+ *
  * 2. The step-two aggregate must be a unary function that accepts as input the
  * output of the step-one aggregate.
- * 
+ *
  */
 
 public class AggregateFunctionCallExpression extends AbstractFunctionCallExpression {

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/metadata/IMetadataProvider.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/metadata/IMetadataProvider.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/metadata/IMetadataProvider.java
index 823ebae..1ad7fe6 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/metadata/IMetadataProvider.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/metadata/IMetadataProvider.java
@@ -78,7 +78,7 @@ public interface IMetadataProvider<S, I> {
     /**
      * Creates the insert runtime of IndexInsertDeletePOperator, which models
      * insert/delete operations into a secondary index.
-     * 
+     *
      * @param dataSource
      *            Target secondary index.
      * @param propagatedSchema
@@ -117,7 +117,7 @@ public interface IMetadataProvider<S, I> {
     /**
      * Creates the delete runtime of IndexInsertDeletePOperator, which models
      * insert/delete operations into a secondary index.
-     * 
+     *
      * @param dataSource
      *            Target secondary index.
      * @param propagatedSchema
@@ -157,7 +157,7 @@ public interface IMetadataProvider<S, I> {
      * Creates the TokenizeOperator for IndexInsertDeletePOperator, which tokenizes
      * secondary key into [token, number of token] pair in a length-partitioned index.
      * In case of non length-partitioned index, it tokenizes secondary key into [token].
-     * 
+     *
      * @param dataSource
      *            Target secondary index.
      * @param propagatedSchema

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AssignOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AssignOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AssignOperator.java
index c5fac83..aebbba8 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AssignOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AssignOperator.java
@@ -36,12 +36,12 @@ import org.apache.hyracks.algebricks.core.algebra.visitors.ILogicalOperatorVisit
 
 /**
  * It corresponds to the Map operator in other algebras.
- * 
+ *
  * @author Nicola
  */
 
 public class AssignOperator extends AbstractAssignOperator {
-	
+
 	private LocalOrderProperty explicitOrderingProperty;
 
     public AssignOperator(List<LogicalVariable> vars, List<Mutable<ILogicalExpression>> exprs) {
@@ -120,4 +120,4 @@ public class AssignOperator extends AbstractAssignOperator {
 			LocalOrderProperty explicitOrderingProperty) {
 		this.explicitOrderingProperty = explicitOrderingProperty;
 	}
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/ExtensionOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/ExtensionOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/ExtensionOperator.java
index dfd2c8f..d2f7715 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/ExtensionOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/ExtensionOperator.java
@@ -116,7 +116,7 @@ public class ExtensionOperator extends AbstractLogicalOperator {
     public String toString() {
         return delegate.toString();
     }
-    
+
     public IOperatorExtension getDelegate() {
         return delegate;
     }

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/IOperatorExtension.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/IOperatorExtension.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/IOperatorExtension.java
index 4d578d9..e61d9a2 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/IOperatorExtension.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/IOperatorExtension.java
@@ -47,8 +47,8 @@ public interface IOperatorExtension {
     void setPhysicalOperator(IPhysicalOperator physicalOperator);
 
     ExecutionMode getExecutionMode();
-    
+
     public void getUsedVariables(Collection<LogicalVariable> usedVars);
-    
+
     public void getProducedVariables(Collection<LogicalVariable> producedVars);
 }

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/PartitioningSplitOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/PartitioningSplitOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/PartitioningSplitOperator.java
index 9d48fa0..1c5f324 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/PartitioningSplitOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/PartitioningSplitOperator.java
@@ -69,11 +69,11 @@ public class PartitioningSplitOperator extends AbstractLogicalOperator {
     public int getDefaultBranchIndex() {
         return defaultBranchIndex;
     }
-    
+
     public int getNumOutputBranches() {
         return (defaultBranchIndex == expressions.size()) ? expressions.size() + 1 : expressions.size();
     }
-    
+
     @Override
     public LogicalOperatorTag getOperatorTag() {
         return LogicalOperatorTag.PARTITIONINGSPLIT;
@@ -116,4 +116,4 @@ public class PartitioningSplitOperator extends AbstractLogicalOperator {
         return createPropagatingAllInputsTypeEnvironment(ctx);
     }
 
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/InMemoryHashJoinPOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/InMemoryHashJoinPOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/InMemoryHashJoinPOperator.java
index 5b04e08..a92bd70 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/InMemoryHashJoinPOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/InMemoryHashJoinPOperator.java
@@ -92,10 +92,10 @@ public class InMemoryHashJoinPOperator extends AbstractHashJoinPOperator {
             Object t = env.getVarType(v);
             comparatorFactories[i++] = bcfp.getBinaryComparatorFactory(t, true);
         }
-        
+
         IPredicateEvaluatorFactoryProvider predEvaluatorFactoryProvider = context.getPredicateEvaluatorFactoryProvider();
         IPredicateEvaluatorFactory predEvaluatorFactory = ( predEvaluatorFactoryProvider == null ? null : predEvaluatorFactoryProvider.getPredicateEvaluatorFactory(keysLeft, keysRight));
-        
+
         RecordDescriptor recDescriptor = JobGenHelper.mkRecordDescriptor(context.getTypeEnvironment(op),
                 propagatedSchema, context);
         IOperatorDescriptorRegistry spec = builder.getJobSpec();

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/ILocalStructuralProperty.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/ILocalStructuralProperty.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/ILocalStructuralProperty.java
index ea9769a..af29994 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/ILocalStructuralProperty.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/ILocalStructuralProperty.java
@@ -36,7 +36,7 @@ public interface ILocalStructuralProperty extends IStructuralProperty {
      * Returns the retained property regarding to a collection of variables,
      * e.g., some variables used in the property may not exist in the input
      * collection and hence the data property changes.
-     * 
+     *
      * @param vars
      *            , an input collection of variables
      * @return the retained data property.
@@ -45,7 +45,7 @@ public interface ILocalStructuralProperty extends IStructuralProperty {
 
     /**
      * Returns the additional data property within each group, which is dictated by the group keys.
-     * 
+     *
      * @param vars
      *            , group keys.
      * @return the additional data property within each group.

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/IPhysicalPropertiesVector.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/IPhysicalPropertiesVector.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/IPhysicalPropertiesVector.java
index bca500a..d872491 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/IPhysicalPropertiesVector.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/IPhysicalPropertiesVector.java
@@ -31,7 +31,7 @@ public interface IPhysicalPropertiesVector {
     public List<ILocalStructuralProperty> getLocalProperties();
 
     /**
-     * 
+     *
      * @param reqd
      *            vector of required properties
      * @param equivalenceClasses

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/LocalOrderProperty.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/LocalOrderProperty.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/LocalOrderProperty.java
index 1097dff..d1d0ca9 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/LocalOrderProperty.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/LocalOrderProperty.java
@@ -90,7 +90,7 @@ public final class LocalOrderProperty implements ILocalStructuralProperty {
 
     /**
      * Whether current property implies the required property
-     * 
+     *
      * @param required
      *            , a required property
      * @return true if the current property satisfies the required property; otherwise false.

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/PropertiesUtil.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/PropertiesUtil.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/PropertiesUtil.java
index ae9f4f1..711c0e7 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/PropertiesUtil.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/PropertiesUtil.java
@@ -177,7 +177,7 @@ public class PropertiesUtil {
 
     /**
      * Converts a list of OrderColumns to a list of LogicalVariables.
-     * 
+     *
      * @param orderColumns
      *            , a list of OrderColumns
      * @return the list of LogicalVariables

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/StructuralPropertiesVector.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/StructuralPropertiesVector.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/StructuralPropertiesVector.java
index 97363b5..7ae7e62 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/StructuralPropertiesVector.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/StructuralPropertiesVector.java
@@ -63,7 +63,7 @@ public class StructuralPropertiesVector implements IPhysicalPropertiesVector {
     }
 
     /**
-     * 
+     *
      * @param reqd
      *            vector of required properties
      * @return a vector of properties from pvector that are not delivered by the
@@ -102,4 +102,4 @@ public class StructuralPropertiesVector implements IPhysicalPropertiesVector {
         }
     }
 
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/VariablePropagationPolicy.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/VariablePropagationPolicy.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/VariablePropagationPolicy.java
index 8885b5d..d78684b 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/VariablePropagationPolicy.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/VariablePropagationPolicy.java
@@ -43,8 +43,8 @@ public abstract class VariablePropagationPolicy {
     /**
      * Adds, from each source, only variables that do not already appear in the
      * target.
-     * 
-     * 
+     *
+     *
      */
     public static final VariablePropagationPolicy ADDNEWVARIABLES = new VariablePropagationPolicy() {
         @Override
@@ -79,4 +79,4 @@ public abstract class VariablePropagationPolicy {
         };
     }
 
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/util/OperatorPropertiesUtil.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/util/OperatorPropertiesUtil.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/util/OperatorPropertiesUtil.java
index 827c075..39de006 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/util/OperatorPropertiesUtil.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/util/OperatorPropertiesUtil.java
@@ -66,7 +66,7 @@ public class OperatorPropertiesUtil {
     /**
      * Adds the free variables of the plan rooted at that operator to the
      * collection provided.
-     * 
+     *
      * @param op
      * @param vars
      *            - The collection to which the free variables will be added.
@@ -107,7 +107,7 @@ public class OperatorPropertiesUtil {
     /**
      * Adds the free variables of the operator path from
      * op to dest, where dest is a direct/indirect input operator of op in the query plan.
-     * 
+     *
      * @param op
      *            , the start operator.
      * @param dest
@@ -165,7 +165,7 @@ public class OperatorPropertiesUtil {
 
     /***
      * Recursively checks if the dest operator is in the path of a nested plan
-     * 
+     *
      * @param op
      * @param dest
      * @return

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/rewriter/base/PhysicalOptimizationConfig.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/rewriter/base/PhysicalOptimizationConfig.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/rewriter/base/PhysicalOptimizationConfig.java
index 03f721c..f0f858d 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/rewriter/base/PhysicalOptimizationConfig.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/rewriter/base/PhysicalOptimizationConfig.java
@@ -22,7 +22,7 @@ import java.util.Properties;
 
 public class PhysicalOptimizationConfig {
     private static final int MB = 1048576;
-    
+
     private static final String FRAMESIZE = "FRAMESIZE";
     private static final String MAX_FRAMES_EXTERNAL_SORT = "MAX_FRAMES_EXTERNAL_SORT";
     private static final String MAX_FRAMES_EXTERNAL_GROUP_BY = "MAX_FRAMES_EXTERNAL_GROUP_BY";
@@ -30,7 +30,7 @@ public class PhysicalOptimizationConfig {
     private static final String MAX_FRAMES_HYBRID_HASH = "MAX_FRAMES_HYBRID_HASH";
     private static final String FUDGE_FACTOR = "FUDGE_FACTOR";
     private static final String MAX_RECORDS_PER_FRAME = "MAX_RECORDS_PER_FRAME";
-    
+
     private static final String DEFAULT_HASH_GROUP_TABLE_SIZE = "DEFAULT_HASH_GROUP_TABLE_SIZE";
     private static final String DEFAULT_EXTERNAL_GROUP_TABLE_SIZE = "DEFAULT_EXTERNAL_GROUP_TABLE_SIZE";
     private static final String DEFAULT_IN_MEM_HASH_JOIN_TABLE_SIZE = "DEFAULT_IN_MEM_HASH_JOIN_TABLE_SIZE";
@@ -56,7 +56,7 @@ public class PhysicalOptimizationConfig {
     public void setFrameSize(int frameSize) {
         setInt(FRAMESIZE, frameSize);
     }
-    
+
     public double getFudgeFactor() {
         return getDouble(FUDGE_FACTOR, 1.3);
     }
@@ -64,7 +64,7 @@ public class PhysicalOptimizationConfig {
     public void setFudgeFactor(double fudgeFactor) {
         setDouble(FUDGE_FACTOR, fudgeFactor);
     }
-    
+
     public int getMaxRecordsPerFrame() {
         return getInt(MAX_RECORDS_PER_FRAME, 512);
     }
@@ -81,7 +81,7 @@ public class PhysicalOptimizationConfig {
     public void setMaxFramesLeftInputHybridHash(int frameLimit) {
         setInt(MAX_FRAMES_LEFT_INPUT_HYBRID_HASH, frameLimit);
     }
-    
+
     public int getMaxFramesHybridHash() {
         int frameSize = getFrameSize();
         return getInt(MAX_FRAMES_HYBRID_HASH, (int) (64L * MB / frameSize));
@@ -99,7 +99,7 @@ public class PhysicalOptimizationConfig {
     public void setMaxFramesExternalGroupBy(int frameLimit) {
         setInt(MAX_FRAMES_EXTERNAL_GROUP_BY, frameLimit);
     }
-    
+
     public int getMaxFramesExternalSort() {
         int frameSize = getFrameSize();
         return getInt(MAX_FRAMES_EXTERNAL_SORT, (int) (((long) 32 * MB) / frameSize));
@@ -144,7 +144,7 @@ public class PhysicalOptimizationConfig {
         else
             return Integer.parseInt(value);
     }
-    
+
     private void setDouble(String property, double value) {
         properties.setProperty(property, Double.toString(value));
     }

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-data/src/main/java/org/apache/hyracks/algebricks/data/IResultSerializerFactoryProvider.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-data/src/main/java/org/apache/hyracks/algebricks/data/IResultSerializerFactoryProvider.java b/algebricks/algebricks-data/src/main/java/org/apache/hyracks/algebricks/data/IResultSerializerFactoryProvider.java
index 8749e25..7525180 100644
--- a/algebricks/algebricks-data/src/main/java/org/apache/hyracks/algebricks/data/IResultSerializerFactoryProvider.java
+++ b/algebricks/algebricks-data/src/main/java/org/apache/hyracks/algebricks/data/IResultSerializerFactoryProvider.java
@@ -25,7 +25,7 @@ import org.apache.hyracks.api.dataflow.value.IResultSerializerFactory;
 public interface IResultSerializerFactoryProvider extends Serializable {
     /**
      * Returns a result serializer factory
-     * 
+     *
      * @param fields
      *            - A position of the fields in the order it should be written in the output.
      * @param printerFactories

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/ast/LoadNode.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/ast/LoadNode.java b/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/ast/LoadNode.java
index 7b7740d..6be1d9f 100644
--- a/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/ast/LoadNode.java
+++ b/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/ast/LoadNode.java
@@ -29,7 +29,7 @@ public class LoadNode extends RelationNode {
         this.dataFile = dataFile;
         this.schema = schema;
     }
-    
+
     @Override
     public Tag getTag() {
         return Tag.LOAD;
@@ -42,4 +42,4 @@ public class LoadNode extends RelationNode {
     public Schema getSchema() {
         return schema;
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/types/Type.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/types/Type.java b/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/types/Type.java
index f91be1e..f8ffe93 100644
--- a/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/types/Type.java
+++ b/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/types/Type.java
@@ -29,6 +29,6 @@ public abstract class Type {
         BAG,
         MAP
     }
-    
+
     public abstract Tag getTag();
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ComplexUnnestToProductRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ComplexUnnestToProductRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ComplexUnnestToProductRule.java
index eb39332..42ae597 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ComplexUnnestToProductRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ComplexUnnestToProductRule.java
@@ -298,7 +298,7 @@ public class ComplexUnnestToProductRule implements IAlgebraicRewriteRule {
 
     /**
      * check whether the operator is inside a sub-plan
-     * 
+     *
      * @param nestedRootRef
      * @return true-if it is; false otherwise.
      */

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ConsolidateSelectsRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ConsolidateSelectsRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ConsolidateSelectsRule.java
index 165530a..0a4672b 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ConsolidateSelectsRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ConsolidateSelectsRule.java
@@ -37,7 +37,7 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
 /**
  * Matches the following operator pattern:
  * (select) <-- ((assign)* <-- (select)*)+
- * 
+ *
  * Consolidates the selects to:
  * (select) <-- (assign)*
  *
@@ -59,7 +59,7 @@ public class ConsolidateSelectsRule implements IAlgebraicRewriteRule {
 
         IFunctionInfo andFn = context.getMetadataProvider().lookupFunction(AlgebricksBuiltinFunctions.AND);
         // New conjuncts for consolidated select.
-        AbstractFunctionCallExpression conj = null;        
+        AbstractFunctionCallExpression conj = null;
         AbstractLogicalOperator topMostOp = null;
         AbstractLogicalOperator selectParent = null;
         AbstractLogicalOperator nextSelect = firstSelect;
@@ -75,14 +75,14 @@ public class ConsolidateSelectsRule implements IAlgebraicRewriteRule {
         	}
             // Remember the top-most op that we are not removing.
             topMostOp = selectParent;
-            
+
             // Initialize the new conjuncts, if necessary.
             if (conj == null) {
             	conj = new ScalarFunctionCallExpression(andFn);
             	// Add the first select's condition.
             	conj.getArguments().add(new MutableObject<ILogicalExpression>(firstSelect.getCondition().getValue()));
             }
-            
+
             // Consolidate all following selects.
             do {
                 // Add the condition nextSelect to the new list of conjuncts.
@@ -90,21 +90,21 @@ public class ConsolidateSelectsRule implements IAlgebraicRewriteRule {
                 selectParent = nextSelect;
                 nextSelect = (AbstractLogicalOperator) nextSelect.getInputs().get(0).getValue();
             } while (nextSelect.getOperatorTag() == LogicalOperatorTag.SELECT);
-            
+
             // Hook up the input of the top-most remaining op if necessary.
             if (topMostOp.getOperatorTag() == LogicalOperatorTag.ASSIGN || topMostOp == firstSelect) {
             	topMostOp.getInputs().set(0, selectParent.getInputs().get(0));
             }
-            
+
             // Prepare for next iteration.
             nextSelect = selectParent;
         } while (true);
-		
+
 		// Did we consolidate any selects?
         if (conj == null) {
         	return false;
         }
-        
+
         // Set the new conjuncts.
         firstSelect.getCondition().setValue(conj);
         context.computeAndSetTypeEnvironmentForOperator(firstSelect);

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EliminateGroupByEmptyKeyRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EliminateGroupByEmptyKeyRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EliminateGroupByEmptyKeyRule.java
index d1fedf2..aab6ce1 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EliminateGroupByEmptyKeyRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EliminateGroupByEmptyKeyRule.java
@@ -35,7 +35,7 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
 /**
  * This rule lift out the aggregate operator out from a group-by operator
  * if the gby operator groups-by on empty key, e.g., the group-by variables are empty.
- * 
+ *
  * @author yingyib
  */
 public class EliminateGroupByEmptyKeyRule implements IAlgebraicRewriteRule {

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EnforceOrderByAfterSubplan.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EnforceOrderByAfterSubplan.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EnforceOrderByAfterSubplan.java
index ee7f6a5..fcec50a 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EnforceOrderByAfterSubplan.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EnforceOrderByAfterSubplan.java
@@ -43,7 +43,7 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
  * If there is any ordering property before the subplan operator, the ordering should
  * be kept after the subplan.
  * This rule adds a redundant order operator after those cases, to guarantee the correctness.
- * 
+ *
  * @author yingyib
  */
 public class EnforceOrderByAfterSubplan implements IAlgebraicRewriteRule {

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractCommonExpressionsRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractCommonExpressionsRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractCommonExpressionsRule.java
index 232a78b..e5581dc 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractCommonExpressionsRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractCommonExpressionsRule.java
@@ -196,7 +196,7 @@ public class ExtractCommonExpressionsRule implements IAlgebraicRewriteRule {
         }
 
         // TODO: For now do not perform replacement in nested plans
-        // due to the complication of figuring out whether the firstOp in an equivalence class is within a subplan, 
+        // due to the complication of figuring out whether the firstOp in an equivalence class is within a subplan,
         // and the resulting variable will not be visible to the outside.
         // Since subplans should be eliminated in most cases, this behavior is acceptable for now.
         /*
@@ -238,7 +238,7 @@ public class ExtractCommonExpressionsRule implements IAlgebraicRewriteRule {
             boolean modified = false;
             ExprEquivalenceClass exprEqClass = exprEqClassMap.get(expr);
             if (exprEqClass != null) {
-                // Replace common subexpression with existing variable. 
+                // Replace common subexpression with existing variable.
                 if (exprEqClass.variableIsSet()) {
                     Set<LogicalVariable> liveVars = new HashSet<LogicalVariable>();
                     List<LogicalVariable> usedVars = new ArrayList<LogicalVariable>();

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractFunctionsFromJoinConditionRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractFunctionsFromJoinConditionRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractFunctionsFromJoinConditionRule.java
index 8604cae..71a00bf 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractFunctionsFromJoinConditionRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractFunctionsFromJoinConditionRule.java
@@ -50,11 +50,11 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
  *
  * <pre>
  * Before plan:
- * 
+ *
  *   join ( eq( funcX($$1), funcX($$2) ) )
- * 
+ *
  * After plan:
- * 
+ *
  *   join (eq($$3,$$4))
  *   assign [$$4] <- [funcY($$2)]
  *   assign [$$3] <- [funcX($$1)]

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/InlineSingleReferenceVariablesRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/InlineSingleReferenceVariablesRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/InlineSingleReferenceVariablesRule.java
index bfa3bfd..71fde61 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/InlineSingleReferenceVariablesRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/InlineSingleReferenceVariablesRule.java
@@ -32,17 +32,17 @@ import org.apache.hyracks.algebricks.core.algebra.operators.logical.visitors.Var
 
 /**
  * Inlines variables that are referenced exactly once.
- * 
+ *
  * Preconditions/Assumptions:
  * Assumes no projects are in the plan.
- * 
+ *
  * Example assuming variable $$3 is referenced exactly once.
- * 
+ *
  * Before plan:
  * select (funcA($$3))
  *   ...
  *     assign [$$3] <- [field-access($$0, 1)]
- * 
+ *
  * After plan:
  * select (funcA(field-access($$0, 1))
  *   ...
@@ -53,14 +53,14 @@ public class InlineSingleReferenceVariablesRule extends InlineVariablesRule {
     // Maps from variable to a list of operators using that variable.
     protected Map<LogicalVariable, List<ILogicalOperator>> usedVarsMap = new HashMap<LogicalVariable, List<ILogicalOperator>>();
     protected List<LogicalVariable> usedVars = new ArrayList<LogicalVariable>();
-    
+
     @Override
     protected void prepare(IOptimizationContext context) {
         super.prepare(context);
         usedVarsMap.clear();
         usedVars.clear();
     }
-    
+
     @Override
     protected boolean performFinalAction() throws AlgebricksException {
         boolean modified = false;
@@ -75,7 +75,7 @@ public class InlineSingleReferenceVariablesRule extends InlineVariablesRule {
                         modified = true;
                     }
                     inlineVisitor.setTargetVariable(null);
-                }         
+                }
             }
         }
         return modified;

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/IntroduceProjectsRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/IntroduceProjectsRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/IntroduceProjectsRule.java
index f8b36dd..6bc129e 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/IntroduceProjectsRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/IntroduceProjectsRule.java
@@ -82,7 +82,7 @@ public class IntroduceProjectsRule implements IAlgebraicRewriteRule {
         parentsUsedVars.addAll(parentUsedVars);
         parentsUsedVars.addAll(usedVars);
 
-        // Descend into children.        
+        // Descend into children.
         for (int i = 0; i < op.getInputs().size(); i++) {
             Mutable<ILogicalOperator> inputOpRef = op.getInputs().get(i);
             if (introduceProjects(op, i, inputOpRef, parentsUsedVars, context)) {
@@ -152,7 +152,7 @@ public class IntroduceProjectsRule implements IAlgebraicRewriteRule {
         }
         return modified;
     }
-    
+
     private boolean canEliminateProjectBelowUnion(UnionAllOperator unionOp, ProjectOperator projectOp,
             int unionInputIndex) throws AlgebricksException {
         List<LogicalVariable> orderedLiveVars = new ArrayList<LogicalVariable>();

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/PushFunctionsBelowJoin.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/PushFunctionsBelowJoin.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/PushFunctionsBelowJoin.java
index 59da252..c04a9d5 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/PushFunctionsBelowJoin.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/PushFunctionsBelowJoin.java
@@ -52,20 +52,20 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
  * a join (which may blow up the cardinality).
  * Also, this rule may help to enable other rules such as common subexpression elimination, again to reduce
  * the number of calls to expensive functions.
- * 
+ *
  * Example: (we are pushing pushMeFunc)
- * 
+ *
  * Before plan:
  * assign [$$10] <- [funcA(funcB(pushMeFunc($$3, $$4)))]
- *   join (some condition) 
+ *   join (some condition)
  *     join_branch_0 where $$3 and $$4 are not live
  *       ...
  *     join_branch_1 where $$3 and $$4 are live
  *       ...
- * 
+ *
  * After plan:
  * assign [$$10] <- [funcA(funcB($$11))]
- *   join (some condition) 
+ *   join (some condition)
  *     join_branch_0 where $$3 and $$4 are not live
  *       ...
  *     join_branch_1 where $$3 and $$4 are live

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantGroupByDecorVars.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantGroupByDecorVars.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantGroupByDecorVars.java
index a303cc6..ebdc88a 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantGroupByDecorVars.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantGroupByDecorVars.java
@@ -43,7 +43,7 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
 public class RemoveRedundantGroupByDecorVars implements IAlgebraicRewriteRule {
 
     private final Set<LogicalVariable> vars = new HashSet<LogicalVariable>();
-    
+
     @Override
     public boolean rewritePost(Mutable<ILogicalOperator> opRef, IOptimizationContext context) {
         AbstractLogicalOperator op = (AbstractLogicalOperator) opRef.getValue();
@@ -54,7 +54,7 @@ public class RemoveRedundantGroupByDecorVars implements IAlgebraicRewriteRule {
             return false;
         }
         vars.clear();
-        
+
         boolean modified = false;
         GroupByOperator groupOp = (GroupByOperator) op;
         Iterator<Pair<LogicalVariable, Mutable<ILogicalExpression>>> iter = groupOp.getDecorList().iterator();

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantProjectionRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantProjectionRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantProjectionRule.java
index e459109..38e97d7 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantProjectionRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantProjectionRule.java
@@ -37,12 +37,12 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
  *  project [var-list1]
  *   project [var-list2]
  *     P
- * 
+ *
  *  if var-list1.equals(var-list2) becomes
- * 
+ *
  *  project [var-list1]
  *    P
- *  
+ *
  */
 
 public class RemoveRedundantProjectionRule implements IAlgebraicRewriteRule {

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantVariablesRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantVariablesRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantVariablesRule.java
index 9e4d8b7..9e867df 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantVariablesRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantVariablesRule.java
@@ -125,7 +125,7 @@ public class RemoveRedundantVariablesRule implements IAlgebraicRewriteRule {
             }
         }
 
-        // Replace variable references with their first representative. 
+        // Replace variable references with their first representative.
         if (op.getOperatorTag() == LogicalOperatorTag.PROJECT) {
             // The project operator does not use expressions, so we need to replace it's variables manually.
             if (replaceProjectVars((ProjectOperator) op)) {
@@ -142,7 +142,7 @@ public class RemoveRedundantVariablesRule implements IAlgebraicRewriteRule {
             }
         }
 
-        // Perform variable replacement in nested plans. 
+        // Perform variable replacement in nested plans.
         if (op.hasNestedPlans()) {
             AbstractOperatorWithNestedPlans opWithNestedPlan = (AbstractOperatorWithNestedPlans) op;
             for (ILogicalPlan nestedPlan : opWithNestedPlan.getNestedPlans()) {

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveUnusedAssignAndAggregateRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveUnusedAssignAndAggregateRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveUnusedAssignAndAggregateRule.java
index 100c14f..b25497c 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveUnusedAssignAndAggregateRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveUnusedAssignAndAggregateRule.java
@@ -106,7 +106,7 @@ public class RemoveUnusedAssignAndAggregateRule implements IAlgebraicRewriteRule
                         rootsToBeRemoved.add(r);
                     }
                 }
-                // Makes sure the operator should have at least ONE nested plan even it is empty 
+                // Makes sure the operator should have at least ONE nested plan even it is empty
                 // (because a lot of places uses this assumption,  TODO(yingyib): clean them up).
                 if (nestedPlan.getRoots().size() == rootsToBeRemoved.size() && opWithNest.getNestedPlans().size() > 1) {
                     nestedPlan.getRoots().removeAll(rootsToBeRemoved);

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/SetExecutionModeRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/SetExecutionModeRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/SetExecutionModeRule.java
index c523bd0..63a33b5 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/SetExecutionModeRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/SetExecutionModeRule.java
@@ -32,7 +32,7 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
  * EXCHANGE operators in the plan. Previously, i.e. before having physical
  * optimizations in place, we were using the IntroduceExchangeRule, which was
  * doing both, to both set excutionMode and introduce data exchange ops.
- * 
+ *
  * @author Nicola
  */
 public class SetExecutionModeRule implements IAlgebraicRewriteRule {

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/EliminateSubplanWithInputCardinalityOneRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/EliminateSubplanWithInputCardinalityOneRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/EliminateSubplanWithInputCardinalityOneRule.java
index f7b6dea..784b6cd 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/EliminateSubplanWithInputCardinalityOneRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/EliminateSubplanWithInputCardinalityOneRule.java
@@ -44,7 +44,7 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
  * The live variables at OP will not be used after SUBPLAN.
  * Note: This rule must be applied after
  * the RemoveRedundantVariablesRule (to avoid the lineage analysis of variable cardinality).
- * 
+ *
  * @author yingyib
  */
 public class EliminateSubplanWithInputCardinalityOneRule implements IAlgebraicRewriteRule {
@@ -122,7 +122,7 @@ public class EliminateSubplanWithInputCardinalityOneRule implements IAlgebraicRe
 
     /**
      * Whether the cardinality of the input free variables are one.
-     * 
+     *
      * @param opRef
      *            the operator to be checked (including its input operators)
      * @param freeVars
@@ -141,7 +141,7 @@ public class EliminateSubplanWithInputCardinalityOneRule implements IAlgebraicRe
 
     /**
      * Recursively adding variables which has cardinality one and in int the input free variable set.
-     * 
+     *
      * @param opRef
      *            , the current operator reference.
      * @param freeVars
@@ -181,7 +181,7 @@ public class EliminateSubplanWithInputCardinalityOneRule implements IAlgebraicRe
 
     /**
      * Find the NestedTupleSource operator in the direct/undirect input operators of opRef.
-     * 
+     *
      * @param opRef
      *            , the current operator reference.
      * @param ntsSet

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/MoveFreeVariableOperatorOutOfSubplanRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/MoveFreeVariableOperatorOutOfSubplanRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/MoveFreeVariableOperatorOutOfSubplanRule.java
index 959466a..d176d05 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/MoveFreeVariableOperatorOutOfSubplanRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/MoveFreeVariableOperatorOutOfSubplanRule.java
@@ -41,7 +41,7 @@ import org.apache.hyracks.algebricks.rewriter.rules.AbstractDecorrelationRule;
  *
  * <pre>
  * Before
- * 
+ *
  *   %PARENT_PLAN
  *   SUBPLAN{
  *     %NESTED_OPERATORS_B+
@@ -50,12 +50,12 @@ import org.apache.hyracks.algebricks.rewriter.rules.AbstractDecorrelationRule;
  *     NESTEDTUPLESOURCE
  *   }
  *   %CHILD_PLAN
- * 
+ *
  *   where
  *     %SUBPLAN has one nested plan with a root AGGREGATE operator.
- * 
+ *
  * After
- * 
+ *
  *   %PARENT_PLAN
  *   SUBPLAN{
  *     %NESTED_OPERATORS_B+

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/PushSubplanIntoGroupByRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/PushSubplanIntoGroupByRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/PushSubplanIntoGroupByRule.java
index 74ff21f..042de2c 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/PushSubplanIntoGroupByRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/PushSubplanIntoGroupByRule.java
@@ -47,7 +47,7 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
 /**
  * This rule pushes an array of subplans on top of a group-by into the
  * nested plan of the group-by.
- * 
+ *
  * @author yingyib
  */
 
@@ -179,7 +179,7 @@ public class PushSubplanIntoGroupByRule implements IAlgebraicRewriteRule {
 
     /**
      * Removes unused aggregation variables (and expressions)
-     * 
+     *
      * @param gby
      * @throws AlgebricksException
      */
@@ -206,4 +206,4 @@ public class PushSubplanIntoGroupByRule implements IAlgebraicRewriteRule {
         return currentOpRef;
     }
 
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/base/ICopySerializableAggregateFunction.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/base/ICopySerializableAggregateFunction.java b/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/base/ICopySerializableAggregateFunction.java
index b3c73fb..078a51d 100644
--- a/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/base/ICopySerializableAggregateFunction.java
+++ b/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/base/ICopySerializableAggregateFunction.java
@@ -26,7 +26,7 @@ import org.apache.hyracks.dataflow.common.data.accessors.IFrameTupleReference;
 public interface ICopySerializableAggregateFunction {
     /**
      * initialize the space occupied by internal state
-     * 
+     *
      * @param state
      * @throws AlgebricksException
      * @return length of the intermediate state
@@ -35,7 +35,7 @@ public interface ICopySerializableAggregateFunction {
 
     /**
      * update the internal state
-     * 
+     *
      * @param tuple
      * @param state
      * @throws AlgebricksException
@@ -44,7 +44,7 @@ public interface ICopySerializableAggregateFunction {
 
     /**
      * output the state to result
-     * 
+     *
      * @param state
      * @param result
      * @throws AlgebricksException
@@ -53,7 +53,7 @@ public interface ICopySerializableAggregateFunction {
 
     /**
      * output the partial state to partial result
-     * 
+     *
      * @param state
      * @param partialResult
      * @throws AlgebricksException

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/std/AssignRuntimeFactory.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/std/AssignRuntimeFactory.java b/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/std/AssignRuntimeFactory.java
index 1877d64..50706bd 100644
--- a/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/std/AssignRuntimeFactory.java
+++ b/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/std/AssignRuntimeFactory.java
@@ -139,8 +139,8 @@ public class AssignRuntimeFactory extends AbstractOneInputOneOutputRuntimeFactor
                 tRef.reset(tAccess, t);
                 produceTuple(tupleBuilder, tAccess, t, tRef);
                 if (flushFramesRapidly) {
-                    // Whenever all the tuples in the incoming frame have been consumed, the assign operator 
-                    // will push its frame to the next operator; i.e., it won't wait until the frame gets full. 
+                    // Whenever all the tuples in the incoming frame have been consumed, the assign operator
+                    // will push its frame to the next operator; i.e., it won't wait until the frame gets full.
                     appendToFrameFromTupleBuilder(tupleBuilder, true);
                 } else {
                     appendToFrameFromTupleBuilder(tupleBuilder);

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/IApplicationContext.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/IApplicationContext.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/IApplicationContext.java
index 1fb2291..6c79abd 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/IApplicationContext.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/IApplicationContext.java
@@ -27,14 +27,14 @@ import org.apache.hyracks.api.service.IControllerService;
 
 /**
  * Base class of the {@link ICCApplicationContext} and the {@link INCApplicationContext}.
- * 
+ *
  * @author vinayakb
  */
 public interface IApplicationContext {
     /**
      * Gets the distributed state that is made available to all the Application
      * Contexts of this application in the cluster.
-     * 
+     *
      * @return
      */
     public Serializable getDistributedState();
@@ -54,4 +54,4 @@ public interface IApplicationContext {
      */
     public IControllerService getControllerService();
 
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/ICCApplicationContext.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/ICCApplicationContext.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/ICCApplicationContext.java
index a629b3a..8b83d83 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/ICCApplicationContext.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/ICCApplicationContext.java
@@ -25,7 +25,7 @@ import org.apache.hyracks.api.job.IJobLifecycleListener;
 
 /**
  * Application Context at the Cluster Controller for an application.
- * 
+ *
  * @author vinayakb
  */
 public interface ICCApplicationContext extends IApplicationContext {
@@ -34,7 +34,7 @@ public interface ICCApplicationContext extends IApplicationContext {
      * NC application contexts. Any state set by calling this method in the {@link ICCApplicationEntryPoint#start(ICCApplicationContext, String[])} call is made available to all the {@link INCApplicationContext} objects
      * at each Node Controller. The state is then available to be inspected by
      * the application at the NC during or after the {@link INCBootstrap#start()} call.
-     * 
+     *
      * @param state
      *            The distributed state
      */
@@ -43,7 +43,7 @@ public interface ICCApplicationContext extends IApplicationContext {
     /**
      * A listener that listens to Job Lifecycle events at the Cluster
      * Controller.
-     * 
+     *
      * @param jobLifecycleListener
      */
     public void addJobLifecycleListener(IJobLifecycleListener jobLifecycleListener);
@@ -51,16 +51,16 @@ public interface ICCApplicationContext extends IApplicationContext {
     /**
      * A listener that listens to Cluster Lifecycle events at the Cluster
      * Controller.
-     * 
+     *
      * @param jobLifecycleListener
      */
     public void addClusterLifecycleListener(IClusterLifecycleListener clusterLifecycleListener);
 
     /**
      * Get the Cluster Controller Context.
-     * 
+     *
      * @return The Cluster Controller Context.
      */
     public ICCContext getCCContext();
 
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/INCApplicationContext.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/INCApplicationContext.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/INCApplicationContext.java
index e9788d9..77934c6 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/INCApplicationContext.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/INCApplicationContext.java
@@ -24,34 +24,34 @@ import org.apache.hyracks.api.resources.memory.IMemoryManager;
 
 /**
  * Application Context at the Node Controller for an application.
- * 
+ *
  * @author vinayakb
  */
 public interface INCApplicationContext extends IApplicationContext {
     /**
      * Gets the life cycle component manager of the Node Controller.
-     * 
+     *
      * @return
      */
     public ILifeCycleComponentManager getLifeCycleComponentManager();
 
     /**
      * Gets the node Id of the Node Controller.
-     * 
+     *
      * @return the Node Id.
      */
     public String getNodeId();
 
     /**
      * Get the Hyracks Root Context.
-     * 
+     *
      * @return The Hyracks Root Context
      */
     public IHyracksRootContext getRootContext();
 
     /**
      * Set an object that can be later retrieved by the {@link #getApplicationObject()} call.
-     * 
+     *
      * @param object
      *            Application Object
      */
@@ -59,22 +59,22 @@ public interface INCApplicationContext extends IApplicationContext {
 
     /**
      * Get the application object previously set by the {@link #setApplicationObject(Object)} call.
-     * 
+     *
      * @return Application Object
      */
     public Object getApplicationObject();
 
     /**
      * Get the memory manager at the node.
-     * 
+     *
      * @return Memory Manager
      */
     public IMemoryManager getMemoryManager();
 
     /**
      * Set the handler for state dumps.
-     * 
+     *
      * @param handler
      */
     public void setStateDumpHandler(IStateDumpHandler handler);
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/HyracksConnection.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/HyracksConnection.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/HyracksConnection.java
index 953d2c1..b57442d 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/HyracksConnection.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/HyracksConnection.java
@@ -53,7 +53,7 @@ import org.apache.hyracks.ipc.impl.JavaSerializationBasedPayloadSerializerDeseri
 /**
  * Connection Class used by a Hyracks Client to interact with a Hyracks Cluster
  * Controller.
- * 
+ *
  * @author vinayakb
  */
 public final class HyracksConnection implements IHyracksClientConnection {
@@ -67,7 +67,7 @@ public final class HyracksConnection implements IHyracksClientConnection {
 
     /**
      * Constructor to create a connection to the Hyracks Cluster Controller.
-     * 
+     *
      * @param ccHost
      *            Host name (or IP Address) where the Cluster Controller can be
      *            reached.
@@ -190,4 +190,4 @@ public final class HyracksConnection implements IHyracksClientConnection {
     public void stopCluster() throws Exception{
         hci.stopCluster();
     }
-}
\ No newline at end of file
+}


Mime
View raw message