You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by am...@apache.org on 2016/02/20 07:09:19 UTC
[9/9] incubator-asterixdb-hyracks git commit: Remove Trailing White
Spaces
Remove Trailing White Spaces
This change removes all trailing white spaces in
java files in hyracks
Change-Id: I1c2ea4ff1190a965a857c0c3760cbebdf21860b3
Reviewed-on: https://asterix-gerrit.ics.uci.edu/645
Tested-by: Jenkins <je...@fulliautomatix.ics.uci.edu>
Reviewed-by: Michael Blow <mi...@couchbase.com>
Reviewed-by: Murtadha Hubail <hu...@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/26a15f03
Tree: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/tree/26a15f03
Diff: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/diff/26a15f03
Branch: refs/heads/master
Commit: 26a15f03b09e3185cc8d8d1d47c5e8aafa69f9e5
Parents: eea815d
Author: Abdullah Alamoudi <ba...@gmail.com>
Authored: Fri Feb 19 23:38:07 2016 +0300
Committer: abdullah alamoudi <ba...@gmail.com>
Committed: Fri Feb 19 22:03:22 2016 -0800
----------------------------------------------------------------------
.../AlgebricksAbsolutePartitionConstraint.java | 2 +-
.../AlgebricksPartitionConstraint.java | 2 +-
.../common/exceptions/AlgebricksException.java | 2 +-
.../exceptions/NotImplementedException.java | 2 +-
.../hyracks/algebricks/common/utils/Pair.java | 2 +-
.../core/algebra/base/ILogicalExpression.java | 2 +-
.../core/algebra/base/ILogicalPlan.java | 2 +-
.../core/algebra/base/IPhysicalOperator.java | 2 +-
.../core/algebra/base/LogicalExpressionTag.java | 2 +-
.../core/algebra/base/LogicalOperatorTag.java | 2 +-
.../AbstractFunctionCallExpression.java | 2 +-
.../algebra/expressions/ConstantExpression.java | 2 +-
.../expressions/IExpressionRuntimeProvider.java | 2 +-
...obGenToExpressionRuntimeProviderAdapter.java | 2 +-
.../VariableReferenceExpression.java | 2 +-
.../algebra/functions/FunctionIdentifier.java | 2 +-
.../AbstractExtensibleLogicalOperator.java | 2 +-
.../logical/AbstractUnnestOperator.java | 2 +-
.../logical/DataSourceScanOperator.java | 2 +-
.../operators/logical/DistinctOperator.java | 238 +++++++++----------
.../logical/EmptyTupleSourceOperator.java | 2 +-
.../operators/logical/IOperatorSchema.java | 2 +-
.../operators/logical/InnerJoinOperator.java | 2 +-
.../logical/NestedTupleSourceOperator.java | 2 +-
.../operators/logical/OrderOperator.java | 2 +-
.../operators/logical/SelectOperator.java | 2 +-
.../operators/logical/SubplanOperator.java | 194 +++++++--------
.../operators/logical/UnnestMapOperator.java | 2 +-
.../operators/logical/UnnestOperator.java | 2 +-
.../physical/AbstractPhysicalOperator.java | 2 +-
.../operators/physical/SubplanPOperator.java | 2 +-
.../core/algebra/plan/ALogicalPlanImpl.java | 76 +++---
.../algebra/prettyprint/PlanPrettyPrinter.java | 152 ++++++------
.../BroadcastPartitioningProperty.java | 2 +-
.../properties/RandomPartitioningProperty.java | 2 +-
.../visitors/ILogicalExpressionVisitor.java | 50 ++--
.../algebricks/core/config/SysoutFormatter.java | 2 +-
.../core/jobgen/impl/OperatorSchemaImpl.java | 2 +-
.../base/AlgebricksOptimizationContext.java | 2 +-
.../data/IBinaryBooleanInspector.java | 2 +-
.../data/IBinaryBooleanInspectorFactory.java | 2 +-
.../data/IBinaryComparatorFactoryProvider.java | 2 +-
.../data/IBinaryIntegerInspectorFactory.java | 2 +-
.../data/impl/BinaryBooleanInspectorImpl.java | 2 +-
.../data/impl/BinaryIntegerInspectorImpl.java | 2 +-
.../algebricks/examples/piglet/ast/ASTNode.java | 2 +-
.../examples/piglet/ast/AssignmentNode.java | 2 +-
.../examples/piglet/ast/DumpNode.java | 2 +-
.../examples/piglet/ast/ExpressionNode.java | 2 +-
.../piglet/ast/FieldAccessExpressionNode.java | 2 +-
.../examples/piglet/ast/FilterNode.java | 2 +-
.../examples/piglet/ast/FunctionTag.java | 2 +-
.../piglet/ast/LiteralExpressionNode.java | 2 +-
.../examples/piglet/ast/RelationNode.java | 2 +-
.../ast/ScalarFunctionExpressionNode.java | 2 +-
.../piglet/compiler/PigletCompiler.java | 2 +-
.../piglet/exceptions/PigletException.java | 2 +-
.../piglet/metadata/FileSplitUtils.java | 2 +-
.../piglet/metadata/PigletFileDataSink.java | 2 +-
.../piglet/metadata/PigletFileDataSource.java | 2 +-
.../piglet/metadata/PigletFunction.java | 2 +-
.../piglet/rewriter/PigletRewriteRuleset.java | 2 +-
.../piglet/runtime/PigletExpressionJobGen.java | 2 +-
.../IPigletFunctionEvaluatorFactoryBuilder.java | 2 +-
.../IntegerEqFunctionEvaluatorFactory.java | 2 +-
.../functions/PigletFunctionRegistry.java | 2 +-
.../examples/piglet/types/BagType.java | 2 +-
.../examples/piglet/types/CharArrayType.java | 2 +-
.../examples/piglet/types/DoubleType.java | 2 +-
.../examples/piglet/types/FloatType.java | 2 +-
.../examples/piglet/types/IntegerType.java | 2 +-
.../examples/piglet/types/LongType.java | 2 +-
.../examples/piglet/types/MapType.java | 2 +-
.../examples/piglet/types/Schema.java | 2 +-
.../examples/piglet/types/TupleType.java | 2 +-
.../rules/IntroduceGroupByCombinerRule.java | 2 +-
.../rewriter/rules/PushSelectIntoJoinRule.java | 2 +-
.../runtime/base/AlgebricksPipeline.java | 2 +-
.../runtime/base/IScalarEvaluator.java | 2 +-
.../runtime/base/IScalarEvaluatorFactory.java | 2 +-
.../runtime/base/IUnnestingPositionWriter.java | 2 +-
.../evaluators/TupleFieldEvaluatorFactory.java | 2 +-
...AlgebricksAccumulatingAggregatorFactory.java | 2 +-
.../std/NestedTupleSourceRuntimeFactory.java | 2 +-
.../pushruntime/IntegerConstantEvalFactory.java | 2 +-
.../pushruntime/IntegerEqualsEvalFactory.java | 2 +-
.../IntegerGreaterThanEvalFactory.java | 2 +-
.../application/ICCApplicationEntryPoint.java | 2 +-
.../application/INCApplicationEntryPoint.java | 2 +-
.../hyracks/api/channels/IInputChannel.java | 2 +-
.../api/channels/IInputChannelMonitor.java | 2 +-
.../api/client/ClusterControllerInfo.java | 2 +-
.../client/HyracksClientInterfaceFunctions.java | 2 +-
.../HyracksClientInterfaceRemoteProxy.java | 2 +-
.../api/client/IHyracksClientInterface.java | 2 +-
.../hyracks/api/client/NodeControllerInfo.java | 2 +-
.../apache/hyracks/api/client/NodeStatus.java | 2 +-
.../impl/ActivityClusterGraphBuilder.java | 2 +-
.../impl/IConnectorDescriptorVisitor.java | 2 +-
.../client/impl/IOperatorDescriptorVisitor.java | 2 +-
.../client/impl/JobActivityGraphBuilder.java | 2 +-
...ionActivityClusterGraphGeneratorFactory.java | 2 +-
.../hyracks/api/client/impl/PlanUtils.java | 2 +-
.../apache/hyracks/api/comm/FrameConstants.java | 2 +-
.../apache/hyracks/api/comm/IFrameReader.java | 2 +-
.../hyracks/api/comm/IFrameTupleAccessor.java | 2 +-
.../apache/hyracks/api/comm/IFrameWriter.java | 2 +-
.../hyracks/api/comm/IPartitionCollector.java | 2 +-
.../api/comm/IPartitionWriterFactory.java | 2 +-
.../hyracks/api/comm/PartitionChannel.java | 2 +-
.../hyracks/api/constraints/Constraint.java | 2 +-
.../api/constraints/IConstraintAcceptor.java | 2 +-
.../constraints/PartitionConstraintHelper.java | 2 +-
.../expressions/ConstantExpression.java | 2 +-
.../expressions/ConstraintExpression.java | 2 +-
.../expressions/LValueConstraintExpression.java | 2 +-
.../expressions/PartitionCountExpression.java | 2 +-
.../PartitionLocationExpression.java | 2 +-
.../apache/hyracks/api/context/ICCContext.java | 2 +-
.../api/context/IHyracksJobletContext.java | 2 +-
.../api/context/IHyracksRootContext.java | 2 +-
.../api/context/IHyracksTaskContext.java | 2 +-
.../apache/hyracks/api/dataflow/ActivityId.java | 2 +-
.../api/dataflow/ConnectorDescriptorId.java | 2 +-
.../apache/hyracks/api/dataflow/IActivity.java | 2 +-
.../api/dataflow/IActivityGraphBuilder.java | 2 +-
.../api/dataflow/IOpenableDataReader.java | 2 +-
.../api/dataflow/IOpenableDataWriter.java | 2 +-
.../api/dataflow/IOperatorNodePullable.java | 2 +-
.../api/dataflow/IOperatorNodePushable.java | 2 +-
.../api/dataflow/OperatorDescriptorId.java | 2 +-
.../api/dataflow/OperatorInstanceId.java | 2 +-
.../hyracks/api/dataflow/TaskAttemptId.java | 2 +-
.../org/apache/hyracks/api/dataflow/TaskId.java | 2 +-
.../dataflow/connectors/IConnectorPolicy.java | 2 +-
.../IConnectorPolicyAssignmentPolicy.java | 2 +-
.../connectors/PipeliningConnectorPolicy.java | 2 +-
...SideMaterializedBlockingConnectorPolicy.java | 2 +-
...deMaterializedPipeliningConnectorPolicy.java | 2 +-
...SideMaterializedBlockingConnectorPolicy.java | 2 +-
...deMaterializedPipeliningConnectorPolicy.java | 2 +-
.../api/dataflow/state/IStateObject.java | 2 +-
.../value/BinaryComparatorConstant.java | 2 +-
.../api/dataflow/value/IBinaryComparator.java | 2 +-
.../value/IBinaryComparatorFactory.java | 2 +-
.../api/dataflow/value/IBinaryHashFunction.java | 2 +-
.../value/IBinaryHashFunctionFactory.java | 2 +-
.../value/IBinaryHashFunctionFamily.java | 2 +-
.../api/dataflow/value/IComparatorFactory.java | 2 +-
.../api/dataflow/value/IHashFunction.java | 2 +-
.../dataflow/value/IHashFunctionFactory.java | 2 +-
.../dataflow/value/ILinearizeComparator.java | 2 +-
.../value/ILinearizeComparatorFactory.java | 2 +-
.../dataflow/value/INormalizedKeyComputer.java | 2 +-
.../value/INormalizedKeyComputerFactory.java | 2 +-
.../value/IRecordDescriptorProvider.java | 2 +-
.../value/ITuplePairComparatorFactory.java | 2 +-
.../dataflow/value/ITuplePartitionComputer.java | 2 +-
.../value/ITuplePartitionComputerFactory.java | 2 +-
.../value/ITuplePartitionComputerFamily.java | 2 +-
.../api/dataflow/value/RecordDescriptor.java | 2 +-
.../hyracks/api/dataset/ResultSetMetaData.java | 2 +-
.../api/exceptions/HyracksDataException.java | 2 +-
.../api/exceptions/HyracksException.java | 2 +-
.../apache/hyracks/api/io/FileReference.java | 2 +-
.../org/apache/hyracks/api/io/IFileHandle.java | 2 +-
.../org/apache/hyracks/api/io/IIOFuture.java | 2 +-
.../apache/hyracks/api/io/IODeviceHandle.java | 2 +-
.../hyracks/api/io/IWorkspaceFileFactory.java | 2 +-
.../apache/hyracks/api/job/ActivityCluster.java | 2 +-
.../hyracks/api/job/ActivityClusterGraph.java | 2 +-
.../hyracks/api/job/ActivityClusterId.java | 2 +-
.../api/job/IActivityClusterGraphGenerator.java | 2 +-
.../IActivityClusterGraphGeneratorFactory.java | 2 +-
.../api/job/IConnectorDescriptorRegistry.java | 2 +-
.../hyracks/api/job/IGlobalJobDataFactory.java | 2 +-
.../hyracks/api/job/IJobLifecycleListener.java | 2 +-
.../hyracks/api/job/IJobletEventListener.java | 2 +-
.../api/job/IJobletEventListenerFactory.java | 2 +-
.../api/job/IOperatorDescriptorRegistry.java | 2 +-
.../hyracks/api/job/IOperatorEnvironment.java | 2 +-
.../hyracks/api/job/JobActivityGraph.java | 2 +-
.../org/apache/hyracks/api/job/JobFlag.java | 2 +-
.../java/org/apache/hyracks/api/job/JobId.java | 2 +-
.../hyracks/api/job/JobSpecification.java | 2 +-
.../org/apache/hyracks/api/job/JobStatus.java | 2 +-
.../hyracks/api/partitions/IPartition.java | 2 +-
.../hyracks/api/partitions/PartitionId.java | 2 +-
.../api/partitions/ResultSetPartitionId.java | 2 +-
.../hyracks/api/resources/IDeallocatable.java | 2 +-
.../api/resources/IDeallocatableRegistry.java | 2 +-
.../api/resources/memory/IMemoryManager.java | 2 +-
.../hyracks/api/service/IControllerService.java | 2 +-
.../hyracks/api/topology/ClusterTopology.java | 2 +-
.../hyracks/api/topology/NetworkEndpoint.java | 2 +-
.../hyracks/api/topology/NetworkSwitch.java | 2 +-
.../hyracks/api/topology/NetworkTerminal.java | 2 +-
.../api/topology/TopologyDefinitionParser.java | 2 +-
.../api/util/JavaSerializationUtils.java | 2 +-
.../client/net/ClientNetworkManager.java | 2 +-
.../channels/DatasetNetworkInputChannel.java | 2 +-
.../comm/channels/NetworkInputChannel.java | 2 +-
.../comm/channels/NetworkOutputChannel.java | 2 +-
.../org/apache/hyracks/control/cc/CCDriver.java | 2 +-
.../hyracks/control/cc/NodeControllerState.java | 2 +-
.../HyracksAdminConsoleApplication.java | 2 +-
.../cc/adminconsole/pages/AbstractPage.java | 2 +-
.../cc/adminconsole/pages/IndexPage.java | 2 +-
.../cc/adminconsole/pages/JobDetailsPage.java | 2 +-
.../cc/adminconsole/pages/NodeDetailsPage.java | 2 +-
.../cc/application/CCApplicationContext.java | 2 +-
.../control/cc/job/ActivityClusterPlan.java | 2 +-
.../hyracks/control/cc/job/ActivityPlan.java | 2 +-
.../cc/job/IJobStatusConditionVariable.java | 2 +-
.../org/apache/hyracks/control/cc/job/Task.java | 2 +-
.../hyracks/control/cc/job/TaskAttempt.java | 2 +-
.../hyracks/control/cc/job/TaskCluster.java | 2 +-
.../control/cc/job/TaskClusterAttempt.java | 2 +-
.../hyracks/control/cc/job/TaskClusterId.java | 2 +-
.../cc/partitions/PartitionMatchMaker.java | 2 +-
.../control/cc/partitions/PartitionUtils.java | 2 +-
.../cc/scheduler/ActivityClusterPlanner.java | 2 +-
.../cc/scheduler/ActivityPartitionDetails.java | 2 +-
.../cc/scheduler/PartitionConstraintSolver.java | 2 +-
.../cc/scheduler/RankedRunnableTaskCluster.java | 2 +-
.../control/cc/scheduler/Runnability.java | 2 +-
.../cc/web/ApplicationInstallationHandler.java | 2 +-
.../control/cc/web/JobsRESTAPIFunction.java | 2 +-
.../control/cc/web/NodesRESTAPIFunction.java | 2 +-
.../hyracks/control/cc/web/WebServer.java | 2 +-
.../cc/web/util/IJSONOutputFunction.java | 2 +-
.../cc/web/util/JSONOutputRequestHandler.java | 2 +-
.../hyracks/control/cc/web/util/JSONUtils.java | 2 +-
.../control/cc/web/util/RoutingHandler.java | 2 +-
.../cc/work/AbstractTaskLifecycleWork.java | 2 +-
.../work/GetActivityClusterGraphJSONWork.java | 2 +-
.../GetDatasetDirectoryServiceInfoWork.java | 2 +-
.../cc/work/GetIpAddressNodeNameMapWork.java | 2 +-
.../hyracks/control/cc/work/GetJobInfoWork.java | 2 +-
.../control/cc/work/GetJobRunJSONWork.java | 2 +-
.../control/cc/work/GetJobStatusWork.java | 2 +-
.../cc/work/GetJobSummariesJSONWork.java | 2 +-
.../cc/work/GetNodeControllersInfoWork.java | 2 +-
.../control/cc/work/GetNodeDetailsJSONWork.java | 2 +-
.../cc/work/GetNodeSummariesJSONWork.java | 2 +-
.../hyracks/control/cc/work/JobStartWork.java | 2 +-
.../cc/work/JobletCleanupNotificationWork.java | 2 +-
.../control/cc/work/NodeHeartbeatWork.java | 2 +-
.../cc/work/RegisterPartitionRequestWork.java | 2 +-
.../RegisterResultPartitionLocationWork.java | 2 +-
.../control/cc/work/RemoveDeadNodesWork.java | 2 +-
.../control/cc/work/ReportProfilesWork.java | 2 +-
.../control/cc/work/UnregisterNodeWork.java | 2 +-
.../cc/work/WaitForJobCompletionWork.java | 2 +-
.../common/application/ApplicationContext.java | 2 +-
.../common/application/ApplicationStatus.java | 2 +-
.../control/common/base/IClusterController.java | 2 +-
.../control/common/base/INodeController.java | 2 +-
.../control/common/context/ServerContext.java | 2 +-
.../common/controllers/NodeParameters.java | 2 +-
.../common/controllers/NodeRegistration.java | 2 +-
.../control/common/heartbeat/HeartbeatData.java | 2 +-
.../common/heartbeat/HeartbeatSchema.java | 2 +-
.../ipc/ClusterControllerRemoteProxy.java | 2 +-
.../common/ipc/NodeControllerRemoteProxy.java | 2 +-
.../control/common/job/PartitionDescriptor.java | 2 +-
.../control/common/job/PartitionRequest.java | 2 +-
.../control/common/job/PartitionState.java | 2 +-
.../common/job/TaskAttemptDescriptor.java | 2 +-
.../common/job/profiling/counters/Counter.java | 2 +-
.../counters/MultiResolutionEventProfiler.java | 2 +-
.../job/profiling/om/AbstractProfile.java | 2 +-
.../common/job/profiling/om/JobProfile.java | 2 +-
.../common/job/profiling/om/JobletProfile.java | 2 +-
.../job/profiling/om/PartitionProfile.java | 2 +-
.../common/job/profiling/om/TaskProfile.java | 2 +-
.../hyracks/control/common/logs/LogFile.java | 2 +-
.../control/common/work/FutureValue.java | 2 +-
.../control/common/work/IPCResponder.java | 2 +-
.../control/common/work/IResultCallback.java | 2 +-
.../control/common/work/SynchronizableWork.java | 2 +-
.../hyracks/control/common/work/WorkQueue.java | 2 +-
.../org/apache/hyracks/control/nc/Joblet.java | 2 +-
.../org/apache/hyracks/control/nc/NCDriver.java | 2 +-
.../org/apache/hyracks/control/nc/Task.java | 2 +-
.../nc/application/NCApplicationContext.java | 2 +-
.../hyracks/control/nc/dataset/ResultState.java | 2 +-
.../hyracks/control/nc/io/FileHandle.java | 2 +-
.../control/nc/io/WorkspaceFileFactory.java | 2 +-
.../nc/partitions/MaterializedPartition.java | 2 +-
.../MaterializedPartitionInputChannel.java | 2 +-
.../partitions/MaterializedPartitionWriter.java | 2 +-
.../MaterializingPipelinedPartition.java | 2 +-
.../control/nc/partitions/PartitionManager.java | 2 +-
.../nc/partitions/PipelinedPartition.java | 2 +-
.../ReceiveSideMaterializingCollector.java | 2 +-
.../ConnectorReceiverProfilingFrameReader.java | 2 +-
.../ConnectorSenderProfilingFrameWriter.java | 2 +-
.../ProfilingPartitionWriterFactory.java | 2 +-
.../resources/DefaultDeallocatableRegistry.java | 2 +-
.../nc/resources/memory/MemoryManager.java | 2 +-
.../control/nc/runtime/RootHyracksContext.java | 2 +-
.../hyracks/control/nc/work/AbortTasksWork.java | 2 +-
.../control/nc/work/ApplicationMessageWork.java | 2 +-
.../control/nc/work/BuildJobProfilesWork.java | 2 +-
.../control/nc/work/CleanupJobletWork.java | 2 +-
.../control/nc/work/NotifyTaskCompleteWork.java | 2 +-
.../control/nc/work/NotifyTaskFailureWork.java | 2 +-
.../std/accessors/MurmurHash3BinaryHash.java | 2 +-
.../MurmurHash3BinaryHashFunctionFamily.java | 2 +-
.../PointableBinaryComparatorFactory.java | 2 +-
.../PointableBinaryHashFunctionFactory.java | 2 +-
.../UTF8StringBinaryHashFunctionFamily.java | 2 +-
.../hyracks/data/std/api/AbstractPointable.java | 2 +-
.../hyracks/data/std/api/IComparable.java | 2 +-
.../data/std/api/IDataOutputProvider.java | 2 +-
.../apache/hyracks/data/std/api/IHashable.java | 2 +-
.../data/std/api/IMutableValueStorage.java | 2 +-
.../apache/hyracks/data/std/api/INumeric.java | 2 +-
.../apache/hyracks/data/std/api/IPointable.java | 2 +-
.../hyracks/data/std/api/IValueReference.java | 2 +-
.../data/std/primitive/BooleanPointable.java | 2 +-
.../data/std/primitive/BytePointable.java | 2 +-
.../data/std/primitive/DoublePointable.java | 2 +-
.../data/std/primitive/FloatPointable.java | 2 +-
.../data/std/primitive/IntegerPointable.java | 2 +-
.../data/std/primitive/LongPointable.java | 2 +-
.../data/std/primitive/ShortPointable.java | 2 +-
.../data/std/primitive/VoidPointable.java | 2 +-
.../util/ByteArrayAccessibleOutputStream.java | 2 +-
.../data/std/util/UTF8StringBuilder.java | 2 +-
.../std/primitive/ByteArrayPointableTest.java | 2 +-
.../std/primitive/UTF8StringPointableTest.java | 2 +-
.../data/std/util/UTF8StringBuilderTest.java | 2 +-
.../util/UTF8StringCharacterIteratorTest.java | 2 +-
.../common/comm/io/FrameDeserializer.java | 2 +-
.../comm/io/FrameDeserializingDataReader.java | 2 +-
.../comm/io/FrameDeserializingDataWriter.java | 2 +-
.../comm/io/FrameTuplePairComparator.java | 2 +-
.../common/comm/util/ByteBufferInputStream.java | 2 +-
.../dataflow/common/comm/util/FrameUtils.java | 2 +-
.../FrameTupleFieldValueReference.java | 2 +-
.../data/accessors/FrameTupleReference.java | 2 +-
.../data/accessors/IFrameTupleReference.java | 2 +-
.../common/data/accessors/ITupleReference.java | 2 +-
.../BooleanSerializerDeserializer.java | 2 +-
.../IntArraySerializerDeserializer.java | 2 +-
.../UTF8StringSerializerDeserializer.java | 2 +-
.../IntegerNormalizedKeyComputerFactory.java | 2 +-
.../UTF8StringNormalizedKeyComputerFactory.java | 2 +-
.../data/parsers/DoubleParserFactory.java | 2 +-
.../common/data/parsers/FloatParserFactory.java | 2 +-
.../common/data/parsers/IValueParser.java | 2 +-
.../data/parsers/IValueParserFactory.java | 2 +-
.../data/parsers/IntegerParserFactory.java | 2 +-
.../common/data/parsers/LongParserFactory.java | 2 +-
.../data/parsers/UTF8StringParserFactory.java | 2 +-
.../FieldHashPartitionComputerFactory.java | 2 +-
.../partition/RepartitionComputerFactory.java | 2 +-
.../common/data/partition/range/RangeMap.java | 2 +-
.../dataflow/common/io/RunFileReader.java | 2 +-
.../dataflow/common/io/RunFileWriter.java | 2 +-
.../dataflow/common/util/ReflectionUtils.java | 2 +-
.../FrameFixedFieldTupleAppenderTest.java | 2 +-
.../ByteArraySerializerDeserializerTest.java | 2 +-
...teArrayNormalizedKeyComputerFactoryTest.java | 2 +-
.../ByteArrayBase64ParserFactoryTest.java | 2 +-
.../parsers/ByteArrayHexParserFactoryTest.java | 2 +-
.../AbstractHadoopOperatorDescriptor.java | 2 +-
.../hadoop/data/AbstractClassBasedDelegate.java | 2 +-
...HadoopHashTuplePartitionComputerFactory.java | 2 +-
...artitionerTuplePartitionComputerFactory.java | 2 +-
...artitionerTuplePartitionComputerFactory.java | 2 +-
.../hadoop/data/KeyBinaryComparatorFactory.java | 2 +-
.../hadoop/data/KeyComparatorFactory.java | 2 +-
.../data/RawComparingComparatorFactory.java | 2 +-
...ritableComparingBinaryComparatorFactory.java | 2 +-
.../dataflow/hadoop/mapreduce/HadoopHelper.java | 2 +-
.../dataflow/hadoop/mapreduce/HadoopTools.java | 2 +-
...hPartitioningShuffleConnectorDescriptor.java | 2 +-
.../hadoop/mapreduce/IInputSplitProvider.java | 2 +-
.../mapreduce/IInputSplitProviderFactory.java | 2 +-
.../hadoop/mapreduce/InputFileSplit.java | 2 +-
.../mapreduce/ReducerOperatorDescriptor.java | 2 +-
.../dataflow/hadoop/util/DatatypeHelper.java | 2 +-
.../dataflow/hadoop/util/MRContextUtil.java | 2 +-
.../dataflow/std/base/AbstractActivityNode.java | 2 +-
.../std/base/AbstractConnectorDescriptor.java | 2 +-
.../std/base/AbstractOperatorDescriptor.java | 2 +-
.../std/base/AbstractOperatorNodePushable.java | 2 +-
...bstractSingleActivityOperatorDescriptor.java | 2 +-
.../dataflow/std/base/AbstractStateObject.java | 2 +-
.../AbstractUnaryInputOperatorNodePushable.java | 2 +-
...tractUnaryInputSinkOperatorNodePushable.java | 2 +-
...aryInputUnaryOutputOperatorNodePushable.java | 2 +-
...AbstractUnaryOutputOperatorNodePushable.java | 2 +-
...ctUnaryOutputSourceOperatorNodePushable.java | 2 +-
.../std/base/IOpenableDataWriterOperator.java | 2 +-
.../collectors/AbstractPartitionCollector.java | 2 +-
.../std/collectors/IPartitionAcceptor.java | 2 +-
.../std/collectors/IPartitionBatchManager.java | 2 +-
.../std/collectors/InputChannelFrameReader.java | 2 +-
.../NonDeterministicChannelReader.java | 2 +-
.../collectors/NonDeterministicFrameReader.java | 2 +-
.../NonDeterministicPartitionBatchManager.java | 2 +-
.../std/collectors/PartitionCollector.java | 2 +-
.../std/collectors/SortMergeFrameReader.java | 2 +-
.../MToNPartitioningConnectorDescriptor.java | 2 +-
...NPartitioningMergingConnectorDescriptor.java | 2 +-
.../connectors/OneToOneConnectorDescriptor.java | 2 +-
...tDeserializedFileScanOperatorDescriptor.java | 2 +-
.../AbstractFileWriteOperatorDescriptor.java | 2 +-
.../std/file/ConstantFileSplitProvider.java | 2 +-
.../file/FieldCursorForDelimitedDataParser.java | 2 +-
.../std/file/FileScanOperatorDescriptor.java | 2 +-
.../hyracks/dataflow/std/file/FileSplit.java | 2 +-
.../file/FrameFileWriterOperatorDescriptor.java | 2 +-
.../dataflow/std/file/IFileSplitProvider.java | 2 +-
.../hyracks/dataflow/std/file/ITupleParser.java | 2 +-
.../file/LineFileWriteOperatorDescriptor.java | 2 +-
.../file/RecordFileScanOperatorDescriptor.java | 2 +-
.../DeserializedPreclusteredGroupOperator.java | 2 +-
.../dataflow/std/group/IGroupAggregator.java | 2 +-
.../ExternalGroupBuildOperatorNodePushable.java | 2 +-
.../ExternalGroupMergeOperatorNodePushable.java | 2 +-
.../std/group/external/ExternalGroupState.java | 2 +-
.../std/group/hash/GroupingHashTable.java | 2 +-
.../HashGroupBuildOperatorNodePushable.java | 2 +-
.../HashGroupOutputOperatorNodePushable.java | 2 +-
.../dataflow/std/group/hash/HashGroupState.java | 2 +-
.../PreclusteredGroupOperatorDescriptor.java | 2 +-
.../PreclusteredGroupOperatorNodePushable.java | 2 +-
.../preclustered/PreclusteredGroupWriter.java | 2 +-
.../sort/ExternalSortGroupByRunGenerator.java | 2 +-
.../sort/SortGroupByOperatorDescriptor.java | 2 +-
.../join/GraceHashJoinOperatorNodePushable.java | 2 +-
...hJoinPartitionBuildOperatorNodePushable.java | 2 +-
.../std/join/GraceHashJoinPartitionState.java | 2 +-
.../join/HybridHashJoinOperatorDescriptor.java | 2 +-
.../InMemoryHashJoinOperatorDescriptor.java | 2 +-
.../join/NestedLoopJoinOperatorDescriptor.java | 2 +-
...timizedHybridHashJoinOperatorDescriptor.java | 2 +-
.../DeserializedMapperOperatorDescriptor.java | 2 +-
.../std/map/IDeserializedMapperFactory.java | 2 +-
...eflectionBasedDeserializedMapperFactory.java | 2 +-
.../map/SamplerDeserializedMapperFactory.java | 2 +-
.../ConstantTupleSourceOperatorDescriptor.java | 2 +-
...ConstantTupleSourceOperatorNodePushable.java | 2 +-
.../std/misc/IdentityOperatorDescriptor.java | 2 +-
.../std/misc/MaterializerTaskState.java | 2 +-
.../misc/MaterializingOperatorDescriptor.java | 2 +-
.../std/misc/NullSinkOperatorDescriptor.java | 2 +-
.../std/misc/PrinterOperatorDescriptor.java | 2 +-
.../std/misc/SplitVectorOperatorDescriptor.java | 2 +-
.../result/ResultWriterOperatorDescriptor.java | 2 +-
.../sort/ExternalSortOperatorDescriptor.java | 2 +-
.../std/sort/ExternalSortRunGenerator.java | 2 +-
.../dataflow/std/sort/FrameSorterQuickSort.java | 2 +-
.../dataflow/std/sort/IRunGenerator.java | 2 +-
.../sort/InMemorySortOperatorDescriptor.java | 2 +-
.../std/sort/RunMergingFrameReader.java | 2 +-
.../sort/buffermanager/IFrameBufferManager.java | 2 +-
.../dataflow/std/structures/IMinMaxHeap.java | 2 +-
.../dataflow/std/structures/TuplePointer.java | 2 +-
.../std/union/UnionAllOperatorDescriptor.java | 2 +-
.../util/DeserializedOperatorNodePushable.java | 2 +-
.../dataflow/std/util/ReferenceEntry.java | 2 +-
.../std/util/ReferencedPriorityQueue.java | 2 +-
.../dataflow/std/util/SelectionTree.java | 2 +-
.../std/util/StringSerializationUtils.java | 2 +-
.../FrameFreeSlotBestFitUsingTreeMapTest.java | 2 +-
.../FrameFreeSlotBiggestFirstTest.java | 2 +-
.../buffermanager/FrameFreeSlotLastFitTest.java | 2 +-
.../buffermanager/VariableFramePoolTest.java | 2 +-
.../VariableFramesMemoryManagerTest.java | 2 +-
.../VariableTupleMemoryManagerTest.java | 2 +-
.../util/DeletableFrameTupleAppenderTest.java | 2 +-
.../dataflow/std/structures/MinHeapTest.java | 2 +-
.../dataflow/std/structures/MinMaxHeapTest.java | 2 +-
.../std/test/util/SelectionTreeTest.java | 2 +-
.../hyracks/dataflow/std/util/MathTest.java | 2 +-
.../client/PrimaryIndexBulkLoadExample.java | 2 +-
.../btree/client/PrimaryIndexSearchExample.java | 2 +-
.../client/SecondaryIndexBulkLoadExample.java | 2 +-
.../client/SecondaryIndexSearchExample.java | 2 +-
.../btree/helper/NCApplicationEntryPoint.java | 2 +-
.../examples/btree/helper/RuntimeContext.java | 2 +-
.../btree/helper/StorageManagerInterface.java | 2 +-
.../LSMBTreePrimaryIndexScanOperatorTest.java | 2 +-
.../LSMBTreePrimaryIndexSearchOperatorTest.java | 2 +-
...SMBTreeSecondaryIndexInsertOperatorTest.java | 2 +-
...SMBTreeSecondaryIndexSearchOperatorTest.java | 2 +-
...SMRTreeSecondaryIndexInsertOperatorTest.java | 2 +-
...SMRTreeSecondaryIndexSearchOperatorTest.java | 2 +-
...rTuplesSecondaryIndexInsertOperatorTest.java | 2 +-
.../am/rtree/AbstractRTreeOperatorTest.java | 2 +-
.../RTreeSecondaryIndexInsertOperatorTest.java | 2 +-
.../RTreeSecondaryIndexScanOperatorTest.java | 2 +-
.../RTreeSecondaryIndexSearchOperatorTest.java | 2 +-
.../RTreeSecondaryIndexStatsOperatorTest.java | 2 +-
.../comm/SerializationDeserializationTest.java | 2 +-
.../tests/integration/CountOfCountsTest.java | 2 +-
.../integration/OptimizedSortMergeTest.java | 2 +-
.../tests/integration/ScanPrintTest.java | 2 +-
.../tests/integration/SortMergeTest.java | 2 +-
.../tests/integration/SplitOperatorTest.java | 2 +-
.../TPCHCustomerOrderHashJoinTest.java | 2 +-
.../TPCHCustomerOrderNestedLoopJoinTest.java | 2 +-
.../hyracks/tests/integration/UnionTest.java | 2 +-
.../unit/IntersectOperatorDescriptorTest.java | 2 +-
.../text/client/ExternalGroupClient.java | 2 +-
.../hyracks/examples/tpch/client/Join.java | 2 +-
.../hdfs/lib/RawBinaryHashFunctionFactory.java | 2 +-
.../java/org/apache/hyracks/ipc/api/IIPCI.java | 2 +-
.../hyracks/ipc/api/IPCPerformanceCounters.java | 2 +-
.../ipc/api/IPayloadSerializerDeserializer.java | 2 +-
.../hyracks/ipc/api/IResponseCallback.java | 2 +-
.../apache/hyracks/ipc/api/RPCInterface.java | 2 +-
.../hyracks/ipc/exceptions/IPCException.java | 2 +-
.../apache/hyracks/ipc/impl/HandleState.java | 2 +-
.../hyracks/ipc/impl/IPCConnectionManager.java | 2 +-
.../org/apache/hyracks/ipc/impl/IPCHandle.java | 2 +-
...ationBasedPayloadSerializerDeserializer.java | 2 +-
.../org/apache/hyracks/ipc/impl/Message.java | 2 +-
.../maven/plugin/AbstractHyracksMojo.java | 2 +-
.../maven/plugin/AbstractHyracksServerMojo.java | 2 +-
.../maven/plugin/HyracksServiceRegistry.java | 2 +-
.../maven/plugin/HyracksStopServicesMojo.java | 2 +-
.../hyracks/net/exceptions/NetException.java | 2 +-
.../net/protocols/muxdemux/IEventCounter.java | 2 +-
.../net/protocols/muxdemux/MuxDemuxCommand.java | 2 +-
.../muxdemux/MuxDemuxPerformanceCounters.java | 2 +-
.../tcp/ITCPConnectionEventListener.java | 2 +-
.../protocols/tcp/ITCPConnectionListener.java | 2 +-
.../net/protocols/tcp/TCPConnection.java | 2 +-
.../hyracks/net/protocols/tcp/TCPEndpoint.java | 2 +-
.../org/apache/hyracks/net/tests/NetTest.java | 2 +-
.../server/drivers/VirtualClusterDriver.java | 2 +-
.../server/process/HyracksCCProcess.java | 2 +-
.../server/process/HyracksNCProcess.java | 2 +-
.../server/process/HyracksServerProcess.java | 2 +-
.../impls/BloomFilterSpecification.java | 2 +-
.../am/bloomfilter/impls/MurmurHash128Bit.java | 2 +-
.../BTreeSearchOperatorNodePushable.java | 2 +-
.../BTreeFieldPrefixNSMLeafFrameFactory.java | 2 +-
.../am/btree/frames/BTreeNSMLeafFrame.java | 2 +-
.../am/btree/impls/BTreeRangeSearchCursor.java | 2 +-
.../storage/am/btree/impls/BTreeSplitKey.java | 2 +-
.../am/common/api/IIndexLifecycleManager.java | 2 +-
.../storage/am/common/api/ISearchPredicate.java | 2 +-
.../api/ITreeIndexMetaDataFrameFactory.java | 2 +-
.../PointablePrimitiveValueProviderFactory.java | 2 +-
.../AbstractTreeIndexOperatorDescriptor.java | 2 +-
.../dataflow/IIndexDataflowHelperFactory.java | 2 +-
.../IndexBulkLoadOperatorNodePushable.java | 2 +-
.../IndexCreateOperatorNodePushable.java | 2 +-
.../am/common/dataflow/IndexDataflowHelper.java | 2 +-
.../dataflow/IndexDropOperatorNodePushable.java | 2 +-
.../common/dataflow/IndexLifecycleManager.java | 2 +-
.../TreeIndexBulkLoadOperatorDescriptor.java | 2 +-
...reeIndexDiskOrderScanOperatorDescriptor.java | 2 +-
...dexInsertUpdateDeleteOperatorDescriptor.java | 2 +-
.../TreeIndexStatsOperatorDescriptor.java | 2 +-
.../am/common/frames/FrameOpSpaceStatus.java | 2 +-
.../am/common/ophelpers/MultiComparator.java | 2 +-
.../am/common/ophelpers/SingleComparator.java | 2 +-
.../am/common/tuples/DualTupleReference.java | 2 +-
.../am/common/tuples/SimpleTupleReference.java | 2 +-
.../am/common/util/IndexFileNameUtil.java | 2 +-
.../lsm/btree/impls/ExternalBTreeOpContext.java | 2 +-
.../impls/ExternalBTreeWithBuddyOpContext.java | 2 +-
.../btree/impls/LSMBTreeCursorInitialState.java | 2 +-
.../am/lsm/btree/impls/LSMBTreeOpContext.java | 2 +-
.../btree/impls/LSMBTreePointSearchCursor.java | 2 +-
.../lsm/btree/impls/LSMBTreeSearchCursor.java | 2 +-
.../impls/LSMBTreeWithBuddySortedCursor.java | 2 +-
.../btree/impls/LSMBuddyBTreeMergeCursor.java | 2 +-
.../LSMTreeIndexCompactOperatorDescriptor.java | 2 +-
...dexInsertUpdateDeleteOperatorDescriptor.java | 2 +-
.../am/lsm/common/impls/BTreeFactory.java | 2 +-
.../BloomFilterAwareBTreePointSearchCursor.java | 2 +-
.../am/lsm/common/impls/IndexFactory.java | 2 +-
.../lsm/common/impls/LSMIndexSearchCursor.java | 2 +-
.../am/lsm/common/impls/TreeIndexFactory.java | 2 +-
...tractLSMInvertedIndexOperatorDescriptor.java | 2 +-
.../LSMInvertedIndexCompactOperator.java | 2 +-
.../LSMInvertedIndexDataflowHelper.java | 2 +-
...InvertedIndexInsertUpdateDeleteOperator.java | 2 +-
...rtitionedLSMInvertedIndexDataflowHelper.java | 2 +-
.../impls/LSMInvertedIndexMergeOperation.java | 2 +-
.../search/InvertedListPartitions.java | 2 +-
.../tokenizers/AbstractUTF8Token.java | 2 +-
.../DelimitedUTF8StringBinaryTokenizer.java | 2 +-
.../lsm/rtree/impls/ExternalRTreeOpContext.java | 2 +-
.../lsm/rtree/impls/LSMRTreeAbstractCursor.java | 2 +-
.../am/lsm/rtree/impls/LSMRTreeOpContext.java | 2 +-
.../lsm/rtree/impls/LSMRTreeSearchCursor.java | 2 +-
.../am/lsm/rtree/impls/TreeTupleSorter.java | 2 +-
.../storage/am/rtree/api/IRTreeFrame.java | 2 +-
.../dataflow/RTreeSearchOperatorDescriptor.java | 2 +-
.../RTreeSearchOperatorNodePushable.java | 2 +-
.../am/rtree/frames/RStarTreePolicy.java | 2 +-
.../am/rtree/frames/RTreeComputationUtils.java | 2 +-
.../storage/am/rtree/frames/RTreeNSMFrame.java | 2 +-
.../storage/am/rtree/frames/RTreePolicy.java | 2 +-
.../storage/am/rtree/impls/RTreeSplitKey.java | 2 +-
.../storage/am/rtree/impls/Rectangle.java | 2 +-
.../storage/am/rtree/util/RTreeUtils.java | 2 +-
.../common/IStorageManagerInterface.java | 2 +-
.../buffercache/AsyncFIFOPageQueueManager.java | 2 +-
.../buffercache/DelayPageCleanerPolicy.java | 2 +-
.../buffercache/DirectBufferAllocator.java | 2 +-
.../common/buffercache/HeapBufferAllocator.java | 2 +-
.../buffercache/IBufferCacheInternal.java | 2 +-
.../storage/common/buffercache/ICachedPage.java | 2 +-
.../common/buffercache/ICachedPageInternal.java | 2 +-
.../buffercache/IPageReplacementStrategy.java | 2 +-
.../ResourceHeapBufferAllocator.java | 2 +-
.../storage/common/file/BufferedFileHandle.java | 2 +-
.../storage/common/file/IResourceIdFactory.java | 2 +-
.../common/file/TransientFileMapManager.java | 2 +-
.../hyracks/storage/common/sync/LatchType.java | 2 +-
.../am/btree/OrderedIndexBulkLoadTest.java | 2 +-
.../am/btree/OrderedIndexExamplesTest.java | 2 +-
.../am/btree/OrderedIndexTestContext.java | 2 +-
.../storage/am/common/IndexTestContext.java | 2 +-
.../am/rtree/AbstractRTreeExamplesTest.java | 2 +-
.../am/rtree/AbstractRTreeTestContext.java | 2 +-
.../storage/am/rtree/RTreeCheckTuple.java | 2 +-
.../hyracks/test/support/CounterContext.java | 2 +-
.../hyracks/test/support/TestJobletContext.java | 2 +-
.../hyracks/test/support/TestRootContext.java | 2 +-
.../TestStorageManagerComponentHolder.java | 2 +-
.../support/TestStorageManagerInterface.java | 2 +-
.../hyracks/test/support/TestTaskContext.java | 2 +-
.../apache/hyracks/test/support/TestUtils.java | 2 +-
.../am/lsm/btree/LSMBTreeMultiBulkLoadTest.java | 2 +-
.../LSMInvertedIndexDeleteTest.java | 2 +-
.../PartitionedLSMInvertedIndexDeleteTest.java | 2 +-
.../util/encoding/VarLenIntEncoderDecoder.java | 2 +-
.../hyracks/util/string/UTF8StringUtil.java | 2 +-
.../hyracks/util/string/UTF8StringWriter.java | 2 +-
.../encoding/VarLenIntEncoderDecoderTest.java | 2 +-
.../util/string/UTF8StringReaderWriterTest.java | 2 +-
.../hyracks/util/string/UTF8StringUtilTest.java | 2 +-
.../yarn/am/HyracksYarnApplicationMaster.java | 2 +-
.../yarn/am/manifest/AbstractProcess.java | 2 +-
.../am/manifest/ContainerSpecification.java | 2 +-
.../yarn/am/manifest/HyracksCluster.java | 2 +-
.../yarn/am/manifest/ManifestParser.java | 2 +-
.../yarn/am/manifest/NodeController.java | 2 +-
.../yarn/client/KillHyracksApplication.java | 2 +-
.../yarn/client/LaunchHyracksApplication.java | 2 +-
.../common/protocols/amrm/AMRMConnection.java | 2 +-
.../protocols/clientrm/YarnApplication.java | 2 +-
.../clientrm/YarnClientRMConnection.java | 2 +-
.../common/resources/LocalResourceHelper.java | 2 +-
.../yarn/common/resources/ResourceHelper.java | 2 +-
658 files changed, 1008 insertions(+), 1008 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/constraints/AlgebricksAbsolutePartitionConstraint.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/constraints/AlgebricksAbsolutePartitionConstraint.java b/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/constraints/AlgebricksAbsolutePartitionConstraint.java
index 6f4cd9a..8394057 100644
--- a/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/constraints/AlgebricksAbsolutePartitionConstraint.java
+++ b/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/constraints/AlgebricksAbsolutePartitionConstraint.java
@@ -33,4 +33,4 @@ public class AlgebricksAbsolutePartitionConstraint extends AlgebricksPartitionCo
public String[] getLocations() {
return locations;
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/constraints/AlgebricksPartitionConstraint.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/constraints/AlgebricksPartitionConstraint.java b/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/constraints/AlgebricksPartitionConstraint.java
index da1f680..ada1390 100644
--- a/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/constraints/AlgebricksPartitionConstraint.java
+++ b/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/constraints/AlgebricksPartitionConstraint.java
@@ -25,4 +25,4 @@ public abstract class AlgebricksPartitionConstraint {
}
public abstract PartitionConstraintType getPartitionConstraintType();
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/exceptions/AlgebricksException.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/exceptions/AlgebricksException.java b/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/exceptions/AlgebricksException.java
index 32af816..ef4d775 100644
--- a/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/exceptions/AlgebricksException.java
+++ b/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/exceptions/AlgebricksException.java
@@ -35,4 +35,4 @@ public class AlgebricksException extends Exception {
public AlgebricksException(String message, Throwable cause) {
super(message, cause);
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/exceptions/NotImplementedException.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/exceptions/NotImplementedException.java b/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/exceptions/NotImplementedException.java
index 799af68..16bc73e 100644
--- a/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/exceptions/NotImplementedException.java
+++ b/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/exceptions/NotImplementedException.java
@@ -36,4 +36,4 @@ public class NotImplementedException extends RuntimeException {
public NotImplementedException(String message, Throwable cause) {
super(message, cause);
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/utils/Pair.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/utils/Pair.java b/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/utils/Pair.java
index 561fd81..77e6f4c 100644
--- a/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/utils/Pair.java
+++ b/algebricks/algebricks-common/src/main/java/org/apache/hyracks/algebricks/common/utils/Pair.java
@@ -51,4 +51,4 @@ public class Pair<T1, T2> implements Serializable {
return first.hashCode() * 31 + second.hashCode();
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalExpression.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalExpression.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalExpression.java
index 4dfc5ee..7e10203 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalExpression.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalExpression.java
@@ -73,4 +73,4 @@ public interface ILogicalExpression {
public abstract ILogicalExpression cloneExpression();
public boolean isFunctional();
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalPlan.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalPlan.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalPlan.java
index 784501c..20cb186 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalPlan.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/ILogicalPlan.java
@@ -24,4 +24,4 @@ import org.apache.commons.lang3.mutable.Mutable;
public interface ILogicalPlan {
public List<Mutable<ILogicalOperator>> getRoots();
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/IPhysicalOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/IPhysicalOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/IPhysicalOperator.java
index e457b74..a3ef5d9 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/IPhysicalOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/IPhysicalOperator.java
@@ -76,4 +76,4 @@ public interface IPhysicalOperator {
*/
public boolean expensiveThanMaterialization();
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalExpressionTag.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalExpressionTag.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalExpressionTag.java
index 043940d..58f4c60 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalExpressionTag.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalExpressionTag.java
@@ -20,4 +20,4 @@ package org.apache.hyracks.algebricks.core.algebra.base;
public enum LogicalExpressionTag {
FUNCTION_CALL, VARIABLE, CONSTANT
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalOperatorTag.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalOperatorTag.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalOperatorTag.java
index 977107c..6361f42 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalOperatorTag.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/LogicalOperatorTag.java
@@ -54,4 +54,4 @@ public enum LogicalOperatorTag {
WRITE,
WRITE_RESULT,
INTERSECT,
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/AbstractFunctionCallExpression.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/AbstractFunctionCallExpression.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/AbstractFunctionCallExpression.java
index bab23f1..7f88e2f 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/AbstractFunctionCallExpression.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/AbstractFunctionCallExpression.java
@@ -356,4 +356,4 @@ public abstract class AbstractFunctionCallExpression extends AbstractLogicalExpr
return true;
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/ConstantExpression.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/ConstantExpression.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/ConstantExpression.java
index eeecfe0..449688b 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/ConstantExpression.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/ConstantExpression.java
@@ -175,4 +175,4 @@ public final class ConstantExpression extends AbstractLogicalExpression {
return false;
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/IExpressionRuntimeProvider.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/IExpressionRuntimeProvider.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/IExpressionRuntimeProvider.java
index c584b47..acce996 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/IExpressionRuntimeProvider.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/IExpressionRuntimeProvider.java
@@ -47,4 +47,4 @@ public interface IExpressionRuntimeProvider {
public IUnnestingEvaluatorFactory createUnnestingFunctionFactory(UnnestingFunctionCallExpression expr,
IVariableTypeEnvironment env, IOperatorSchema[] inputSchemas, JobGenContext context)
throws AlgebricksException;
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/LogicalExpressionJobGenToExpressionRuntimeProviderAdapter.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/LogicalExpressionJobGenToExpressionRuntimeProviderAdapter.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/LogicalExpressionJobGenToExpressionRuntimeProviderAdapter.java
index 02993f7..5b07a7e 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/LogicalExpressionJobGenToExpressionRuntimeProviderAdapter.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/LogicalExpressionJobGenToExpressionRuntimeProviderAdapter.java
@@ -68,4 +68,4 @@ public class LogicalExpressionJobGenToExpressionRuntimeProviderAdapter implement
throws AlgebricksException {
return lejg.createUnnestingFunctionFactory(expr, env, inputSchemas, context);
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/VariableReferenceExpression.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/VariableReferenceExpression.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/VariableReferenceExpression.java
index 3cd510a..865e781 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/VariableReferenceExpression.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/VariableReferenceExpression.java
@@ -111,4 +111,4 @@ public class VariableReferenceExpression extends AbstractLogicalExpression {
public boolean splitIntoConjuncts(List<Mutable<ILogicalExpression>> conjs) {
return false;
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/functions/FunctionIdentifier.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/functions/FunctionIdentifier.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/functions/FunctionIdentifier.java
index 4d779c7..2f2b7e3 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/functions/FunctionIdentifier.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/functions/FunctionIdentifier.java
@@ -71,4 +71,4 @@ public final class FunctionIdentifier implements Serializable {
public String getNamespace() {
return namespace;
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AbstractExtensibleLogicalOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AbstractExtensibleLogicalOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AbstractExtensibleLogicalOperator.java
index 03b2feb..dd555e2 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AbstractExtensibleLogicalOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AbstractExtensibleLogicalOperator.java
@@ -57,4 +57,4 @@ public abstract class AbstractExtensibleLogicalOperator implements IOperatorExte
public void setPhysicalOperator(IPhysicalOperator physicalOperator) {
this.physicalOperator = physicalOperator;
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AbstractUnnestOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AbstractUnnestOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AbstractUnnestOperator.java
index fcba3ba..9f528bd 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AbstractUnnestOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/AbstractUnnestOperator.java
@@ -50,4 +50,4 @@ public abstract class AbstractUnnestOperator extends AbstractScanOperator {
return visitor.transform(expression);
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/DataSourceScanOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/DataSourceScanOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/DataSourceScanOperator.java
index 7d3306e..2511fa9 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/DataSourceScanOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/DataSourceScanOperator.java
@@ -133,4 +133,4 @@ public class DataSourceScanOperator extends AbstractDataSourceOperator {
public List<Mutable<ILogicalExpression>> getAdditionalFilteringExpressions() {
return additionalFilteringExpressions;
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/DistinctOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/DistinctOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/DistinctOperator.java
index e122dc4..205099f 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/DistinctOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/DistinctOperator.java
@@ -16,123 +16,123 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.apache.hyracks.algebricks.core.algebra.operators.logical;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import org.apache.commons.lang3.mutable.Mutable;
-
-import org.apache.hyracks.algebricks.common.exceptions.AlgebricksException;
-import org.apache.hyracks.algebricks.core.algebra.base.ILogicalExpression;
-import org.apache.hyracks.algebricks.core.algebra.base.LogicalExpressionTag;
-import org.apache.hyracks.algebricks.core.algebra.base.LogicalOperatorTag;
-import org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable;
-import org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment;
-import org.apache.hyracks.algebricks.core.algebra.expressions.VariableReferenceExpression;
-import org.apache.hyracks.algebricks.core.algebra.properties.VariablePropagationPolicy;
-import org.apache.hyracks.algebricks.core.algebra.typing.ITypingContext;
-import org.apache.hyracks.algebricks.core.algebra.visitors.ILogicalExpressionReferenceTransform;
-import org.apache.hyracks.algebricks.core.algebra.visitors.ILogicalOperatorVisitor;
-
-public class DistinctOperator extends AbstractLogicalOperator {
- private final List<Mutable<ILogicalExpression>> expressions;
-
- public DistinctOperator(List<Mutable<ILogicalExpression>> expressions) {
- this.expressions = expressions;
- }
-
- @Override
- public LogicalOperatorTag getOperatorTag() {
- return LogicalOperatorTag.DISTINCT;
- }
-
- public List<Mutable<ILogicalExpression>> getExpressions() {
- return expressions;
- }
-
- @Override
- public void recomputeSchema() {
- schema = new ArrayList<LogicalVariable>();
- schema.addAll(this.getDistinctByVarList());
- List<LogicalVariable> inputSchema = inputs.get(0).getValue().getSchema();
- for (LogicalVariable var : inputSchema) {
- if (!schema.contains(var)) {
- schema.add(var);
- }
- }
- }
-
- @Override
- public VariablePropagationPolicy getVariablePropagationPolicy() {
- return new VariablePropagationPolicy() {
- @Override
- public void propagateVariables(IOperatorSchema target, IOperatorSchema... sources)
- throws AlgebricksException {
- /** make sure distinct key vars laid-out first */
- for (LogicalVariable keyVar : getDistinctByVarList()) {
- target.addVariable(keyVar);
- }
- /** add other source vars */
- for (IOperatorSchema srcSchema : sources) {
- for (LogicalVariable srcVar : srcSchema)
- if (target.findVariable(srcVar) < 0) {
- target.addVariable(srcVar);
- }
- }
- }
- };
- }
-
- @Override
- public boolean acceptExpressionTransform(ILogicalExpressionReferenceTransform visitor) throws AlgebricksException {
- boolean changed = false;
- for (Mutable<ILogicalExpression> e : expressions) {
- if (visitor.transform(e)) {
- changed = true;
- }
- }
- return changed;
- }
-
- @Override
- public <R, T> R accept(ILogicalOperatorVisitor<R, T> visitor, T arg) throws AlgebricksException {
- return visitor.visitDistinctOperator(this, arg);
- }
-
- @Override
- public boolean isMap() {
- return false;
+package org.apache.hyracks.algebricks.core.algebra.operators.logical;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.apache.commons.lang3.mutable.Mutable;
+
+import org.apache.hyracks.algebricks.common.exceptions.AlgebricksException;
+import org.apache.hyracks.algebricks.core.algebra.base.ILogicalExpression;
+import org.apache.hyracks.algebricks.core.algebra.base.LogicalExpressionTag;
+import org.apache.hyracks.algebricks.core.algebra.base.LogicalOperatorTag;
+import org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable;
+import org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment;
+import org.apache.hyracks.algebricks.core.algebra.expressions.VariableReferenceExpression;
+import org.apache.hyracks.algebricks.core.algebra.properties.VariablePropagationPolicy;
+import org.apache.hyracks.algebricks.core.algebra.typing.ITypingContext;
+import org.apache.hyracks.algebricks.core.algebra.visitors.ILogicalExpressionReferenceTransform;
+import org.apache.hyracks.algebricks.core.algebra.visitors.ILogicalOperatorVisitor;
+
+public class DistinctOperator extends AbstractLogicalOperator {
+ private final List<Mutable<ILogicalExpression>> expressions;
+
+ public DistinctOperator(List<Mutable<ILogicalExpression>> expressions) {
+ this.expressions = expressions;
}
-
- public List<LogicalVariable> getDistinctByVarList() {
- List<LogicalVariable> varList = new ArrayList<LogicalVariable>(expressions.size());
- for (Mutable<ILogicalExpression> eRef : expressions) {
- ILogicalExpression e = eRef.getValue();
- if (e.getExpressionTag() == LogicalExpressionTag.VARIABLE) {
- VariableReferenceExpression v = (VariableReferenceExpression) e;
- varList.add(v.getVariableReference());
- }
- }
- return varList;
- }
-
- public boolean isDistinctByVar(LogicalVariable var) {
- for (Mutable<ILogicalExpression> eRef : expressions) {
- ILogicalExpression e = eRef.getValue();
- if (e.getExpressionTag() == LogicalExpressionTag.VARIABLE) {
- VariableReferenceExpression v = (VariableReferenceExpression) e;
- if (v.getVariableReference() == var) {
- return true;
- }
- }
- }
- return false;
- }
-
- @Override
- public IVariableTypeEnvironment computeOutputTypeEnvironment(ITypingContext ctx) throws AlgebricksException {
- return createPropagatingAllInputsTypeEnvironment(ctx);
- }
-
-}
+
+ @Override
+ public LogicalOperatorTag getOperatorTag() {
+ return LogicalOperatorTag.DISTINCT;
+ }
+
+ public List<Mutable<ILogicalExpression>> getExpressions() {
+ return expressions;
+ }
+
+ @Override
+ public void recomputeSchema() {
+ schema = new ArrayList<LogicalVariable>();
+ schema.addAll(this.getDistinctByVarList());
+ List<LogicalVariable> inputSchema = inputs.get(0).getValue().getSchema();
+ for (LogicalVariable var : inputSchema) {
+ if (!schema.contains(var)) {
+ schema.add(var);
+ }
+ }
+ }
+
+ @Override
+ public VariablePropagationPolicy getVariablePropagationPolicy() {
+ return new VariablePropagationPolicy() {
+ @Override
+ public void propagateVariables(IOperatorSchema target, IOperatorSchema... sources)
+ throws AlgebricksException {
+ /** make sure distinct key vars laid-out first */
+ for (LogicalVariable keyVar : getDistinctByVarList()) {
+ target.addVariable(keyVar);
+ }
+ /** add other source vars */
+ for (IOperatorSchema srcSchema : sources) {
+ for (LogicalVariable srcVar : srcSchema)
+ if (target.findVariable(srcVar) < 0) {
+ target.addVariable(srcVar);
+ }
+ }
+ }
+ };
+ }
+
+ @Override
+ public boolean acceptExpressionTransform(ILogicalExpressionReferenceTransform visitor) throws AlgebricksException {
+ boolean changed = false;
+ for (Mutable<ILogicalExpression> e : expressions) {
+ if (visitor.transform(e)) {
+ changed = true;
+ }
+ }
+ return changed;
+ }
+
+ @Override
+ public <R, T> R accept(ILogicalOperatorVisitor<R, T> visitor, T arg) throws AlgebricksException {
+ return visitor.visitDistinctOperator(this, arg);
+ }
+
+ @Override
+ public boolean isMap() {
+ return false;
+ }
+
+ public List<LogicalVariable> getDistinctByVarList() {
+ List<LogicalVariable> varList = new ArrayList<LogicalVariable>(expressions.size());
+ for (Mutable<ILogicalExpression> eRef : expressions) {
+ ILogicalExpression e = eRef.getValue();
+ if (e.getExpressionTag() == LogicalExpressionTag.VARIABLE) {
+ VariableReferenceExpression v = (VariableReferenceExpression) e;
+ varList.add(v.getVariableReference());
+ }
+ }
+ return varList;
+ }
+
+ public boolean isDistinctByVar(LogicalVariable var) {
+ for (Mutable<ILogicalExpression> eRef : expressions) {
+ ILogicalExpression e = eRef.getValue();
+ if (e.getExpressionTag() == LogicalExpressionTag.VARIABLE) {
+ VariableReferenceExpression v = (VariableReferenceExpression) e;
+ if (v.getVariableReference() == var) {
+ return true;
+ }
+ }
+ }
+ return false;
+ }
+
+ @Override
+ public IVariableTypeEnvironment computeOutputTypeEnvironment(ITypingContext ctx) throws AlgebricksException {
+ return createPropagatingAllInputsTypeEnvironment(ctx);
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/EmptyTupleSourceOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/EmptyTupleSourceOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/EmptyTupleSourceOperator.java
index 0feaec5..1af0ce4 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/EmptyTupleSourceOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/EmptyTupleSourceOperator.java
@@ -97,4 +97,4 @@ public class EmptyTupleSourceOperator extends AbstractLogicalOperator {
};
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/IOperatorSchema.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/IOperatorSchema.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/IOperatorSchema.java
index f6d4788..28a8499 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/IOperatorSchema.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/IOperatorSchema.java
@@ -34,4 +34,4 @@ public interface IOperatorSchema extends Iterable<LogicalVariable> {
public int getSize();
public void clear();
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/InnerJoinOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/InnerJoinOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/InnerJoinOperator.java
index f6830ed..a6055cb 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/InnerJoinOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/InnerJoinOperator.java
@@ -54,4 +54,4 @@ public class InnerJoinOperator extends AbstractBinaryJoinOperator {
return createPropagatingAllInputsTypeEnvironment(ctx);
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/NestedTupleSourceOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/NestedTupleSourceOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/NestedTupleSourceOperator.java
index 8993495..a3a446a 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/NestedTupleSourceOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/NestedTupleSourceOperator.java
@@ -109,4 +109,4 @@ public class NestedTupleSourceOperator extends AbstractLogicalOperator {
return computeOutputTypeEnvironment(ctx);
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/OrderOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/OrderOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/OrderOperator.java
index e55eef3..cea7e23 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/OrderOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/OrderOperator.java
@@ -172,4 +172,4 @@ public class OrderOperator extends AbstractLogicalOperator {
public int getTopK() {
return topK;
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/SelectOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/SelectOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/SelectOperator.java
index 2f3373c..8a8d1f2 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/SelectOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/SelectOperator.java
@@ -122,4 +122,4 @@ public class SelectOperator extends AbstractLogicalOperator {
public boolean requiresVariableReferenceExpressions() {
return false;
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/SubplanOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/SubplanOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/SubplanOperator.java
index 0659365..cf11b3e 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/SubplanOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/SubplanOperator.java
@@ -16,100 +16,100 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.apache.hyracks.algebricks.core.algebra.operators.logical;
-
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.List;
-
-import org.apache.commons.lang3.mutable.Mutable;
-import org.apache.commons.lang3.mutable.MutableObject;
-
-import org.apache.hyracks.algebricks.common.exceptions.AlgebricksException;
-import org.apache.hyracks.algebricks.core.algebra.base.ILogicalOperator;
-import org.apache.hyracks.algebricks.core.algebra.base.ILogicalPlan;
-import org.apache.hyracks.algebricks.core.algebra.base.LogicalOperatorTag;
-import org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable;
-import org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment;
-import org.apache.hyracks.algebricks.core.algebra.plan.ALogicalPlanImpl;
-import org.apache.hyracks.algebricks.core.algebra.properties.TypePropagationPolicy;
-import org.apache.hyracks.algebricks.core.algebra.properties.VariablePropagationPolicy;
-import org.apache.hyracks.algebricks.core.algebra.typing.ITypeEnvPointer;
-import org.apache.hyracks.algebricks.core.algebra.typing.ITypingContext;
-import org.apache.hyracks.algebricks.core.algebra.typing.OpRefTypeEnvPointer;
-import org.apache.hyracks.algebricks.core.algebra.typing.PropagatingTypeEnvironment;
-import org.apache.hyracks.algebricks.core.algebra.visitors.ILogicalExpressionReferenceTransform;
-import org.apache.hyracks.algebricks.core.algebra.visitors.ILogicalOperatorVisitor;
-
-public class SubplanOperator extends AbstractOperatorWithNestedPlans {
-
- public SubplanOperator() {
- super();
- }
-
- public SubplanOperator(List<ILogicalPlan> plans) {
- super(plans);
- }
-
- public SubplanOperator(ILogicalOperator planRoot) {
- ArrayList<Mutable<ILogicalOperator>> roots = new ArrayList<Mutable<ILogicalOperator>>(1);
- roots.add(new MutableObject<ILogicalOperator>(planRoot));
- nestedPlans.add(new ALogicalPlanImpl(roots));
- }
-
- public void setRootOp(Mutable<ILogicalOperator> opRef) {
- ILogicalPlan p = new ALogicalPlanImpl(opRef);
- nestedPlans.add(p);
- }
-
- @Override
- public boolean acceptExpressionTransform(ILogicalExpressionReferenceTransform visitor) {
- // do nothing
- return false;
- }
-
- @Override
- public LogicalOperatorTag getOperatorTag() {
- return LogicalOperatorTag.SUBPLAN;
- }
-
- @Override
- public VariablePropagationPolicy getVariablePropagationPolicy() {
- return VariablePropagationPolicy.ADDNEWVARIABLES;
- }
-
- @Override
- public <R, T> R accept(ILogicalOperatorVisitor<R, T> visitor, T arg) throws AlgebricksException {
- return visitor.visitSubplanOperator(this, arg);
- }
-
- @Override
- public void getProducedVariablesExceptNestedPlans(Collection<LogicalVariable> vars) {
- // do nothing
- }
-
- @Override
- public void getUsedVariablesExceptNestedPlans(Collection<LogicalVariable> vars) {
- // do nothing
- }
-
- @Override
- public IVariableTypeEnvironment computeOutputTypeEnvironment(ITypingContext ctx) throws AlgebricksException {
- int n = 0;
- for (ILogicalPlan p : nestedPlans) {
- n += p.getRoots().size();
- }
- ITypeEnvPointer[] envPointers = new ITypeEnvPointer[n + 1];
- envPointers[0] = new OpRefTypeEnvPointer(inputs.get(0), ctx);
- int i = 1;
- for (ILogicalPlan p : nestedPlans) {
- for (Mutable<ILogicalOperator> r : p.getRoots()) {
- envPointers[i] = new OpRefTypeEnvPointer(r, ctx);
- i++;
- }
- }
- return new PropagatingTypeEnvironment(ctx.getExpressionTypeComputer(), ctx.getNullableTypeComputer(),
- ctx.getMetadataProvider(), TypePropagationPolicy.LEFT_OUTER, envPointers);
- }
-
-}
+package org.apache.hyracks.algebricks.core.algebra.operators.logical;
+
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.List;
+
+import org.apache.commons.lang3.mutable.Mutable;
+import org.apache.commons.lang3.mutable.MutableObject;
+
+import org.apache.hyracks.algebricks.common.exceptions.AlgebricksException;
+import org.apache.hyracks.algebricks.core.algebra.base.ILogicalOperator;
+import org.apache.hyracks.algebricks.core.algebra.base.ILogicalPlan;
+import org.apache.hyracks.algebricks.core.algebra.base.LogicalOperatorTag;
+import org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable;
+import org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment;
+import org.apache.hyracks.algebricks.core.algebra.plan.ALogicalPlanImpl;
+import org.apache.hyracks.algebricks.core.algebra.properties.TypePropagationPolicy;
+import org.apache.hyracks.algebricks.core.algebra.properties.VariablePropagationPolicy;
+import org.apache.hyracks.algebricks.core.algebra.typing.ITypeEnvPointer;
+import org.apache.hyracks.algebricks.core.algebra.typing.ITypingContext;
+import org.apache.hyracks.algebricks.core.algebra.typing.OpRefTypeEnvPointer;
+import org.apache.hyracks.algebricks.core.algebra.typing.PropagatingTypeEnvironment;
+import org.apache.hyracks.algebricks.core.algebra.visitors.ILogicalExpressionReferenceTransform;
+import org.apache.hyracks.algebricks.core.algebra.visitors.ILogicalOperatorVisitor;
+
+public class SubplanOperator extends AbstractOperatorWithNestedPlans {
+
+ public SubplanOperator() {
+ super();
+ }
+
+ public SubplanOperator(List<ILogicalPlan> plans) {
+ super(plans);
+ }
+
+ public SubplanOperator(ILogicalOperator planRoot) {
+ ArrayList<Mutable<ILogicalOperator>> roots = new ArrayList<Mutable<ILogicalOperator>>(1);
+ roots.add(new MutableObject<ILogicalOperator>(planRoot));
+ nestedPlans.add(new ALogicalPlanImpl(roots));
+ }
+
+ public void setRootOp(Mutable<ILogicalOperator> opRef) {
+ ILogicalPlan p = new ALogicalPlanImpl(opRef);
+ nestedPlans.add(p);
+ }
+
+ @Override
+ public boolean acceptExpressionTransform(ILogicalExpressionReferenceTransform visitor) {
+ // do nothing
+ return false;
+ }
+
+ @Override
+ public LogicalOperatorTag getOperatorTag() {
+ return LogicalOperatorTag.SUBPLAN;
+ }
+
+ @Override
+ public VariablePropagationPolicy getVariablePropagationPolicy() {
+ return VariablePropagationPolicy.ADDNEWVARIABLES;
+ }
+
+ @Override
+ public <R, T> R accept(ILogicalOperatorVisitor<R, T> visitor, T arg) throws AlgebricksException {
+ return visitor.visitSubplanOperator(this, arg);
+ }
+
+ @Override
+ public void getProducedVariablesExceptNestedPlans(Collection<LogicalVariable> vars) {
+ // do nothing
+ }
+
+ @Override
+ public void getUsedVariablesExceptNestedPlans(Collection<LogicalVariable> vars) {
+ // do nothing
+ }
+
+ @Override
+ public IVariableTypeEnvironment computeOutputTypeEnvironment(ITypingContext ctx) throws AlgebricksException {
+ int n = 0;
+ for (ILogicalPlan p : nestedPlans) {
+ n += p.getRoots().size();
+ }
+ ITypeEnvPointer[] envPointers = new ITypeEnvPointer[n + 1];
+ envPointers[0] = new OpRefTypeEnvPointer(inputs.get(0), ctx);
+ int i = 1;
+ for (ILogicalPlan p : nestedPlans) {
+ for (Mutable<ILogicalOperator> r : p.getRoots()) {
+ envPointers[i] = new OpRefTypeEnvPointer(r, ctx);
+ i++;
+ }
+ }
+ return new PropagatingTypeEnvironment(ctx.getExpressionTypeComputer(), ctx.getNullableTypeComputer(),
+ ctx.getMetadataProvider(), TypePropagationPolicy.LEFT_OUTER, envPointers);
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/UnnestMapOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/UnnestMapOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/UnnestMapOperator.java
index 09d02f2..ebcc4f2 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/UnnestMapOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/UnnestMapOperator.java
@@ -131,4 +131,4 @@ public class UnnestMapOperator extends AbstractUnnestOperator {
public boolean isMap() {
return true;
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/UnnestOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/UnnestOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/UnnestOperator.java
index 1ee0942..ecc4772 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/UnnestOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/UnnestOperator.java
@@ -60,4 +60,4 @@ public class UnnestOperator extends AbstractUnnestNonMapOperator {
public LogicalOperatorTag getOperatorTag() {
return LogicalOperatorTag.UNNEST;
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/AbstractPhysicalOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/AbstractPhysicalOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/AbstractPhysicalOperator.java
index 27d06f0..b1c16a1 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/AbstractPhysicalOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/AbstractPhysicalOperator.java
@@ -161,4 +161,4 @@ public abstract class AbstractPhysicalOperator implements IPhysicalOperator {
throw new IllegalStateException();
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/26a15f03/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/SubplanPOperator.java
----------------------------------------------------------------------
diff --git a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/SubplanPOperator.java b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/SubplanPOperator.java
index 617e7ec..aa5672e 100644
--- a/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/SubplanPOperator.java
+++ b/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/SubplanPOperator.java
@@ -111,4 +111,4 @@ public class SubplanPOperator extends AbstractPhysicalOperator {
public boolean expensiveThanMaterialization() {
return true;
}
-}
\ No newline at end of file
+}