add missing license headers
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/01a66bf5 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/01a66bf5 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/01a66bf5 Branch: refs/heads/master Commit: 01a66bf5b17a9fce94fcdac4fbaa2f28c2df9189 Parents: c48f63e Author: P. Taylor Goetz <[email protected]> Authored: Tue May 5 16:14:33 2015 -0400 Committer: P. Taylor Goetz <[email protected]> Committed: Tue May 5 16:14:33 2015 -0400 ---------------------------------------------------------------------- .../apache/storm/flux/api/TopologySource.java | 17 +++ .../storm/flux/model/ConfigMethodDef.java | 17 +++ .../storm/flux/model/TopologySourceDef.java | 17 +++ .../java/org/apache/storm/flux/FrankenBean.java | 138 ------------------- .../org/apache/storm/flux/IntegrationTest.java | 17 +++ .../src/main/resources/hbase_bolt.properties | 16 +++ .../src/main/resources/hdfs_bolt.properties | 17 +++ .../storm/flux/wrappers/bolts/LogInfoBolt.java | 18 +++ 8 files changed, 119 insertions(+), 138 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/01a66bf5/flux-core/src/main/java/org/apache/storm/flux/api/TopologySource.java ---------------------------------------------------------------------- diff --git a/flux-core/src/main/java/org/apache/storm/flux/api/TopologySource.java b/flux-core/src/main/java/org/apache/storm/flux/api/TopologySource.java index 779e676..fbccfb7 100644 --- a/flux-core/src/main/java/org/apache/storm/flux/api/TopologySource.java +++ b/flux-core/src/main/java/org/apache/storm/flux/api/TopologySource.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 org.apache.storm.flux.api; http://git-wip-us.apache.org/repos/asf/storm/blob/01a66bf5/flux-core/src/main/java/org/apache/storm/flux/model/ConfigMethodDef.java ---------------------------------------------------------------------- diff --git a/flux-core/src/main/java/org/apache/storm/flux/model/ConfigMethodDef.java b/flux-core/src/main/java/org/apache/storm/flux/model/ConfigMethodDef.java index e274915..6f7e4d4 100644 --- a/flux-core/src/main/java/org/apache/storm/flux/model/ConfigMethodDef.java +++ b/flux-core/src/main/java/org/apache/storm/flux/model/ConfigMethodDef.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 org.apache.storm.flux.model; import java.util.ArrayList; http://git-wip-us.apache.org/repos/asf/storm/blob/01a66bf5/flux-core/src/main/java/org/apache/storm/flux/model/TopologySourceDef.java ---------------------------------------------------------------------- diff --git a/flux-core/src/main/java/org/apache/storm/flux/model/TopologySourceDef.java b/flux-core/src/main/java/org/apache/storm/flux/model/TopologySourceDef.java index 2949659..d6a2f57 100644 --- a/flux-core/src/main/java/org/apache/storm/flux/model/TopologySourceDef.java +++ b/flux-core/src/main/java/org/apache/storm/flux/model/TopologySourceDef.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 org.apache.storm.flux.model; public class TopologySourceDef extends ObjectDef { http://git-wip-us.apache.org/repos/asf/storm/blob/01a66bf5/flux-core/src/test/java/org/apache/storm/flux/FrankenBean.java ---------------------------------------------------------------------- diff --git a/flux-core/src/test/java/org/apache/storm/flux/FrankenBean.java b/flux-core/src/test/java/org/apache/storm/flux/FrankenBean.java deleted file mode 100644 index 80a3c90..0000000 --- a/flux-core/src/test/java/org/apache/storm/flux/FrankenBean.java +++ /dev/null @@ -1,138 +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 org.apache.storm.flux; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.lang.reflect.Constructor; -import java.lang.reflect.Field; -import java.lang.reflect.Method; -import java.util.ArrayList; -import java.util.HashMap; - -/** - * Test class that is a hybrid java bean -- it has both standard - * java bean setters, as well as public instance variables. - */ -public class FrankenBean { - private static final Logger LOG = LoggerFactory.getLogger(FrankenBean.class); - - public String publicString; - public boolean publicBoolean; - - private String privateString; - private boolean privateBoolean; - - public void setPrivateBoolean(boolean b){ - this.privateBoolean = b; - } - - public void setPrivateString(String string){ - this.privateString = string; - } - - static class Test { - public Test(int i){ - System.out.println("Constructor: " + i); - } - } - - public static void main(String[] args) throws Exception{ - Integer i = new Integer(1); - - Class clazz = Test.class; - - Constructor ctor = clazz.getConstructor(new Class[]{int.class}); - ctor.newInstance(i); - - System.out.println("isNumber: " + Number.class.isAssignableFrom(i.getClass())); - } - - public static void main2(String[] args) throws Exception { - Class clazz = Class.forName("org.apache.storm.flux.FrankenBean"); - HashMap<String, Object> props = new HashMap<String, Object>(); - props.put("publicString", "foo"); - props.put("privateString", "bar"); - - props.put("privateBoolean", true); - props.put("publicBoolean", true); - - props.put("notgonnafindit", "foobar"); - - // only support default constructors for now - Object instance = clazz.newInstance(); - - for(String key : props.keySet()){ - Method setter = findSetter(clazz, key, props.get(key)); - if(setter != null){ - // invoke setter - setter.invoke(instance, new Object[]{props.get(key)}); - } else { - // look for a public instance variable - Field field = findPublicField(clazz, key, props.get(key)); - if(field != null) { - field.set(instance, props.get(key)); - } - } - } - - LOG.info("Bean: {}", instance); - - } - - - public static Field findPublicField(Class clazz, String property, Object arg){ - Field field = null; - try{ - field = clazz.getField(property); - } catch (NoSuchFieldException e){ - LOG.warn("Could not find setter or public variable for property: " + property, e); - } - return field; - } - - public static Method findSetter(Class clazz, String property, Object arg){ - String setterName = toSetterName(property); - -// ArrayList<Method> candidates = new ArrayList<Method>(); - Method retval = null; - Method[] methods = clazz.getMethods(); - for(Method method : methods){ - if(setterName.equals(method.getName())) { - LOG.info("Found setter method: " + method.getName()); - retval = method; - } - } - return retval; - } - - public static String toSetterName(String name){ - return "set" + name.substring(0,1).toUpperCase() + name.substring(1, name.length()); - } - - public String toString(){ - return String.format("publicString: %s, privateString: %s, " + - "publicBoolean: %s, privateBoolean: %s", - this.publicString, - this.privateString, - this.publicBoolean, - this.privateBoolean); - } - -} http://git-wip-us.apache.org/repos/asf/storm/blob/01a66bf5/flux-core/src/test/java/org/apache/storm/flux/IntegrationTest.java ---------------------------------------------------------------------- diff --git a/flux-core/src/test/java/org/apache/storm/flux/IntegrationTest.java b/flux-core/src/test/java/org/apache/storm/flux/IntegrationTest.java index 2dea72a..5e17f5e 100644 --- a/flux-core/src/test/java/org/apache/storm/flux/IntegrationTest.java +++ b/flux-core/src/test/java/org/apache/storm/flux/IntegrationTest.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 org.apache.storm.flux; import org.junit.Test; http://git-wip-us.apache.org/repos/asf/storm/blob/01a66bf5/flux-examples/src/main/resources/hbase_bolt.properties ---------------------------------------------------------------------- diff --git a/flux-examples/src/main/resources/hbase_bolt.properties b/flux-examples/src/main/resources/hbase_bolt.properties index 9903b41..f8ed50c 100644 --- a/flux-examples/src/main/resources/hbase_bolt.properties +++ b/flux-examples/src/main/resources/hbase_bolt.properties @@ -1,2 +1,18 @@ +# 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. + hbase.rootdir=hdfs://hadoop:54310/hbase hbase.zookeeper.quorum=hadoop \ No newline at end of file http://git-wip-us.apache.org/repos/asf/storm/blob/01a66bf5/flux-examples/src/main/resources/hdfs_bolt.properties ---------------------------------------------------------------------- diff --git a/flux-examples/src/main/resources/hdfs_bolt.properties b/flux-examples/src/main/resources/hdfs_bolt.properties index dd1307d..7bcbe7a 100644 --- a/flux-examples/src/main/resources/hdfs_bolt.properties +++ b/flux-examples/src/main/resources/hdfs_bolt.properties @@ -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. + + # The HDFS url hdfs.url=hdfs://hadoop:54310 http://git-wip-us.apache.org/repos/asf/storm/blob/01a66bf5/flux-wrappers/src/main/java/org/apache/storm/flux/wrappers/bolts/LogInfoBolt.java ---------------------------------------------------------------------- diff --git a/flux-wrappers/src/main/java/org/apache/storm/flux/wrappers/bolts/LogInfoBolt.java b/flux-wrappers/src/main/java/org/apache/storm/flux/wrappers/bolts/LogInfoBolt.java index 5f91909..a42d7c3 100644 --- a/flux-wrappers/src/main/java/org/apache/storm/flux/wrappers/bolts/LogInfoBolt.java +++ b/flux-wrappers/src/main/java/org/apache/storm/flux/wrappers/bolts/LogInfoBolt.java @@ -1,3 +1,21 @@ +/* + * 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 org.apache.storm.flux.wrappers.bolts; import backtype.storm.topology.BasicOutputCollector;
