storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ptgo...@apache.org
Subject [06/18] add Apache license headers to source files
Date Fri, 13 Dec 2013 17:14:50 GMT
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/state/SynchronizeOutputCollector.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/state/SynchronizeOutputCollector.java b/storm-core/src/jvm/backtype/storm/state/SynchronizeOutputCollector.java
index 8bf56c6..9fbba6e 100644
--- a/storm-core/src/jvm/backtype/storm/state/SynchronizeOutputCollector.java
+++ b/storm-core/src/jvm/backtype/storm/state/SynchronizeOutputCollector.java
@@ -1,3 +1,20 @@
+/**
+ * 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.state;
 
 import java.util.List;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/task/GeneralTopologyContext.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/task/GeneralTopologyContext.java b/storm-core/src/jvm/backtype/storm/task/GeneralTopologyContext.java
index 3065b23..53141b1 100644
--- a/storm-core/src/jvm/backtype/storm/task/GeneralTopologyContext.java
+++ b/storm-core/src/jvm/backtype/storm/task/GeneralTopologyContext.java
@@ -1,3 +1,20 @@
+/**
+ * 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.task;
 
 import backtype.storm.Config;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/task/IBolt.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/task/IBolt.java b/storm-core/src/jvm/backtype/storm/task/IBolt.java
index 9ead806..58362c8 100644
--- a/storm-core/src/jvm/backtype/storm/task/IBolt.java
+++ b/storm-core/src/jvm/backtype/storm/task/IBolt.java
@@ -1,3 +1,20 @@
+/**
+ * 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.task;
 
 import backtype.storm.tuple.Tuple;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/task/IErrorReporter.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/task/IErrorReporter.java b/storm-core/src/jvm/backtype/storm/task/IErrorReporter.java
index d2e7e5d..ad25450 100644
--- a/storm-core/src/jvm/backtype/storm/task/IErrorReporter.java
+++ b/storm-core/src/jvm/backtype/storm/task/IErrorReporter.java
@@ -1,3 +1,20 @@
+/**
+ * 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.task;
 
 public interface IErrorReporter {

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/task/IMetricsContext.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/task/IMetricsContext.java b/storm-core/src/jvm/backtype/storm/task/IMetricsContext.java
index a12f066..a1d8bc2 100644
--- a/storm-core/src/jvm/backtype/storm/task/IMetricsContext.java
+++ b/storm-core/src/jvm/backtype/storm/task/IMetricsContext.java
@@ -1,3 +1,20 @@
+/**
+ * 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.task;
 
 import backtype.storm.metric.api.CombinedMetric;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/task/IOutputCollector.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/task/IOutputCollector.java b/storm-core/src/jvm/backtype/storm/task/IOutputCollector.java
index 8e56bfa..a62563a 100644
--- a/storm-core/src/jvm/backtype/storm/task/IOutputCollector.java
+++ b/storm-core/src/jvm/backtype/storm/task/IOutputCollector.java
@@ -1,3 +1,20 @@
+/**
+ * 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.task;
 
 import backtype.storm.tuple.Tuple;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/task/OutputCollector.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/task/OutputCollector.java b/storm-core/src/jvm/backtype/storm/task/OutputCollector.java
index d4cd6e0..620d33d 100644
--- a/storm-core/src/jvm/backtype/storm/task/OutputCollector.java
+++ b/storm-core/src/jvm/backtype/storm/task/OutputCollector.java
@@ -1,3 +1,20 @@
+/**
+ * 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.task;
 
 import backtype.storm.tuple.Tuple;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/task/ShellBolt.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/task/ShellBolt.java b/storm-core/src/jvm/backtype/storm/task/ShellBolt.java
index 3fa6741..118e90e 100644
--- a/storm-core/src/jvm/backtype/storm/task/ShellBolt.java
+++ b/storm-core/src/jvm/backtype/storm/task/ShellBolt.java
@@ -1,3 +1,20 @@
+/**
+ * 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.task;
 
 import backtype.storm.Config;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/task/TopologyContext.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/task/TopologyContext.java b/storm-core/src/jvm/backtype/storm/task/TopologyContext.java
index 038a41b..c9df979 100644
--- a/storm-core/src/jvm/backtype/storm/task/TopologyContext.java
+++ b/storm-core/src/jvm/backtype/storm/task/TopologyContext.java
@@ -1,3 +1,20 @@
+/**
+ * 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.task;
 
 import backtype.storm.generated.GlobalStreamId;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/task/WorkerTopologyContext.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/task/WorkerTopologyContext.java b/storm-core/src/jvm/backtype/storm/task/WorkerTopologyContext.java
index 0d4d17a..9c2f49b 100644
--- a/storm-core/src/jvm/backtype/storm/task/WorkerTopologyContext.java
+++ b/storm-core/src/jvm/backtype/storm/task/WorkerTopologyContext.java
@@ -1,3 +1,20 @@
+/**
+ * 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.task;
 
 import backtype.storm.generated.StormTopology;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/AckFailDelegate.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/AckFailDelegate.java b/storm-core/src/jvm/backtype/storm/testing/AckFailDelegate.java
index e7587d4..d65c8bd 100644
--- a/storm-core/src/jvm/backtype/storm/testing/AckFailDelegate.java
+++ b/storm-core/src/jvm/backtype/storm/testing/AckFailDelegate.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import java.io.Serializable;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/AckFailMapTracker.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/AckFailMapTracker.java b/storm-core/src/jvm/backtype/storm/testing/AckFailMapTracker.java
index 1eb77a9..e16afd8 100644
--- a/storm-core/src/jvm/backtype/storm/testing/AckFailMapTracker.java
+++ b/storm-core/src/jvm/backtype/storm/testing/AckFailMapTracker.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.utils.RegisteredGlobalState;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/AckTracker.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/AckTracker.java b/storm-core/src/jvm/backtype/storm/testing/AckTracker.java
index 0187f0a..ad80475 100644
--- a/storm-core/src/jvm/backtype/storm/testing/AckTracker.java
+++ b/storm-core/src/jvm/backtype/storm/testing/AckTracker.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import java.util.Map;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/BatchNumberList.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/BatchNumberList.java b/storm-core/src/jvm/backtype/storm/testing/BatchNumberList.java
index a0d8dd8..26f964a 100644
--- a/storm-core/src/jvm/backtype/storm/testing/BatchNumberList.java
+++ b/storm-core/src/jvm/backtype/storm/testing/BatchNumberList.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.coordination.BatchOutputCollector;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/BatchProcessWord.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/BatchProcessWord.java b/storm-core/src/jvm/backtype/storm/testing/BatchProcessWord.java
index 546f563..7f3eaf1 100644
--- a/storm-core/src/jvm/backtype/storm/testing/BatchProcessWord.java
+++ b/storm-core/src/jvm/backtype/storm/testing/BatchProcessWord.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.topology.BasicOutputCollector;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/BatchRepeatA.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/BatchRepeatA.java b/storm-core/src/jvm/backtype/storm/testing/BatchRepeatA.java
index e00a4ab..107f2ed 100644
--- a/storm-core/src/jvm/backtype/storm/testing/BatchRepeatA.java
+++ b/storm-core/src/jvm/backtype/storm/testing/BatchRepeatA.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.topology.BasicOutputCollector;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/BoltTracker.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/BoltTracker.java b/storm-core/src/jvm/backtype/storm/testing/BoltTracker.java
index e10b762..3fe4e7a 100644
--- a/storm-core/src/jvm/backtype/storm/testing/BoltTracker.java
+++ b/storm-core/src/jvm/backtype/storm/testing/BoltTracker.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.topology.IRichBolt;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/CompleteTopologyParam.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/CompleteTopologyParam.java b/storm-core/src/jvm/backtype/storm/testing/CompleteTopologyParam.java
index 5355ed7..91ecb57 100644
--- a/storm-core/src/jvm/backtype/storm/testing/CompleteTopologyParam.java
+++ b/storm-core/src/jvm/backtype/storm/testing/CompleteTopologyParam.java
@@ -1,50 +1,67 @@
-package backtype.storm.testing;
-
-import backtype.storm.Config;
-
-/**
- * The param class for the <code>Testing.completeTopology</code>.
- */
-public class CompleteTopologyParam {
-	/**
-	 * The mocked spout sources
-	 */
-	private MockedSources mockedSources;
-	/**
-	 * the config for the topology when it was submitted to the cluster
-	 */
-	private Config stormConf;
-	/**
-	 * whether cleanup the state?
-	 */
-	private Boolean cleanupState;
-	/**
-	 * the topology name you want to submit to the cluster
-	 */
-	private String topologyName;
-	
-	public MockedSources getMockedSources() {
-		return mockedSources;
-	}
-	public void setMockedSources(MockedSources mockedSources) {
-		this.mockedSources = mockedSources;
-	}
-	public Config getStormConf() {
-		return stormConf;
-	}
-	public void setStormConf(Config stormConf) {
-		this.stormConf = stormConf;
-	}
-	public Boolean getCleanupState() {
-		return cleanupState;
-	}
-	public void setCleanupState(Boolean cleanupState) {
-		this.cleanupState = cleanupState;
-	}
-	public String getTopologyName() {
-		return topologyName;
-	}
-	public void setTopologyName(String topologyName) {
-		this.topologyName = topologyName;
-	}
-}
+/**
+ * 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.testing;
+
+import backtype.storm.Config;
+
+/**
+ * The param class for the <code>Testing.completeTopology</code>.
+ */
+public class CompleteTopologyParam {
+	/**
+	 * The mocked spout sources
+	 */
+	private MockedSources mockedSources;
+	/**
+	 * the config for the topology when it was submitted to the cluster
+	 */
+	private Config stormConf;
+	/**
+	 * whether cleanup the state?
+	 */
+	private Boolean cleanupState;
+	/**
+	 * the topology name you want to submit to the cluster
+	 */
+	private String topologyName;
+	
+	public MockedSources getMockedSources() {
+		return mockedSources;
+	}
+	public void setMockedSources(MockedSources mockedSources) {
+		this.mockedSources = mockedSources;
+	}
+	public Config getStormConf() {
+		return stormConf;
+	}
+	public void setStormConf(Config stormConf) {
+		this.stormConf = stormConf;
+	}
+	public Boolean getCleanupState() {
+		return cleanupState;
+	}
+	public void setCleanupState(Boolean cleanupState) {
+		this.cleanupState = cleanupState;
+	}
+	public String getTopologyName() {
+		return topologyName;
+	}
+	public void setTopologyName(String topologyName) {
+		this.topologyName = topologyName;
+	}
+}

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/CountingBatchBolt.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/CountingBatchBolt.java b/storm-core/src/jvm/backtype/storm/testing/CountingBatchBolt.java
index 2f32bd5..882801c 100644
--- a/storm-core/src/jvm/backtype/storm/testing/CountingBatchBolt.java
+++ b/storm-core/src/jvm/backtype/storm/testing/CountingBatchBolt.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.task.TopologyContext;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/CountingCommitBolt.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/CountingCommitBolt.java b/storm-core/src/jvm/backtype/storm/testing/CountingCommitBolt.java
index c5108e9..cb8f7e5 100644
--- a/storm-core/src/jvm/backtype/storm/testing/CountingCommitBolt.java
+++ b/storm-core/src/jvm/backtype/storm/testing/CountingCommitBolt.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.task.TopologyContext;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/FeederSpout.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/FeederSpout.java b/storm-core/src/jvm/backtype/storm/testing/FeederSpout.java
index 837e990..1ffb594 100644
--- a/storm-core/src/jvm/backtype/storm/testing/FeederSpout.java
+++ b/storm-core/src/jvm/backtype/storm/testing/FeederSpout.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.topology.OutputFieldsDeclarer;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/FixedTuple.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/FixedTuple.java b/storm-core/src/jvm/backtype/storm/testing/FixedTuple.java
index 23619a1..ceb0d35 100644
--- a/storm-core/src/jvm/backtype/storm/testing/FixedTuple.java
+++ b/storm-core/src/jvm/backtype/storm/testing/FixedTuple.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.utils.Utils;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/FixedTupleSpout.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/FixedTupleSpout.java b/storm-core/src/jvm/backtype/storm/testing/FixedTupleSpout.java
index f78f958..9527803 100644
--- a/storm-core/src/jvm/backtype/storm/testing/FixedTupleSpout.java
+++ b/storm-core/src/jvm/backtype/storm/testing/FixedTupleSpout.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.spout.SpoutOutputCollector;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/IdentityBolt.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/IdentityBolt.java b/storm-core/src/jvm/backtype/storm/testing/IdentityBolt.java
index 76e9ac3..dcad640 100644
--- a/storm-core/src/jvm/backtype/storm/testing/IdentityBolt.java
+++ b/storm-core/src/jvm/backtype/storm/testing/IdentityBolt.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.topology.BasicOutputCollector;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/KeyedCountingBatchBolt.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/KeyedCountingBatchBolt.java b/storm-core/src/jvm/backtype/storm/testing/KeyedCountingBatchBolt.java
index d3ffa48..1c4d5b3 100644
--- a/storm-core/src/jvm/backtype/storm/testing/KeyedCountingBatchBolt.java
+++ b/storm-core/src/jvm/backtype/storm/testing/KeyedCountingBatchBolt.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.task.TopologyContext;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/KeyedCountingCommitterBolt.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/KeyedCountingCommitterBolt.java b/storm-core/src/jvm/backtype/storm/testing/KeyedCountingCommitterBolt.java
index 39ccdc0..813e5b2 100644
--- a/storm-core/src/jvm/backtype/storm/testing/KeyedCountingCommitterBolt.java
+++ b/storm-core/src/jvm/backtype/storm/testing/KeyedCountingCommitterBolt.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.transactional.ICommitter;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/KeyedSummingBatchBolt.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/KeyedSummingBatchBolt.java b/storm-core/src/jvm/backtype/storm/testing/KeyedSummingBatchBolt.java
index 89422db..887eb4e 100644
--- a/storm-core/src/jvm/backtype/storm/testing/KeyedSummingBatchBolt.java
+++ b/storm-core/src/jvm/backtype/storm/testing/KeyedSummingBatchBolt.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.coordination.BatchOutputCollector;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/MemoryTransactionalSpout.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/MemoryTransactionalSpout.java b/storm-core/src/jvm/backtype/storm/testing/MemoryTransactionalSpout.java
index 2e9ff12..3b492e1 100644
--- a/storm-core/src/jvm/backtype/storm/testing/MemoryTransactionalSpout.java
+++ b/storm-core/src/jvm/backtype/storm/testing/MemoryTransactionalSpout.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.Config;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/MemoryTransactionalSpoutMeta.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/MemoryTransactionalSpoutMeta.java b/storm-core/src/jvm/backtype/storm/testing/MemoryTransactionalSpoutMeta.java
index d6aea20..29681fb 100644
--- a/storm-core/src/jvm/backtype/storm/testing/MemoryTransactionalSpoutMeta.java
+++ b/storm-core/src/jvm/backtype/storm/testing/MemoryTransactionalSpoutMeta.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 public class MemoryTransactionalSpoutMeta {

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/MkClusterParam.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/MkClusterParam.java b/storm-core/src/jvm/backtype/storm/testing/MkClusterParam.java
index c64f05a..cd677c8 100644
--- a/storm-core/src/jvm/backtype/storm/testing/MkClusterParam.java
+++ b/storm-core/src/jvm/backtype/storm/testing/MkClusterParam.java
@@ -1,40 +1,57 @@
-package backtype.storm.testing;
-
-import java.util.Map;
-
-/**
- * The param arg for <code>Testing.withSimulatedTimeCluster</code> and <code>Testing.withTrackedCluster</code>
- */
-public class MkClusterParam {
-	/**
-	 * count of supervisors for the cluster.
-	 */
-	private Integer supervisors;
-	/**
-	 * count of port for each supervisor
-	 */
-	private Integer portsPerSupervisor;
-	/**
-	 * cluster config
-	 */
-	private Map daemonConf;
-	
-	public Integer getSupervisors() {
-		return supervisors;
-	}
-	public void setSupervisors(Integer supervisors) {
-		this.supervisors = supervisors;
-	}
-	public Integer getPortsPerSupervisor() {
-		return portsPerSupervisor;
-	}
-	public void setPortsPerSupervisor(Integer portsPerSupervisor) {
-		this.portsPerSupervisor = portsPerSupervisor;
-	}
-	public Map getDaemonConf() {
-		return daemonConf;
-	}
-	public void setDaemonConf(Map daemonConf) {
-		this.daemonConf = daemonConf;
-	}
-}
+/**
+ * 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.testing;
+
+import java.util.Map;
+
+/**
+ * The param arg for <code>Testing.withSimulatedTimeCluster</code> and <code>Testing.withTrackedCluster</code>
+ */
+public class MkClusterParam {
+	/**
+	 * count of supervisors for the cluster.
+	 */
+	private Integer supervisors;
+	/**
+	 * count of port for each supervisor
+	 */
+	private Integer portsPerSupervisor;
+	/**
+	 * cluster config
+	 */
+	private Map daemonConf;
+	
+	public Integer getSupervisors() {
+		return supervisors;
+	}
+	public void setSupervisors(Integer supervisors) {
+		this.supervisors = supervisors;
+	}
+	public Integer getPortsPerSupervisor() {
+		return portsPerSupervisor;
+	}
+	public void setPortsPerSupervisor(Integer portsPerSupervisor) {
+		this.portsPerSupervisor = portsPerSupervisor;
+	}
+	public Map getDaemonConf() {
+		return daemonConf;
+	}
+	public void setDaemonConf(Map daemonConf) {
+		this.daemonConf = daemonConf;
+	}
+}

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/MkTupleParam.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/MkTupleParam.java b/storm-core/src/jvm/backtype/storm/testing/MkTupleParam.java
index 6ab2341..34a8c68 100644
--- a/storm-core/src/jvm/backtype/storm/testing/MkTupleParam.java
+++ b/storm-core/src/jvm/backtype/storm/testing/MkTupleParam.java
@@ -1,34 +1,51 @@
-package backtype.storm.testing;
-
-import java.util.ArrayList;
-import java.util.List;
-
-public class MkTupleParam {
-	private String stream;
-	private String component;
-	private List<String> fields;
-	
-	public String getStream() {
-		return stream;
-	}
-	public void setStream(String stream) {
-		this.stream = stream;
-	}
-	
-	public String getComponent() {
-		return component;
-	}
-	public void setComponent(String component) {
-		this.component = component;
-	}
-	
-	public List<String> getFields() {
-		return fields;
-	}
-	public void setFields(String... fields) {
-		this.fields = new ArrayList<String>();
-		for (int i = 0; i < fields.length; i++) {
-			this.fields.add(fields[i]);
-		}
-	}
-}
+/**
+ * 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.testing;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class MkTupleParam {
+	private String stream;
+	private String component;
+	private List<String> fields;
+	
+	public String getStream() {
+		return stream;
+	}
+	public void setStream(String stream) {
+		this.stream = stream;
+	}
+	
+	public String getComponent() {
+		return component;
+	}
+	public void setComponent(String component) {
+		this.component = component;
+	}
+	
+	public List<String> getFields() {
+		return fields;
+	}
+	public void setFields(String... fields) {
+		this.fields = new ArrayList<String>();
+		for (int i = 0; i < fields.length; i++) {
+			this.fields.add(fields[i]);
+		}
+	}
+}

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/MockedSources.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/MockedSources.java b/storm-core/src/jvm/backtype/storm/testing/MockedSources.java
index db7aeca..1fd6b85 100644
--- a/storm-core/src/jvm/backtype/storm/testing/MockedSources.java
+++ b/storm-core/src/jvm/backtype/storm/testing/MockedSources.java
@@ -1,43 +1,60 @@
-package backtype.storm.testing;
-
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-import backtype.storm.tuple.Values;
-import backtype.storm.utils.Utils;
-
-public class MockedSources {
-	/**
-	 * mocked spout sources for the [spout, stream] pair.
-	 */
-    private Map<String, List<FixedTuple>> data = new HashMap<String, List<FixedTuple>>();
-    
-    /**
-     * add mock data for the spout.
-     * 
-     * @param spoutId the spout to be mocked
-     * @param streamId the stream of the spout to be mocked
-     * @param objects the mocked data
-     */
-    public void addMockData(String spoutId, String streamId, Values... valueses) {
-        if (!data.containsKey(spoutId)) {
-            data.put(spoutId, new ArrayList<FixedTuple>());
-        }
-        
-        List<FixedTuple> tuples = data.get(spoutId);
-        for (int i = 0; i < valueses.length; i++) {
-            FixedTuple tuple = new FixedTuple(streamId, valueses[i]);
-            tuples.add(tuple);
-        }
-    }
-    
-    public void addMockData(String spoutId, Values... valueses) {
-        this.addMockData(spoutId, Utils.DEFAULT_STREAM_ID, valueses);
-    }
-    
-    public Map<String, List<FixedTuple>> getData() {
-        return this.data;
-    }
-}
+/**
+ * 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.testing;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import backtype.storm.tuple.Values;
+import backtype.storm.utils.Utils;
+
+public class MockedSources {
+	/**
+	 * mocked spout sources for the [spout, stream] pair.
+	 */
+    private Map<String, List<FixedTuple>> data = new HashMap<String, List<FixedTuple>>();
+    
+    /**
+     * add mock data for the spout.
+     * 
+     * @param spoutId the spout to be mocked
+     * @param streamId the stream of the spout to be mocked
+     * @param objects the mocked data
+     */
+    public void addMockData(String spoutId, String streamId, Values... valueses) {
+        if (!data.containsKey(spoutId)) {
+            data.put(spoutId, new ArrayList<FixedTuple>());
+        }
+        
+        List<FixedTuple> tuples = data.get(spoutId);
+        for (int i = 0; i < valueses.length; i++) {
+            FixedTuple tuple = new FixedTuple(streamId, valueses[i]);
+            tuples.add(tuple);
+        }
+    }
+    
+    public void addMockData(String spoutId, Values... valueses) {
+        this.addMockData(spoutId, Utils.DEFAULT_STREAM_ID, valueses);
+    }
+    
+    public Map<String, List<FixedTuple>> getData() {
+        return this.data;
+    }
+}

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/NGrouping.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/NGrouping.java b/storm-core/src/jvm/backtype/storm/testing/NGrouping.java
index 3a07a71..785ed92 100644
--- a/storm-core/src/jvm/backtype/storm/testing/NGrouping.java
+++ b/storm-core/src/jvm/backtype/storm/testing/NGrouping.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.generated.GlobalStreamId;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/NonRichBoltTracker.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/NonRichBoltTracker.java b/storm-core/src/jvm/backtype/storm/testing/NonRichBoltTracker.java
index 250463d..ccbb67f 100644
--- a/storm-core/src/jvm/backtype/storm/testing/NonRichBoltTracker.java
+++ b/storm-core/src/jvm/backtype/storm/testing/NonRichBoltTracker.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.task.IBolt;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/OpaqueMemoryTransactionalSpout.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/OpaqueMemoryTransactionalSpout.java b/storm-core/src/jvm/backtype/storm/testing/OpaqueMemoryTransactionalSpout.java
index d21dd48..1ff01b9 100644
--- a/storm-core/src/jvm/backtype/storm/testing/OpaqueMemoryTransactionalSpout.java
+++ b/storm-core/src/jvm/backtype/storm/testing/OpaqueMemoryTransactionalSpout.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.Config;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/PrepareBatchBolt.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/PrepareBatchBolt.java b/storm-core/src/jvm/backtype/storm/testing/PrepareBatchBolt.java
index 6a13b12..0bd9833 100644
--- a/storm-core/src/jvm/backtype/storm/testing/PrepareBatchBolt.java
+++ b/storm-core/src/jvm/backtype/storm/testing/PrepareBatchBolt.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.topology.BasicOutputCollector;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/SpoutTracker.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/SpoutTracker.java b/storm-core/src/jvm/backtype/storm/testing/SpoutTracker.java
index b69f546..75ba2b8 100644
--- a/storm-core/src/jvm/backtype/storm/testing/SpoutTracker.java
+++ b/storm-core/src/jvm/backtype/storm/testing/SpoutTracker.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.spout.ISpoutOutputCollector;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/TestAggregatesCounter.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/TestAggregatesCounter.java b/storm-core/src/jvm/backtype/storm/testing/TestAggregatesCounter.java
index 4b58638..e8c0a61 100644
--- a/storm-core/src/jvm/backtype/storm/testing/TestAggregatesCounter.java
+++ b/storm-core/src/jvm/backtype/storm/testing/TestAggregatesCounter.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.topology.base.BaseRichBolt;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/TestConfBolt.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/TestConfBolt.java b/storm-core/src/jvm/backtype/storm/testing/TestConfBolt.java
index 0f5f862..5790fb3 100644
--- a/storm-core/src/jvm/backtype/storm/testing/TestConfBolt.java
+++ b/storm-core/src/jvm/backtype/storm/testing/TestConfBolt.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.task.TopologyContext;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/TestGlobalCount.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/TestGlobalCount.java b/storm-core/src/jvm/backtype/storm/testing/TestGlobalCount.java
index 1605022..5ef464a 100644
--- a/storm-core/src/jvm/backtype/storm/testing/TestGlobalCount.java
+++ b/storm-core/src/jvm/backtype/storm/testing/TestGlobalCount.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.topology.base.BaseRichBolt;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/TestJob.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/TestJob.java b/storm-core/src/jvm/backtype/storm/testing/TestJob.java
index 325cb7a..d41c36a 100644
--- a/storm-core/src/jvm/backtype/storm/testing/TestJob.java
+++ b/storm-core/src/jvm/backtype/storm/testing/TestJob.java
@@ -1,24 +1,41 @@
-package backtype.storm.testing;
-
-import backtype.storm.ILocalCluster;
-
-/**
- * This is the core interface for the storm java testing, usually
- * we put our java unit testing logic in the run method. A sample
- * code will be:
- * <code>
- * Testing.withSimulatedTimeLocalCluster(new TestJob() {
- *     public void run(Cluster cluster) {
- *         // your testing logic here.
- *     }
- * });
- */
-public interface TestJob {
-	/**
-	 * run the testing logic with the cluster.
-	 * 
-	 * @param cluster the cluster which created by <code>Testing.withSimulatedTimeLocalCluster</code>
-	 *        and <code>Testing.withTrackedCluster</code>.
-	 */
-    public void run(ILocalCluster cluster) throws Exception;
-}
+/**
+ * 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.testing;
+
+import backtype.storm.ILocalCluster;
+
+/**
+ * This is the core interface for the storm java testing, usually
+ * we put our java unit testing logic in the run method. A sample
+ * code will be:
+ * <code>
+ * Testing.withSimulatedTimeLocalCluster(new TestJob() {
+ *     public void run(Cluster cluster) {
+ *         // your testing logic here.
+ *     }
+ * });
+ */
+public interface TestJob {
+	/**
+	 * run the testing logic with the cluster.
+	 * 
+	 * @param cluster the cluster which created by <code>Testing.withSimulatedTimeLocalCluster</code>
+	 *        and <code>Testing.withTrackedCluster</code>.
+	 */
+    public void run(ILocalCluster cluster) throws Exception;
+}

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/TestKryoDecorator.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/TestKryoDecorator.java b/storm-core/src/jvm/backtype/storm/testing/TestKryoDecorator.java
index cf8ab43..96addd0 100644
--- a/storm-core/src/jvm/backtype/storm/testing/TestKryoDecorator.java
+++ b/storm-core/src/jvm/backtype/storm/testing/TestKryoDecorator.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.serialization.IKryoDecorator;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/TestPlannerBolt.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/TestPlannerBolt.java b/storm-core/src/jvm/backtype/storm/testing/TestPlannerBolt.java
index 0149f14..0d30b26 100644
--- a/storm-core/src/jvm/backtype/storm/testing/TestPlannerBolt.java
+++ b/storm-core/src/jvm/backtype/storm/testing/TestPlannerBolt.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.task.OutputCollector;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/TestPlannerSpout.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/TestPlannerSpout.java b/storm-core/src/jvm/backtype/storm/testing/TestPlannerSpout.java
index ff62390..f4c27c0 100644
--- a/storm-core/src/jvm/backtype/storm/testing/TestPlannerSpout.java
+++ b/storm-core/src/jvm/backtype/storm/testing/TestPlannerSpout.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.Config;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/TestSerObject.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/TestSerObject.java b/storm-core/src/jvm/backtype/storm/testing/TestSerObject.java
index ffbbd4c..2c0ee5b 100644
--- a/storm-core/src/jvm/backtype/storm/testing/TestSerObject.java
+++ b/storm-core/src/jvm/backtype/storm/testing/TestSerObject.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import java.io.Serializable;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/TestWordCounter.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/TestWordCounter.java b/storm-core/src/jvm/backtype/storm/testing/TestWordCounter.java
index 2d8a476..551b054 100644
--- a/storm-core/src/jvm/backtype/storm/testing/TestWordCounter.java
+++ b/storm-core/src/jvm/backtype/storm/testing/TestWordCounter.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.topology.base.BaseBasicBolt;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/TestWordSpout.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/TestWordSpout.java b/storm-core/src/jvm/backtype/storm/testing/TestWordSpout.java
index 767a8e8..745bf71 100644
--- a/storm-core/src/jvm/backtype/storm/testing/TestWordSpout.java
+++ b/storm-core/src/jvm/backtype/storm/testing/TestWordSpout.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.Config;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/TrackedTopology.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/TrackedTopology.java b/storm-core/src/jvm/backtype/storm/testing/TrackedTopology.java
index d7fe5f6..f2691b7 100644
--- a/storm-core/src/jvm/backtype/storm/testing/TrackedTopology.java
+++ b/storm-core/src/jvm/backtype/storm/testing/TrackedTopology.java
@@ -1,17 +1,34 @@
-package backtype.storm.testing;
-
-import java.util.HashMap;
-import java.util.Map;
-
-import backtype.storm.generated.StormTopology;
-import clojure.lang.Keyword;
-
-public class TrackedTopology extends HashMap{
-	public TrackedTopology(Map map) {
-		super(map);
-	}
-	
-	public StormTopology getTopology() {
-		return (StormTopology)get(Keyword.intern("topology"));
-	}
-}
+/**
+ * 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.testing;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import backtype.storm.generated.StormTopology;
+import clojure.lang.Keyword;
+
+public class TrackedTopology extends HashMap{
+	public TrackedTopology(Map map) {
+		super(map);
+	}
+	
+	public StormTopology getTopology() {
+		return (StormTopology)get(Keyword.intern("topology"));
+	}
+}

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/testing/TupleCaptureBolt.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/testing/TupleCaptureBolt.java b/storm-core/src/jvm/backtype/storm/testing/TupleCaptureBolt.java
index 8d88671..e163576 100644
--- a/storm-core/src/jvm/backtype/storm/testing/TupleCaptureBolt.java
+++ b/storm-core/src/jvm/backtype/storm/testing/TupleCaptureBolt.java
@@ -1,3 +1,20 @@
+/**
+ * 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.testing;
 
 import backtype.storm.task.OutputCollector;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/topology/BaseConfigurationDeclarer.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/topology/BaseConfigurationDeclarer.java b/storm-core/src/jvm/backtype/storm/topology/BaseConfigurationDeclarer.java
index ce5c706..0c67324 100644
--- a/storm-core/src/jvm/backtype/storm/topology/BaseConfigurationDeclarer.java
+++ b/storm-core/src/jvm/backtype/storm/topology/BaseConfigurationDeclarer.java
@@ -1,3 +1,20 @@
+/**
+ * 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.topology;
 
 import backtype.storm.Config;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/topology/BasicBoltExecutor.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/topology/BasicBoltExecutor.java b/storm-core/src/jvm/backtype/storm/topology/BasicBoltExecutor.java
index a5f69a8..6c9cdc1 100644
--- a/storm-core/src/jvm/backtype/storm/topology/BasicBoltExecutor.java
+++ b/storm-core/src/jvm/backtype/storm/topology/BasicBoltExecutor.java
@@ -1,3 +1,20 @@
+/**
+ * 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.topology;
 
 import backtype.storm.task.OutputCollector;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/topology/BasicOutputCollector.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/topology/BasicOutputCollector.java b/storm-core/src/jvm/backtype/storm/topology/BasicOutputCollector.java
index 26f170c..be1c242 100644
--- a/storm-core/src/jvm/backtype/storm/topology/BasicOutputCollector.java
+++ b/storm-core/src/jvm/backtype/storm/topology/BasicOutputCollector.java
@@ -1,3 +1,20 @@
+/**
+ * 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.topology;
 
 import backtype.storm.task.IOutputCollector;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/topology/BoltDeclarer.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/topology/BoltDeclarer.java b/storm-core/src/jvm/backtype/storm/topology/BoltDeclarer.java
index dd73cbf..ff2ec2d 100644
--- a/storm-core/src/jvm/backtype/storm/topology/BoltDeclarer.java
+++ b/storm-core/src/jvm/backtype/storm/topology/BoltDeclarer.java
@@ -1,3 +1,20 @@
+/**
+ * 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.topology;
 
 public interface BoltDeclarer extends InputDeclarer<BoltDeclarer>, ComponentConfigurationDeclarer<BoltDeclarer> {

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/topology/ComponentConfigurationDeclarer.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/topology/ComponentConfigurationDeclarer.java b/storm-core/src/jvm/backtype/storm/topology/ComponentConfigurationDeclarer.java
index 2b252a9..d05dda0 100644
--- a/storm-core/src/jvm/backtype/storm/topology/ComponentConfigurationDeclarer.java
+++ b/storm-core/src/jvm/backtype/storm/topology/ComponentConfigurationDeclarer.java
@@ -1,3 +1,20 @@
+/**
+ * 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.topology;
 
 import java.util.Map;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/731a8e51/storm-core/src/jvm/backtype/storm/topology/FailedException.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/topology/FailedException.java b/storm-core/src/jvm/backtype/storm/topology/FailedException.java
index 38b8d45..e174b5a 100644
--- a/storm-core/src/jvm/backtype/storm/topology/FailedException.java
+++ b/storm-core/src/jvm/backtype/storm/topology/FailedException.java
@@ -1,3 +1,20 @@
+/**
+ * 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.topology;
 
 public class FailedException extends RuntimeException {


Mime
View raw message