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/02/10 02:06:56 UTC
[5/5] incubator-asterixdb-hyracks git commit: remove end-of-line
whitespace
remove end-of-line whitespace
Change-Id: If3542874d7f3a536a6fe524aba2fffaf6447a614
Reviewed-on: https://asterix-gerrit.ics.uci.edu/600
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-hyracks/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/commit/6464d723
Tree: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/tree/6464d723
Diff: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/diff/6464d723
Branch: refs/heads/master
Commit: 6464d723fdda15826f0cd7a5d27e48798e16f8d6
Parents: d960fd3
Author: Till Westmann <ti...@apache.org>
Authored: Tue Feb 9 16:03:14 2016 -0800
Committer: Till Westmann <ti...@apache.org>
Committed: Tue Feb 9 17:02:02 2016 -0800
----------------------------------------------------------------------
.../api/AbstractCompilerFactoryBuilder.java | 2 +-
.../PrioritizedRuleController.java | 8 +--
.../SequentialFixpointRuleController.java | 2 +-
.../core/algebra/base/ILogicalOperator.java | 6 +--
.../core/algebra/base/LogicalVariable.java | 4 +-
.../AggregateFunctionCallExpression.java | 8 +--
.../algebra/metadata/IMetadataProvider.java | 6 +--
.../operators/logical/AssignOperator.java | 6 +--
.../operators/logical/ExtensionOperator.java | 2 +-
.../operators/logical/IOperatorExtension.java | 4 +-
.../logical/PartitioningSplitOperator.java | 6 +--
.../physical/InMemoryHashJoinPOperator.java | 4 +-
.../properties/ILocalStructuralProperty.java | 4 +-
.../properties/IPhysicalPropertiesVector.java | 2 +-
.../algebra/properties/LocalOrderProperty.java | 2 +-
.../core/algebra/properties/PropertiesUtil.java | 2 +-
.../properties/StructuralPropertiesVector.java | 4 +-
.../properties/VariablePropagationPolicy.java | 6 +--
.../algebra/util/OperatorPropertiesUtil.java | 6 +--
.../base/PhysicalOptimizationConfig.java | 14 +++---
.../data/IResultSerializerFactoryProvider.java | 2 +-
.../examples/piglet/ast/LoadNode.java | 4 +-
.../algebricks/examples/piglet/types/Type.java | 4 +-
.../rules/ComplexUnnestToProductRule.java | 2 +-
.../rewriter/rules/ConsolidateSelectsRule.java | 16 +++---
.../rules/EliminateGroupByEmptyKeyRule.java | 2 +-
.../rules/EnforceOrderByAfterSubplan.java | 2 +-
.../rules/ExtractCommonExpressionsRule.java | 4 +-
.../ExtractFunctionsFromJoinConditionRule.java | 6 +--
.../InlineSingleReferenceVariablesRule.java | 14 +++---
.../rewriter/rules/IntroduceProjectsRule.java | 4 +-
.../rewriter/rules/PushFunctionsBelowJoin.java | 10 ++--
.../rules/RemoveRedundantGroupByDecorVars.java | 4 +-
.../rules/RemoveRedundantProjectionRule.java | 6 +--
.../rules/RemoveRedundantVariablesRule.java | 4 +-
.../RemoveUnusedAssignAndAggregateRule.java | 2 +-
.../rewriter/rules/SetExecutionModeRule.java | 2 +-
...inateSubplanWithInputCardinalityOneRule.java | 8 +--
...oveFreeVariableOperatorOutOfSubplanRule.java | 8 +--
.../subplan/PushSubplanIntoGroupByRule.java | 6 +--
.../ICopySerializableAggregateFunction.java | 8 +--
.../operators/std/AssignRuntimeFactory.java | 4 +-
.../api/application/IApplicationContext.java | 6 +--
.../api/application/ICCApplicationContext.java | 12 ++---
.../api/application/INCApplicationContext.java | 18 +++----
.../hyracks/api/client/HyracksConnection.java | 6 +--
.../api/client/IHyracksClientConnection.java | 30 +++++------
.../api/dataflow/IConnectorDescriptor.java | 14 +++---
.../hyracks/api/dataflow/IDataReader.java | 8 +--
.../hyracks/api/dataflow/IDataWriter.java | 2 +-
.../api/dataflow/IOperatorDescriptor.java | 16 +++---
.../api/dataflow/value/IPredicateEvaluator.java | 2 +-
.../value/IPredicateEvaluatorFactory.java | 2 +-
.../IPredicateEvaluatorFactoryProvider.java | 2 +-
.../api/dataflow/value/IResultSerializer.java | 4 +-
.../value/IResultSerializerFactory.java | 4 +-
.../dataflow/value/ISerializerDeserializer.java | 6 +--
.../api/dataflow/value/JSONSerializable.java | 4 +-
...yracksDatasetDirectoryServiceConnection.java | 4 +-
...HyracksDatasetDirectoryServiceInterface.java | 4 +-
.../hyracks/api/deployment/DeploymentId.java | 2 +-
.../api/job/IJobSerializerDeserializer.java | 8 +--
.../IJobSerializerDeserializerContainer.java | 6 +--
.../api/job/profiling/counters/ICounter.java | 10 ++--
.../job/profiling/counters/ICounterContext.java | 6 +--
.../rewriter/ActivityClusterGraphRewriter.java | 12 ++---
.../OneToOneConnectedActivityCluster.java | 14 +++---
.../api/rewriter/runtime/SuperActivity.java | 2 +-
.../client/stats/IClusterCounterContext.java | 2 +-
.../client/stats/impl/ClientCounterContext.java | 6 +--
.../control/cc/scheduler/JobScheduler.java | 8 +--
.../control/cc/work/CliDeployBinaryWork.java | 2 +-
.../control/cc/work/CliUnDeployBinaryWork.java | 2 +-
.../control/cc/work/NotifyDeployBinaryWork.java | 2 +-
.../ClassLoaderJobSerializerDeserializer.java | 2 +-
.../common/deployment/DeploymentRun.java | 4 +-
.../common/deployment/DeploymentUtils.java | 14 +++---
.../IDeploymentStatusConditionVariable.java | 4 +-
.../control/common/shutdown/ShutdownRun.java | 2 +-
.../nc/io/profiling/IOCounterFactory.java | 2 +-
.../control/nc/work/DeployBinaryWork.java | 2 +-
.../hyracks/control/nc/work/StartTasksWork.java | 2 +-
.../control/nc/work/UnDeployBinaryWork.java | 2 +-
.../std/algorithms/BinarySearchAlgorithm.java | 8 +--
.../hyracks/data/std/api/IPointableFactory.java | 4 +-
.../collections/api/IValueReferenceVector.java | 12 ++---
.../data/std/util/ArrayBackedValueStorage.java | 4 +-
.../common/comm/io/ArrayTupleBuilder.java | 16 +++---
.../common/comm/io/ArrayTupleReference.java | 6 +--
.../FieldRangePartitionComputerFactory.java | 4 +-
.../dataflow/common/util/TupleUtils.java | 2 +-
.../base/AbstractMToNConnectorDescriptor.java | 4 +-
.../std/connectors/HashtableLocalityMap.java | 4 +-
...wareMToNPartitioningConnectorDescriptor.java | 4 +-
.../LocalityAwarePartitionDataWriter.java | 8 +--
.../file/PlainFileWriterOperatorDescriptor.java | 2 +-
.../std/group/IAggregatorDescriptor.java | 12 ++---
.../std/group/IFieldAggregateDescriptor.java | 14 +++---
.../AvgFieldGroupAggregatorFactory.java | 2 +-
.../AvgFieldMergeAggregatorFactory.java | 2 +-
.../CountFieldAggregatorFactory.java | 2 +-
.../FloatSumFieldAggregatorFactory.java | 26 +++++-----
.../IntSumFieldAggregatorFactory.java | 2 +-
.../MinMaxStringFieldAggregatorFactory.java | 2 +-
.../MultiFieldsAggregatorFactory.java | 2 +-
.../ExternalGroupOperatorDescriptor.java | 2 +-
.../group/hash/HashGroupOperatorDescriptor.java | 4 +-
.../join/GraceHashJoinOperatorDescriptor.java | 4 +-
.../btree/client/InsertPipelineExample.java | 4 +-
...rTuplesSecondaryIndexSearchOperatorTest.java | 4 +-
.../integration/LocalityAwareConnectorTest.java | 4 +-
.../shutdown/test/ClusterShutdownIT.java | 4 +-
.../examples/text/client/WordCountMain.java | 4 +-
.../hyracks/hdfs/api/IKeyValueParser.java | 6 +--
.../hdfs/api/IKeyValueParserFactory.java | 4 +-
.../hyracks/hdfs/api/INcCollectionBuilder.java | 2 +-
.../apache/hyracks/hdfs/api/ITupleWriter.java | 6 +--
.../dataflow/HDFSReadOperatorDescriptor.java | 2 +-
.../dataflow/HDFSWriteOperatorDescriptor.java | 2 +-
.../hdfs/dataflow/InputSplitsFactory.java | 4 +-
.../hyracks/hdfs/scheduler/Scheduler.java | 20 ++++----
.../hdfs2/dataflow/FileSplitsFactory.java | 4 +-
.../dataflow/HDFSReadOperatorDescriptor.java | 2 +-
.../dataflow/HDFSWriteOperatorDescriptor.java | 2 +-
.../hyracks/hdfs2/scheduler/Scheduler.java | 10 ++--
.../hyracks/hdfs/dataflow/DataflowTest.java | 6 +--
.../hyracks/hdfs/scheduler/SchedulerTest.java | 10 ++--
.../hyracks/hdfs2/dataflow/DataflowTest.java | 6 +--
.../hyracks/hdfs2/scheduler/SchedulerTest.java | 8 +--
.../org/apache/hyracks/ipc/api/IIPCHandle.java | 4 +-
.../org/apache/hyracks/ipc/impl/IPCSystem.java | 4 +-
.../hyracks/net/buffers/IBufferAcceptor.java | 6 +--
.../net/buffers/ICloseableBufferAcceptor.java | 6 +--
.../protocols/muxdemux/ChannelControlBlock.java | 8 +--
.../muxdemux/IChannelOpenListener.java | 6 +--
.../muxdemux/IChannelReadInterface.java | 10 ++--
.../muxdemux/IChannelWriteInterface.java | 10 ++--
.../muxdemux/MultiplexedConnection.java | 6 +--
.../net/protocols/muxdemux/MuxDemux.java | 14 +++---
.../am/bloomfilter/impls/BloomCalculations.java | 4 +-
.../hyracks/storage/am/btree/impls/BTree.java | 6 +--
.../am/btree/impls/BTreeCursorInitialState.java | 2 +-
.../hyracks/storage/am/common/api/IIndex.java | 14 +++---
.../storage/am/common/api/IIndexAccessor.java | 16 +++---
.../storage/am/common/api/IIndexBulkLoader.java | 4 +-
.../am/common/api/IMetaDataPageManager.java | 2 +-
.../api/IModificationOperationCallback.java | 1 +
.../am/common/api/ITreeIndexAccessor.java | 6 +--
.../am/common/api/ITreeIndexMetaDataFrame.java | 2 +-
.../am/common/api/ITreeIndexTupleReference.java | 2 +-
.../storage/am/common/api/ITupleUpdater.java | 2 +-
.../am/common/api/ITwoPCIndexBulkLoader.java | 6 +--
.../storage/am/common/api/IndexException.java | 2 +-
.../am/common/api/TreeIndexException.java | 2 +-
.../am/common/api/UnsortedInputException.java | 6 +--
.../dataflow/ITreeIndexOperatorDescriptor.java | 6 +--
.../am/common/dataflow/IndexDataflowHelper.java | 6 +--
.../datagen/PersonNameFieldValueGenerator.java | 6 +--
.../SortedDoubleFieldValueGenerator.java | 8 +--
.../datagen/SortedFloatFieldValueGenerator.java | 6 +--
.../SortedIntegerFieldValueGenerator.java | 4 +-
.../datagen/StringFieldValueGenerator.java | 4 +-
.../storage/am/common/datagen/TupleBatch.java | 10 ++--
.../am/common/datagen/TupleGenerator.java | 14 +++---
.../am/common/frames/AbstractSlotManager.java | 6 +--
.../am/common/impls/AbstractTreeIndex.java | 4 +-
.../am/common/ophelpers/LongArrayList.java | 2 +-
.../am/common/ophelpers/SlotOffTupleOff.java | 4 +-
.../tuples/ConcatenatingTupleReference.java | 22 ++++-----
.../common/tuples/PermutingTupleReference.java | 4 +-
.../storage/am/common/util/HashMultiSet.java | 20 ++++----
.../storage/am/common/util/TreeIndexUtils.java | 4 +-
.../am/lsm/btree/impls/ExternalBTree.java | 2 +-
.../impls/LSMBTreeWithBuddySearchCursor.java | 12 ++---
.../btree/tuples/LSMBTreeCopyTupleWriter.java | 2 +-
.../tuples/LSMBTreeCopyTupleWriterFactory.java | 2 +-
.../btree/tuples/LSMBTreeTupleReference.java | 10 ++--
.../tuples/LSMBTreeTupleWriterFactory.java | 2 +-
.../am/lsm/common/api/ILSMComponent.java | 2 +-
.../common/api/ILSMComponentFilterFrame.java | 2 +-
.../lsm/common/api/ILSMIOOperationCallback.java | 4 +-
.../am/lsm/common/api/ILSMIndexAccessor.java | 10 ++--
.../common/api/ILSMIndexAccessorInternal.java | 4 +-
.../am/lsm/common/api/ILSMIndexFileManager.java | 6 +--
.../am/lsm/common/api/ILSMIndexInternal.java | 4 +-
.../lsm/common/api/ILSMMergePolicyFactory.java | 4 +-
.../am/lsm/common/api/ILSMOperationTracker.java | 2 +-
.../storage/am/lsm/common/api/ITwoPCIndex.java | 16 +++---
.../lsm/common/impls/AsynchronousScheduler.java | 4 +-
.../impls/LSMComponentFileReferences.java | 2 +-
.../lsm/common/impls/LSMTreeIndexAccessor.java | 4 +-
.../impls/MultitenantVirtualBufferCache.java | 8 +--
.../impls/NoOpOperationTrackerProvider.java | 2 +-
.../am/lsm/common/impls/PrefixMergePolicy.java | 2 +-
.../am/lsm/common/impls/VirtualBufferCache.java | 2 +-
.../lsm/invertedindex/api/IInvertedIndex.java | 14 +++---
.../api/IInvertedIndexOperatorDescriptor.java | 10 ++--
.../api/IInvertedIndexSearcher.java | 2 +-
.../invertedindex/api/IInvertedListCursor.java | 2 +-
.../exceptions/InvertedIndexException.java | 4 +-
.../invertedindex/impls/LSMInvertedIndex.java | 2 +-
.../InMemoryInvertedIndexOpContext.java | 2 +-
.../ondisk/OnDiskInvertedIndex.java | 4 +-
.../OnDiskInvertedIndexRangeSearchCursor.java | 4 +-
.../ondisk/OnDiskInvertedIndexSearchCursor.java | 6 +--
.../PartitionedOnDiskInvertedIndexFactory.java | 2 +-
.../ConjunctiveEditDistanceSearchModifier.java | 4 +-
...nctiveEditDistanceSearchModifierFactory.java | 4 +-
...njunctiveListEditDistanceSearchModifier.java | 2 +-
.../search/ConjunctiveSearchModifier.java | 2 +-
.../EditDistanceSearchModifierFactory.java | 4 +-
.../search/ListEditDistanceSearchModifier.java | 2 +-
.../search/PartitionedTOccurrenceSearcher.java | 4 +-
.../lsm/invertedindex/search/SearchResult.java | 8 +--
.../am/lsm/rtree/impls/ExternalRTree.java | 2 +-
.../rtree/impls/LSMRTreeCursorInitialState.java | 4 +-
.../lsm/rtree/impls/LSMRTreeSortedCursor.java | 4 +-
.../tuples/LSMTypeAwareTupleWriterFactory.java | 2 +-
.../hyracks/storage/am/rtree/impls/RTree.java | 2 +-
.../am/rtree/impls/RTreeSearchCursor.java | 4 +-
.../linearize/HilbertDoubleComparator.java | 8 +--
.../HilbertDoubleComparatorFactory.java | 6 +--
.../ZCurveDoubleComparatorFactory.java | 6 +--
.../linearize/ZCurveIntComparatorFactory.java | 6 +--
.../RTreeTypeAwareTupleWriterFactory.java | 2 +-
.../common/buffercache/DebugBufferCache.java | 8 +--
.../common/buffercache/FIFOLocalWriter.java | 2 +-
.../common/buffercache/IBufferCache.java | 2 +-
.../buffercache/ICacheMemoryAllocator.java | 4 +-
.../common/buffercache/IPageCleanerPolicy.java | 10 ++--
.../storage/common/file/IFileMapManager.java | 12 ++---
.../storage/common/file/IFileMapProvider.java | 12 ++---
.../TransientLocalResourceFactoryProvider.java | 2 +-
.../hyracks/storage/am/common/CheckTuple.java | 16 +++---
.../storage/am/common/IIndexTestContext.java | 2 +-
.../am/common/ITreeIndexTestContext.java | 2 +-
.../am/common/TestOperationSelector.java | 12 ++---
.../storage/am/common/TestWorkloadConf.java | 4 +-
.../storage/am/btree/BTreeInsertTest.java | 8 +--
.../storage/am/btree/BTreeUpsertTest.java | 8 +--
.../btree/multithread/BTreeMultiThreadTest.java | 2 +-
.../am/btree/multithread/BTreeTestWorker.java | 2 +-
.../am/lsm/btree/perf/BTreePageSizePerf.java | 12 ++---
.../am/lsm/btree/perf/IExperimentRunner.java | 8 +--
.../am/lsm/btree/perf/PerfExperiment.java | 2 +-
.../am/lsm/btree/tuples/LSMBTreeTuplesTest.java | 52 ++++++++++----------
.../InMemoryInvertedIndexDeleteTest.java | 2 +-
.../InMemoryInvertedIndexInsertTest.java | 2 +-
...titionedInMemoryInvertedIndexDeleteTest.java | 2 +-
.../ondisk/FixedSizeFrameTupleTest.java | 2 +-
.../util/LSMInvertedIndexTestContext.java | 2 +-
.../util/LSMInvertedIndexTestUtils.java | 2 +-
.../storage/am/rtree/RTreeDeleteTest.java | 2 +-
.../storage/am/rtree/RTreeInsertTest.java | 2 +-
.../hyracks/storage/common/BufferCacheTest.java | 6 +--
.../yarn/am/manifest/ClusterController.java | 4 +-
256 files changed, 736 insertions(+), 735 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/api/AbstractCompilerFactoryBuilder.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/api/AbstractCompilerFactoryBuilder.java b/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/api/AbstractCompilerFactoryBuilder.java
index 616dfa9..d5fe6ed 100644
--- a/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/api/AbstractCompilerFactoryBuilder.java
+++ b/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/api/AbstractCompilerFactoryBuilder.java
@@ -116,7 +116,7 @@ public abstract class AbstractCompilerFactoryBuilder {
public IBinaryComparatorFactoryProvider getComparatorFactoryProvider() {
return comparatorFactoryProvider;
}
-
+
public void setPredicateEvaluatorFactoryProvider(IPredicateEvaluatorFactoryProvider predEvaluatorFactoryProvider) {
this.predEvaluatorFactoryProvider = predEvaluatorFactoryProvider;
}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/PrioritizedRuleController.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/PrioritizedRuleController.java b/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/PrioritizedRuleController.java
index 2f5acda..5a1b461 100644
--- a/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/PrioritizedRuleController.java
+++ b/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/PrioritizedRuleController.java
@@ -28,13 +28,13 @@ import org.apache.hyracks.algebricks.core.rewriter.base.AbstractRuleController;
import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
/**
- *
+ *
* Runs each rule until it produces no changes. Then the whole collection of
* rules is run again until no change is made.
- *
- *
+ *
+ *
* @author Nicola
- *
+ *
*/
public class PrioritizedRuleController extends AbstractRuleController {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/SequentialFixpointRuleController.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/SequentialFixpointRuleController.java b/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/SequentialFixpointRuleController.java
index b6d6d61..61b75c9 100644
--- a/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/SequentialFixpointRuleController.java
+++ b/algebricks/algebricks-compiler/src/main/java/org/apache/hyracks/algebricks/compiler/rewriter/rulecontrollers/SequentialFixpointRuleController.java
@@ -30,7 +30,7 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
/**
* Runs rules sequentially (round-robin), until one iteration over all rules
* produces no change.
- *
+ *
* @author Nicola
*/
public class SequentialFixpointRuleController extends AbstractRuleController {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalOperator.java
index 90c0de2..9d68fae 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalOperator.java
@@ -50,7 +50,7 @@ public interface ILogicalOperator {
public List<LogicalVariable> getSchema();
/*
- *
+ *
* support for visitors
*/
@@ -73,7 +73,7 @@ public interface ILogicalOperator {
/**
* Get the variable propogation policy from this operator's input to its
* output.
- *
+ *
* @return The VariablePropogationPolicy.
*/
public VariablePropagationPolicy getVariablePropagationPolicy();
@@ -103,4 +103,4 @@ public interface ILogicalOperator {
* Indicates whether the expressions used by this operator must be variable reference expressions.
*/
public boolean requiresVariableReferenceExpressions();
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalVariable.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalVariable.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalVariable.java
index 465d1a2..fc30ce2 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalVariable.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalVariable.java
@@ -20,7 +20,7 @@ package org.apache.hyracks.algebricks.core.algebra.base;
/**
* Represents a logical variable in an asterix logical plan.
- *
+ *
* @author Vinayak R. Borkar [vborkar@ics.uci.edu]
*/
public final class LogicalVariable {
@@ -52,4 +52,4 @@ public final class LogicalVariable {
public int hashCode() {
return id;
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/AggregateFunctionCallExpression.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/AggregateFunctionCallExpression.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/AggregateFunctionCallExpression.java
index 11207e0..67f285d 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/AggregateFunctionCallExpression.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/AggregateFunctionCallExpression.java
@@ -28,17 +28,17 @@ import org.apache.hyracks.algebricks.core.algebra.functions.IFunctionInfo;
import org.apache.hyracks.algebricks.core.algebra.visitors.ILogicalExpressionVisitor;
/**
- *
+ *
* An aggregate function may be executed in a "two step" mode. First the
* "step-one" aggregates are run and then the results are passed to the
* "step-two" aggregators. The convention is the following:
- *
+ *
* 1. The step-one aggregate must be able to accept the same arguments as the
* original aggregate function call.
- *
+ *
* 2. The step-two aggregate must be a unary function that accepts as input the
* output of the step-one aggregate.
- *
+ *
*/
public class AggregateFunctionCallExpression extends AbstractFunctionCallExpression {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/metadata/IMetadataProvider.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/metadata/IMetadataProvider.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/metadata/IMetadataProvider.java
index 823ebae..1ad7fe6 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/metadata/IMetadataProvider.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/metadata/IMetadataProvider.java
@@ -78,7 +78,7 @@ public interface IMetadataProvider<S, I> {
/**
* Creates the insert runtime of IndexInsertDeletePOperator, which models
* insert/delete operations into a secondary index.
- *
+ *
* @param dataSource
* Target secondary index.
* @param propagatedSchema
@@ -117,7 +117,7 @@ public interface IMetadataProvider<S, I> {
/**
* Creates the delete runtime of IndexInsertDeletePOperator, which models
* insert/delete operations into a secondary index.
- *
+ *
* @param dataSource
* Target secondary index.
* @param propagatedSchema
@@ -157,7 +157,7 @@ public interface IMetadataProvider<S, I> {
* Creates the TokenizeOperator for IndexInsertDeletePOperator, which tokenizes
* secondary key into [token, number of token] pair in a length-partitioned index.
* In case of non length-partitioned index, it tokenizes secondary key into [token].
- *
+ *
* @param dataSource
* Target secondary index.
* @param propagatedSchema
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AssignOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AssignOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AssignOperator.java
index c5fac83..aebbba8 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AssignOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AssignOperator.java
@@ -36,12 +36,12 @@ import org.apache.hyracks.algebricks.core.algebra.visitors.ILogicalOperatorVisit
/**
* It corresponds to the Map operator in other algebras.
- *
+ *
* @author Nicola
*/
public class AssignOperator extends AbstractAssignOperator {
-
+
private LocalOrderProperty explicitOrderingProperty;
public AssignOperator(List<LogicalVariable> vars, List<Mutable<ILogicalExpression>> exprs) {
@@ -120,4 +120,4 @@ public class AssignOperator extends AbstractAssignOperator {
LocalOrderProperty explicitOrderingProperty) {
this.explicitOrderingProperty = explicitOrderingProperty;
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/ExtensionOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/ExtensionOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/ExtensionOperator.java
index dfd2c8f..d2f7715 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/ExtensionOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/ExtensionOperator.java
@@ -116,7 +116,7 @@ public class ExtensionOperator extends AbstractLogicalOperator {
public String toString() {
return delegate.toString();
}
-
+
public IOperatorExtension getDelegate() {
return delegate;
}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/IOperatorExtension.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/IOperatorExtension.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/IOperatorExtension.java
index 4d578d9..e61d9a2 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/IOperatorExtension.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/IOperatorExtension.java
@@ -47,8 +47,8 @@ public interface IOperatorExtension {
void setPhysicalOperator(IPhysicalOperator physicalOperator);
ExecutionMode getExecutionMode();
-
+
public void getUsedVariables(Collection<LogicalVariable> usedVars);
-
+
public void getProducedVariables(Collection<LogicalVariable> producedVars);
}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/PartitioningSplitOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/PartitioningSplitOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/PartitioningSplitOperator.java
index 9d48fa0..1c5f324 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/PartitioningSplitOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/PartitioningSplitOperator.java
@@ -69,11 +69,11 @@ public class PartitioningSplitOperator extends AbstractLogicalOperator {
public int getDefaultBranchIndex() {
return defaultBranchIndex;
}
-
+
public int getNumOutputBranches() {
return (defaultBranchIndex == expressions.size()) ? expressions.size() + 1 : expressions.size();
}
-
+
@Override
public LogicalOperatorTag getOperatorTag() {
return LogicalOperatorTag.PARTITIONINGSPLIT;
@@ -116,4 +116,4 @@ public class PartitioningSplitOperator extends AbstractLogicalOperator {
return createPropagatingAllInputsTypeEnvironment(ctx);
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/InMemoryHashJoinPOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/InMemoryHashJoinPOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/InMemoryHashJoinPOperator.java
index 5b04e08..a92bd70 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/InMemoryHashJoinPOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/InMemoryHashJoinPOperator.java
@@ -92,10 +92,10 @@ public class InMemoryHashJoinPOperator extends AbstractHashJoinPOperator {
Object t = env.getVarType(v);
comparatorFactories[i++] = bcfp.getBinaryComparatorFactory(t, true);
}
-
+
IPredicateEvaluatorFactoryProvider predEvaluatorFactoryProvider = context.getPredicateEvaluatorFactoryProvider();
IPredicateEvaluatorFactory predEvaluatorFactory = ( predEvaluatorFactoryProvider == null ? null : predEvaluatorFactoryProvider.getPredicateEvaluatorFactory(keysLeft, keysRight));
-
+
RecordDescriptor recDescriptor = JobGenHelper.mkRecordDescriptor(context.getTypeEnvironment(op),
propagatedSchema, context);
IOperatorDescriptorRegistry spec = builder.getJobSpec();
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/ILocalStructuralProperty.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/ILocalStructuralProperty.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/ILocalStructuralProperty.java
index ea9769a..af29994 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/ILocalStructuralProperty.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/ILocalStructuralProperty.java
@@ -36,7 +36,7 @@ public interface ILocalStructuralProperty extends IStructuralProperty {
* Returns the retained property regarding to a collection of variables,
* e.g., some variables used in the property may not exist in the input
* collection and hence the data property changes.
- *
+ *
* @param vars
* , an input collection of variables
* @return the retained data property.
@@ -45,7 +45,7 @@ public interface ILocalStructuralProperty extends IStructuralProperty {
/**
* Returns the additional data property within each group, which is dictated by the group keys.
- *
+ *
* @param vars
* , group keys.
* @return the additional data property within each group.
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/IPhysicalPropertiesVector.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/IPhysicalPropertiesVector.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/IPhysicalPropertiesVector.java
index bca500a..d872491 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/IPhysicalPropertiesVector.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/IPhysicalPropertiesVector.java
@@ -31,7 +31,7 @@ public interface IPhysicalPropertiesVector {
public List<ILocalStructuralProperty> getLocalProperties();
/**
- *
+ *
* @param reqd
* vector of required properties
* @param equivalenceClasses
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/LocalOrderProperty.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/LocalOrderProperty.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/LocalOrderProperty.java
index 1097dff..d1d0ca9 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/LocalOrderProperty.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/LocalOrderProperty.java
@@ -90,7 +90,7 @@ public final class LocalOrderProperty implements ILocalStructuralProperty {
/**
* Whether current property implies the required property
- *
+ *
* @param required
* , a required property
* @return true if the current property satisfies the required property; otherwise false.
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/PropertiesUtil.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/PropertiesUtil.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/PropertiesUtil.java
index ae9f4f1..711c0e7 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/PropertiesUtil.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/PropertiesUtil.java
@@ -177,7 +177,7 @@ public class PropertiesUtil {
/**
* Converts a list of OrderColumns to a list of LogicalVariables.
- *
+ *
* @param orderColumns
* , a list of OrderColumns
* @return the list of LogicalVariables
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/StructuralPropertiesVector.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/StructuralPropertiesVector.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/StructuralPropertiesVector.java
index 97363b5..7ae7e62 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/StructuralPropertiesVector.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/StructuralPropertiesVector.java
@@ -63,7 +63,7 @@ public class StructuralPropertiesVector implements IPhysicalPropertiesVector {
}
/**
- *
+ *
* @param reqd
* vector of required properties
* @return a vector of properties from pvector that are not delivered by the
@@ -102,4 +102,4 @@ public class StructuralPropertiesVector implements IPhysicalPropertiesVector {
}
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/VariablePropagationPolicy.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/VariablePropagationPolicy.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/VariablePropagationPolicy.java
index 8885b5d..d78684b 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/VariablePropagationPolicy.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/VariablePropagationPolicy.java
@@ -43,8 +43,8 @@ public abstract class VariablePropagationPolicy {
/**
* Adds, from each source, only variables that do not already appear in the
* target.
- *
- *
+ *
+ *
*/
public static final VariablePropagationPolicy ADDNEWVARIABLES = new VariablePropagationPolicy() {
@Override
@@ -79,4 +79,4 @@ public abstract class VariablePropagationPolicy {
};
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/util/OperatorPropertiesUtil.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/util/OperatorPropertiesUtil.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/util/OperatorPropertiesUtil.java
index 827c075..39de006 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/util/OperatorPropertiesUtil.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/util/OperatorPropertiesUtil.java
@@ -66,7 +66,7 @@ public class OperatorPropertiesUtil {
/**
* Adds the free variables of the plan rooted at that operator to the
* collection provided.
- *
+ *
* @param op
* @param vars
* - The collection to which the free variables will be added.
@@ -107,7 +107,7 @@ public class OperatorPropertiesUtil {
/**
* Adds the free variables of the operator path from
* op to dest, where dest is a direct/indirect input operator of op in the query plan.
- *
+ *
* @param op
* , the start operator.
* @param dest
@@ -165,7 +165,7 @@ public class OperatorPropertiesUtil {
/***
* Recursively checks if the dest operator is in the path of a nested plan
- *
+ *
* @param op
* @param dest
* @return
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/rewriter/base/PhysicalOptimizationConfig.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/rewriter/base/PhysicalOptimizationConfig.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/rewriter/base/PhysicalOptimizationConfig.java
index 03f721c..f0f858d 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/rewriter/base/PhysicalOptimizationConfig.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/rewriter/base/PhysicalOptimizationConfig.java
@@ -22,7 +22,7 @@ import java.util.Properties;
public class PhysicalOptimizationConfig {
private static final int MB = 1048576;
-
+
private static final String FRAMESIZE = "FRAMESIZE";
private static final String MAX_FRAMES_EXTERNAL_SORT = "MAX_FRAMES_EXTERNAL_SORT";
private static final String MAX_FRAMES_EXTERNAL_GROUP_BY = "MAX_FRAMES_EXTERNAL_GROUP_BY";
@@ -30,7 +30,7 @@ public class PhysicalOptimizationConfig {
private static final String MAX_FRAMES_HYBRID_HASH = "MAX_FRAMES_HYBRID_HASH";
private static final String FUDGE_FACTOR = "FUDGE_FACTOR";
private static final String MAX_RECORDS_PER_FRAME = "MAX_RECORDS_PER_FRAME";
-
+
private static final String DEFAULT_HASH_GROUP_TABLE_SIZE = "DEFAULT_HASH_GROUP_TABLE_SIZE";
private static final String DEFAULT_EXTERNAL_GROUP_TABLE_SIZE = "DEFAULT_EXTERNAL_GROUP_TABLE_SIZE";
private static final String DEFAULT_IN_MEM_HASH_JOIN_TABLE_SIZE = "DEFAULT_IN_MEM_HASH_JOIN_TABLE_SIZE";
@@ -56,7 +56,7 @@ public class PhysicalOptimizationConfig {
public void setFrameSize(int frameSize) {
setInt(FRAMESIZE, frameSize);
}
-
+
public double getFudgeFactor() {
return getDouble(FUDGE_FACTOR, 1.3);
}
@@ -64,7 +64,7 @@ public class PhysicalOptimizationConfig {
public void setFudgeFactor(double fudgeFactor) {
setDouble(FUDGE_FACTOR, fudgeFactor);
}
-
+
public int getMaxRecordsPerFrame() {
return getInt(MAX_RECORDS_PER_FRAME, 512);
}
@@ -81,7 +81,7 @@ public class PhysicalOptimizationConfig {
public void setMaxFramesLeftInputHybridHash(int frameLimit) {
setInt(MAX_FRAMES_LEFT_INPUT_HYBRID_HASH, frameLimit);
}
-
+
public int getMaxFramesHybridHash() {
int frameSize = getFrameSize();
return getInt(MAX_FRAMES_HYBRID_HASH, (int) (64L * MB / frameSize));
@@ -99,7 +99,7 @@ public class PhysicalOptimizationConfig {
public void setMaxFramesExternalGroupBy(int frameLimit) {
setInt(MAX_FRAMES_EXTERNAL_GROUP_BY, frameLimit);
}
-
+
public int getMaxFramesExternalSort() {
int frameSize = getFrameSize();
return getInt(MAX_FRAMES_EXTERNAL_SORT, (int) (((long) 32 * MB) / frameSize));
@@ -144,7 +144,7 @@ public class PhysicalOptimizationConfig {
else
return Integer.parseInt(value);
}
-
+
private void setDouble(String property, double value) {
properties.setProperty(property, Double.toString(value));
}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-data/src/main/java/org/apache/hyracks/algebricks/data/IResultSerializerFactoryProvider.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-data/src/main/java/org/apache/hyracks/algebricks/data/IResultSerializerFactoryProvider.java b/algebricks/algebricks-data/src/main/java/org/apache/hyracks/algebricks/data/IResultSerializerFactoryProvider.java
index 8749e25..7525180 100644
--- a/algebricks/algebricks-data/src/main/java/org/apache/hyracks/algebricks/data/IResultSerializerFactoryProvider.java
+++ b/algebricks/algebricks-data/src/main/java/org/apache/hyracks/algebricks/data/IResultSerializerFactoryProvider.java
@@ -25,7 +25,7 @@ import org.apache.hyracks.api.dataflow.value.IResultSerializerFactory;
public interface IResultSerializerFactoryProvider extends Serializable {
/**
* Returns a result serializer factory
- *
+ *
* @param fields
* - A position of the fields in the order it should be written in the output.
* @param printerFactories
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/ast/LoadNode.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/ast/LoadNode.java b/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/ast/LoadNode.java
index 7b7740d..6be1d9f 100644
--- a/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/ast/LoadNode.java
+++ b/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/ast/LoadNode.java
@@ -29,7 +29,7 @@ public class LoadNode extends RelationNode {
this.dataFile = dataFile;
this.schema = schema;
}
-
+
@Override
public Tag getTag() {
return Tag.LOAD;
@@ -42,4 +42,4 @@ public class LoadNode extends RelationNode {
public Schema getSchema() {
return schema;
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/types/Type.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/types/Type.java b/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/types/Type.java
index f91be1e..f8ffe93 100644
--- a/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/types/Type.java
+++ b/algebricks/algebricks-examples/piglet-example/src/main/java/org/apache/hyracks/algebricks/examples/piglet/types/Type.java
@@ -29,6 +29,6 @@ public abstract class Type {
BAG,
MAP
}
-
+
public abstract Tag getTag();
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ComplexUnnestToProductRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ComplexUnnestToProductRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ComplexUnnestToProductRule.java
index eb39332..42ae597 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ComplexUnnestToProductRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ComplexUnnestToProductRule.java
@@ -298,7 +298,7 @@ public class ComplexUnnestToProductRule implements IAlgebraicRewriteRule {
/**
* check whether the operator is inside a sub-plan
- *
+ *
* @param nestedRootRef
* @return true-if it is; false otherwise.
*/
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ConsolidateSelectsRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ConsolidateSelectsRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ConsolidateSelectsRule.java
index 165530a..0a4672b 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ConsolidateSelectsRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ConsolidateSelectsRule.java
@@ -37,7 +37,7 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
/**
* Matches the following operator pattern:
* (select) <-- ((assign)* <-- (select)*)+
- *
+ *
* Consolidates the selects to:
* (select) <-- (assign)*
*
@@ -59,7 +59,7 @@ public class ConsolidateSelectsRule implements IAlgebraicRewriteRule {
IFunctionInfo andFn = context.getMetadataProvider().lookupFunction(AlgebricksBuiltinFunctions.AND);
// New conjuncts for consolidated select.
- AbstractFunctionCallExpression conj = null;
+ AbstractFunctionCallExpression conj = null;
AbstractLogicalOperator topMostOp = null;
AbstractLogicalOperator selectParent = null;
AbstractLogicalOperator nextSelect = firstSelect;
@@ -75,14 +75,14 @@ public class ConsolidateSelectsRule implements IAlgebraicRewriteRule {
}
// Remember the top-most op that we are not removing.
topMostOp = selectParent;
-
+
// Initialize the new conjuncts, if necessary.
if (conj == null) {
conj = new ScalarFunctionCallExpression(andFn);
// Add the first select's condition.
conj.getArguments().add(new MutableObject<ILogicalExpression>(firstSelect.getCondition().getValue()));
}
-
+
// Consolidate all following selects.
do {
// Add the condition nextSelect to the new list of conjuncts.
@@ -90,21 +90,21 @@ public class ConsolidateSelectsRule implements IAlgebraicRewriteRule {
selectParent = nextSelect;
nextSelect = (AbstractLogicalOperator) nextSelect.getInputs().get(0).getValue();
} while (nextSelect.getOperatorTag() == LogicalOperatorTag.SELECT);
-
+
// Hook up the input of the top-most remaining op if necessary.
if (topMostOp.getOperatorTag() == LogicalOperatorTag.ASSIGN || topMostOp == firstSelect) {
topMostOp.getInputs().set(0, selectParent.getInputs().get(0));
}
-
+
// Prepare for next iteration.
nextSelect = selectParent;
} while (true);
-
+
// Did we consolidate any selects?
if (conj == null) {
return false;
}
-
+
// Set the new conjuncts.
firstSelect.getCondition().setValue(conj);
context.computeAndSetTypeEnvironmentForOperator(firstSelect);
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EliminateGroupByEmptyKeyRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EliminateGroupByEmptyKeyRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EliminateGroupByEmptyKeyRule.java
index d1fedf2..aab6ce1 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EliminateGroupByEmptyKeyRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EliminateGroupByEmptyKeyRule.java
@@ -35,7 +35,7 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
/**
* This rule lift out the aggregate operator out from a group-by operator
* if the gby operator groups-by on empty key, e.g., the group-by variables are empty.
- *
+ *
* @author yingyib
*/
public class EliminateGroupByEmptyKeyRule implements IAlgebraicRewriteRule {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EnforceOrderByAfterSubplan.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EnforceOrderByAfterSubplan.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EnforceOrderByAfterSubplan.java
index ee7f6a5..fcec50a 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EnforceOrderByAfterSubplan.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/EnforceOrderByAfterSubplan.java
@@ -43,7 +43,7 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
* If there is any ordering property before the subplan operator, the ordering should
* be kept after the subplan.
* This rule adds a redundant order operator after those cases, to guarantee the correctness.
- *
+ *
* @author yingyib
*/
public class EnforceOrderByAfterSubplan implements IAlgebraicRewriteRule {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractCommonExpressionsRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractCommonExpressionsRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractCommonExpressionsRule.java
index 232a78b..e5581dc 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractCommonExpressionsRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractCommonExpressionsRule.java
@@ -196,7 +196,7 @@ public class ExtractCommonExpressionsRule implements IAlgebraicRewriteRule {
}
// TODO: For now do not perform replacement in nested plans
- // due to the complication of figuring out whether the firstOp in an equivalence class is within a subplan,
+ // due to the complication of figuring out whether the firstOp in an equivalence class is within a subplan,
// and the resulting variable will not be visible to the outside.
// Since subplans should be eliminated in most cases, this behavior is acceptable for now.
/*
@@ -238,7 +238,7 @@ public class ExtractCommonExpressionsRule implements IAlgebraicRewriteRule {
boolean modified = false;
ExprEquivalenceClass exprEqClass = exprEqClassMap.get(expr);
if (exprEqClass != null) {
- // Replace common subexpression with existing variable.
+ // Replace common subexpression with existing variable.
if (exprEqClass.variableIsSet()) {
Set<LogicalVariable> liveVars = new HashSet<LogicalVariable>();
List<LogicalVariable> usedVars = new ArrayList<LogicalVariable>();
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractFunctionsFromJoinConditionRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractFunctionsFromJoinConditionRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractFunctionsFromJoinConditionRule.java
index 8604cae..71a00bf 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractFunctionsFromJoinConditionRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/ExtractFunctionsFromJoinConditionRule.java
@@ -50,11 +50,11 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
*
* <pre>
* Before plan:
- *
+ *
* join ( eq( funcX($$1), funcX($$2) ) )
- *
+ *
* After plan:
- *
+ *
* join (eq($$3,$$4))
* assign [$$4] <- [funcY($$2)]
* assign [$$3] <- [funcX($$1)]
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/InlineSingleReferenceVariablesRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/InlineSingleReferenceVariablesRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/InlineSingleReferenceVariablesRule.java
index bfa3bfd..71fde61 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/InlineSingleReferenceVariablesRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/InlineSingleReferenceVariablesRule.java
@@ -32,17 +32,17 @@ import org.apache.hyracks.algebricks.core.algebra.operators.logical.visitors.Var
/**
* Inlines variables that are referenced exactly once.
- *
+ *
* Preconditions/Assumptions:
* Assumes no projects are in the plan.
- *
+ *
* Example assuming variable $$3 is referenced exactly once.
- *
+ *
* Before plan:
* select (funcA($$3))
* ...
* assign [$$3] <- [field-access($$0, 1)]
- *
+ *
* After plan:
* select (funcA(field-access($$0, 1))
* ...
@@ -53,14 +53,14 @@ public class InlineSingleReferenceVariablesRule extends InlineVariablesRule {
// Maps from variable to a list of operators using that variable.
protected Map<LogicalVariable, List<ILogicalOperator>> usedVarsMap = new HashMap<LogicalVariable, List<ILogicalOperator>>();
protected List<LogicalVariable> usedVars = new ArrayList<LogicalVariable>();
-
+
@Override
protected void prepare(IOptimizationContext context) {
super.prepare(context);
usedVarsMap.clear();
usedVars.clear();
}
-
+
@Override
protected boolean performFinalAction() throws AlgebricksException {
boolean modified = false;
@@ -75,7 +75,7 @@ public class InlineSingleReferenceVariablesRule extends InlineVariablesRule {
modified = true;
}
inlineVisitor.setTargetVariable(null);
- }
+ }
}
}
return modified;
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/IntroduceProjectsRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/IntroduceProjectsRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/IntroduceProjectsRule.java
index f8b36dd..6bc129e 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/IntroduceProjectsRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/IntroduceProjectsRule.java
@@ -82,7 +82,7 @@ public class IntroduceProjectsRule implements IAlgebraicRewriteRule {
parentsUsedVars.addAll(parentUsedVars);
parentsUsedVars.addAll(usedVars);
- // Descend into children.
+ // Descend into children.
for (int i = 0; i < op.getInputs().size(); i++) {
Mutable<ILogicalOperator> inputOpRef = op.getInputs().get(i);
if (introduceProjects(op, i, inputOpRef, parentsUsedVars, context)) {
@@ -152,7 +152,7 @@ public class IntroduceProjectsRule implements IAlgebraicRewriteRule {
}
return modified;
}
-
+
private boolean canEliminateProjectBelowUnion(UnionAllOperator unionOp, ProjectOperator projectOp,
int unionInputIndex) throws AlgebricksException {
List<LogicalVariable> orderedLiveVars = new ArrayList<LogicalVariable>();
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/PushFunctionsBelowJoin.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/PushFunctionsBelowJoin.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/PushFunctionsBelowJoin.java
index 59da252..c04a9d5 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/PushFunctionsBelowJoin.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/PushFunctionsBelowJoin.java
@@ -52,20 +52,20 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
* a join (which may blow up the cardinality).
* Also, this rule may help to enable other rules such as common subexpression elimination, again to reduce
* the number of calls to expensive functions.
- *
+ *
* Example: (we are pushing pushMeFunc)
- *
+ *
* Before plan:
* assign [$$10] <- [funcA(funcB(pushMeFunc($$3, $$4)))]
- * join (some condition)
+ * join (some condition)
* join_branch_0 where $$3 and $$4 are not live
* ...
* join_branch_1 where $$3 and $$4 are live
* ...
- *
+ *
* After plan:
* assign [$$10] <- [funcA(funcB($$11))]
- * join (some condition)
+ * join (some condition)
* join_branch_0 where $$3 and $$4 are not live
* ...
* join_branch_1 where $$3 and $$4 are live
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantGroupByDecorVars.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantGroupByDecorVars.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantGroupByDecorVars.java
index a303cc6..ebdc88a 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantGroupByDecorVars.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantGroupByDecorVars.java
@@ -43,7 +43,7 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
public class RemoveRedundantGroupByDecorVars implements IAlgebraicRewriteRule {
private final Set<LogicalVariable> vars = new HashSet<LogicalVariable>();
-
+
@Override
public boolean rewritePost(Mutable<ILogicalOperator> opRef, IOptimizationContext context) {
AbstractLogicalOperator op = (AbstractLogicalOperator) opRef.getValue();
@@ -54,7 +54,7 @@ public class RemoveRedundantGroupByDecorVars implements IAlgebraicRewriteRule {
return false;
}
vars.clear();
-
+
boolean modified = false;
GroupByOperator groupOp = (GroupByOperator) op;
Iterator<Pair<LogicalVariable, Mutable<ILogicalExpression>>> iter = groupOp.getDecorList().iterator();
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantProjectionRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantProjectionRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantProjectionRule.java
index e459109..38e97d7 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantProjectionRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantProjectionRule.java
@@ -37,12 +37,12 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
* project [var-list1]
* project [var-list2]
* P
- *
+ *
* if var-list1.equals(var-list2) becomes
- *
+ *
* project [var-list1]
* P
- *
+ *
*/
public class RemoveRedundantProjectionRule implements IAlgebraicRewriteRule {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantVariablesRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantVariablesRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantVariablesRule.java
index 9e4d8b7..9e867df 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantVariablesRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveRedundantVariablesRule.java
@@ -125,7 +125,7 @@ public class RemoveRedundantVariablesRule implements IAlgebraicRewriteRule {
}
}
- // Replace variable references with their first representative.
+ // Replace variable references with their first representative.
if (op.getOperatorTag() == LogicalOperatorTag.PROJECT) {
// The project operator does not use expressions, so we need to replace it's variables manually.
if (replaceProjectVars((ProjectOperator) op)) {
@@ -142,7 +142,7 @@ public class RemoveRedundantVariablesRule implements IAlgebraicRewriteRule {
}
}
- // Perform variable replacement in nested plans.
+ // Perform variable replacement in nested plans.
if (op.hasNestedPlans()) {
AbstractOperatorWithNestedPlans opWithNestedPlan = (AbstractOperatorWithNestedPlans) op;
for (ILogicalPlan nestedPlan : opWithNestedPlan.getNestedPlans()) {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveUnusedAssignAndAggregateRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveUnusedAssignAndAggregateRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveUnusedAssignAndAggregateRule.java
index 100c14f..b25497c 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveUnusedAssignAndAggregateRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/RemoveUnusedAssignAndAggregateRule.java
@@ -106,7 +106,7 @@ public class RemoveUnusedAssignAndAggregateRule implements IAlgebraicRewriteRule
rootsToBeRemoved.add(r);
}
}
- // Makes sure the operator should have at least ONE nested plan even it is empty
+ // Makes sure the operator should have at least ONE nested plan even it is empty
// (because a lot of places uses this assumption, TODO(yingyib): clean them up).
if (nestedPlan.getRoots().size() == rootsToBeRemoved.size() && opWithNest.getNestedPlans().size() > 1) {
nestedPlan.getRoots().removeAll(rootsToBeRemoved);
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/SetExecutionModeRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/SetExecutionModeRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/SetExecutionModeRule.java
index c523bd0..63a33b5 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/SetExecutionModeRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/SetExecutionModeRule.java
@@ -32,7 +32,7 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
* EXCHANGE operators in the plan. Previously, i.e. before having physical
* optimizations in place, we were using the IntroduceExchangeRule, which was
* doing both, to both set excutionMode and introduce data exchange ops.
- *
+ *
* @author Nicola
*/
public class SetExecutionModeRule implements IAlgebraicRewriteRule {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/EliminateSubplanWithInputCardinalityOneRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/EliminateSubplanWithInputCardinalityOneRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/EliminateSubplanWithInputCardinalityOneRule.java
index f7b6dea..784b6cd 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/EliminateSubplanWithInputCardinalityOneRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/EliminateSubplanWithInputCardinalityOneRule.java
@@ -44,7 +44,7 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
* The live variables at OP will not be used after SUBPLAN.
* Note: This rule must be applied after
* the RemoveRedundantVariablesRule (to avoid the lineage analysis of variable cardinality).
- *
+ *
* @author yingyib
*/
public class EliminateSubplanWithInputCardinalityOneRule implements IAlgebraicRewriteRule {
@@ -122,7 +122,7 @@ public class EliminateSubplanWithInputCardinalityOneRule implements IAlgebraicRe
/**
* Whether the cardinality of the input free variables are one.
- *
+ *
* @param opRef
* the operator to be checked (including its input operators)
* @param freeVars
@@ -141,7 +141,7 @@ public class EliminateSubplanWithInputCardinalityOneRule implements IAlgebraicRe
/**
* Recursively adding variables which has cardinality one and in int the input free variable set.
- *
+ *
* @param opRef
* , the current operator reference.
* @param freeVars
@@ -181,7 +181,7 @@ public class EliminateSubplanWithInputCardinalityOneRule implements IAlgebraicRe
/**
* Find the NestedTupleSource operator in the direct/undirect input operators of opRef.
- *
+ *
* @param opRef
* , the current operator reference.
* @param ntsSet
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/MoveFreeVariableOperatorOutOfSubplanRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/MoveFreeVariableOperatorOutOfSubplanRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/MoveFreeVariableOperatorOutOfSubplanRule.java
index 959466a..d176d05 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/MoveFreeVariableOperatorOutOfSubplanRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/MoveFreeVariableOperatorOutOfSubplanRule.java
@@ -41,7 +41,7 @@ import org.apache.hyracks.algebricks.rewriter.rules.AbstractDecorrelationRule;
*
* <pre>
* Before
- *
+ *
* %PARENT_PLAN
* SUBPLAN{
* %NESTED_OPERATORS_B+
@@ -50,12 +50,12 @@ import org.apache.hyracks.algebricks.rewriter.rules.AbstractDecorrelationRule;
* NESTEDTUPLESOURCE
* }
* %CHILD_PLAN
- *
+ *
* where
* %SUBPLAN has one nested plan with a root AGGREGATE operator.
- *
+ *
* After
- *
+ *
* %PARENT_PLAN
* SUBPLAN{
* %NESTED_OPERATORS_B+
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/PushSubplanIntoGroupByRule.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/PushSubplanIntoGroupByRule.java b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/PushSubplanIntoGroupByRule.java
index 74ff21f..042de2c 100644
--- a/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/PushSubplanIntoGroupByRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/org/apache/hyracks/algebricks/rewriter/rules/subplan/PushSubplanIntoGroupByRule.java
@@ -47,7 +47,7 @@ import org.apache.hyracks.algebricks.core.rewriter.base.IAlgebraicRewriteRule;
/**
* This rule pushes an array of subplans on top of a group-by into the
* nested plan of the group-by.
- *
+ *
* @author yingyib
*/
@@ -179,7 +179,7 @@ public class PushSubplanIntoGroupByRule implements IAlgebraicRewriteRule {
/**
* Removes unused aggregation variables (and expressions)
- *
+ *
* @param gby
* @throws AlgebricksException
*/
@@ -206,4 +206,4 @@ public class PushSubplanIntoGroupByRule implements IAlgebraicRewriteRule {
return currentOpRef;
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/base/ICopySerializableAggregateFunction.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/base/ICopySerializableAggregateFunction.java b/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/base/ICopySerializableAggregateFunction.java
index b3c73fb..078a51d 100644
--- a/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/base/ICopySerializableAggregateFunction.java
+++ b/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/base/ICopySerializableAggregateFunction.java
@@ -26,7 +26,7 @@ import org.apache.hyracks.dataflow.common.data.accessors.IFrameTupleReference;
public interface ICopySerializableAggregateFunction {
/**
* initialize the space occupied by internal state
- *
+ *
* @param state
* @throws AlgebricksException
* @return length of the intermediate state
@@ -35,7 +35,7 @@ public interface ICopySerializableAggregateFunction {
/**
* update the internal state
- *
+ *
* @param tuple
* @param state
* @throws AlgebricksException
@@ -44,7 +44,7 @@ public interface ICopySerializableAggregateFunction {
/**
* output the state to result
- *
+ *
* @param state
* @param result
* @throws AlgebricksException
@@ -53,7 +53,7 @@ public interface ICopySerializableAggregateFunction {
/**
* output the partial state to partial result
- *
+ *
* @param state
* @param partialResult
* @throws AlgebricksException
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/std/AssignRuntimeFactory.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/std/AssignRuntimeFactory.java b/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/std/AssignRuntimeFactory.java
index 1877d64..50706bd 100644
--- a/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/std/AssignRuntimeFactory.java
+++ b/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/std/AssignRuntimeFactory.java
@@ -139,8 +139,8 @@ public class AssignRuntimeFactory extends AbstractOneInputOneOutputRuntimeFactor
tRef.reset(tAccess, t);
produceTuple(tupleBuilder, tAccess, t, tRef);
if (flushFramesRapidly) {
- // Whenever all the tuples in the incoming frame have been consumed, the assign operator
- // will push its frame to the next operator; i.e., it won't wait until the frame gets full.
+ // Whenever all the tuples in the incoming frame have been consumed, the assign operator
+ // will push its frame to the next operator; i.e., it won't wait until the frame gets full.
appendToFrameFromTupleBuilder(tupleBuilder, true);
} else {
appendToFrameFromTupleBuilder(tupleBuilder);
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/IApplicationContext.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/IApplicationContext.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/IApplicationContext.java
index 1fb2291..6c79abd 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/IApplicationContext.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/IApplicationContext.java
@@ -27,14 +27,14 @@ import org.apache.hyracks.api.service.IControllerService;
/**
* Base class of the {@link ICCApplicationContext} and the {@link INCApplicationContext}.
- *
+ *
* @author vinayakb
*/
public interface IApplicationContext {
/**
* Gets the distributed state that is made available to all the Application
* Contexts of this application in the cluster.
- *
+ *
* @return
*/
public Serializable getDistributedState();
@@ -54,4 +54,4 @@ public interface IApplicationContext {
*/
public IControllerService getControllerService();
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/ICCApplicationContext.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/ICCApplicationContext.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/ICCApplicationContext.java
index a629b3a..8b83d83 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/ICCApplicationContext.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/ICCApplicationContext.java
@@ -25,7 +25,7 @@ import org.apache.hyracks.api.job.IJobLifecycleListener;
/**
* Application Context at the Cluster Controller for an application.
- *
+ *
* @author vinayakb
*/
public interface ICCApplicationContext extends IApplicationContext {
@@ -34,7 +34,7 @@ public interface ICCApplicationContext extends IApplicationContext {
* NC application contexts. Any state set by calling this method in the {@link ICCApplicationEntryPoint#start(ICCApplicationContext, String[])} call is made available to all the {@link INCApplicationContext} objects
* at each Node Controller. The state is then available to be inspected by
* the application at the NC during or after the {@link INCBootstrap#start()} call.
- *
+ *
* @param state
* The distributed state
*/
@@ -43,7 +43,7 @@ public interface ICCApplicationContext extends IApplicationContext {
/**
* A listener that listens to Job Lifecycle events at the Cluster
* Controller.
- *
+ *
* @param jobLifecycleListener
*/
public void addJobLifecycleListener(IJobLifecycleListener jobLifecycleListener);
@@ -51,16 +51,16 @@ public interface ICCApplicationContext extends IApplicationContext {
/**
* A listener that listens to Cluster Lifecycle events at the Cluster
* Controller.
- *
+ *
* @param jobLifecycleListener
*/
public void addClusterLifecycleListener(IClusterLifecycleListener clusterLifecycleListener);
/**
* Get the Cluster Controller Context.
- *
+ *
* @return The Cluster Controller Context.
*/
public ICCContext getCCContext();
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/INCApplicationContext.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/INCApplicationContext.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/INCApplicationContext.java
index e9788d9..77934c6 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/INCApplicationContext.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/application/INCApplicationContext.java
@@ -24,34 +24,34 @@ import org.apache.hyracks.api.resources.memory.IMemoryManager;
/**
* Application Context at the Node Controller for an application.
- *
+ *
* @author vinayakb
*/
public interface INCApplicationContext extends IApplicationContext {
/**
* Gets the life cycle component manager of the Node Controller.
- *
+ *
* @return
*/
public ILifeCycleComponentManager getLifeCycleComponentManager();
/**
* Gets the node Id of the Node Controller.
- *
+ *
* @return the Node Id.
*/
public String getNodeId();
/**
* Get the Hyracks Root Context.
- *
+ *
* @return The Hyracks Root Context
*/
public IHyracksRootContext getRootContext();
/**
* Set an object that can be later retrieved by the {@link #getApplicationObject()} call.
- *
+ *
* @param object
* Application Object
*/
@@ -59,22 +59,22 @@ public interface INCApplicationContext extends IApplicationContext {
/**
* Get the application object previously set by the {@link #setApplicationObject(Object)} call.
- *
+ *
* @return Application Object
*/
public Object getApplicationObject();
/**
* Get the memory manager at the node.
- *
+ *
* @return Memory Manager
*/
public IMemoryManager getMemoryManager();
/**
* Set the handler for state dumps.
- *
+ *
* @param handler
*/
public void setStateDumpHandler(IStateDumpHandler handler);
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/HyracksConnection.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/HyracksConnection.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/HyracksConnection.java
index 953d2c1..b57442d 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/HyracksConnection.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/HyracksConnection.java
@@ -53,7 +53,7 @@ import org.apache.hyracks.ipc.impl.JavaSerializationBasedPayloadSerializerDeseri
/**
* Connection Class used by a Hyracks Client to interact with a Hyracks Cluster
* Controller.
- *
+ *
* @author vinayakb
*/
public final class HyracksConnection implements IHyracksClientConnection {
@@ -67,7 +67,7 @@ public final class HyracksConnection implements IHyracksClientConnection {
/**
* Constructor to create a connection to the Hyracks Cluster Controller.
- *
+ *
* @param ccHost
* Host name (or IP Address) where the Cluster Controller can be
* reached.
@@ -190,4 +190,4 @@ public final class HyracksConnection implements IHyracksClientConnection {
public void stopCluster() throws Exception{
hci.stopCluster();
}
-}
\ No newline at end of file
+}