asterixdb-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ti...@apache.org
Subject [4/4] incubator-asterixdb git commit: remove end-of-line whitespace
Date Fri, 29 Jan 2016 22:46:15 GMT
remove end-of-line whitespace

Change-Id: I5c0415f47d4c3a9827574fbdab949b45718d9ea4
Reviewed-on: https://asterix-gerrit.ics.uci.edu/601
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/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/commit/e2439b44
Tree: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/tree/e2439b44
Diff: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/diff/e2439b44

Branch: refs/heads/master
Commit: e2439b4435769a8a2082e18698e4889dcb004727
Parents: e05d17c
Author: Till Westmann <tillw@apache.org>
Authored: Thu Jan 28 17:06:21 2016 -0800
Committer: Till Westmann <tillw@apache.org>
Committed: Fri Jan 29 14:41:34 2016 -0800

----------------------------------------------------------------------
 .../rules/CheckFilterExpressionTypeRule.java    |  2 +-
 .../rules/DisjunctivePredicateToJoinRule.java   |  2 +-
 .../rules/InlineUnnestFunctionRule.java         |  2 +-
 .../optimizer/rules/LoadRecordFieldsRule.java   |  4 +-
 .../PushAggFuncIntoStandaloneAggregateRule.java |  8 +-
 .../rules/RemoveRedundantSelectRule.java        |  2 +-
 .../rules/am/AccessMethodAnalysisContext.java   |  2 +-
 .../optimizer/rules/am/IAccessMethod.java       |  8 +-
 .../translator/TranslationException.java        |  2 +-
 .../feed/FeedJobNotificationHandler.java        |  8 +-
 .../apache/asterix/feed/FeedLoadManager.java    |  2 +-
 .../file/SecondaryRTreeOperationsHelper.java    |  2 +-
 .../asterix/common/api/IAsterixContextInfo.java |  2 +-
 .../common/api/IClusterEventsSubscriber.java    |  2 +-
 .../common/api/IDatasetLifecycleManager.java    | 10 +--
 .../asterix/common/config/DatasetConfig.java    |  2 +-
 .../asterix/common/config/GlobalConfig.java     |  2 +-
 .../common/context/DatasetLifecycleManager.java |  6 +-
 ...rtedIndexInsertDeleteOperatorDescriptor.java |  2 +-
 .../IAsterixApplicationContextInfo.java         |  6 +-
 .../common/exceptions/TypeException.java        |  2 +-
 .../common/replication/IReplicationChannel.java |  4 +-
 .../common/replication/IReplicationManager.java | 20 ++---
 .../common/replication/IReplicationThread.java  |  4 +-
 .../asterix/common/transactions/DatasetId.java  |  2 +-
 .../common/transactions/ILockManager.java       |  8 +-
 .../common/transactions/ILogManager.java        |  6 +-
 .../common/transactions/IRecoveryManager.java   | 14 ++--
 .../transactions/ITransactionManager.java       | 12 +--
 .../transactions/ITransactionSubsystem.java     |  2 +-
 .../asterix/common/transactions/LogRecord.java  |  6 +-
 .../asterix/common/utils/ANameSchema.java       |  2 +-
 .../asterix/external/api/IAdapterFactory.java   |  6 +-
 .../asterix/external/api/INodeResolver.java     |  2 +-
 .../external/api/INodeResolverFactory.java      |  2 +-
 .../feed/api/IFeedConnectionManager.java        | 10 +--
 .../asterix/external/feed/api/IFeedJoint.java   |  8 +-
 .../external/feed/api/IFeedLoadManager.java     |  2 +-
 .../external/feed/api/IFeedMemoryComponent.java |  2 +-
 .../external/feed/api/IFeedMemoryManager.java   |  6 +-
 .../asterix/external/feed/api/IFeedMessage.java |  2 +-
 .../external/feed/api/IFeedMessageService.java  |  2 +-
 .../feed/api/IFeedWorkEventListener.java        |  2 +-
 .../FeedCollectRuntimeInputHandler.java         |  2 +-
 .../external/feed/dataflow/FeedFrameCache.java  |  4 +-
 .../feed/dataflow/FeedFrameTupleAccessor.java   |  4 +-
 .../feed/management/FeedConnectionRequest.java  |  2 +-
 .../asterix/external/feed/watch/SeriesAvg.java  |  2 +-
 .../indexing/ExternalFileIndexAccessor.java     |  2 +-
 .../input/record/reader/HDFSTextLineReader.java | 10 +--
 ...xternalDatasetIndexesOperatorDescriptor.java |  2 +-
 .../ExternalLookupOperatorDescriptor.java       |  2 +-
 .../operators/IndexInfoOperatorDescriptor.java  |  2 +-
 .../asterix/fuzzyjoin/FuzzyJoinConfig.java      |  2 +-
 .../apache/asterix/fuzzyjoin/FuzzyJoinUtil.java |  6 +-
 .../similarity/SimilarityFiltersJaccard.java    |  2 +-
 .../fuzzyjoin/tokenizer/NGramTokenizer.java     |  2 +-
 .../asterix/fuzzyjoin/tokenizer/Token.java      |  2 +-
 .../fuzzyjoin/tokenizer/WordTokenizer.java      |  2 +-
 .../tokenorder/IntTokenCountRankFrequency.java  |  2 +-
 .../tokenorder/IntTokenRankFrequency.java       |  2 +-
 .../tokenorder/TokenRankBufferedFrequency.java  |  2 +-
 .../tokenorder/TokenRankFrequency.java          |  2 +-
 .../installer/test/AbstractExecutionIT.java     |  4 +-
 .../installer/test/ClusterExecutionIT.java      |  4 +-
 .../installer/test/ManagixExecutionIT.java      |  4 +-
 .../installer/test/ManagixSqlppExecutionIT.java |  4 +-
 .../common/context/FunctionExpressionMap.java   |  2 +-
 .../lang/common/literal/DoubleLiteral.java      |  2 +-
 .../lang/common/literal/FloatLiteral.java       |  2 +-
 .../lang/common/literal/IntegerLiteral.java     |  2 +-
 .../lang/common/literal/LongIntegerLiteral.java |  2 +-
 .../lang/common/literal/NullLiteral.java        |  2 +-
 .../lexergenerator/LexerGeneratorMojo.java      |  6 +-
 .../src/main/resources/Lexer.java               | 44 +++++-----
 .../src/main/resources/LexerException.java      |  4 +-
 .../apache/asterix/lexergenerator/Fixtures.java | 34 ++++----
 .../lexergenerator/LexerNodeAddRuleTest.java    |  2 +-
 .../lexergenerator/LexerNodeAppendNodeTest.java |  6 +-
 .../lexergenerator/LexerNodeAppendRuleTest.java |  4 +-
 .../LexerNodeAuxFunctionsTest.java              | 10 +--
 .../recordmanagergenerator/Generator.java       | 32 +++----
 .../RecordManagerGeneratorMojo.java             | 26 +++---
 .../recordmanagergenerator/RecordType.java      | 72 ++++++++--------
 .../src/main/resources/AllocInfo.java           |  8 +-
 .../src/main/resources/ArenaManager.java        | 28 +++----
 .../src/main/resources/RecordManager.java       | 50 +++++------
 .../src/main/resources/RecordManagerStats.java  |  2 +-
 .../src/main/resources/TypeUtil.java            | 10 +--
 .../apache/asterix/metadata/MetadataCache.java  |  8 +-
 .../api/IMetadataEntityTupleTranslator.java     |  6 +-
 .../asterix/metadata/api/IMetadataNode.java     | 76 ++++++++---------
 .../asterix/metadata/api/IValueExtractor.java   |  2 +-
 .../cluster/AbstractClusterManagementWork.java  |  2 +-
 .../cluster/ClusterManagementWorkResponse.java  |  2 +-
 .../metadata/dataset/hints/DatasetHints.java    |  2 +-
 .../asterix/metadata/dataset/hints/IHint.java   |  4 +-
 .../utils/ExternalDatasetsRegistry.java         |  2 +-
 ...AWrappedAscNormalizedKeyComputerFactory.java |  2 +-
 .../om/base/temporal/ADateParserFactory.java    |  6 +-
 .../om/base/temporal/ATimeParserFactory.java    | 12 +--
 .../temporal/DurationArithmeticOperations.java  |  2 +-
 .../base/temporal/GregorianCalendarSystem.java  | 40 ++++-----
 .../om/base/temporal/ICalendarSystem.java       |  6 +-
 .../functions/IFunctionDescriptorFactory.java   |  2 +-
 .../asterix/om/io/AsterixIOException.java       |  2 +-
 .../om/pointables/AListVisitablePointable.java  |  2 +-
 .../om/pointables/PointableAllocator.java       |  4 +-
 .../apache/asterix/om/types/TypeHierarchy.java  |  2 +-
 .../asterix/om/util/AsterixAppContextInfo.java  |  2 +-
 .../om/util/container/IObjectFactory.java       |  2 +-
 .../asterix/om/util/container/IObjectPool.java  |  2 +-
 .../functions/ReplicationProtocol.java          |  6 +-
 .../replication/management/NetworkingUtil.java  |  4 +-
 .../management/ReplicationChannel.java          | 12 +--
 .../aggregates/std/SqlSumAggregateFunction.java |  2 +-
 .../aggregates/std/SumAggregateFunction.java    |  2 +-
 .../AbstractNumericArithmeticEval.java          |  4 +-
 .../functions/temporal/IntervalLogic.java       | 14 ++--
 .../PersistentLocalResourceRepository.java      |  4 +-
 .../service/locking/DatasetLockInfo.java        |  8 +-
 .../service/locking/DeadlockDetector.java       |  8 +-
 .../service/locking/EntityInfoManager.java      |  8 +-
 .../service/locking/EntityLockInfoManager.java  | 42 +++++-----
 .../management/service/locking/JobInfo.java     |  6 +-
 .../management/service/locking/LockManager.java | 88 ++++++++++----------
 .../LockManagerDeterministicUnitTest.java       |  4 +-
 .../service/locking/LockManagerStats.java       | 12 +--
 .../service/locking/LockWaiterManager.java      |  6 +-
 .../service/locking/PrimitiveIntHashMap.java    | 46 +++++-----
 .../service/recovery/CheckpointObject.java      |  4 +-
 .../service/recovery/CheckpointThread.java      | 22 ++---
 .../service/recovery/RecoveryManager.java       | 20 ++---
 .../TransactionManagementConstants.java         |  6 +-
 .../service/transaction/TransactionManager.java |  2 +-
 .../asterix/aoya/AsterixApplicationMaster.java  | 26 +++---
 .../apache/asterix/aoya/AsterixYARNClient.java  | 24 +++---
 .../java/org/apache/asterix/aoya/Deleter.java   |  4 +-
 .../java/org/apache/asterix/aoya/Utils.java     | 20 ++---
 139 files changed, 609 insertions(+), 609 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/CheckFilterExpressionTypeRule.java
