You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pa...@apache.org on 2015/11/12 22:06:57 UTC
[5/8] storm git commit: Addressing some comments.
Addressing some comments.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/8fd01161
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/8fd01161
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/8fd01161
Branch: refs/heads/master
Commit: 8fd011618f1328df669e4a8dd31edb1a2e78928b
Parents: 124c62c
Author: Parth Brahmbhatt <br...@gmail.com>
Authored: Mon Nov 9 22:31:49 2015 -0800
Committer: Parth Brahmbhatt <br...@gmail.com>
Committed: Mon Nov 9 22:31:49 2015 -0800
----------------------------------------------------------------------
.../nimbus/InMemoryTopologyAcitonNotifier.java | 53 --------------------
.../nimbus/InMemoryTopologyActionNotifier.java | 53 ++++++++++++++++++++
2 files changed, 53 insertions(+), 53 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/8fd01161/storm-core/test/jvm/backtype/storm/nimbus/InMemoryTopologyAcitonNotifier.java
----------------------------------------------------------------------
diff --git a/storm-core/test/jvm/backtype/storm/nimbus/InMemoryTopologyAcitonNotifier.java b/storm-core/test/jvm/backtype/storm/nimbus/InMemoryTopologyAcitonNotifier.java
deleted file mode 100644
index 3388a51..0000000
--- a/storm-core/test/jvm/backtype/storm/nimbus/InMemoryTopologyAcitonNotifier.java
+++ /dev/null
@@ -1,53 +0,0 @@
-/**
- * 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.
- */
-package backtype.storm.nimbus;
-
-import java.util.Map;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.HashMap;
-
-public class InMemoryTopologyAcitonNotifier implements ITopologyActionNotifierPlugin {
-
- //static to ensure eventhough the class is created using reflection we can still get
- //the topology to actions
- private static final Map<String, LinkedList<String>> topologyToActions = new HashMap<>();
-
-
- @Override
- public void prepare(Map StormConf) {
- //no-op
- }
-
- @Override
- public synchronized void notify(String topologyName, String action) {
- if(!topologyToActions.containsKey(topologyName)) {
- topologyToActions.put(topologyName, new LinkedList<String>());
- }
- topologyToActions.get(topologyName).addLast(action);
- }
-
- public List<String> getTopologyActions(String topologyName) {
- return topologyToActions.get(topologyName);
- }
-
- @Override
- public void cleanup() {
- //no-op
- }
-}
http://git-wip-us.apache.org/repos/asf/storm/blob/8fd01161/storm-core/test/jvm/backtype/storm/nimbus/InMemoryTopologyActionNotifier.java
----------------------------------------------------------------------
diff --git a/storm-core/test/jvm/backtype/storm/nimbus/InMemoryTopologyActionNotifier.java b/storm-core/test/jvm/backtype/storm/nimbus/InMemoryTopologyActionNotifier.java
new file mode 100644
index 0000000..16cac76
--- /dev/null
+++ b/storm-core/test/jvm/backtype/storm/nimbus/InMemoryTopologyActionNotifier.java
@@ -0,0 +1,53 @@
+/**
+ * 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.
+ */
+package backtype.storm.nimbus;
+
+import java.util.Map;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.HashMap;
+
+public class InMemoryTopologyActionNotifier implements ITopologyActionNotifierPlugin {
+
+ //static to ensure eventhough the class is created using reflection we can still get
+ //the topology to actions
+ private static final Map<String, LinkedList<String>> topologyToActions = new HashMap<>();
+
+
+ @Override
+ public void prepare(Map StormConf) {
+ //no-op
+ }
+
+ @Override
+ public synchronized void notify(String topologyName, String action) {
+ if(!topologyToActions.containsKey(topologyName)) {
+ topologyToActions.put(topologyName, new LinkedList<String>());
+ }
+ topologyToActions.get(topologyName).addLast(action);
+ }
+
+ public List<String> getTopologyActions(String topologyName) {
+ return topologyToActions.get(topologyName);
+ }
+
+ @Override
+ public void cleanup() {
+ //no-op
+ }
+}