You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@helix.apache.org by zz...@apache.org on 2013/09/10 02:54:13 UTC
git commit: [HELIX-109] Review Helix model package, add missing file
Updated Branches:
refs/heads/helix-logical-model 16cfa2b8b -> 73b82fc05
[HELIX-109] Review Helix model package, add missing file
Project: http://git-wip-us.apache.org/repos/asf/incubator-helix/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-helix/commit/73b82fc0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-helix/tree/73b82fc0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-helix/diff/73b82fc0
Branch: refs/heads/helix-logical-model
Commit: 73b82fc05c78710df795d25eb019d416c45f679c
Parents: 16cfa2b
Author: zzhang <zz...@apache.org>
Authored: Mon Sep 9 17:54:01 2013 -0700
Committer: zzhang <zz...@apache.org>
Committed: Mon Sep 9 17:54:01 2013 -0700
----------------------------------------------------------------------
.../stages/NewTaskAssignmentStage.java | 8 ++---
.../helix/model/ClusterConfiguration.java | 38 ++++++++++++++++++++
2 files changed, 42 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-helix/blob/73b82fc0/helix-core/src/main/java/org/apache/helix/controller/stages/NewTaskAssignmentStage.java
----------------------------------------------------------------------
diff --git a/helix-core/src/main/java/org/apache/helix/controller/stages/NewTaskAssignmentStage.java b/helix-core/src/main/java/org/apache/helix/controller/stages/NewTaskAssignmentStage.java
index 678defc..31a0614 100644
--- a/helix-core/src/main/java/org/apache/helix/controller/stages/NewTaskAssignmentStage.java
+++ b/helix-core/src/main/java/org/apache/helix/controller/stages/NewTaskAssignmentStage.java
@@ -139,10 +139,10 @@ public class NewTaskAssignmentStage extends AbstractBaseStage {
+ " transit " + message.getPartitionId() + "|" + message.getPartitionIds() + " from:"
+ message.getFromState() + " to:" + message.getToState());
- System.out.println("[dbg] Sending Message " + message.getMsgId() + " to "
- + message.getTgtName() + " transit " + message.getPartitionId() + "|"
- + message.getPartitionId() + " from: " + message.getFromState() + " to: "
- + message.getToState());
+ // System.out.println("[dbg] Sending Message " + message.getMsgId() + " to "
+ // + message.getTgtName() + " transit " + message.getPartitionId() + "|"
+ // + message.getPartitionId() + " from: " + message.getFromState() + " to: "
+ // + message.getToState());
keys.add(keyBuilder.message(message.getTgtName(), message.getId()));
}
http://git-wip-us.apache.org/repos/asf/incubator-helix/blob/73b82fc0/helix-core/src/main/java/org/apache/helix/model/ClusterConfiguration.java
----------------------------------------------------------------------
diff --git a/helix-core/src/main/java/org/apache/helix/model/ClusterConfiguration.java b/helix-core/src/main/java/org/apache/helix/model/ClusterConfiguration.java
new file mode 100644
index 0000000..04a2c82
--- /dev/null
+++ b/helix-core/src/main/java/org/apache/helix/model/ClusterConfiguration.java
@@ -0,0 +1,38 @@
+package org.apache.helix.model;
+
+import org.apache.helix.HelixProperty;
+import org.apache.helix.api.ClusterId;
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+/**
+ * Persisted configuration properties for a cluster
+ */
+public class ClusterConfiguration extends HelixProperty {
+
+ /**
+ * Instantiate for an id
+ * @param id cluster id
+ */
+ public ClusterConfiguration(ClusterId id) {
+ super(id.stringify());
+ }
+
+}