----------------------------------------------------------------------
diff --git a/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/CheckFilterExpressionTypeRule.java b/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/CheckFilterExpressionTypeRule.java
index 874a1d6..3eadba3 100644
--- a/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/CheckFilterExpressionTypeRule.java
+++ b/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/CheckFilterExpressionTypeRule.java
@@ -70,7 +70,7 @@ public class CheckFilterExpressionTypeRule implements IAlgebraicRewriteRule {
 
     /**
      * Check if the type is optional boolean or not
-     * 
+     *
      * @param type
      * @return true if it is; false otherwise.
      */

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/DisjunctivePredicateToJoinRule.java
----------------------------------------------------------------------
diff --git a/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/DisjunctivePredicateToJoinRule.java b/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/DisjunctivePredicateToJoinRule.java
index 2e02c07..5b6a8b1 100644
--- a/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/DisjunctivePredicateToJoinRule.java
+++ b/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/DisjunctivePredicateToJoinRule.java
@@ -158,7 +158,7 @@ public class DisjunctivePredicateToJoinRule implements IAlgebraicRewriteRule {
      * when joining. Right now this compatibility is defined as type equality, but it could we relaxed.
      * Once type promotion works correctly in all parts of the system, this check should not be needed anymore.
      * (see https://code.google.com/p/asterixdb/issues/detail?id=716)
-     * 
+     *
      * @param t1
      *            one type
      * @param t2

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/InlineUnnestFunctionRule.java
----------------------------------------------------------------------
diff --git a/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/InlineUnnestFunctionRule.java b/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/InlineUnnestFunctionRule.java
index bd7c6ad..1c27a6e 100644
--- a/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/InlineUnnestFunctionRule.java
+++ b/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/InlineUnnestFunctionRule.java
@@ -84,7 +84,7 @@ public class InlineUnnestFunctionRule implements IAlgebraicRewriteRule {
 
     /**
      * This method is to inline one variable
-     * 
+     *
      * @param usedVar
      *            A variable that is used by the scan-collection function in the unnest operator
      * @param unnestOp

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/LoadRecordFieldsRule.java
----------------------------------------------------------------------
diff --git a/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/LoadRecordFieldsRule.java b/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/LoadRecordFieldsRule.java
index ecca996..598c775 100644
--- a/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/LoadRecordFieldsRule.java
+++ b/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/LoadRecordFieldsRule.java
@@ -223,7 +223,7 @@ public class LoadRecordFieldsRule implements IAlgebraicRewriteRule {
 
     /**
      * Pushes one field-access assignment above toPushThroughChildRef
-     * 
+     *
      * @param toPush
      * @param toPushThroughChildRef
      */
@@ -243,7 +243,7 @@ public class LoadRecordFieldsRule implements IAlgebraicRewriteRule {
      * into
      * assign $x := Expr
      * assign $y := record-constructor { "field": Expr, ... }
-     * 
+     *
      * @param toPush
      */
     private static boolean findAndEliminateRedundantFieldAccess(AssignOperator assign) throws AlgebricksException {

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/PushAggFuncIntoStandaloneAggregateRule.java
----------------------------------------------------------------------
diff --git a/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/PushAggFuncIntoStandaloneAggregateRule.java b/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/PushAggFuncIntoStandaloneAggregateRule.java
index 833352a..7d768b2 100644
--- a/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/PushAggFuncIntoStandaloneAggregateRule.java
+++ b/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/PushAggFuncIntoStandaloneAggregateRule.java
@@ -87,7 +87,7 @@ public class PushAggFuncIntoStandaloneAggregateRule implements IAlgebraicRewrite
 
     /**
      * Recursively check whether the list of expressions contains an aggregate function.
-     * 
+     *
      * @param exprRefs
      * @return true if the list contains an aggregate function and false otherwise.
      */
@@ -117,7 +117,7 @@ public class PushAggFuncIntoStandaloneAggregateRule implements IAlgebraicRewrite
      * Check whether the join is aggregate-pushable, that is,
      * 1) the join condition is true;
      * 2) each join branch produces only one tuple.
-     * 
+     *
      * @param join
      * @return true if pushable
      */
@@ -145,7 +145,7 @@ public class PushAggFuncIntoStandaloneAggregateRule implements IAlgebraicRewrite
 
     /**
      * Does the actual push of aggregates for qualified joins.
-     * 
+     *
      * @param join
      * @param assignOp
      *            that contains aggregate function calls.
@@ -213,7 +213,7 @@ public class PushAggFuncIntoStandaloneAggregateRule implements IAlgebraicRewrite
             FunctionIdentifier aggFuncIdent = AsterixBuiltinFunctions.getAggregateFunction(assignFuncExpr
                     .getFunctionIdentifier());
 
-            // Push the agg func into the agg op.                
+            // Push the agg func into the agg op.
 
             List<Mutable<ILogicalExpression>> aggArgs = new ArrayList<Mutable<ILogicalExpression>>();
             aggArgs.add(aggOpExpr.getArguments().get(0));

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/RemoveRedundantSelectRule.java
----------------------------------------------------------------------
diff --git a/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/RemoveRedundantSelectRule.java b/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/RemoveRedundantSelectRule.java
index fb25568..fe9e49e 100644
--- a/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/RemoveRedundantSelectRule.java
+++ b/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/RemoveRedundantSelectRule.java
@@ -66,7 +66,7 @@ public class RemoveRedundantSelectRule implements IAlgebraicRewriteRule {
 
     /**
      * Whether the condition expression always returns true.
-     * 
+     *
      * @param cond
      * @return true if the condition always holds; false otherwise.
      */

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/AccessMethodAnalysisContext.java
----------------------------------------------------------------------
diff --git a/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/AccessMethodAnalysisContext.java b/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/AccessMethodAnalysisContext.java
index b17cdfe..ca5da98 100644
--- a/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/AccessMethodAnalysisContext.java
+++ b/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/AccessMethodAnalysisContext.java
@@ -39,7 +39,7 @@ public class AccessMethodAnalysisContext {
     public List<IOptimizableFuncExpr> matchedFuncExprs = new ArrayList<IOptimizableFuncExpr>();
 
     // Contains candidate indexes and a list of (integer,integer) tuples that index into matchedFuncExprs and matched variable inside this expr.
-    // We are mapping from candidate indexes to a list of function expressions 
+    // We are mapping from candidate indexes to a list of function expressions
     // that match one of the index's expressions.
     public Map<Index, List<Pair<Integer, Integer>>> indexExprsAndVars = new TreeMap<Index, List<Pair<Integer, Integer>>>();
 

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/IAccessMethod.java
----------------------------------------------------------------------
diff --git a/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/IAccessMethod.java b/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/IAccessMethod.java
index 432d933..6538ead 100644
--- a/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/IAccessMethod.java
+++ b/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/IAccessMethod.java
@@ -51,7 +51,7 @@ public interface IAccessMethod {
      * optimizable by this access method based on its function identifier. If
      * funcExpr has been found to be optimizable, this method adds an
      * OptimizableFunction to analysisCtx.matchedFuncExprs for further analysis.
-     * 
+     *
      * @return true if funcExpr is optimizable by this access method, false
      *         otherwise
      * @throws AlgebricksException
@@ -63,7 +63,7 @@ public interface IAccessMethod {
     /**
      * Indicates whether all index expressions must be matched in order for this
      * index to be applicable.
-     * 
+     *
      * @return boolean
      */
     public boolean matchAllIndexExprs();
@@ -71,7 +71,7 @@ public interface IAccessMethod {
     /**
      * Indicates whether this index is applicable if only a prefix of the index
      * expressions are matched.
-     * 
+     *
      * @return boolean
      */
     public boolean matchPrefixIndexExprs();
@@ -95,7 +95,7 @@ public interface IAccessMethod {
 
     /**
      * Analyzes expr to see whether it is optimizable by the given concrete index.
-     * 
+     *
      * @throws AlgebricksException
      */
     public boolean exprIsOptimizable(Index index, IOptimizableFuncExpr optFuncExpr) throws AlgebricksException;

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-algebra/src/main/java/org/apache/asterix/translator/TranslationException.java
----------------------------------------------------------------------
diff --git a/asterix-algebra/src/main/java/org/apache/asterix/translator/TranslationException.java b/asterix-algebra/src/main/java/org/apache/asterix/translator/TranslationException.java
index 2928297..93586fc 100644
--- a/asterix-algebra/src/main/java/org/apache/asterix/translator/TranslationException.java
+++ b/asterix-algebra/src/main/java/org/apache/asterix/translator/TranslationException.java
@@ -22,7 +22,7 @@ import org.apache.asterix.common.exceptions.AsterixException;
 
 public class TranslationException extends AsterixException {
     /**
-     * 
+     *
      */
     private static final long serialVersionUID = 685960054131778068L;
 

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-app/src/main/java/org/apache/asterix/feed/FeedJobNotificationHandler.java
----------------------------------------------------------------------
diff --git a/asterix-app/src/main/java/org/apache/asterix/feed/FeedJobNotificationHandler.java b/asterix-app/src/main/java/org/apache/asterix/feed/FeedJobNotificationHandler.java
index b42ef1e..49b88ca 100644
--- a/asterix-app/src/main/java/org/apache/asterix/feed/FeedJobNotificationHandler.java
+++ b/asterix-app/src/main/java/org/apache/asterix/feed/FeedJobNotificationHandler.java
@@ -309,7 +309,7 @@ public class FeedJobNotificationHandler implements Runnable {
         intakeJobInfo.getIntakeFeedJoint().setState(State.ACTIVE);
         intakeJobInfo.setState(FeedJobState.ACTIVE);
 
-        // notify event listeners 
+        // notify event listeners
         notifyFeedEventSubscribers(intakeJobInfo, FeedLifecycleEvent.FEED_INTAKE_STARTED);
     }
 
@@ -424,7 +424,7 @@ public class FeedJobNotificationHandler implements Runnable {
         // remove feed joints
         deregisterFeedIntakeJob(message.jobId);
 
-        // notify event listeners 
+        // notify event listeners
         notifyFeedEventSubscribers(intakeInfo, event);
 
     }
@@ -458,7 +458,7 @@ public class FeedJobNotificationHandler implements Runnable {
         }
         deregisterFeedActivity(cInfo);
 
-        // notify event listeners 
+        // notify event listeners
         FeedLifecycleEvent event = failure ? FeedLifecycleEvent.FEED_COLLECT_FAILURE : FeedLifecycleEvent.FEED_ENDED;
         notifyFeedEventSubscribers(cInfo, event);
     }
@@ -739,4 +739,4 @@ public class FeedJobNotificationHandler implements Runnable {
         }
 
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-app/src/main/java/org/apache/asterix/feed/FeedLoadManager.java
----------------------------------------------------------------------
diff --git a/asterix-app/src/main/java/org/apache/asterix/feed/FeedLoadManager.java b/asterix-app/src/main/java/org/apache/asterix/feed/FeedLoadManager.java
index ee4da11..18e885d 100644
--- a/asterix-app/src/main/java/org/apache/asterix/feed/FeedLoadManager.java
+++ b/asterix-app/src/main/java/org/apache/asterix/feed/FeedLoadManager.java
@@ -122,7 +122,7 @@ public class FeedLoadManager implements IFeedLoadManager {
                 // Step 2) send prepare to  stall message
                 gracefullyTerminateDataFlow(message.getConnectionId(), Integer.MAX_VALUE);
 
-                // Step 3) run the altered job specification 
+                // Step 3) run the altered job specification
                 if (LOGGER.isLoggable(Level.INFO)) {
                     LOGGER.info("New Job after adjusting to the workload " + jobSpec);
                 }

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-app/src/main/java/org/apache/asterix/file/SecondaryRTreeOperationsHelper.java
----------------------------------------------------------------------
diff --git a/asterix-app/src/main/java/org/apache/asterix/file/SecondaryRTreeOperationsHelper.java b/asterix-app/src/main/java/org/apache/asterix/file/SecondaryRTreeOperationsHelper.java
index 418d143..83f91a0 100644
--- a/asterix-app/src/main/java/org/apache/asterix/file/SecondaryRTreeOperationsHelper.java
+++ b/asterix-app/src/main/java/org/apache/asterix/file/SecondaryRTreeOperationsHelper.java
@@ -240,7 +240,7 @@ public class SecondaryRTreeOperationsHelper extends SecondaryIndexOperationsHelp
         JobSpecification spec = JobSpecificationUtils.createJobSpecification();
         boolean temp = dataset.getDatasetDetails().isTemp();
         if (dataset.getDatasetType() == DatasetType.INTERNAL) {
-            // Create dummy key provider for feeding the primary index scan. 
+            // Create dummy key provider for feeding the primary index scan.
             AbstractOperatorDescriptor keyProviderOp = createDummyKeyProviderOp(spec);
 
             // Create primary index scan op.

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/api/IAsterixContextInfo.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/api/IAsterixContextInfo.java b/asterix-common/src/main/java/org/apache/asterix/common/api/IAsterixContextInfo.java
index 2eb4fb2..d092df7 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/api/IAsterixContextInfo.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/api/IAsterixContextInfo.java
@@ -24,7 +24,7 @@ public interface IAsterixContextInfo {
 
     /**
      * Returns an instance of the implementation for ICCApplicationContext.
-     * 
+     *
      * @return ICCApplicationContext implementation instance
      */
     public ICCApplicationContext getCCApplicationContext();

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/api/IClusterEventsSubscriber.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/api/IClusterEventsSubscriber.java b/asterix-common/src/main/java/org/apache/asterix/common/api/IClusterEventsSubscriber.java
index bb2c19a..3a98b82 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/api/IClusterEventsSubscriber.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/api/IClusterEventsSubscriber.java
@@ -46,6 +46,6 @@ public interface IClusterEventsSubscriber {
      * @param newState
      */
     public void notifyStateChange(ClusterState previousState, ClusterState newState);
-    
+
 
 }

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/api/IDatasetLifecycleManager.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/api/IDatasetLifecycleManager.java b/asterix-common/src/main/java/org/apache/asterix/common/api/IDatasetLifecycleManager.java
index 803e708..7e02faf 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/api/IDatasetLifecycleManager.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/api/IDatasetLifecycleManager.java
@@ -39,14 +39,14 @@ public interface IDatasetLifecycleManager extends IIndexLifecycleManager {
 
     /**
      * Flushes all open datasets synchronously.
-     * 
+     *
      * @throws HyracksDataException
      */
     void flushAllDatasets() throws HyracksDataException;
 
     /**
      * Schedules asynchronous flush on datasets that have memory components with first LSN < nonSharpCheckpointTargetLSN.
-     * 
+     *
      * @param nonSharpCheckpointTargetLSN
      * @throws HyracksDataException
      */
@@ -54,7 +54,7 @@ public interface IDatasetLifecycleManager extends IIndexLifecycleManager {
 
     /**
      * creates (if necessary) and returns the dataset info.
-     * 
+     *
      * @param datasetID
      * @return
      */
@@ -71,7 +71,7 @@ public interface IDatasetLifecycleManager extends IIndexLifecycleManager {
 
     /**
      * creates (if necessary) and returns the primary index operation tracker of a dataset.
-     * 
+     *
      * @param datasetID
      * @return
      */
@@ -79,7 +79,7 @@ public interface IDatasetLifecycleManager extends IIndexLifecycleManager {
 
     /**
      * creates (if necessary) and returns the dataset virtual buffer caches.
-     * 
+     *
      * @param datasetID
      * @return
      */

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/config/DatasetConfig.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/config/DatasetConfig.java b/asterix-common/src/main/java/org/apache/asterix/common/config/DatasetConfig.java
index ba3b30a..49ffa28 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/config/DatasetConfig.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/config/DatasetConfig.java
@@ -45,7 +45,7 @@ public class DatasetConfig {
     public enum ExternalDatasetTransactionState {
         COMMIT, // The committed state <- nothing is required->
         BEGIN, // The state after starting the refresh transaction <- will either abort moving to committed state or move to ready to commit->
-        READY_TO_COMMIT // The transaction is ready to commit <- can only move forward to committed state-> 
+        READY_TO_COMMIT // The transaction is ready to commit <- can only move forward to committed state->
     };
 
     public enum ExternalFilePendingOp {

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/config/GlobalConfig.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/config/GlobalConfig.java b/asterix-common/src/main/java/org/apache/asterix/common/config/GlobalConfig.java
index 14ffa3f..bc8fd5f 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/config/GlobalConfig.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/config/GlobalConfig.java
@@ -42,7 +42,7 @@ public class GlobalConfig {
     public static int DEFAULT_INPUT_DATA_COLUMN = 0;
 
     public static final String DEFAULT_COMPACTION_POLICY_NAME = "prefix";
-    
+
     public static final String DEFAULT_FILTERED_DATASET_COMPACTION_POLICY_NAME = "correlated-prefix";
 
     public static final Map<String, String> DEFAULT_COMPACTION_POLICY_PROPERTIES;

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/context/DatasetLifecycleManager.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/context/DatasetLifecycleManager.java b/asterix-common/src/main/java/org/apache/asterix/common/context/DatasetLifecycleManager.java
index 438db58..93d78e8 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/context/DatasetLifecycleManager.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/context/DatasetLifecycleManager.java
@@ -214,8 +214,8 @@ public class DatasetLifecycleManager implements IDatasetLifecycleManager, ILifeC
     }
 
     private boolean evictCandidateDataset() throws HyracksDataException {
-        // We will take a dataset that has no active transactions, it is open (a dataset consuming memory), 
-        // that is not being used (refcount == 0) and has been least recently used. The sort order defined 
+        // We will take a dataset that has no active transactions, it is open (a dataset consuming memory),
+        // that is not being used (refcount == 0) and has been least recently used. The sort order defined
         // for DatasetInfo maintains this. See DatasetInfo.compareTo().
         List<DatasetInfo> datasetInfosList = new ArrayList<DatasetInfo>(datasetInfos.values());
         Collections.sort(datasetInfosList);
@@ -572,7 +572,7 @@ public class DatasetLifecycleManager implements IDatasetLifecycleManager, ILifeC
             }
         } else {
             for (IndexInfo iInfo : dsInfo.indexes.values()) {
-                // TODO: This is not efficient since we flush the indexes sequentially. 
+                // TODO: This is not efficient since we flush the indexes sequentially.
                 // Think of a way to allow submitting the flush requests concurrently. We don't do them concurrently because this
                 // may lead to a deadlock scenario between the DatasetLifeCycleManager and the PrimaryIndexOperationTracker.
                 flushAndWaitForIO(dsInfo, iInfo);

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/dataflow/AsterixLSMInvertedIndexInsertDeleteOperatorDescriptor.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/dataflow/AsterixLSMInvertedIndexInsertDeleteOperatorDescriptor.java b/asterix-common/src/main/java/org/apache/asterix/common/dataflow/AsterixLSMInvertedIndexInsertDeleteOperatorDescriptor.java
index 06b0729..0d7d1d7 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/dataflow/AsterixLSMInvertedIndexInsertDeleteOperatorDescriptor.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/dataflow/AsterixLSMInvertedIndexInsertDeleteOperatorDescriptor.java
@@ -40,7 +40,7 @@ public class AsterixLSMInvertedIndexInsertDeleteOperatorDescriptor extends LSMIn
     private static final long serialVersionUID = 1L;
 
     private final String indexName;
-    
+
     public AsterixLSMInvertedIndexInsertDeleteOperatorDescriptor(IOperatorDescriptorRegistry spec,
             RecordDescriptor recDesc, IStorageManagerInterface storageManager, IFileSplitProvider fileSplitProvider,
             IIndexLifecycleManagerProvider lifecycleManagerProvider, ITypeTraits[] tokenTypeTraits,

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/dataflow/IAsterixApplicationContextInfo.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/dataflow/IAsterixApplicationContextInfo.java b/asterix-common/src/main/java/org/apache/asterix/common/dataflow/IAsterixApplicationContextInfo.java
index a5cd72b..9647452 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/dataflow/IAsterixApplicationContextInfo.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/dataflow/IAsterixApplicationContextInfo.java
@@ -31,21 +31,21 @@ public interface IAsterixApplicationContextInfo {
 
     /**
      * Returns an instance of the implementation for IIndexLifecycleManagerProvider.
-     * 
+     *
      * @return IIndexLifecycleManagerProvider implementation instance
      */
     public IIndexLifecycleManagerProvider getIndexLifecycleManagerProvider();
 
     /**
      * Returns an instance of the implementation for IStorageManagerInterface.
-     * 
+     *
      * @return IStorageManagerInterface implementation instance
      */
     public IStorageManagerInterface getStorageManagerInterface();
 
     /**
      * Returns an instance of the implementation for ICCApplicationContext.
-     * 
+     *
      * @return ICCApplicationContext implementation instance
      */
     public ICCApplicationContext getCCApplicationContext();

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/exceptions/TypeException.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/exceptions/TypeException.java b/asterix-common/src/main/java/org/apache/asterix/common/exceptions/TypeException.java
index 4f08322..f8795a4 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/exceptions/TypeException.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/exceptions/TypeException.java
@@ -21,7 +21,7 @@ package org.apache.asterix.common.exceptions;
 public class TypeException extends AsterixException {
 
     /**
-     * 
+     *
      */
     private static final long serialVersionUID = 6823056042083694786L;
 

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/replication/IReplicationChannel.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/replication/IReplicationChannel.java b/asterix-common/src/main/java/org/apache/asterix/common/replication/IReplicationChannel.java
index 56ae20f..e77f792 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/replication/IReplicationChannel.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/replication/IReplicationChannel.java
@@ -29,9 +29,9 @@ public interface IReplicationChannel {
 
     /**
      * Closes the replication channel.
-     * 
+     *
      * @throws IOException
      */
     public void close() throws IOException;
 
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/replication/IReplicationManager.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/replication/IReplicationManager.java b/asterix-common/src/main/java/org/apache/asterix/common/replication/IReplicationManager.java
index 276d498..76f8767 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/replication/IReplicationManager.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/replication/IReplicationManager.java
@@ -30,7 +30,7 @@ public interface IReplicationManager extends IIOReplicationManager {
 
     /**
      * Asynchronously sends a serialized version of the record to remote replicas.
-     * 
+     *
      * @param logRecord
      *            The log record to be replicated,
      */
@@ -38,7 +38,7 @@ public interface IReplicationManager extends IIOReplicationManager {
 
     /**
      * Checks whether a log record has been replicated
-     * 
+     *
      * @param logRecord
      *            the log to check for.
      * @return true, if all ACKs were received from remote replicas.
@@ -47,7 +47,7 @@ public interface IReplicationManager extends IIOReplicationManager {
 
     /**
      * Requests txns logs from a remote replica.
-     * 
+     *
      * @param remoteReplicaId
      *            The replica id to send the request to.
      * @param replicasDataToRecover
@@ -63,7 +63,7 @@ public interface IReplicationManager extends IIOReplicationManager {
 
     /**
      * Requests LSM components files from a remote replica.
-     * 
+     *
      * @param remoteReplicaId
      *            The replica id to send the request to.
      * @param replicasDataToRecover
@@ -74,7 +74,7 @@ public interface IReplicationManager extends IIOReplicationManager {
 
     /**
      * Requests current maximum LSN from remote replicas.
-     * 
+     *
      * @param remoteReplicaIds
      *            remote replicas to send the request to.
      * @return The maximum of the received maximum LSNs.
@@ -84,7 +84,7 @@ public interface IReplicationManager extends IIOReplicationManager {
 
     /**
      * Sends the IP address of the local replica to all remote replicas.
-     * 
+     *
      * @throws IOException
      */
     public void broadcastNewIPAddress() throws IOException;
@@ -111,7 +111,7 @@ public interface IReplicationManager extends IIOReplicationManager {
 
     /**
      * Updates remote replica (in-memory) information.
-     * 
+     *
      * @param replica
      *            the replica to update.
      */
@@ -124,14 +124,14 @@ public interface IReplicationManager extends IIOReplicationManager {
 
     /**
      * Submits a ReplicaEvent to ReplicationEventsMonitor thread.
-     * 
+     *
      * @param event
      */
     public void reportReplicaEvent(ReplicaEvent event);
 
     /**
      * Requests the current minimum LSN of a remote replica.
-     * 
+     *
      * @param replicaId
      *            The replica to send the request to.
      * @return The returned minimum LSN from the remote replica.
@@ -141,7 +141,7 @@ public interface IReplicationManager extends IIOReplicationManager {
 
     /**
      * Sends a request to remote replicas to flush indexes that have LSN less than nonSharpCheckpointTargetLSN
-     * 
+     *
      * @param nonSharpCheckpointTargetLSN
      * @throws IOException
      */

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/replication/IReplicationThread.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/replication/IReplicationThread.java b/asterix-common/src/main/java/org/apache/asterix/common/replication/IReplicationThread.java
index 3e2569d..9226a66 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/replication/IReplicationThread.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/replication/IReplicationThread.java
@@ -24,9 +24,9 @@ public interface IReplicationThread extends Runnable {
 
     /**
      * Sends a notification to this thread that logRecord has been flushed.
-     * 
+     *
      * @param logRecord
      *            The log that has been flushed.
      */
     public void notifyLogReplicationRequester(LogRecord logRecord);
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/transactions/DatasetId.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/transactions/DatasetId.java b/asterix-common/src/main/java/org/apache/asterix/common/transactions/DatasetId.java
index 4bcbada..81ece13 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/transactions/DatasetId.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/transactions/DatasetId.java
@@ -22,7 +22,7 @@ import java.io.Serializable;
 
 public class DatasetId implements Serializable {
     /**
-     * 
+     *
      */
     private static final long serialVersionUID = 1L;
     /**

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/transactions/ILockManager.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/transactions/ILockManager.java b/asterix-common/src/main/java/org/apache/asterix/common/transactions/ILockManager.java
index 05f76cb..7909622 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/transactions/ILockManager.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/transactions/ILockManager.java
@@ -41,7 +41,7 @@ public interface ILockManager {
      * has a "weaker" lock, then the request would be interpreted as a convert
      * request
      * Waiting transaction would eventually garb the lock, or get timed-out
-     * 
+     *
      * @param datasetId
      * @param entityHashValue
      * @param lockMode
@@ -56,7 +56,7 @@ public interface ILockManager {
      * transaction on "All" resources Upon releasing each lock on each resource,
      * potential waiters, which can be waken up based on their requested lock
      * mode and the waiting policy would be waken up
-     * 
+     *
      * @param txnContext
      * @throws ACIDException
      */
@@ -76,7 +76,7 @@ public interface ILockManager {
 
     /**
      * Call to lock and unlock a specific resource in a specific lock mode
-     * 
+     *
      * @param datasetId
      * @param entityHashValue
      * @param lockMode
@@ -112,7 +112,7 @@ public interface ILockManager {
 
     /**
      * Prints out the contents of the transactions' table in a readable fashion
-     * 
+     *
      * @return
      * @throws ACIDException
      */

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/transactions/ILogManager.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/transactions/ILogManager.java b/asterix-common/src/main/java/org/apache/asterix/common/transactions/ILogManager.java
index 82a0cca..cff4184 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/transactions/ILogManager.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/transactions/ILogManager.java
@@ -27,7 +27,7 @@ public interface ILogManager {
 
     /**
      * Submits a logRecord to log Manager which appends it to the log tail
-     * 
+     *
      * @param logRecord
      * @throws ACIDException
      */
@@ -46,7 +46,7 @@ public interface ILogManager {
 
     /**
      * Deletes all log partitions which have a maximum LSN less than checkpointLSN
-     * 
+     *
      * @param checkpointLSN
      */
     public void deleteOldLogFiles(long checkpointLSN);
@@ -63,7 +63,7 @@ public interface ILogManager {
 
     /**
      * Delete all log files and start new log partition > LSNtoStartFrom
-     * 
+     *
      * @param LSNtoStartFrom
      * @throws IOException
      */

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/transactions/IRecoveryManager.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/transactions/IRecoveryManager.java b/asterix-common/src/main/java/org/apache/asterix/common/transactions/IRecoveryManager.java
index a2b7a82..cb3f8c3 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/transactions/IRecoveryManager.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/transactions/IRecoveryManager.java
@@ -51,7 +51,7 @@ public interface IRecoveryManager {
      * The system is recovering HEALTHY: The system is in healthy state
      * CORRUPTEED: The system is in corrupted state. This happens when a
      * rollback or recovery task fails. In this state the system is unusable.
-     * 
+     *
      * @see SystemState
      * @return SystemState The state of the system
      * @throws ACIDException
@@ -60,7 +60,7 @@ public interface IRecoveryManager {
 
     /**
      * Initiates a crash recovery.
-     * 
+     *
      * @param synchronous
      *            indicates if the recovery is to be done in a synchronous
      *            manner. In asynchronous mode, the recovery will happen as part
@@ -73,7 +73,7 @@ public interface IRecoveryManager {
 
     /**
      * Rolls back a transaction.
-     * 
+     *
      * @param txnContext
      *            the transaction context associated with the transaction
      * @throws ACIDException
@@ -89,7 +89,7 @@ public interface IRecoveryManager {
      * @throws HyracksDataException
      */
     public long checkpoint(boolean isSharpCheckpoint, long nonSharpCheckpointTargetLSN) throws ACIDException, HyracksDataException;
-    
+
     /**
      * Performs recovery based on the passed logs
      * @param remoteLogs the remote logs to be replayed
@@ -99,14 +99,14 @@ public interface IRecoveryManager {
     public void replayRemoteLogs(ArrayList<ILogRecord> remoteLogs) throws HyracksDataException, ACIDException;
 
     /**
-     * 
+     *
      * @return min first LSN of the open indexes (including remote indexes if replication is enabled)
      * @throws HyracksDataException
      */
     public long getMinFirstLSN() throws HyracksDataException;
-    
+
     /**
-     * 
+     *
      * @return min first LSN of the open indexes
      * @throws HyracksDataException
      */

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/transactions/ITransactionManager.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/transactions/ITransactionManager.java b/asterix-common/src/main/java/org/apache/asterix/common/transactions/ITransactionManager.java
index 73b43cd..c81faf0 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/transactions/ITransactionManager.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/transactions/ITransactionManager.java
@@ -41,7 +41,7 @@ public interface ITransactionManager {
     /**
      * Begins a transaction identified by a transaction id and returns the
      * associated transaction context.
-     * 
+     *
      * @param jobId
      *            a unique value for the transaction id.
      * @return the transaction context associated with the initiated transaction
@@ -53,7 +53,7 @@ public interface ITransactionManager {
     /**
      * Returns the transaction context of an active transaction given the
      * transaction id.
-     * 
+     *
      * @param jobId
      *            a unique value for the transaction id.
      * @param createIfNotExist
@@ -65,7 +65,7 @@ public interface ITransactionManager {
 
     /**
      * Commits a transaction.
-     * 
+     *
      * @param txnContext
      *            the transaction context associated with the transaction
      * @param datasetId
@@ -81,7 +81,7 @@ public interface ITransactionManager {
 
     /**
      * Aborts a transaction.
-     * 
+     *
      * @param txnContext
      *            the transaction context associated with the transaction
      * @param datasetId
@@ -99,7 +99,7 @@ public interface ITransactionManager {
      * Indicates end of all activity for a transaction. In other words, all
      * participating threads in the transaction have completed the intended
      * task.
-     * 
+     *
      * @param txnContext
      *            the transaction context associated with the transaction
      * @param datasetId
@@ -118,7 +118,7 @@ public interface ITransactionManager {
      * Returns the Transaction Provider for the transaction eco-system. A
      * transaction eco-system consists of a Log Manager, a Recovery Manager, a
      * Transaction Manager and a Lock Manager.
-     * 
+     *
      * @see ITransactionSubsystem
      * @return TransactionProvider
      */

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/transactions/ITransactionSubsystem.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/transactions/ITransactionSubsystem.java b/asterix-common/src/main/java/org/apache/asterix/common/transactions/ITransactionSubsystem.java
index daa1ee9..4ce84b5 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/transactions/ITransactionSubsystem.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/transactions/ITransactionSubsystem.java
@@ -32,5 +32,5 @@ public interface ITransactionSubsystem {
     public IAsterixAppRuntimeContextProvider getAsterixAppRuntimeContextProvider();
 
     public String getId();
-    
+
 }

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/transactions/LogRecord.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/transactions/LogRecord.java b/asterix-common/src/main/java/org/apache/asterix/common/transactions/LogRecord.java
index f837df2..51eca0b 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/transactions/LogRecord.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/transactions/LogRecord.java
@@ -41,7 +41,7 @@ import org.apache.hyracks.storage.am.common.tuples.SimpleTupleWriter;
  * NodeIdLength(4)
  * NodeId(?)
  * ---------------------------
- * [Header2] (12 bytes + PKValueSize) : for entity_commit and update log types 
+ * [Header2] (12 bytes + PKValueSize) : for entity_commit and update log types
  * DatasetId(4) //stored in dataset_dataset in Metadata Node
  * PKHashValue(4)
  * PKValueSize(4)
@@ -230,7 +230,7 @@ public class LogRecord implements ILogRecord {
 
     private void writeTuple(ByteBuffer buffer, ITupleReference tuple, int size) {
         tupleWriter.writeTuple(tuple, buffer.array(), buffer.position());
-        //writeTuple() doesn't change the position of the buffer. 
+        //writeTuple() doesn't change the position of the buffer.
         buffer.position(buffer.position() + size);
     }
 
@@ -614,7 +614,7 @@ public class LogRecord implements ILogRecord {
         if (logType == LogType.FLUSH) {
             //LSN
             logSize += (Long.SIZE / 8);
-            //num of indexes 
+            //num of indexes
             logSize += (Integer.SIZE / 8);
         }
 

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-common/src/main/java/org/apache/asterix/common/utils/ANameSchema.java
----------------------------------------------------------------------
diff --git a/asterix-common/src/main/java/org/apache/asterix/common/utils/ANameSchema.java b/asterix-common/src/main/java/org/apache/asterix/common/utils/ANameSchema.java
index 2b12658..2ce3cca 100644
--- a/asterix-common/src/main/java/org/apache/asterix/common/utils/ANameSchema.java
+++ b/asterix-common/src/main/java/org/apache/asterix/common/utils/ANameSchema.java
@@ -20,7 +20,7 @@ package org.apache.asterix.common.utils;
 
 /*
  * Author: Guangqiang Li
- * Created on Nov 30, 2009 
+ * Created on Nov 30, 2009
  */
 public class ANameSchema {
     public static final int LOCALNAME_PROPERTY = 0;

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/api/IAdapterFactory.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/api/IAdapterFactory.java b/asterix-external-data/src/main/java/org/apache/asterix/external/api/IAdapterFactory.java
index bf2db9a..17916e5 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/api/IAdapterFactory.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/api/IAdapterFactory.java
@@ -34,7 +34,7 @@ public interface IAdapterFactory extends Serializable {
 
     /**
      * Returns the display name corresponding to the Adapter type that is created by the factory.
-     * 
+     *
      * @return the display name
      */
     public String getAlias();
@@ -54,7 +54,7 @@ public interface IAdapterFactory extends Serializable {
 
     /**
      * Creates an instance of IDatasourceAdapter.
-     * 
+     *
      * @param HyracksTaskContext
      * @param partition
      * @return An instance of IDatasourceAdapter.
@@ -71,7 +71,7 @@ public interface IAdapterFactory extends Serializable {
 
     /**
      * Gets the record type associated with the output of the adapter
-     * 
+     *
      * @return
      */
     public ARecordType getAdapterOutputType();

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/api/INodeResolver.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/api/INodeResolver.java b/asterix-external-data/src/main/java/org/apache/asterix/external/api/INodeResolver.java
index 831cd69..b0f1ae7 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/api/INodeResolver.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/api/INodeResolver.java
@@ -27,7 +27,7 @@ public interface INodeResolver {
 
     /**
      * Resolve a passed-in value to a node controller id.
-     * 
+     *
      * @param value
      *            string to be resolved
      * @return resolved result (a node controller id)

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/api/INodeResolverFactory.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/api/INodeResolverFactory.java b/asterix-external-data/src/main/java/org/apache/asterix/external/api/INodeResolverFactory.java
index ce49596..0eda060 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/api/INodeResolverFactory.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/api/INodeResolverFactory.java
@@ -27,7 +27,7 @@ public interface INodeResolverFactory {
 
     /**
      * Create an instance of {@link INodeResolver}
-     * 
+     *
      * @return an instance of INodeResolver
      */
     public INodeResolver createNodeResolver();

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedConnectionManager.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedConnectionManager.java b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedConnectionManager.java
index 35d4cd7..32d551a 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedConnectionManager.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedConnectionManager.java
@@ -33,7 +33,7 @@ public interface IFeedConnectionManager {
 
     /**
      * Allows registration of a feedRuntime.
-     * 
+     *
      * @param feedRuntime
      * @throws Exception
      */
@@ -41,7 +41,7 @@ public interface IFeedConnectionManager {
 
     /**
      * Obtain feed runtime corresponding to a feedRuntimeId
-     * 
+     *
      * @param feedRuntimeId
      * @return
      */
@@ -49,7 +49,7 @@ public interface IFeedConnectionManager {
 
     /**
      * De-register a feed
-     * 
+     *
      * @param feedConnection
      * @throws IOException
      */
@@ -57,7 +57,7 @@ public interface IFeedConnectionManager {
 
     /**
      * Obtain the feed runtime manager associated with a feed.
-     * 
+     *
      * @param feedConnection
      * @return
      */
@@ -65,7 +65,7 @@ public interface IFeedConnectionManager {
 
     /**
      * Allows de-registration of a feed runtime.
-     * 
+     *
      * @param feedRuntimeId
      */
     void deRegisterFeedRuntime(FeedConnectionId connectionId, FeedRuntimeId feedRuntimeId);

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedJoint.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedJoint.java b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedJoint.java
index d990e45..2a3932d 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedJoint.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedJoint.java
@@ -80,7 +80,7 @@ public interface IFeedJoint {
 
     /**
      * Returns the feed subscriber {@link FeedSubscriber} corresponding to a given feed connection id.
-     * 
+     *
      * @param feedConnectionId
      *            the unique id of a feed connection
      * @return an instance of feedConnectionId {@link FeedConnectionId}
@@ -94,7 +94,7 @@ public interface IFeedJoint {
 
     /**
      * Remove the subscriber from the set of registered subscribers to the FeedJoint
-     * 
+     *
      * @param connectionId
      *            the connectionId that needs to be removed
      */
@@ -104,14 +104,14 @@ public interface IFeedJoint {
 
     /**
      * Add a feed connectionId to the set of registered subscribers
-     * 
+     *
      * @param connectionId
      */
     public void addReceiver(FeedConnectionId connectionId);
 
     /**
      * Add a feed subscription request {@link FeedConnectionRequest} for the FeedJoint
-     * 
+     *
      * @param request
      */
     public void addConnectionRequest(FeedConnectionRequest request);

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLoadManager.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLoadManager.java b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLoadManager.java
index f511979..1b6347a 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLoadManager.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLoadManager.java
@@ -52,7 +52,7 @@ public interface IFeedLoadManager {
     void reportFeedActivity(FeedConnectionId connectionId, FeedActivity activity);
 
     void removeFeedActivity(FeedConnectionId connectionId);
-    
+
     public FeedActivity getFeedActivity(FeedConnectionId connectionId);
 
     public Collection<FeedActivity> getFeedActivities();

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryComponent.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryComponent.java b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryComponent.java
index 313dc1b..8e25b69 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryComponent.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryComponent.java
@@ -45,7 +45,7 @@ public interface IFeedMemoryComponent {
 
     /**
      * Expands this memory component by the speficied number of frames
-     * 
+     *
      * @param delta
      *            the amount (measured in number of frames) by which this memory component
      *            should be expanded

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryManager.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryManager.java b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryManager.java
index fb81373..508602c 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryManager.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryManager.java
@@ -30,7 +30,7 @@ public interface IFeedMemoryManager {
 
     /**
      * Gets a memory component allocated from the feed memory budget
-     * 
+     *
      * @param type
      *            the kind of memory component that needs to be allocated
      * @return
@@ -40,7 +40,7 @@ public interface IFeedMemoryManager {
 
     /**
      * Expand a memory component by the default increment
-     * 
+     *
      * @param memoryComponent
      * @return true if the expansion succeeded
      *         false if the requested expansion violates the configured budget
@@ -49,7 +49,7 @@ public interface IFeedMemoryManager {
 
     /**
      * Releases the given memory component to reclaim the memory allocated for the component
-     * 
+     *
      * @param memoryComponent
      *            the memory component that is being reclaimed/released
      */

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMessage.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMessage.java b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMessage.java
index aa1af3a..bc2c938 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMessage.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMessage.java
@@ -44,7 +44,7 @@ public interface IFeedMessage extends Serializable, JSONSerializable {
 
     /**
      * Gets the type associated with this message
-     * 
+     *
      * @return MessageType type associated with this message
      */
     public MessageType getMessageType();

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMessageService.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMessageService.java b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMessageService.java
index 42f71a7..a98cf2b 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMessageService.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMessageService.java
@@ -26,7 +26,7 @@ public interface IFeedMessageService extends IFeedService {
     /**
      * Sends a message ({@code IFeedMessage} to the {@code CentralFeedManager} running at the CC
      * The message is sent asynchronously.
-     * 
+     *
      * @param message
      *            the message to be sent
      */

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedWorkEventListener.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedWorkEventListener.java b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedWorkEventListener.java
index e5797d0..e94ca46 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedWorkEventListener.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedWorkEventListener.java
@@ -33,7 +33,7 @@ public interface IFeedWorkEventListener {
     /**
      * A call back that is invokved after a failed execution of a feed
      * management task.
-     * 
+     *
      * @param e
      *            exception encountered during execution of the task.
      */

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedCollectRuntimeInputHandler.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedCollectRuntimeInputHandler.java b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedCollectRuntimeInputHandler.java
index 6761d9a..4a361fb 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedCollectRuntimeInputHandler.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedCollectRuntimeInputHandler.java
@@ -56,7 +56,7 @@ public class FeedCollectRuntimeInputHandler extends FeedRuntimeInputHandler {
     public void dropTill(int recordId) {
         feedFrameCache.dropTillRecordId(recordId);
     }
-    
+
     public void replayCached() throws HyracksDataException{
         feedFrameCache.replayAll();
     }

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameCache.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameCache.java b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameCache.java
index cd040c9..0a595b7 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameCache.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameCache.java
@@ -101,7 +101,7 @@ public class FeedFrameCache extends MessageReceiver<ByteBuffer> {
 
     /**
      * Replay the frame from the tuple (inclusive) with recordId as specified.
-     * 
+     *
      * @param recordId
      * @param frame
      * @throws HyracksDataException
@@ -132,7 +132,7 @@ public class FeedFrameCache extends MessageReceiver<ByteBuffer> {
 
     /**
      * Replay the frame
-     * 
+     *
      * @param frame
      * @throws HyracksDataException
      */

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameTupleAccessor.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameTupleAccessor.java b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameTupleAccessor.java
index f08243e..d3897f3 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameTupleAccessor.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameTupleAccessor.java
@@ -44,8 +44,8 @@ public class FeedFrameTupleAccessor implements IFrameTupleAccessor {
                 + StatisticsConstants.INTAKE_PARTITION.length() + 2 + 1;
         return buffer.getInt(recordStart + partitionOffset);
     }
-    
-    
+
+
 
     @Override
     public int getFieldCount() {

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionRequest.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionRequest.java b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionRequest.java
index 5f22a72..0175dcb 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionRequest.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionRequest.java
@@ -66,7 +66,7 @@ public class FeedConnectionRequest {
 
     private final FeedId receivingFeedId;
 
-    
+
     public FeedConnectionRequest(FeedJointKey feedPointKey, ConnectionLocation connectionLocation,
             List<String> functionsToApply, String targetDataset, String policy, Map<String, String> policyParameters,
             FeedId receivingFeedId) {

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/SeriesAvg.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/SeriesAvg.java b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/SeriesAvg.java
index f75379d..6182753 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/SeriesAvg.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/SeriesAvg.java
@@ -39,7 +39,7 @@ public class SeriesAvg extends Series {
         runningSum += value;
         count++;
     }
-    
+
     public  void reset(){
         count = 0;
     }

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/ExternalFileIndexAccessor.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/ExternalFileIndexAccessor.java b/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/ExternalFileIndexAccessor.java
index d94db08..5d98961 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/ExternalFileIndexAccessor.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/indexing/ExternalFileIndexAccessor.java
@@ -48,7 +48,7 @@ import org.apache.hyracks.storage.am.lsm.btree.impls.ExternalBTree;
 import org.apache.hyracks.storage.am.lsm.common.api.ILSMIndexAccessorInternal;
 
 /*
- * This class was created specifically to facilitate accessing 
+ * This class was created specifically to facilitate accessing
  * external file index when doing external lookup during runtime
  */
 @SuppressWarnings({ "rawtypes", "unchecked" })

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/HDFSTextLineReader.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/HDFSTextLineReader.java b/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/HDFSTextLineReader.java
index 9466a96..ea851a5 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/HDFSTextLineReader.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/HDFSTextLineReader.java
@@ -45,7 +45,7 @@ public class HDFSTextLineReader {
     /**
      * Create a line reader that reads from the given stream using the
      * default buffer-size (32k).
-     * 
+     *
      * @param in
      *            The input stream
      * @throws IOException
@@ -57,7 +57,7 @@ public class HDFSTextLineReader {
     /**
      * Create a line reader that reads from the given stream using the
      * given buffer-size.
-     * 
+     *
      * @param in
      *            The input stream
      * @param bufferSize
@@ -78,7 +78,7 @@ public class HDFSTextLineReader {
 
     /**
      * Create a line reader that reads from the given stream using the <code>io.file.buffer.size</code> specified in the given <code>Configuration</code>.
-     * 
+     *
      * @param in
      *            input stream
      * @param conf
@@ -176,7 +176,7 @@ public class HDFSTextLineReader {
 
     /**
      * Read from the InputStream into the given Text.
-     * 
+     *
      * @param str
      *            the object to store the given line
      * @param maxLineLength
@@ -191,7 +191,7 @@ public class HDFSTextLineReader {
 
     /**
      * Read from the InputStream into the given Text.
-     * 
+     *
      * @param str
      *            the object to store the given line
      * @return the number of bytes read including the newline

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/operators/AbstractExternalDatasetIndexesOperatorDescriptor.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/operators/AbstractExternalDatasetIndexesOperatorDescriptor.java b/asterix-external-data/src/main/java/org/apache/asterix/external/operators/AbstractExternalDatasetIndexesOperatorDescriptor.java
index 371c603..9b37722 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/operators/AbstractExternalDatasetIndexesOperatorDescriptor.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/operators/AbstractExternalDatasetIndexesOperatorDescriptor.java
@@ -35,7 +35,7 @@ import org.apache.hyracks.storage.am.lsm.btree.dataflow.ExternalBTreeWithBuddyDa
 import org.apache.hyracks.storage.am.lsm.rtree.dataflow.ExternalRTreeDataflowHelperFactory;
 
 // This is an operator that takes a single file index and an array of secondary indexes
-// it is intended to be used for 
+// it is intended to be used for
 // 1. commit transaction operation
 // 2. abort transaction operation
 // 3. recover transaction operation

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalLookupOperatorDescriptor.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalLookupOperatorDescriptor.java b/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalLookupOperatorDescriptor.java
index c8881a3..9e35617 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalLookupOperatorDescriptor.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalLookupOperatorDescriptor.java
@@ -66,7 +66,7 @@ public class ExternalLookupOperatorDescriptor extends AbstractTreeIndexOperatorD
             final IRecordDescriptorProvider recordDescProvider, final int partition, int nPartitions)
                     throws HyracksDataException {
         // Create a file index accessor to be used for files lookup operations
-        // Note that all file index accessors will use partition 0 since we only have 1 files index per NC 
+        // Note that all file index accessors will use partition 0 since we only have 1 files index per NC
         final ExternalFileIndexAccessor snapshotAccessor = new ExternalFileIndexAccessor(
                 (ExternalBTreeDataflowHelper) dataflowHelperFactory.createIndexDataflowHelper(this, ctx, partition),
                 this);

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-external-data/src/main/java/org/apache/asterix/external/operators/IndexInfoOperatorDescriptor.java
----------------------------------------------------------------------
diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/operators/IndexInfoOperatorDescriptor.java b/asterix-external-data/src/main/java/org/apache/asterix/external/operators/IndexInfoOperatorDescriptor.java
index 99c555a..2bc6043 100644
--- a/asterix-external-data/src/main/java/org/apache/asterix/external/operators/IndexInfoOperatorDescriptor.java
+++ b/asterix-external-data/src/main/java/org/apache/asterix/external/operators/IndexInfoOperatorDescriptor.java
@@ -49,7 +49,7 @@ public class IndexInfoOperatorDescriptor implements IIndexOperatorDescriptor{
         this.fileSplitProvider = fileSplitProvider;
         this.lifecycleManagerProvider = lifecycleManagerProvider;
         this.storageManager = storageManager;
-        
+
     }
 
     @Override

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/FuzzyJoinConfig.java
----------------------------------------------------------------------
diff --git a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/FuzzyJoinConfig.java b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/FuzzyJoinConfig.java
index eca4563..8b1ab07 100644
--- a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/FuzzyJoinConfig.java
+++ b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/FuzzyJoinConfig.java
@@ -42,7 +42,7 @@ public class FuzzyJoinConfig {
     public static final String RECORD_DATA1_VALUE = "1";
     //
     // data
-    //    
+    //
     public static final String DATA_TOKENS_PROPERTY = NAMESPACE + ".data.tokens";
     //
     // const

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/FuzzyJoinUtil.java
----------------------------------------------------------------------
diff --git a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/FuzzyJoinUtil.java b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/FuzzyJoinUtil.java
index 41e7ca1..b540d16 100644
--- a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/FuzzyJoinUtil.java
+++ b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/FuzzyJoinUtil.java
@@ -28,11 +28,11 @@ public class FuzzyJoinUtil {
     public static String clean(String in) {
         /*
          * - remove punctuation
-         * 
+         *
          * - normalize case
-         * 
+         *
          * - remove extra spaces
-         * 
+         *
          * - repalce space with FuzzyJoinDriver.TOKEN_SEPARATOR
          */
 

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/similarity/SimilarityFiltersJaccard.java
----------------------------------------------------------------------
diff --git a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/similarity/SimilarityFiltersJaccard.java b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/similarity/SimilarityFiltersJaccard.java
index d8d9d7e..f16fed9 100644
--- a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/similarity/SimilarityFiltersJaccard.java
+++ b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/similarity/SimilarityFiltersJaccard.java
@@ -42,7 +42,7 @@ public class SimilarityFiltersJaccard implements SimilarityFilters {
     }
 
     /**
-     * 
+     *
      */
     private static final long serialVersionUID = 1L;
 

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenizer/NGramTokenizer.java
----------------------------------------------------------------------
diff --git a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenizer/NGramTokenizer.java b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenizer/NGramTokenizer.java
index e612364..5594e43 100644
--- a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenizer/NGramTokenizer.java
+++ b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenizer/NGramTokenizer.java
@@ -26,7 +26,7 @@ import java.util.List;
 public class NGramTokenizer implements Tokenizer {
 
     /**
-     * 
+     *
      */
     private static final long serialVersionUID = 1L;
 

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenizer/Token.java
----------------------------------------------------------------------
diff --git a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenizer/Token.java b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenizer/Token.java
index ecdeff1..720d269 100644
--- a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenizer/Token.java
+++ b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenizer/Token.java
@@ -23,7 +23,7 @@ import java.io.Serializable;
 
 public class Token implements Serializable {
     /**
-     * 
+     *
      */
     private static final long serialVersionUID = 1L;
 

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenizer/WordTokenizer.java
----------------------------------------------------------------------
diff --git a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenizer/WordTokenizer.java b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenizer/WordTokenizer.java
index 3470ac2..fa0bfe7 100644
--- a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenizer/WordTokenizer.java
+++ b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenizer/WordTokenizer.java
@@ -26,7 +26,7 @@ import java.util.List;
 public class WordTokenizer implements Tokenizer {
 
     /**
-     * 
+     *
      */
     private static final long serialVersionUID = 1L;
 

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/IntTokenCountRankFrequency.java
----------------------------------------------------------------------
diff --git a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/IntTokenCountRankFrequency.java b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/IntTokenCountRankFrequency.java
index ea6e21d..d54c7d6 100644
--- a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/IntTokenCountRankFrequency.java
+++ b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/IntTokenCountRankFrequency.java
@@ -25,7 +25,7 @@ import org.apache.asterix.fuzzyjoin.IntPair;
 
 public class IntTokenCountRankFrequency implements IntTokenCountRank {
     /**
-     * 
+     *
      */
     private static final long serialVersionUID = 1L;
 

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/IntTokenRankFrequency.java
----------------------------------------------------------------------
diff --git a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/IntTokenRankFrequency.java b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/IntTokenRankFrequency.java
index ba9bf86..08d1c93 100644
--- a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/IntTokenRankFrequency.java
+++ b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/IntTokenRankFrequency.java
@@ -23,7 +23,7 @@ import java.util.HashMap;
 
 public class IntTokenRankFrequency implements IntTokenRank {
     /**
-     * 
+     *
      */
     private static final long serialVersionUID = 1L;
 

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/TokenRankBufferedFrequency.java
----------------------------------------------------------------------
diff --git a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/TokenRankBufferedFrequency.java b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/TokenRankBufferedFrequency.java
index 428f576..57fc325 100644
--- a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/TokenRankBufferedFrequency.java
+++ b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/TokenRankBufferedFrequency.java
@@ -26,7 +26,7 @@ import org.apache.asterix.fuzzyjoin.tokenizer.Token;
 
 public class TokenRankBufferedFrequency implements TokenRank {
     /**
-     * 
+     *
      */
     private static final long serialVersionUID = 1L;
 

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/e2439b44/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/TokenRankFrequency.java
----------------------------------------------------------------------
diff --git a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/TokenRankFrequency.java b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/TokenRankFrequency.java
index 2903336..97b9503 100644
--- a/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/TokenRankFrequency.java
+++ b/asterix-fuzzyjoin/src/main/java/org/apache/asterix/fuzzyjoin/tokenorder/TokenRankFrequency.java
@@ -25,7 +25,7 @@ import java.util.TreeSet;
 
 public class TokenRankFrequency implements TokenRank {
     /**
-     * 
+     *
      */
     private static final long serialVersionUID = 1L;
 



Mime
View raw message