Removed unused folders. Moved controller interfaces into controller packages
git-svn-id: https://hyracks.googlecode.com/svn/trunk@33 123451ca-8445-de46-9d55-352943316053
diff --git a/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/api/controller/NodeCapability.java b/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/NodeCapability.java
similarity index 95%
rename from hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/api/controller/NodeCapability.java
rename to hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/NodeCapability.java
index 62d627c..65fcd44 100644
--- a/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/api/controller/NodeCapability.java
+++ b/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/NodeCapability.java
@@ -12,7 +12,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package edu.uci.ics.hyracks.api.controller;
+package edu.uci.ics.hyracks.controller;
import java.io.Serializable;
diff --git a/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/api/controller/NodeParameters.java b/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/NodeParameters.java
similarity index 95%
rename from hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/api/controller/NodeParameters.java
rename to hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/NodeParameters.java
index 3856fea..b04ad9d 100644
--- a/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/api/controller/NodeParameters.java
+++ b/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/NodeParameters.java
@@ -12,7 +12,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package edu.uci.ics.hyracks.api.controller;
+package edu.uci.ics.hyracks.controller;
import java.io.Serializable;
diff --git a/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/clustercontroller/ClusterControllerService.java b/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/clustercontroller/ClusterControllerService.java
index 543fca0..94413f4 100644
--- a/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/clustercontroller/ClusterControllerService.java
+++ b/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/clustercontroller/ClusterControllerService.java
@@ -48,9 +48,7 @@
import org.eclipse.jetty.server.handler.AbstractHandler;
import org.eclipse.jetty.server.handler.ContextHandler;
-import edu.uci.ics.hyracks.api.controller.IClusterController;
-import edu.uci.ics.hyracks.api.controller.INodeController;
-import edu.uci.ics.hyracks.api.controller.NodeParameters;
+import edu.uci.ics.hyracks.api.client.IHyracksClientInterface;
import edu.uci.ics.hyracks.api.dataflow.ActivityNodeId;
import edu.uci.ics.hyracks.api.dataflow.OperatorDescriptorId;
import edu.uci.ics.hyracks.api.dataflow.PortInstanceId;
@@ -62,6 +60,8 @@
import edu.uci.ics.hyracks.comm.Endpoint;
import edu.uci.ics.hyracks.config.CCConfig;
import edu.uci.ics.hyracks.controller.AbstractRemoteService;
+import edu.uci.ics.hyracks.controller.NodeParameters;
+import edu.uci.ics.hyracks.controller.nodecontroller.INodeController;
import edu.uci.ics.hyracks.job.JobPlan;
import edu.uci.ics.hyracks.web.WebServer;
@@ -99,6 +99,7 @@
public void start() throws Exception {
LOGGER.log(Level.INFO, "Starting ClusterControllerService");
Registry registry = LocateRegistry.createRegistry(ccConfig.port);
+ registry.rebind(IHyracksClientInterface.class.getName(), this);
registry.rebind(IClusterController.class.getName(), this);
webServer.setPort(ccConfig.httpPort);
webServer.start();
diff --git a/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/api/controller/IClusterController.java b/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/clustercontroller/IClusterController.java
similarity index 88%
rename from hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/api/controller/IClusterController.java
rename to hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/clustercontroller/IClusterController.java
index c1ed4c1..f59e712 100644
--- a/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/api/controller/IClusterController.java
+++ b/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/clustercontroller/IClusterController.java
@@ -12,13 +12,15 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package edu.uci.ics.hyracks.api.controller;
+package edu.uci.ics.hyracks.controller.clustercontroller;
import java.rmi.Remote;
import java.util.UUID;
import edu.uci.ics.hyracks.api.client.IHyracksClientInterface;
import edu.uci.ics.hyracks.api.job.statistics.StageletStatistics;
+import edu.uci.ics.hyracks.controller.NodeParameters;
+import edu.uci.ics.hyracks.controller.nodecontroller.INodeController;
public interface IClusterController extends Remote, IHyracksClientInterface {
public NodeParameters registerNode(INodeController nodeController) throws Exception;
diff --git a/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/clustercontroller/NodeControllerState.java b/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/clustercontroller/NodeControllerState.java
index e209515..a1dac8c 100644
--- a/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/clustercontroller/NodeControllerState.java
+++ b/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/clustercontroller/NodeControllerState.java
@@ -1,6 +1,6 @@
package edu.uci.ics.hyracks.controller.clustercontroller;
-import edu.uci.ics.hyracks.api.controller.INodeController;
+import edu.uci.ics.hyracks.controller.nodecontroller.INodeController;
public class NodeControllerState {
private final INodeController nodeController;
diff --git a/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/api/controller/INodeController.java b/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/nodecontroller/INodeController.java
similarity index 91%
rename from hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/api/controller/INodeController.java
rename to hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/nodecontroller/INodeController.java
index 8f46316..6eaacb1 100644
--- a/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/api/controller/INodeController.java
+++ b/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/nodecontroller/INodeController.java
@@ -12,7 +12,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package edu.uci.ics.hyracks.api.controller;
+package edu.uci.ics.hyracks.controller.nodecontroller;
import java.rmi.Remote;
import java.util.Map;
@@ -24,6 +24,8 @@
import edu.uci.ics.hyracks.api.dataflow.PortInstanceId;
import edu.uci.ics.hyracks.comm.Endpoint;
import edu.uci.ics.hyracks.config.NCConfig;
+import edu.uci.ics.hyracks.controller.NodeCapability;
+import edu.uci.ics.hyracks.controller.clustercontroller.IClusterController;
import edu.uci.ics.hyracks.job.JobPlan;
public interface INodeController extends Remote {
diff --git a/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/nodecontroller/NodeControllerService.java b/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/nodecontroller/NodeControllerService.java
index 2ebaa2e..461fc18 100644
--- a/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/nodecontroller/NodeControllerService.java
+++ b/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/controller/nodecontroller/NodeControllerService.java
@@ -38,10 +38,6 @@
import edu.uci.ics.hyracks.api.comm.IFrameReader;
import edu.uci.ics.hyracks.api.comm.IFrameWriter;
import edu.uci.ics.hyracks.api.context.IHyracksContext;
-import edu.uci.ics.hyracks.api.controller.IClusterController;
-import edu.uci.ics.hyracks.api.controller.INodeController;
-import edu.uci.ics.hyracks.api.controller.NodeCapability;
-import edu.uci.ics.hyracks.api.controller.NodeParameters;
import edu.uci.ics.hyracks.api.dataflow.ActivityNodeId;
import edu.uci.ics.hyracks.api.dataflow.Direction;
import edu.uci.ics.hyracks.api.dataflow.IActivityNode;
@@ -64,6 +60,9 @@
import edu.uci.ics.hyracks.config.NCConfig;
import edu.uci.ics.hyracks.context.HyracksContext;
import edu.uci.ics.hyracks.controller.AbstractRemoteService;
+import edu.uci.ics.hyracks.controller.NodeCapability;
+import edu.uci.ics.hyracks.controller.NodeParameters;
+import edu.uci.ics.hyracks.controller.clustercontroller.IClusterController;
import edu.uci.ics.hyracks.job.JobPlan;
import edu.uci.ics.hyracks.runtime.OperatorRunnable;
diff --git a/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/coreops/hadoop/HadoopReadOperatorDescriptor.java b/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/coreops/hadoop/HadoopReadOperatorDescriptor.java
index c17e62e..b5fc1ac 100644
--- a/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/coreops/hadoop/HadoopReadOperatorDescriptor.java
+++ b/hyracks/hyracks-core/src/main/java/edu/uci/ics/hyracks/coreops/hadoop/HadoopReadOperatorDescriptor.java
@@ -38,11 +38,11 @@
import edu.uci.ics.hyracks.api.constraints.ExplicitPartitionConstraint;
import edu.uci.ics.hyracks.api.constraints.LocationConstraint;
import edu.uci.ics.hyracks.api.constraints.PartitionConstraint;
-import edu.uci.ics.hyracks.api.controller.IClusterController;
-import edu.uci.ics.hyracks.api.controller.INodeController;
import edu.uci.ics.hyracks.api.dataflow.value.RecordDescriptor;
import edu.uci.ics.hyracks.api.job.JobSpecification;
import edu.uci.ics.hyracks.config.NCConfig;
+import edu.uci.ics.hyracks.controller.clustercontroller.IClusterController;
+import edu.uci.ics.hyracks.controller.nodecontroller.INodeController;
import edu.uci.ics.hyracks.coreops.file.IRecordReader;
import edu.uci.ics.hyracks.hadoop.util.DatatypeHelper;
import edu.uci.ics.hyracks.hadoop.util.HadoopAdapter;