You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by ti...@apache.org on 2016/01/29 23:46:15 UTC
[4/4] incubator-asterixdb git commit: remove end-of-line whitespace
remove end-of-line whitespace
Change-Id: I5c0415f47d4c3a9827574fbdab949b45718d9ea4
Reviewed-on: https://asterix-gerrit.ics.uci.edu/601
Tested-by: Jenkins <je...@fulliautomatix.ics.uci.edu>
Reviewed-by: Yingyi Bu <bu...@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 <ti...@apache.org>
Authored: Thu Jan 28 17:06:21 2016 -0800
Committer: Till Westmann <ti...@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;