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:55 UTC
[4/5] incubator-asterixdb-hyracks git commit: remove end-of-line
whitespace
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/IHyracksClientConnection.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/IHyracksClientConnection.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/IHyracksClientConnection.java
index 7e5de94..824c914 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/IHyracksClientConnection.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/client/IHyracksClientConnection.java
@@ -34,13 +34,13 @@ import org.apache.hyracks.api.topology.ClusterTopology;
/**
* Interface used by clients to communicate with the Hyracks Cluster Controller.
- *
+ *
* @author vinayakb
*/
public interface IHyracksClientConnection {
/**
* Gets the status of the specified Job.
- *
+ *
* @param jobId
* JobId of the Job
* @return {@link JobStatus}
@@ -50,7 +50,7 @@ public interface IHyracksClientConnection {
/**
* Gets detailed information about the specified Job.
- *
+ *
* @param jobId
* JobId of the Job
* @return {@link JobStatus}
@@ -60,7 +60,7 @@ public interface IHyracksClientConnection {
/**
* Start the specified Job.
- *
+ *
* @param appName
* Name of the application
* @param jobSpec
@@ -71,7 +71,7 @@ public interface IHyracksClientConnection {
/**
* Start the specified Job.
- *
+ *
* @param appName
* Name of the application
* @param jobSpec
@@ -84,7 +84,7 @@ public interface IHyracksClientConnection {
/**
* Start the specified Job.
- *
+ *
* @param appName
* Name of the application
* @param acggf
@@ -97,7 +97,7 @@ public interface IHyracksClientConnection {
/**
* Gets the IP Address and port for the DatasetDirectoryService wrapped in NetworkAddress
- *
+ *
* @return {@link NetworkAddress}
* @throws Exception
*/
@@ -106,7 +106,7 @@ public interface IHyracksClientConnection {
/**
* Waits until the specified job has completed, either successfully or has
* encountered a permanent failure.
- *
+ *
* @param jobId
* JobId of the Job
* @throws Exception
@@ -115,14 +115,14 @@ public interface IHyracksClientConnection {
/**
* Gets a map of node controller names to node information.
- *
+ *
* @return Map of node name to node information.
*/
public Map<String, NodeControllerInfo> getNodeControllerInfos() throws Exception;
/**
* Get the cluster topology
- *
+ *
* @return the cluster topology
* @throws Exception
*/
@@ -130,7 +130,7 @@ public interface IHyracksClientConnection {
/**
* Deploy the user-defined jars to the cluster
- *
+ *
* @param jars
* a list of user-defined jars
*/
@@ -138,7 +138,7 @@ public interface IHyracksClientConnection {
/**
* undeploy a certain deployment
- *
+ *
* @param jars
* a list of user-defined jars
*/
@@ -146,7 +146,7 @@ public interface IHyracksClientConnection {
/**
* Start the specified Job.
- *
+ *
* @param deploymentId
* the id of the specific deployment
* @param jobSpec
@@ -157,7 +157,7 @@ public interface IHyracksClientConnection {
/**
* Start the specified Job.
- *
+ *
* @param deploymentId
* the id of the specific deployment
* @param jobSpec
@@ -171,7 +171,7 @@ public interface IHyracksClientConnection {
/**
* Start the specified Job.
- *
+ *
* @param deploymentId
* the id of the specific deployment
* @param acggf
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/IConnectorDescriptor.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/IConnectorDescriptor.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/IConnectorDescriptor.java
index 70f8f7d..81a0290 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/IConnectorDescriptor.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/IConnectorDescriptor.java
@@ -36,13 +36,13 @@ import org.apache.hyracks.api.job.ActivityCluster;
/**
* Connector that connects operators in a Job.
- *
+ *
* @author vinayakb
*/
public interface IConnectorDescriptor extends Serializable {
/**
* Gets the id of the connector.
- *
+ *
* @return
*/
public ConnectorDescriptorId getConnectorId();
@@ -50,7 +50,7 @@ public interface IConnectorDescriptor extends Serializable {
/**
* Factory method to create the send side writer that writes into this
* connector.
- *
+ *
* @param ctx
* Context
* @param recordDesc
@@ -73,7 +73,7 @@ public interface IConnectorDescriptor extends Serializable {
/**
* Factory metod to create the receive side reader that reads data from this
* connector.
- *
+ *
* @param ctx
* Context
* @param recordDesc
@@ -92,7 +92,7 @@ public interface IConnectorDescriptor extends Serializable {
/**
* Contribute any scheduling constraints imposed by this connector
- *
+ *
* @param constraintAcceptor
* - Constraint Acceptor
* @param ac
@@ -131,9 +131,9 @@ public interface IConnectorDescriptor extends Serializable {
/**
* Translate this connector descriptor to JSON.
- *
+ *
* @return
* @throws JSONException
*/
public JSONObject toJSON() throws JSONException;
-}
\ 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/dataflow/IDataReader.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/IDataReader.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/IDataReader.java
index 7202235..3eb0367 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/IDataReader.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/IDataReader.java
@@ -22,13 +22,13 @@ import org.apache.hyracks.api.exceptions.HyracksDataException;
/**
* Provides data to a consumer.
- *
+ *
* @author vinayakb
*/
public interface IDataReader<T> {
/**
* Reads one data item.
- *
+ *
* @return data. <code>null</code> indicates end of stream.
* @throws Exception
*/
@@ -36,8 +36,8 @@ public interface IDataReader<T> {
/**
* Closes this reader.
- *
+ *
* @throws Exception
*/
public void close() throws HyracksDataException;
-}
\ 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/dataflow/IDataWriter.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/IDataWriter.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/IDataWriter.java
index 0b8ffc0..9125b1c 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/IDataWriter.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/IDataWriter.java
@@ -50,4 +50,4 @@ public interface IDataWriter<T> {
* @throws Exception
*/
public void close() throws HyracksDataException;
-}
\ 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/dataflow/IOperatorDescriptor.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/IOperatorDescriptor.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/IOperatorDescriptor.java
index 32b4e2b..1b85fbd 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/IOperatorDescriptor.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/IOperatorDescriptor.java
@@ -29,34 +29,34 @@ import org.apache.hyracks.api.dataflow.value.RecordDescriptor;
/**
* Descriptor for operators in Hyracks.
- *
+ *
* @author vinayakb
*/
public interface IOperatorDescriptor extends Serializable {
/**
* Returns the id of the operator.
- *
+ *
* @return operator id
*/
public OperatorDescriptorId getOperatorId();
/**
* Returns the number of inputs into this operator.
- *
+ *
* @return Number of inputs.
*/
public int getInputArity();
/**
* Returns the number of outputs out of this operator.
- *
+ *
* @return Number of outputs.
*/
public int getOutputArity();
/**
* Gets the output record descriptor
- *
+ *
* @return Array of RecordDescriptor, one per output.
*/
public RecordDescriptor[] getOutputRecordDescriptors();
@@ -64,7 +64,7 @@ public interface IOperatorDescriptor extends Serializable {
/**
* Contributes the activity graph that describes the behavior of this
* operator.
- *
+ *
* @param builder
* - graph builder
*/
@@ -72,7 +72,7 @@ public interface IOperatorDescriptor extends Serializable {
/**
* Contributes any scheduling constraints imposed by this operator.
- *
+ *
* @param constraintAcceptor
* - Constraint Acceptor
* @param plan
@@ -94,4 +94,4 @@ public interface IOperatorDescriptor extends Serializable {
* Translates this operator descriptor to JSON.
*/
public JSONObject toJSON() throws JSONException;
-}
\ 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/dataflow/value/IPredicateEvaluator.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IPredicateEvaluator.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IPredicateEvaluator.java
index ff1fd0c..5fbc1ab 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IPredicateEvaluator.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IPredicateEvaluator.java
@@ -22,7 +22,7 @@ package org.apache.hyracks.api.dataflow.value;
import org.apache.hyracks.api.comm.IFrameTupleAccessor;
/*
- * Compares two tuples to make sure that records, whose comparison keys are NULL do not pass comparator filter
+ * Compares two tuples to make sure that records, whose comparison keys are NULL do not pass comparator filter
*/
public interface IPredicateEvaluator {
public boolean evaluate(IFrameTupleAccessor fta0, int tupId0, IFrameTupleAccessor fta1, int tupId1);
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IPredicateEvaluatorFactory.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IPredicateEvaluatorFactory.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IPredicateEvaluatorFactory.java
index 89bb24a..eb94514 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IPredicateEvaluatorFactory.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IPredicateEvaluatorFactory.java
@@ -22,7 +22,7 @@ package org.apache.hyracks.api.dataflow.value;
import java.io.Serializable;
/*
- * Provides PredicateEvaluator for equi-join related operators
+ * Provides PredicateEvaluator for equi-join related operators
*/
public interface IPredicateEvaluatorFactory extends Serializable {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IPredicateEvaluatorFactoryProvider.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IPredicateEvaluatorFactoryProvider.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IPredicateEvaluatorFactoryProvider.java
index 6da25c3..3eefc29 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IPredicateEvaluatorFactoryProvider.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IPredicateEvaluatorFactoryProvider.java
@@ -22,7 +22,7 @@ package org.apache.hyracks.api.dataflow.value;
import java.io.Serializable;
/*
- * Provides PredicateEvaluatorFactory based on (equi-join) keys
+ * Provides PredicateEvaluatorFactory based on (equi-join) keys
*/
public interface IPredicateEvaluatorFactoryProvider extends Serializable {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IResultSerializer.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IResultSerializer.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IResultSerializer.java
index 39f9ce8..cbd808b 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IResultSerializer.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IResultSerializer.java
@@ -31,7 +31,7 @@ public interface IResultSerializer extends Serializable {
/**
* Method to serialize the result and append it to the provided output stream
- *
+ *
* @param tAccess
* - A frame tuple accessor object that contains the original data to be serialized
* @param tIdx
@@ -39,4 +39,4 @@ public interface IResultSerializer extends Serializable {
* @return true if the tuple was appended successfully, else false.
*/
public boolean appendTuple(IFrameTupleAccessor tAccess, int tIdx) throws HyracksDataException;
-}
\ 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/dataflow/value/IResultSerializerFactory.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IResultSerializerFactory.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IResultSerializerFactory.java
index 2c4b000..f21913c 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IResultSerializerFactory.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/IResultSerializerFactory.java
@@ -24,10 +24,10 @@ import java.io.Serializable;
public interface IResultSerializerFactory extends Serializable {
/**
* Creates a result serialized appender
- *
+ *
* @param printStream
* - A print stream object to which the serialized results will be written.
* @return A new instance of result serialized appender.
*/
public IResultSerializer createResultSerializer(RecordDescriptor recordDesc, PrintStream printStream);
-}
\ 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/dataflow/value/ISerializerDeserializer.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/ISerializerDeserializer.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/ISerializerDeserializer.java
index a93de4c..065e32d 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/ISerializerDeserializer.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/ISerializerDeserializer.java
@@ -27,7 +27,7 @@ import org.apache.hyracks.api.exceptions.HyracksDataException;
public interface ISerializerDeserializer<T> extends Serializable {
/**
* Deserialization method.
- *
+ *
* @param in
* - Stream to read instance from.
* @return A new instance of T with data.
@@ -36,7 +36,7 @@ public interface ISerializerDeserializer<T> extends Serializable {
/**
* Serialization method.
- *
+ *
* @param instance
* - the instance to serialize.
* @param out
@@ -49,4 +49,4 @@ public interface ISerializerDeserializer<T> extends Serializable {
* T deserialize(DataInput in, T mutable)
* to provide deserialization without creating objects
*/
-}
\ 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/dataflow/value/JSONSerializable.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/JSONSerializable.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/JSONSerializable.java
index 9b8bf34..391b637 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/JSONSerializable.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/JSONSerializable.java
@@ -24,8 +24,8 @@ import org.json.JSONObject;
public interface JSONSerializable {
/**
* Returns the JSON representation of the object.
- *
+ *
* @return A new JSONObject instance representing this Java object.
*/
public JSONObject toJSON() throws JSONException;
-}
\ 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/dataset/IHyracksDatasetDirectoryServiceConnection.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataset/IHyracksDatasetDirectoryServiceConnection.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataset/IHyracksDatasetDirectoryServiceConnection.java
index 6799690..200f5e5 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataset/IHyracksDatasetDirectoryServiceConnection.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataset/IHyracksDatasetDirectoryServiceConnection.java
@@ -24,7 +24,7 @@ import org.apache.hyracks.api.job.JobId;
public interface IHyracksDatasetDirectoryServiceConnection {
/**
* Gets the result status for the given result set.
- *
+ *
* @param jobId
* ID of the job
* @param rsId
@@ -36,7 +36,7 @@ public interface IHyracksDatasetDirectoryServiceConnection {
/**
* Gets the IP Addresses and ports for the partition generating the result for each location.
- *
+ *
* @param jobId
* ID of the job
* @param rsId
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataset/IHyracksDatasetDirectoryServiceInterface.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataset/IHyracksDatasetDirectoryServiceInterface.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataset/IHyracksDatasetDirectoryServiceInterface.java
index 596bdf1..56c0af9 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataset/IHyracksDatasetDirectoryServiceInterface.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataset/IHyracksDatasetDirectoryServiceInterface.java
@@ -24,7 +24,7 @@ import org.apache.hyracks.api.job.JobId;
public interface IHyracksDatasetDirectoryServiceInterface {
/**
* Gets the result status for the given result set.
- *
+ *
* @param jobId
* ID of the job
* @param rsId
@@ -36,7 +36,7 @@ public interface IHyracksDatasetDirectoryServiceInterface {
/**
* Gets the IP Addresses and ports for the partition generating the result for each location.
- *
+ *
* @param jobId
* ID of the job
* @param rsId
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/deployment/DeploymentId.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/deployment/DeploymentId.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/deployment/DeploymentId.java
index 04fc0d8..2e32a70 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/deployment/DeploymentId.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/deployment/DeploymentId.java
@@ -28,7 +28,7 @@ import org.apache.hyracks.api.io.IWritable;
/**
* The representation of a deployment id
- *
+ *
* @author yingyib
*/
public class DeploymentId implements IWritable, Serializable {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/IJobSerializerDeserializer.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/IJobSerializerDeserializer.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/IJobSerializerDeserializer.java
index 14473ce..f943a4e 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/IJobSerializerDeserializer.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/IJobSerializerDeserializer.java
@@ -27,14 +27,14 @@ import org.apache.hyracks.api.exceptions.HyracksException;
/**
* The serializer/deserializer/classloader interface for job/task information such as job specifications, activity graphs and so on.
- *
+ *
* @author yingyib
*/
public interface IJobSerializerDeserializer {
/**
* Deserialize the bytes to an object
- *
+ *
* @param bytes
* the binary content of an object
* @return the deserialized object
@@ -44,7 +44,7 @@ public interface IJobSerializerDeserializer {
/**
* Serialize a object into bytes
- *
+ *
* @param object
* a Serializable Java object
* @return
@@ -55,7 +55,7 @@ public interface IJobSerializerDeserializer {
/**
* Load a class by its name
- *
+ *
* @param className
* the name of the class
* @return
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/IJobSerializerDeserializerContainer.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/IJobSerializerDeserializerContainer.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/IJobSerializerDeserializerContainer.java
index 52959fd..e63c18b 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/IJobSerializerDeserializerContainer.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/IJobSerializerDeserializerContainer.java
@@ -25,7 +25,7 @@ public interface IJobSerializerDeserializerContainer {
/**
* Get the IJobSerializerDeserializer implementation instance for a specific deployment id
- *
+ *
* @param deploymentId
* @return
*/
@@ -33,7 +33,7 @@ public interface IJobSerializerDeserializerContainer {
/**
* Add a deployment with the job serializer deserializer
- *
+ *
* @param deploymentId
* @param jobSerDe
*/
@@ -41,7 +41,7 @@ public interface IJobSerializerDeserializerContainer {
/**
* Remove a deployment
- *
+ *
* @param deploymentId
*/
public void removeJobSerializerDeserializer(DeploymentId deploymentId);
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/profiling/counters/ICounter.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/profiling/counters/ICounter.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/profiling/counters/ICounter.java
index f7ee39e..987b86b 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/profiling/counters/ICounter.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/profiling/counters/ICounter.java
@@ -21,14 +21,14 @@ package org.apache.hyracks.api.job.profiling.counters;
public interface ICounter {
/**
* Get the fully-qualified name of the counter.
- *
+ *
* @return Name of the counter.
*/
public String getName();
/**
* Update the value of the counter to be current + delta.
- *
+ *
* @param delta
* - Amount to change the counter value by.
* @return the new value after update.
@@ -37,7 +37,7 @@ public interface ICounter {
/**
* Set the value of the counter.
- *
+ *
* @param value
* - New value of the counter.
* @return Old value of the counter.
@@ -46,8 +46,8 @@ public interface ICounter {
/**
* Get the value of the counter.
- *
+ *
* @return the value of the counter.
*/
public long get();
-}
\ 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/job/profiling/counters/ICounterContext.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/profiling/counters/ICounterContext.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/profiling/counters/ICounterContext.java
index cd09d0c..b328daf 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/profiling/counters/ICounterContext.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/job/profiling/counters/ICounterContext.java
@@ -20,13 +20,13 @@ package org.apache.hyracks.api.job.profiling.counters;
/**
* A namespace that holds named counters.
- *
+ *
* @author vinayakb
*/
public interface ICounterContext {
/**
* Get a counter with the specified name.
- *
+ *
* @param name
* - Name of the counter to get.
* @param create
@@ -36,4 +36,4 @@ public interface ICounterContext {
* else returns <code>null</code>.
*/
public ICounter getCounter(String name, boolean create);
-}
\ 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/rewriter/ActivityClusterGraphRewriter.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/ActivityClusterGraphRewriter.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/ActivityClusterGraphRewriter.java
index 8570a78..38e7fbe 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/ActivityClusterGraphRewriter.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/ActivityClusterGraphRewriter.java
@@ -46,7 +46,7 @@ import org.apache.hyracks.api.rewriter.runtime.SuperActivity;
* DAGs into super activities.
* </p>
* Each super activity internally maintains a DAG and execute it at the runtime.
- *
+ *
* @author yingyib
*/
public class ActivityClusterGraphRewriter {
@@ -56,7 +56,7 @@ public class ActivityClusterGraphRewriter {
* rewrite an activity cluster graph to eliminate
* all one-to-one connections and merge one-to-one connected
* DAGs into super activities.
- *
+ *
* @param acg
* the activity cluster graph
*/
@@ -75,7 +75,7 @@ public class ActivityClusterGraphRewriter {
/**
* rewrite the blocking relationship among activity cluster
- *
+ *
* @param ac
* the activity cluster to be rewritten
*/
@@ -119,7 +119,7 @@ public class ActivityClusterGraphRewriter {
/**
* rewrite an activity cluster internally
- *
+ *
* @param ac
* the activity cluster to be rewritten
*/
@@ -323,7 +323,7 @@ public class ActivityClusterGraphRewriter {
/**
* Create a new super activity
- *
+ *
* @param acg
* the activity cluster
* @param superActivities
@@ -351,7 +351,7 @@ public class ActivityClusterGraphRewriter {
/**
* One super activity swallows another existing super activity.
- *
+ *
* @param superActivities
* the map from activity id to current super activities
* @param toBeExpendedMap
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/OneToOneConnectedActivityCluster.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/OneToOneConnectedActivityCluster.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/OneToOneConnectedActivityCluster.java
index 5ebf55a..68041bb 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/OneToOneConnectedActivityCluster.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/OneToOneConnectedActivityCluster.java
@@ -31,7 +31,7 @@ import org.apache.hyracks.api.job.ActivityClusterId;
/**
* All the connectors in an OneToOneConnectedCluster are OneToOneConnectorDescriptors.
- *
+ *
* @author yingyib
*/
public class OneToOneConnectedActivityCluster extends ActivityCluster {
@@ -49,7 +49,7 @@ public class OneToOneConnectedActivityCluster extends ActivityCluster {
/**
* Set up the mapping of the cluster's output channel to an internal activity and its output channel
- *
+ *
* @param clusterOutputIndex
* the output channel index for the cluster
* @param activityId
@@ -64,7 +64,7 @@ public class OneToOneConnectedActivityCluster extends ActivityCluster {
/**
* get the an internal activity and its output channel of a cluster output channel
- *
+ *
* @param clusterOutputIndex
* the output channel index for the cluster
* @return a pair containing the activity id of the corresponding internal activity and the output channel index
@@ -75,7 +75,7 @@ public class OneToOneConnectedActivityCluster extends ActivityCluster {
/**
* Set up the mapping of the cluster's input channel to an internal activity and input output channel
- *
+ *
* @param clusterInputIndex
* the input channel index for the cluster
* @param activityId
@@ -90,7 +90,7 @@ public class OneToOneConnectedActivityCluster extends ActivityCluster {
/**
* get the an internal activity and its input channel of a cluster input channel
- *
+ *
* @param clusterOutputIndex
* the output channel index for the cluster
* @return a pair containing the activity id of the corresponding internal activity and the output channel index
@@ -101,7 +101,7 @@ public class OneToOneConnectedActivityCluster extends ActivityCluster {
/**
* Get the cluster input channel of an input-boundary activity and its input channel
- *
+ *
* @param activityInputChannel
* the input-boundary activity and its input channel
* @return the cluster input channel
@@ -113,7 +113,7 @@ public class OneToOneConnectedActivityCluster extends ActivityCluster {
/**
* Get the cluster output channel of an input-boundary activity and its output channel
- *
+ *
* @param activityOutputChannel
* the output-boundary activity and its output channel
* @return the cluster output channel
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/runtime/SuperActivity.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/runtime/SuperActivity.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/runtime/SuperActivity.java
index 9f9809d..2f3c72b 100644
--- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/runtime/SuperActivity.java
+++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/runtime/SuperActivity.java
@@ -42,7 +42,7 @@ import org.apache.hyracks.api.rewriter.OneToOneConnectedActivityCluster;
/**
* This class can be used to execute a DAG of activities inside which
* there are only one-to-one connectors.
- *
+ *
* @author yingyib
*/
public class SuperActivity extends OneToOneConnectedActivityCluster implements IActivity {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-client/src/main/java/org/apache/hyracks/client/stats/IClusterCounterContext.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-client/src/main/java/org/apache/hyracks/client/stats/IClusterCounterContext.java b/hyracks/hyracks-client/src/main/java/org/apache/hyracks/client/stats/IClusterCounterContext.java
index 3f37ac5..a04a61c 100644
--- a/hyracks/hyracks-client/src/main/java/org/apache/hyracks/client/stats/IClusterCounterContext.java
+++ b/hyracks/hyracks-client/src/main/java/org/apache/hyracks/client/stats/IClusterCounterContext.java
@@ -25,5 +25,5 @@ import org.apache.hyracks.api.job.profiling.counters.ICounterContext;
public interface IClusterCounterContext extends ICounterContext {
public ICounter getCounter(String machineName, String counterName, boolean create);
-
+
}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-client/src/main/java/org/apache/hyracks/client/stats/impl/ClientCounterContext.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-client/src/main/java/org/apache/hyracks/client/stats/impl/ClientCounterContext.java b/hyracks/hyracks-client/src/main/java/org/apache/hyracks/client/stats/impl/ClientCounterContext.java
index 29d1184..74b61b2 100644
--- a/hyracks/hyracks-client/src/main/java/org/apache/hyracks/client/stats/impl/ClientCounterContext.java
+++ b/hyracks/hyracks-client/src/main/java/org/apache/hyracks/client/stats/impl/ClientCounterContext.java
@@ -146,7 +146,7 @@ public class ClientCounterContext implements IClusterCounterContext {
/**
* Update counters
- *
+ *
* @param jo
* the Profile JSON object
*/
@@ -205,7 +205,7 @@ public class ClientCounterContext implements IClusterCounterContext {
/**
* Request a counter from the slave machine
- *
+ *
* @param slaveMachine
* @return the JSON string from the slave machine
*/
@@ -275,4 +275,4 @@ public class ClientCounterContext implements IClusterCounterContext {
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/scheduler/JobScheduler.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/scheduler/JobScheduler.java b/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/scheduler/JobScheduler.java
index f221530..5813700 100644
--- a/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/scheduler/JobScheduler.java
+++ b/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/scheduler/JobScheduler.java
@@ -221,7 +221,7 @@ public class JobScheduler {
* Runnability rank has the following semantics
* Runnability(Runnable TaskCluster depending on completed TaskClusters) = {RUNNABLE, 0}
* Runnability(Runnable TaskCluster) = max(Rank(Dependent TaskClusters)) + 1
- * Runnability(Non-schedulable TaskCluster) = {NOT_RUNNABLE, _}
+ * Runnability(Non-schedulable TaskCluster) = {NOT_RUNNABLE, _}
*/
private Runnability assignRunnabilityRank(TaskCluster goal, Map<TaskCluster, Runnability> runnabilityMap) {
if (LOGGER.isLoggable(Level.FINE)) {
@@ -626,7 +626,7 @@ public class JobScheduler {
/**
* Indicates that a single task attempt has encountered a failure.
- *
+ *
* @param ta
* - Failed Task Attempt
* @param ac
@@ -661,7 +661,7 @@ public class JobScheduler {
/**
* Indicates that the provided set of nodes have left the cluster.
- *
+ *
* @param deadNodes
* - Set of failed nodes
*/
@@ -749,4 +749,4 @@ public class JobScheduler {
}
return jobLogObject;
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/work/CliDeployBinaryWork.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/work/CliDeployBinaryWork.java b/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/work/CliDeployBinaryWork.java
index 880878d..741c641 100644
--- a/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/work/CliDeployBinaryWork.java
+++ b/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/work/CliDeployBinaryWork.java
@@ -39,7 +39,7 @@ import org.apache.hyracks.control.common.work.SynchronizableWork;
* It first deploys the jar to CC application context.
* Then, it remotely calls each NC service to deploy the jars listed as http URLs.
* NOTE: in current implementation, a user cannot deploy with the same deployment id simultaneously.
- *
+ *
* @author yingyib
*/
public class CliDeployBinaryWork extends SynchronizableWork {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/work/CliUnDeployBinaryWork.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/work/CliUnDeployBinaryWork.java b/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/work/CliUnDeployBinaryWork.java
index 685501e..5f97ce2 100644
--- a/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/work/CliUnDeployBinaryWork.java
+++ b/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/work/CliUnDeployBinaryWork.java
@@ -37,7 +37,7 @@ import org.apache.hyracks.control.common.work.SynchronizableWork;
* It first undeploys the jar to CC application context by giving it a deployment id.
* Then, it remotely calls each NC service to undeploy by giving them a deployment id.
* NOTE: in current implementation, a user cannot undeploy with the same deployment id simultaneously.
- *
+ *
* @author yingyib
*/
public class CliUnDeployBinaryWork extends SynchronizableWork {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/work/NotifyDeployBinaryWork.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/work/NotifyDeployBinaryWork.java b/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/work/NotifyDeployBinaryWork.java
index 75dfe03..f4b80b1 100644
--- a/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/work/NotifyDeployBinaryWork.java
+++ b/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/work/NotifyDeployBinaryWork.java
@@ -26,7 +26,7 @@ import org.apache.hyracks.control.common.deployment.DeploymentStatus;
/***
* This is the work happens on the CC when CC gets a deployment or undeployment notification status message from one NC.
- *
+ *
* @author yingyib
*/
public class NotifyDeployBinaryWork extends AbstractHeartbeatWork {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/ClassLoaderJobSerializerDeserializer.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/ClassLoaderJobSerializerDeserializer.java b/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/ClassLoaderJobSerializerDeserializer.java
index 2880cb6..60ff2d3 100644
--- a/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/ClassLoaderJobSerializerDeserializer.java
+++ b/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/ClassLoaderJobSerializerDeserializer.java
@@ -33,7 +33,7 @@ import org.apache.hyracks.api.util.JavaSerializationUtils;
/**
* This is the IJobSerializerDeserializer implementation for jobs with dynamic deployed jars.
- *
+ *
* @author yingyib
*/
public class ClassLoaderJobSerializerDeserializer implements IJobSerializerDeserializer {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/DeploymentRun.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/DeploymentRun.java b/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/DeploymentRun.java
index a50233f..416b0e6 100644
--- a/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/DeploymentRun.java
+++ b/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/DeploymentRun.java
@@ -25,7 +25,7 @@ import java.util.TreeSet;
/**
* The class maintain the status of a deployment process and the states
* of all slave machines involved in the deployment.
- *
+ *
* @author yingyib
*/
public class DeploymentRun implements IDeploymentStatusConditionVariable {
@@ -39,7 +39,7 @@ public class DeploymentRun implements IDeploymentStatusConditionVariable {
/**
* One notify the deployment status
- *
+ *
* @param nodeId
* @param status
*/
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/DeploymentUtils.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/DeploymentUtils.java b/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/DeploymentUtils.java
index fba5b54..aaf2e20 100644
--- a/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/DeploymentUtils.java
+++ b/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/DeploymentUtils.java
@@ -44,7 +44,7 @@ import org.apache.hyracks.control.common.context.ServerContext;
/**
* A utility class which is in charge of the actual work of deployments.
- *
+ *
* @author yingyib
*/
public class DeploymentUtils {
@@ -53,7 +53,7 @@ public class DeploymentUtils {
/**
* undeploy an existing deployment
- *
+ *
* @param deploymentId
* the deployment id
* @param container
@@ -78,7 +78,7 @@ public class DeploymentUtils {
/**
* Deploying jars in NC or CC
- *
+ *
* @param deploymentId
* the deployment id
* @param urls
@@ -106,7 +106,7 @@ public class DeploymentUtils {
/**
* Deserialize bytes to an object according to a specific deployment
- *
+ *
* @param bytes
* the bytes to be deserialized
* @param deploymentId
@@ -130,7 +130,7 @@ public class DeploymentUtils {
/**
* Load a class from its class name
- *
+ *
* @param className
* @param deploymentId
* @param appCtx
@@ -153,7 +153,7 @@ public class DeploymentUtils {
/**
* Get the classloader of a specific deployment
- *
+ *
* @param deploymentId
* @param appCtx
* @return
@@ -174,7 +174,7 @@ public class DeploymentUtils {
/**
* Download remote Http URLs and return the stored local file URLs
- *
+ *
* @param urls
* the remote Http URLs
* @param deploymentDir
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/IDeploymentStatusConditionVariable.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/IDeploymentStatusConditionVariable.java b/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/IDeploymentStatusConditionVariable.java
index 0020d60..2652701 100644
--- a/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/IDeploymentStatusConditionVariable.java
+++ b/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/deployment/IDeploymentStatusConditionVariable.java
@@ -21,14 +21,14 @@ package org.apache.hyracks.control.common.deployment;
/**
* The conditional variable interface for deployment
- *
+ *
* @author yingyib
*/
public interface IDeploymentStatusConditionVariable {
/**
* synchronously wait the deployment to complete
- *
+ *
* @return the deployment status
* @throws Exception
*/
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/shutdown/ShutdownRun.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/shutdown/ShutdownRun.java b/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/shutdown/ShutdownRun.java
index 8bd7407..6912892 100644
--- a/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/shutdown/ShutdownRun.java
+++ b/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/shutdown/ShutdownRun.java
@@ -54,7 +54,7 @@ public class ShutdownRun implements IShutdownStatusConditionVariable{
wait(SHUTDOWN_TIMER_MS);
return shutdownSuccess;
}
-
+
public synchronized Set<String> getRemainingNodes(){
return shutdownNodeIds;
}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/io/profiling/IOCounterFactory.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/io/profiling/IOCounterFactory.java b/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/io/profiling/IOCounterFactory.java
index 8e5b0d7..1b7cf8f 100644
--- a/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/io/profiling/IOCounterFactory.java
+++ b/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/io/profiling/IOCounterFactory.java
@@ -23,7 +23,7 @@ public class IOCounterFactory {
/**
* Get the IOCounter for the specific underlying OS
- *
+ *
* @return an IIOCounter instance
*/
public IIOCounter getIOCounter() {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/work/DeployBinaryWork.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/work/DeployBinaryWork.java b/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/work/DeployBinaryWork.java
index 3097687..264a131 100644
--- a/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/work/DeployBinaryWork.java
+++ b/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/work/DeployBinaryWork.java
@@ -31,7 +31,7 @@ import org.apache.hyracks.control.nc.NodeControllerService;
/**
* Deploy binary work that happens at each NC
- *
+ *
* @author yingyib
*
*/
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/work/StartTasksWork.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/work/StartTasksWork.java b/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/work/StartTasksWork.java
index b3468b0..b585199 100644
--- a/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/work/StartTasksWork.java
+++ b/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/work/StartTasksWork.java
@@ -246,7 +246,7 @@ public class StartTasksWork extends AbstractWork {
/**
* Create a list of known channels for each input connector
- *
+ *
* @param td
* the task attempt id
* @param inputs
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/work/UnDeployBinaryWork.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/work/UnDeployBinaryWork.java b/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/work/UnDeployBinaryWork.java
index 381fb39..f564ff4 100644
--- a/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/work/UnDeployBinaryWork.java
+++ b/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/work/UnDeployBinaryWork.java
@@ -28,7 +28,7 @@ import org.apache.hyracks.control.nc.NodeControllerService;
/**
* undeploy binaries regarding to a deployment id
- *
+ *
* @author yingyib
*/
public class UnDeployBinaryWork extends AbstractWork {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/algorithms/BinarySearchAlgorithm.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/algorithms/BinarySearchAlgorithm.java b/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/algorithms/BinarySearchAlgorithm.java
index dca83a6..245fbd8 100644
--- a/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/algorithms/BinarySearchAlgorithm.java
+++ b/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/algorithms/BinarySearchAlgorithm.java
@@ -25,7 +25,7 @@ import org.apache.hyracks.data.std.collections.api.IValueReferenceVector;
* Performs Binary Search over a vector of value references.
* Assumption: The items in the vector are sorted in ascending order with respect
* to the specified key.
- *
+ *
* @author vinayakb
*/
public class BinarySearchAlgorithm {
@@ -39,7 +39,7 @@ public class BinarySearchAlgorithm {
* and sets the {@link #index} value that is retrievable by calling {@link #getIndex()} to refer to
* the index in the array where the key was found (if it was found), and where it should have been (if
* not found).
- *
+ *
* @param vector
* - Sorted vector of items
* @param key
@@ -68,11 +68,11 @@ public class BinarySearchAlgorithm {
/**
* Get the index as a result of binary search.
- *
+ *
* @return the index in the array where the key was found (if it was found), and where it should have been (if
* not found).
*/
public int getIndex() {
return index;
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/api/IPointableFactory.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/api/IPointableFactory.java b/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/api/IPointableFactory.java
index 9228809..5294d17 100644
--- a/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/api/IPointableFactory.java
+++ b/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/api/IPointableFactory.java
@@ -24,6 +24,6 @@ import org.apache.hyracks.api.dataflow.value.ITypeTraits;
public interface IPointableFactory extends Serializable {
public IPointable createPointable();
-
+
public ITypeTraits getTypeTraits();
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/collections/api/IValueReferenceVector.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/collections/api/IValueReferenceVector.java b/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/collections/api/IValueReferenceVector.java
index fb82166..f03dcc8 100644
--- a/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/collections/api/IValueReferenceVector.java
+++ b/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/collections/api/IValueReferenceVector.java
@@ -22,20 +22,20 @@ package org.apache.hyracks.data.std.collections.api;
* Represents an immutable vector of ValueReferences. Users of this interface make the assumption
* that it provides random access to the items in it. In other words, each of the getXXX(index) calls
* have O(1) complexity.
- *
+ *
* @author vinayakb
*/
public interface IValueReferenceVector {
/**
* Number of items in this vector.
- *
+ *
* @return - the number of items in this vector.
*/
public int getSize();
/**
* Get the byte array that contains the item referenced by <code>index</code>
- *
+ *
* @param index
* - Index of the item in the vector
* @return Byte Array that contains the item.
@@ -44,7 +44,7 @@ public interface IValueReferenceVector {
/**
* Get the start offset of the item referenced by <code>index</code>
- *
+ *
* @param index
* - Index of the item in the vector
* @return Start Offset in the Byte Array of the item
@@ -53,10 +53,10 @@ public interface IValueReferenceVector {
/**
* Get the length of the item referenced by <code>index</code>
- *
+ *
* @param index
* - Index of the item in the vector
* @return Length in the Byte Array of the item
*/
public int getLength(int index);
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/util/ArrayBackedValueStorage.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/util/ArrayBackedValueStorage.java b/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/util/ArrayBackedValueStorage.java
index 868e402..250d21a 100644
--- a/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/util/ArrayBackedValueStorage.java
+++ b/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/util/ArrayBackedValueStorage.java
@@ -25,7 +25,7 @@ import org.apache.hyracks.data.std.api.IMutableValueStorage;
import org.apache.hyracks.data.std.api.IValueReference;
public class ArrayBackedValueStorage implements IMutableValueStorage {
-
+
private final GrowableArray data = new GrowableArray();
@Override
@@ -65,4 +65,4 @@ public class ArrayBackedValueStorage implements IMutableValueStorage {
reset();
append(value);
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/comm/io/ArrayTupleBuilder.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/comm/io/ArrayTupleBuilder.java b/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/comm/io/ArrayTupleBuilder.java
index 46536f1..84ddab6 100644
--- a/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/comm/io/ArrayTupleBuilder.java
+++ b/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/comm/io/ArrayTupleBuilder.java
@@ -30,7 +30,7 @@ import org.apache.hyracks.data.std.util.GrowableArray;
/**
* Array backed tuple builder.
- *
+ *
* @author vinayakb
*/
public class ArrayTupleBuilder implements IDataOutputProvider {
@@ -53,7 +53,7 @@ public class ArrayTupleBuilder implements IDataOutputProvider {
/**
* Get the end offsets of the fields in this tuple.
- *
+ *
* @return end offsets of the fields.
*/
public int[] getFieldEndOffsets() {
@@ -62,7 +62,7 @@ public class ArrayTupleBuilder implements IDataOutputProvider {
/**
* Get the data area in this builder.
- *
+ *
* @return Data byte array.
*/
public byte[] getByteArray() {
@@ -71,7 +71,7 @@ public class ArrayTupleBuilder implements IDataOutputProvider {
/**
* Get the size of the data area.
- *
+ *
* @return data area size.
*/
public int getSize() {
@@ -80,7 +80,7 @@ public class ArrayTupleBuilder implements IDataOutputProvider {
/**
* Add a field to the tuple from a field in a frame.
- *
+ *
* @param accessor
* - Frame that contains the field to be copied into the tuple
* builder.
@@ -110,7 +110,7 @@ public class ArrayTupleBuilder implements IDataOutputProvider {
/**
* Add a field to the tuple by serializing the given object using the given
* serializer.
- *
+ *
* @param serDeser
* - Serializer
* @param instance
@@ -124,7 +124,7 @@ public class ArrayTupleBuilder implements IDataOutputProvider {
/**
* Add a field to the tuple by copying the data bytes from a byte array.
- *
+ *
* @param bytes
* - Byte array to copy the field data from.
* @param start
@@ -166,4 +166,4 @@ public class ArrayTupleBuilder implements IDataOutputProvider {
public void addFieldEndOffset() {
fEndOffsets[nextField++] = fieldData.getLength();
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/comm/io/ArrayTupleReference.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/comm/io/ArrayTupleReference.java b/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/comm/io/ArrayTupleReference.java
index f1398c0..8cb473d 100644
--- a/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/comm/io/ArrayTupleReference.java
+++ b/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/comm/io/ArrayTupleReference.java
@@ -25,7 +25,7 @@ import org.apache.hyracks.dataflow.common.data.accessors.ITupleReference;
* a frame. It is meant to be reset directly with the field slots and tuple data
* provided by ArrayTupleBuilder. The purpose is to avoid coping the built tuple
* into a frame before being able to use it as an ITupleReference.
- *
+ *
* @author alexander.behm
*/
public class ArrayTupleReference implements ITupleReference {
@@ -36,7 +36,7 @@ public class ArrayTupleReference implements ITupleReference {
this.fEndOffsets = fEndOffsets;
this.tupleData = tupleData;
}
-
+
@Override
public int getFieldCount() {
return fEndOffsets.length;
@@ -49,7 +49,7 @@ public class ArrayTupleReference implements ITupleReference {
@Override
public int getFieldStart(int fIdx) {
- return (fIdx == 0) ? 0 : fEndOffsets[fIdx - 1];
+ return (fIdx == 0) ? 0 : fEndOffsets[fIdx - 1];
}
@Override
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/data/partition/range/FieldRangePartitionComputerFactory.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/data/partition/range/FieldRangePartitionComputerFactory.java b/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/data/partition/range/FieldRangePartitionComputerFactory.java
index 06f92bb..f4da9bf 100644
--- a/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/data/partition/range/FieldRangePartitionComputerFactory.java
+++ b/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/data/partition/range/FieldRangePartitionComputerFactory.java
@@ -47,7 +47,7 @@ public class FieldRangePartitionComputerFactory implements ITuplePartitionComput
return new ITuplePartitionComputer() {
@Override
/**
- * Determine the range partition.
+ * Determine the range partition.
*/
public int partition(IFrameTupleAccessor accessor, int tIndex, int nParts) throws HyracksDataException {
if (nParts == 1) {
@@ -98,4 +98,4 @@ public class FieldRangePartitionComputerFactory implements ITuplePartitionComput
};
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/util/TupleUtils.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/util/TupleUtils.java b/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/util/TupleUtils.java
index c5b8a9f..fcc6274 100644
--- a/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/util/TupleUtils.java
+++ b/hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/util/TupleUtils.java
@@ -130,7 +130,7 @@ public class TupleUtils {
tupleCopy.reset(tupleBuilder.getFieldEndOffsets(), tupleBuilder.getByteArray());
return tupleCopy;
}
-
+
public static void copyTuple(ArrayTupleBuilder tupleBuilder, ITupleReference tuple, int numFields) throws HyracksDataException {
tupleBuilder.reset();
for (int i = 0; i < numFields; i++) {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/base/AbstractMToNConnectorDescriptor.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/base/AbstractMToNConnectorDescriptor.java b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/base/AbstractMToNConnectorDescriptor.java
index 216f410..cf4808f 100644
--- a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/base/AbstractMToNConnectorDescriptor.java
+++ b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/base/AbstractMToNConnectorDescriptor.java
@@ -42,9 +42,9 @@ public abstract class AbstractMToNConnectorDescriptor extends AbstractConnectorD
sourceBitmap.clear();
sourceBitmap.set(0, nProducerPartitions);
}
-
+
@Override
public boolean allProducersToAllConsumers(){
return true;
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/connectors/HashtableLocalityMap.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/connectors/HashtableLocalityMap.java b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/connectors/HashtableLocalityMap.java
index e6a3bb3..3e95bc6 100644
--- a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/connectors/HashtableLocalityMap.java
+++ b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/connectors/HashtableLocalityMap.java
@@ -32,7 +32,7 @@ public class HashtableLocalityMap implements ILocalityMap {
/*
* (non-Javadoc)
- *
+ *
* @see
* org.apache.hyracks.examples.text.client.aggregation.helpers.ILocalityMap
* #getConsumers(int, int)
@@ -58,7 +58,7 @@ public class HashtableLocalityMap implements ILocalityMap {
/*
* (non-Javadoc)
- *
+ *
* @see
* org.apache.hyracks.examples.text.client.aggregation.helpers.ILocalityMap
* #getConsumerPartitionCount(int)
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/connectors/LocalityAwareMToNPartitioningConnectorDescriptor.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/connectors/LocalityAwareMToNPartitioningConnectorDescriptor.java b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/connectors/LocalityAwareMToNPartitioningConnectorDescriptor.java
index a4c47c4..7856d6a 100644
--- a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/connectors/LocalityAwareMToNPartitioningConnectorDescriptor.java
+++ b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/connectors/LocalityAwareMToNPartitioningConnectorDescriptor.java
@@ -50,7 +50,7 @@ public class LocalityAwareMToNPartitioningConnectorDescriptor extends AbstractMT
/*
* (non-Javadoc)
- *
+ *
* @see
* org.apache.hyracks.api.dataflow.IConnectorDescriptor#createPartitioner
* (org.apache.hyracks.api.context.IHyracksTaskContext,
@@ -67,7 +67,7 @@ public class LocalityAwareMToNPartitioningConnectorDescriptor extends AbstractMT
/*
* (non-Javadoc)
- *
+ *
* @see org.apache.hyracks.api.dataflow.IConnectorDescriptor#
* createPartitionCollector
* (org.apache.hyracks.api.context.IHyracksTaskContext,
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/connectors/LocalityAwarePartitionDataWriter.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/connectors/LocalityAwarePartitionDataWriter.java b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/connectors/LocalityAwarePartitionDataWriter.java
index 830075c..253b3e3 100644
--- a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/connectors/LocalityAwarePartitionDataWriter.java
+++ b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/connectors/LocalityAwarePartitionDataWriter.java
@@ -63,7 +63,7 @@ public class LocalityAwarePartitionDataWriter implements IFrameWriter {
/*
* (non-Javadoc)
- *
+ *
* @see org.apache.hyracks.api.comm.IFrameWriter#open()
*/
@Override
@@ -76,7 +76,7 @@ public class LocalityAwarePartitionDataWriter implements IFrameWriter {
/*
* (non-Javadoc)
- *
+ *
* @see
* org.apache.hyracks.api.comm.IFrameWriter#nextFrame(java.nio.ByteBuffer)
*/
@@ -92,7 +92,7 @@ public class LocalityAwarePartitionDataWriter implements IFrameWriter {
/*
* (non-Javadoc)
- *
+ *
* @see org.apache.hyracks.api.comm.IFrameWriter#fail()
*/
@Override
@@ -118,7 +118,7 @@ public class LocalityAwarePartitionDataWriter implements IFrameWriter {
/*
* (non-Javadoc)
- *
+ *
* @see org.apache.hyracks.api.comm.IFrameWriter#close()
*/
@Override
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/file/PlainFileWriterOperatorDescriptor.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/file/PlainFileWriterOperatorDescriptor.java b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/file/PlainFileWriterOperatorDescriptor.java
index b687684..33ac540 100644
--- a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/file/PlainFileWriterOperatorDescriptor.java
+++ b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/file/PlainFileWriterOperatorDescriptor.java
@@ -58,7 +58,7 @@ public class PlainFileWriterOperatorDescriptor extends AbstractSingleActivityOpe
/*
* (non-Javadoc)
- *
+ *
* @see
* org.apache.hyracks.api.dataflow.IActivityNode#createPushRuntime(edu.
* uci.ics.hyracks.api.context.IHyracksContext,
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/IAggregatorDescriptor.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/IAggregatorDescriptor.java b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/IAggregatorDescriptor.java
index 1ef3b9e..4607032 100644
--- a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/IAggregatorDescriptor.java
+++ b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/IAggregatorDescriptor.java
@@ -26,14 +26,14 @@ public interface IAggregatorDescriptor {
/**
* Create an aggregate state
- *
+ *
* @return
*/
public AggregateState createAggregateStates();
/**
* Initialize the state based on the input tuple.
- *
+ *
* @param accessor
* @param tIndex
* @param fieldOutput
@@ -51,14 +51,14 @@ public interface IAggregatorDescriptor {
* too. Note that here the frame is not an input argument, since it can be
* reset outside of the aggregator (simply reset the starting index of the
* buffer).
- *
+ *
* @param state
*/
public void reset();
/**
* Aggregate the value. Aggregate state should be updated correspondingly.
- *
+ *
* @param accessor
* @param tIndex
* @param data
@@ -75,7 +75,7 @@ public interface IAggregatorDescriptor {
/**
* Output the partial aggregation result.
- *
+ *
* @param fieldOutput
* The data output for the output frame
* @param data
@@ -91,7 +91,7 @@ public interface IAggregatorDescriptor {
/**
* Output the final aggregation result.
- *
+ *
* @param fieldOutput
* The data output for the output frame
* @param data
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/IFieldAggregateDescriptor.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/IFieldAggregateDescriptor.java b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/IFieldAggregateDescriptor.java
index e8d7754..fc50f1f 100644
--- a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/IFieldAggregateDescriptor.java
+++ b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/IFieldAggregateDescriptor.java
@@ -30,13 +30,13 @@ public interface IFieldAggregateDescriptor {
/**
* Initialize the state based on the input tuple.
- *
+ *
* @param accessor
* @param tIndex
* @param fieldOutput
* The data output for the frame containing the state. This may
* be null, if the state is maintained as a java object.
- *
+ *
* Note that we have an assumption that the initialization of the
* binary state (if any) inserts the state fields into the buffer
* in a appending fashion. This means that an arbitrary initial
@@ -53,21 +53,21 @@ public interface IFieldAggregateDescriptor {
* too. Note that here the frame is not an input argument, since it can be
* reset outside of the aggregator (simply reset the starting index of the
* buffer).
- *
+ *
* @param state
*/
public void reset();
/**
* Aggregate the value. Aggregate state should be updated correspondingly.
- *
+ *
* @param accessor
* @param tIndex
* @param data
* The buffer containing the state, if frame-based-state is used.
* This means that it can be null if java-object-based-state is
* used.
- *
+ *
* Here the length of binary state can be obtains from the state
* parameter, and if the content to be filled into that is over-
* flowing (larger than the reversed space), error should be
@@ -82,7 +82,7 @@ public interface IFieldAggregateDescriptor {
/**
* Output the partial aggregation result.
- *
+ *
* @param fieldOutput
* The data output for the output frame
* @param data
@@ -97,7 +97,7 @@ public interface IFieldAggregateDescriptor {
/**
* Output the final aggregation result.
- *
+ *
* @param fieldOutput
* The data output for the output frame
* @param data
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/AvgFieldGroupAggregatorFactory.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/AvgFieldGroupAggregatorFactory.java b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/AvgFieldGroupAggregatorFactory.java
index 8a87486..7acd687 100644
--- a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/AvgFieldGroupAggregatorFactory.java
+++ b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/AvgFieldGroupAggregatorFactory.java
@@ -50,7 +50,7 @@ public class AvgFieldGroupAggregatorFactory implements IFieldAggregateDescriptor
/*
* (non-Javadoc)
- *
+ *
* @see org.apache.hyracks.dataflow.std.aggregations.
* IFieldAggregateDescriptorFactory
* #createAggregator(org.apache.hyracks.api.context.IHyracksTaskContext,
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/AvgFieldMergeAggregatorFactory.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/AvgFieldMergeAggregatorFactory.java b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/AvgFieldMergeAggregatorFactory.java
index ae1c16f..b77c91c 100644
--- a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/AvgFieldMergeAggregatorFactory.java
+++ b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/AvgFieldMergeAggregatorFactory.java
@@ -50,7 +50,7 @@ public class AvgFieldMergeAggregatorFactory implements IFieldAggregateDescriptor
/*
* (non-Javadoc)
- *
+ *
* @see org.apache.hyracks.dataflow.std.aggregations.
* IFieldAggregateDescriptorFactory
* #createAggregator(org.apache.hyracks.api.context.IHyracksTaskContext,
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/CountFieldAggregatorFactory.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/CountFieldAggregatorFactory.java b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/CountFieldAggregatorFactory.java
index 357a2f8..bba9900 100644
--- a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/CountFieldAggregatorFactory.java
+++ b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/CountFieldAggregatorFactory.java
@@ -47,7 +47,7 @@ public class CountFieldAggregatorFactory implements IFieldAggregateDescriptorFac
/*
* (non-Javadoc)
- *
+ *
* @see org.apache.hyracks.dataflow.std.aggregations.
* IFieldAggregateDescriptorFactory
* #createAggregator(org.apache.hyracks.api.context.IHyracksTaskContext,
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/FloatSumFieldAggregatorFactory.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/FloatSumFieldAggregatorFactory.java b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/FloatSumFieldAggregatorFactory.java
index 4a83127..771303f 100644
--- a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/FloatSumFieldAggregatorFactory.java
+++ b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/FloatSumFieldAggregatorFactory.java
@@ -43,12 +43,12 @@ public class FloatSumFieldAggregatorFactory implements
private final int aggField;
private final boolean useObjectState;
-
+
public FloatSumFieldAggregatorFactory(int aggField, boolean useObjState){
this.aggField = aggField;
this.useObjectState = useObjState;
}
-
+
/* (non-Javadoc)
* @see org.apache.hyracks.dataflow.std.group.IFieldAggregateDescriptorFactory#createAggregator(org.apache.hyracks.api.context.IHyracksTaskContext, org.apache.hyracks.api.dataflow.value.RecordDescriptor, org.apache.hyracks.api.dataflow.value.RecordDescriptor)
*/
@@ -57,12 +57,12 @@ public class FloatSumFieldAggregatorFactory implements
RecordDescriptor inRecordDescriptor,
RecordDescriptor outRecordDescriptor) throws HyracksDataException {
return new IFieldAggregateDescriptor() {
-
+
@Override
public void reset() {
-
+
}
-
+
@Override
public void outputPartialResult(DataOutput fieldOutput, byte[] data,
int offset, AggregateState state) throws HyracksDataException {
@@ -78,7 +78,7 @@ public class FloatSumFieldAggregatorFactory implements
throw new HyracksDataException("I/O exception when writing aggregation to the output buffer.");
}
}
-
+
@Override
public void outputFinalResult(DataOutput fieldOutput, byte[] data,
int offset, AggregateState state) throws HyracksDataException {
@@ -94,17 +94,17 @@ public class FloatSumFieldAggregatorFactory implements
throw new HyracksDataException("I/O exception when writing aggregation to the output buffer.");
}
}
-
+
@Override
public boolean needsObjectState() {
return useObjectState;
}
-
+
@Override
public boolean needsBinaryState() {
return !useObjectState;
}
-
+
@Override
public void init(IFrameTupleAccessor accessor, int tIndex,
DataOutput fieldOutput, AggregateState state)
@@ -125,18 +125,18 @@ public class FloatSumFieldAggregatorFactory implements
state.state = sum;
}
}
-
+
@Override
public AggregateState createState() {
return new AggregateState(new Float(0.0));
}
-
+
@Override
public void close() {
// TODO Auto-generated method stub
-
+
}
-
+
@Override
public void aggregate(IFrameTupleAccessor accessor, int tIndex,
byte[] data, int offset, AggregateState state)
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/IntSumFieldAggregatorFactory.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/IntSumFieldAggregatorFactory.java b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/IntSumFieldAggregatorFactory.java
index 9983541..511b651 100644
--- a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/IntSumFieldAggregatorFactory.java
+++ b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/IntSumFieldAggregatorFactory.java
@@ -50,7 +50,7 @@ public class IntSumFieldAggregatorFactory implements IFieldAggregateDescriptorFa
/*
* (non-Javadoc)
- *
+ *
* @see org.apache.hyracks.dataflow.std.aggregations.
* IFieldAggregateDescriptorFactory
* #createAggregator(org.apache.hyracks.api.context.IHyracksTaskContext,
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/6464d723/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/MinMaxStringFieldAggregatorFactory.java
----------------------------------------------------------------------
diff --git a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/MinMaxStringFieldAggregatorFactory.java b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/MinMaxStringFieldAggregatorFactory.java
index 4e69437..6900918 100644
--- a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/MinMaxStringFieldAggregatorFactory.java
+++ b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/aggregators/MinMaxStringFieldAggregatorFactory.java
@@ -55,7 +55,7 @@ public class MinMaxStringFieldAggregatorFactory implements IFieldAggregateDescri
/*
* (non-Javadoc)
- *
+ *
* @see
* org.apache.hyracks.dataflow.std.aggregators.IAggregatorDescriptorFactory
* #createAggregator(org.apache.hyracks.api.context.IHyracksTaskContext,