From fb12b2c1c7821f203aac5422a9af6213ce5dabae Mon Sep 17 00:00:00 2001 From: "P. Taylor Goetz" Date: Tue, 18 Feb 2014 00:19:41 -0500 Subject: [PATCH] release personal (ptgoetz) copyrights to apache apply apache copyright headers remove author tags --- LICENSE.txt | 6 - README.md | 19 +++ examples/pom.xml | 17 +++ .../example/CassandraReachTopology.java | 18 ++- .../example/PersistentWordCount.java | 17 +++ .../cassandra/example/TestWordCounter.java | 17 +++ .../cassandra/example/TestWordSpout.java | 17 +++ examples/src/main/resources/log4j.properties | 15 ++ pom-int.xml | 128 ------------------ pom.xml | 30 +++- .../cassandra/StormCassandraConstants.java | 17 +++ .../cassandra/bolt/AbstractBatchingBolt.java | 20 ++- .../storm/cassandra/bolt/AckStrategy.java | 20 ++- .../cassandra/bolt/CassandraBatchingBolt.java | 20 ++- .../storm/cassandra/bolt/CassandraBolt.java | 17 +++ .../bolt/CassandraCounterBatchingBolt.java | 17 +++ .../cassandra/bolt/CassandraLookupBolt.java | 19 ++- .../bolt/TransactionalCassandraBatchBolt.java | 17 +++ .../bolt/TridentCassandraBatchBolt.java | 22 ++- .../cassandra/bolt/mapper/ColumnMapper.java | 19 ++- .../bolt/mapper/CompositeRowTupleMapper.java | 17 +++ .../mapper/DefaultTupleCounterMapper.java | 17 +++ .../bolt/mapper/DefaultTupleMapper.java | 17 +++ .../bolt/mapper/DelimitedColumnsMapper.java | 21 ++- .../storm/cassandra/bolt/mapper/Equality.java | 17 +++ .../bolt/mapper/RangeQueryTupleMapper.java | 17 +++ .../bolt/mapper/TridentColumnMapper.java | 20 ++- .../bolt/mapper/TridentTupleMapper.java | 19 ++- .../bolt/mapper/TupleCounterMapper.java | 20 ++- .../cassandra/bolt/mapper/TupleMapper.java | 17 +++ .../bolt/mapper/ValuelessColumnsMapper.java | 21 ++- .../cassandra/client/AstyanaxClient.java | 25 +++- .../storm/cassandra/composite/Composite2.java | 17 +++ .../exceptions/ExceptionHandler.java | 17 +++ .../exceptions/MappedExceptionHandler.java | 17 +++ .../exceptions/StormCassandraException.java | 20 ++- .../exceptions/TupleMappingException.java | 18 +++ .../cassandra/trident/CassandraMapState.java | 17 +++ .../cassandra/trident/CassandraQuery.java | 17 +++ .../cassandra/trident/CassandraState.java | 17 +++ .../trident/CassandraStateFactory.java | 17 +++ .../cassandra/trident/CassandraUpdater.java | 17 +++ .../TridentCassandraLookupFunction.java | 17 +++ .../TridentCassandraWriteFunction.java | 17 +++ .../cassandra/bolt/AstyanaxComposites.java | 17 +++ .../storm/cassandra/bolt/AstyanaxUtil.java | 17 +++ .../cassandra/bolt/CassandraBoltTest.java | 17 +++ .../cassandra/bolt/CassandraMapStateTest.java | 17 +++ .../CompositeColumnTridentTupleMapper.java | 17 +++ .../storm/cassandra/bolt/CompositeTest.java | 17 +++ .../cassandra/bolt/MockTopologyContext.java | 17 +++ .../storm/cassandra/bolt/MockTuple.java | 17 +++ .../storm/cassandra/bolt/SimpleComposite.java | 17 +++ .../bolt/SimpleTridentTupleMapper.java | 17 +++ .../cassandra/bolt/SimpleTupleMapper.java | 17 +++ .../bolt/SingletonEmbeddedCassandra.java | 17 +++ src/test/resources/CassandraBoltTest.yaml | 15 ++ src/test/resources/cassandra-template.yaml | 15 ++ src/test/resources/log4j.properties | 15 ++ 59 files changed, 987 insertions(+), 170 deletions(-) delete mode 100644 pom-int.xml diff --git a/LICENSE.txt b/LICENSE.txt index 896e3c1..6a376ad 100644 --- a/LICENSE.txt +++ b/LICENSE.txt @@ -201,9 +201,3 @@ See the License for the specific language governing permissions and limitations under the License. - -THIRD-PARTY DEPENDENCIES -======================== -Convenience copies of some third-party dependencies are distributed with -Apache Cassandra as Java jar files in lib/. Licensing information for -these files can be found in the lib/licenses directory. diff --git a/README.md b/README.md index 9d4170a..91ddc4c 100644 --- a/README.md +++ b/README.md @@ -190,3 +190,22 @@ The output should resemble the following: 5 Rows Returned. Elapsed time: 8 msec(s). + +## License + +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. diff --git a/examples/pom.xml b/examples/pom.xml index ca079ff..ca29640 100644 --- a/examples/pom.xml +++ b/examples/pom.xml @@ -1,3 +1,20 @@ + + 4.0.0 diff --git a/examples/src/main/java/com/hmsonline/storm/cassandra/example/CassandraReachTopology.java b/examples/src/main/java/com/hmsonline/storm/cassandra/example/CassandraReachTopology.java index c3a6792..09202eb 100644 --- a/examples/src/main/java/com/hmsonline/storm/cassandra/example/CassandraReachTopology.java +++ b/examples/src/main/java/com/hmsonline/storm/cassandra/example/CassandraReachTopology.java @@ -1,4 +1,20 @@ -// Copyright (c) 2012 P. Taylor Goetz +/* + * 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 com.hmsonline.storm.cassandra.example; diff --git a/examples/src/main/java/com/hmsonline/storm/cassandra/example/PersistentWordCount.java b/examples/src/main/java/com/hmsonline/storm/cassandra/example/PersistentWordCount.java index 03f15fb..77a9f87 100644 --- a/examples/src/main/java/com/hmsonline/storm/cassandra/example/PersistentWordCount.java +++ b/examples/src/main/java/com/hmsonline/storm/cassandra/example/PersistentWordCount.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 com.hmsonline.storm.cassandra.example; import java.util.Arrays; diff --git a/examples/src/main/java/com/hmsonline/storm/cassandra/example/TestWordCounter.java b/examples/src/main/java/com/hmsonline/storm/cassandra/example/TestWordCounter.java index c60c75b..25de3e6 100644 --- a/examples/src/main/java/com/hmsonline/storm/cassandra/example/TestWordCounter.java +++ b/examples/src/main/java/com/hmsonline/storm/cassandra/example/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 com.hmsonline.storm.cassandra.example; import static backtype.storm.utils.Utils.tuple; diff --git a/examples/src/main/java/com/hmsonline/storm/cassandra/example/TestWordSpout.java b/examples/src/main/java/com/hmsonline/storm/cassandra/example/TestWordSpout.java index c0e7df3..9c2d65e 100644 --- a/examples/src/main/java/com/hmsonline/storm/cassandra/example/TestWordSpout.java +++ b/examples/src/main/java/com/hmsonline/storm/cassandra/example/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 com.hmsonline.storm.cassandra.example; import java.util.Map; diff --git a/examples/src/main/resources/log4j.properties b/examples/src/main/resources/log4j.properties index 28a349e..6e2517d 100644 --- a/examples/src/main/resources/log4j.properties +++ b/examples/src/main/resources/log4j.properties @@ -1,3 +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. log4j.rootLogger=INFO, stdout log4j.appender.stdout=org.apache.log4j.ConsoleAppender diff --git a/pom-int.xml b/pom-int.xml deleted file mode 100644 index 470559f..0000000 --- a/pom-int.xml +++ /dev/null @@ -1,128 +0,0 @@ - - - 4.0.0 - com.hmsonline - storm-cassandra - 0.4.0-hmsint-3-SNAPSHOT - Storm Cassandra Support - Storm Cassandra Support - - - - Eclipse Public License - v 1.0 - http://www.eclipse.org/legal/epl-v10.html - repo - - - - scm:git:git@plgithub01.hmsonline.com:hms/storm-cassandra.git - scm:git:git@plgithub01.hmsonline.com:hms/storm-cassandra.git - scm:git@plgithub01.hmsonline.com:hms/storm-cassandra.git - HEAD - - - - - central - libs-releases - http://plmproxy01:8081/artifactory/libs-releases-local - - - snapshots - libs-snapshots - http://plmproxy01:8081/artifactory/libs-snapshots-local - - - - - - ptgoetz - P. Taylor Goetz - ptgoetz@gmail.com - - - - - - clojars.org - http://clojars.org/repo - - - twitter4j - http://twitter4j.org/maven2 - - - - - 0.8.1 - 1.1.2 - - - - - junit - junit - 4.10 - - - org.slf4j - slf4j-log4j12 - 1.6.4 - - - org.slf4j - slf4j-api - 1.6.4 - - - storm - storm - ${storm.version} - - provided - - - slf4j-api - org.slf4j - - - - - com.netflix.astyanax - astyanax - 1.0.6 - - - commons-lang - commons-lang - - - - - - - - - - - org.apache.maven.plugins - maven-compiler-plugin - 2.5.1 - - 1.6 - 1.6 - - - - org.apache.maven.plugins - maven-release-plugin - 2.3.2 - - pom-int.xml - false - - - - - - diff --git a/pom.xml b/pom.xml index 4b68f71..975e78f 100644 --- a/pom.xml +++ b/pom.xml @@ -1,3 +1,20 @@ + + @@ -13,13 +30,12 @@ Storm Cassandra Support Storm Cassandra Support - - - Eclipse Public License - v 1.0 - http://www.eclipse.org/legal/epl-v10.html - repo - - + + + The Apache Software License, Version 2.0 + http://www.apache.org/licenses/LICENSE-2.0.txt + + scm:git:git@github.com:hmsonline/storm-cassandra.git scm:git:git@github.com:hmsonline/storm-cassandra.git diff --git a/src/main/java/com/hmsonline/storm/cassandra/StormCassandraConstants.java b/src/main/java/com/hmsonline/storm/cassandra/StormCassandraConstants.java index 518f1ef..bfbed37 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/StormCassandraConstants.java +++ b/src/main/java/com/hmsonline/storm/cassandra/StormCassandraConstants.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 com.hmsonline.storm.cassandra; // diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/AbstractBatchingBolt.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/AbstractBatchingBolt.java index 2786891..e6cbd05 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/AbstractBatchingBolt.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/AbstractBatchingBolt.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 com.hmsonline.storm.cassandra.bolt; import java.util.ArrayList; @@ -31,8 +48,7 @@ * methods must call the corresponding methods on the superclass * (i.e. super.prepare() and super.cleanup()) to * ensure proper initialization and termination. - * - * @author ptgoetz + * */ @SuppressWarnings("serial") public abstract class AbstractBatchingBolt extends CassandraBolt implements IRichBolt { diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/AckStrategy.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/AckStrategy.java index 7b15578..e6413a5 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/AckStrategy.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/AckStrategy.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 com.hmsonline.storm.cassandra.bolt; /** @@ -14,8 +31,7 @@ * ACK_ON_WRITE: The Cassandra bolt will only ack tuples after the * resulting cassandra write(s) (potentially batched), have all * succeeded. - * - * @author tgoetz + * * */ public enum AckStrategy { diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/CassandraBatchingBolt.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/CassandraBatchingBolt.java index 816ab18..b4ad901 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/CassandraBatchingBolt.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/CassandraBatchingBolt.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 com.hmsonline.storm.cassandra.bolt; import java.util.List; @@ -16,8 +33,7 @@ * It does *not* implement IBatchBolt for that reason. If you want to use the * batching inside a transactional topology, use * TransactionalBatchingCassandraBolt. - * - * @author boneill42 + * */ @SuppressWarnings("serial") public class CassandraBatchingBolt extends AbstractBatchingBolt { diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/CassandraBolt.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/CassandraBolt.java index c5e5bf2..b555c16 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/CassandraBolt.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/CassandraBolt.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 com.hmsonline.storm.cassandra.bolt; import java.io.Serializable; diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/CassandraCounterBatchingBolt.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/CassandraCounterBatchingBolt.java index 61f0d65..b946136 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/CassandraCounterBatchingBolt.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/CassandraCounterBatchingBolt.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 com.hmsonline.storm.cassandra.bolt; import java.util.List; diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/CassandraLookupBolt.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/CassandraLookupBolt.java index e664f82..841076e 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/CassandraLookupBolt.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/CassandraLookupBolt.java @@ -1,5 +1,20 @@ -// Copyright (c) 2012 P. Taylor Goetz - +/* + * 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 com.hmsonline.storm.cassandra.bolt; import java.util.List; diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/TransactionalCassandraBatchBolt.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/TransactionalCassandraBatchBolt.java index f0056ce..772f1a3 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/TransactionalCassandraBatchBolt.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/TransactionalCassandraBatchBolt.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 com.hmsonline.storm.cassandra.bolt; import java.util.ArrayList; diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/TridentCassandraBatchBolt.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/TridentCassandraBatchBolt.java index 9794b14..10bbcd1 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/TridentCassandraBatchBolt.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/TridentCassandraBatchBolt.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 com.hmsonline.storm.cassandra.bolt; import java.util.ArrayList; @@ -16,7 +33,10 @@ import com.hmsonline.storm.cassandra.bolt.mapper.TupleMapper; /** - * @author boneill42 + * + * @param + * @param + * @param */ @SuppressWarnings({ "serial", "rawtypes", "unchecked" }) public class TridentCassandraBatchBolt extends TransactionalCassandraBatchBolt implements ITridentBatchBolt { diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/ColumnMapper.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/ColumnMapper.java index cfbba8c..1423022 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/ColumnMapper.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/ColumnMapper.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 com.hmsonline.storm.cassandra.bolt.mapper; import java.io.Serializable; @@ -9,8 +26,6 @@ import backtype.storm.tuple.Values; /** - * - * @author tgoetz * * @param * @param diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/CompositeRowTupleMapper.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/CompositeRowTupleMapper.java index c109695..66d1991 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/CompositeRowTupleMapper.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/CompositeRowTupleMapper.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 com.hmsonline.storm.cassandra.bolt.mapper; import java.util.Arrays; diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/DefaultTupleCounterMapper.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/DefaultTupleCounterMapper.java index eb0faad..18cbf29 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/DefaultTupleCounterMapper.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/DefaultTupleCounterMapper.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 com.hmsonline.storm.cassandra.bolt.mapper; import java.util.ArrayList; diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/DefaultTupleMapper.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/DefaultTupleMapper.java index e226134..c2c3a9c 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/DefaultTupleMapper.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/DefaultTupleMapper.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 com.hmsonline.storm.cassandra.bolt.mapper; import java.util.HashMap; diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/DelimitedColumnsMapper.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/DelimitedColumnsMapper.java index aad5aae..9e2bce4 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/DelimitedColumnsMapper.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/DelimitedColumnsMapper.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 com.hmsonline.storm.cassandra.bolt.mapper; import java.io.Serializable; @@ -51,9 +68,7 @@ * {rowKey:mike, follower:john} * {rowKey:mike, follower:bob} * - * - * @author tgoetz - * @author boneill42 + * */ @SuppressWarnings("serial") public class DelimitedColumnsMapper implements ColumnMapper, Serializable { diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/Equality.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/Equality.java index 47afaa7..303fa70 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/Equality.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/Equality.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 com.hmsonline.storm.cassandra.bolt.mapper; public enum Equality { diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/RangeQueryTupleMapper.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/RangeQueryTupleMapper.java index 2af061d..ec7990c 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/RangeQueryTupleMapper.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/RangeQueryTupleMapper.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 com.hmsonline.storm.cassandra.bolt.mapper; import backtype.storm.tuple.Tuple; diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/TridentColumnMapper.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/TridentColumnMapper.java index ce55d50..91d560b 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/TridentColumnMapper.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/TridentColumnMapper.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 com.hmsonline.storm.cassandra.bolt.mapper; import java.io.Serializable; @@ -9,8 +26,7 @@ /** * Interface for mapping a Cassandra row(s) to Trident tuples. - * - * @author tgoetz + * * * @param - Cassandra row key type * @param - Cassandra column name (column key) type diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/TridentTupleMapper.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/TridentTupleMapper.java index 2698fa6..9e6abdf 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/TridentTupleMapper.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/TridentTupleMapper.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 com.hmsonline.storm.cassandra.bolt.mapper; import java.io.Serializable; @@ -11,8 +28,6 @@ /** * Interface for mapping Trident storm.trident.tuple.TridentTuple * objects to Cassandra rows. - * - * @author tgoetz * * @param - the Cassandra row key type * @param - the Cassandra column key/name type diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/TupleCounterMapper.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/TupleCounterMapper.java index ef3d77f..83cc02f 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/TupleCounterMapper.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/TupleCounterMapper.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 com.hmsonline.storm.cassandra.bolt.mapper; import java.io.Serializable; @@ -7,8 +24,7 @@ /** * Interface for mapping storm Tuples to Cassandra counter columns. - * - * @author tgoetz + * * */ public interface TupleCounterMapper extends Serializable { diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/TupleMapper.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/TupleMapper.java index 774ccf5..ea95a98 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/TupleMapper.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/TupleMapper.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 com.hmsonline.storm.cassandra.bolt.mapper; import java.io.Serializable; diff --git a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/ValuelessColumnsMapper.java b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/ValuelessColumnsMapper.java index 3721bcf..f9e0a78 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/ValuelessColumnsMapper.java +++ b/src/main/java/com/hmsonline/storm/cassandra/bolt/mapper/ValuelessColumnsMapper.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 com.hmsonline.storm.cassandra.bolt.mapper; import java.io.Serializable; @@ -52,9 +69,7 @@ * {rowKey:mike, follower:john} * {rowKey:mike, follower:bob} * - * - * @author tgoetz - * @author boneill42 + * */ @SuppressWarnings("serial") public class ValuelessColumnsMapper implements ColumnMapper, Serializable { diff --git a/src/main/java/com/hmsonline/storm/cassandra/client/AstyanaxClient.java b/src/main/java/com/hmsonline/storm/cassandra/client/AstyanaxClient.java index 26932d5..346b57b 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/client/AstyanaxClient.java +++ b/src/main/java/com/hmsonline/storm/cassandra/client/AstyanaxClient.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 com.hmsonline.storm.cassandra.client; import java.beans.IntrospectionException; @@ -71,9 +89,10 @@ import com.netflix.astyanax.util.RangeBuilder; /** - * - * @author tgoetz - * + * + * @param + * @param + * @param */ public class AstyanaxClient { private static final Logger LOG = LoggerFactory.getLogger(AstyanaxClient.class); diff --git a/src/main/java/com/hmsonline/storm/cassandra/composite/Composite2.java b/src/main/java/com/hmsonline/storm/cassandra/composite/Composite2.java index a4bb943..b1c90a9 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/composite/Composite2.java +++ b/src/main/java/com/hmsonline/storm/cassandra/composite/Composite2.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 com.hmsonline.storm.cassandra.composite; import com.netflix.astyanax.annotations.Component; diff --git a/src/main/java/com/hmsonline/storm/cassandra/exceptions/ExceptionHandler.java b/src/main/java/com/hmsonline/storm/cassandra/exceptions/ExceptionHandler.java index c1b11ff..b4b9cc3 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/exceptions/ExceptionHandler.java +++ b/src/main/java/com/hmsonline/storm/cassandra/exceptions/ExceptionHandler.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 com.hmsonline.storm.cassandra.exceptions; diff --git a/src/main/java/com/hmsonline/storm/cassandra/exceptions/MappedExceptionHandler.java b/src/main/java/com/hmsonline/storm/cassandra/exceptions/MappedExceptionHandler.java index 989db3c..2ed94b7 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/exceptions/MappedExceptionHandler.java +++ b/src/main/java/com/hmsonline/storm/cassandra/exceptions/MappedExceptionHandler.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 com.hmsonline.storm.cassandra.exceptions; import backtype.storm.topology.FailedException; diff --git a/src/main/java/com/hmsonline/storm/cassandra/exceptions/StormCassandraException.java b/src/main/java/com/hmsonline/storm/cassandra/exceptions/StormCassandraException.java index 8ba0fb2..67d0ac8 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/exceptions/StormCassandraException.java +++ b/src/main/java/com/hmsonline/storm/cassandra/exceptions/StormCassandraException.java @@ -1,11 +1,27 @@ +/* + * 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 com.hmsonline.storm.cassandra.exceptions; /** * Exception indicating that a recoverable error has occurred when * interacting with Cassandra, and Storm should * replay a tuple. - * - * @author tgoetz + * * */ public class StormCassandraException extends RuntimeException { diff --git a/src/main/java/com/hmsonline/storm/cassandra/exceptions/TupleMappingException.java b/src/main/java/com/hmsonline/storm/cassandra/exceptions/TupleMappingException.java index ac79af8..9138052 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/exceptions/TupleMappingException.java +++ b/src/main/java/com/hmsonline/storm/cassandra/exceptions/TupleMappingException.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. + */ + // // Copyright (c) 2013 Health Market Science, Inc. // diff --git a/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraMapState.java b/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraMapState.java index f52c296..ca712cd 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraMapState.java +++ b/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraMapState.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 com.hmsonline.storm.cassandra.trident; import java.io.Serializable; diff --git a/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraQuery.java b/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraQuery.java index b2e3d6d..7fa3557 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraQuery.java +++ b/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraQuery.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 com.hmsonline.storm.cassandra.trident; import java.util.List; diff --git a/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraState.java b/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraState.java index 92ec32c..5db88e8 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraState.java +++ b/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraState.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 com.hmsonline.storm.cassandra.trident; import java.util.ArrayList; diff --git a/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraStateFactory.java b/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraStateFactory.java index 2bf6ba9..4b10343 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraStateFactory.java +++ b/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraStateFactory.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 com.hmsonline.storm.cassandra.trident; import java.util.Map; diff --git a/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraUpdater.java b/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraUpdater.java index 1b6b199..b09ed6b 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraUpdater.java +++ b/src/main/java/com/hmsonline/storm/cassandra/trident/CassandraUpdater.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 com.hmsonline.storm.cassandra.trident; import java.util.List; diff --git a/src/main/java/com/hmsonline/storm/cassandra/trident/TridentCassandraLookupFunction.java b/src/main/java/com/hmsonline/storm/cassandra/trident/TridentCassandraLookupFunction.java index dc61fb0..66d779f 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/trident/TridentCassandraLookupFunction.java +++ b/src/main/java/com/hmsonline/storm/cassandra/trident/TridentCassandraLookupFunction.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 com.hmsonline.storm.cassandra.trident; import java.util.ArrayList; diff --git a/src/main/java/com/hmsonline/storm/cassandra/trident/TridentCassandraWriteFunction.java b/src/main/java/com/hmsonline/storm/cassandra/trident/TridentCassandraWriteFunction.java index 76de58d..47ecb7b 100644 --- a/src/main/java/com/hmsonline/storm/cassandra/trident/TridentCassandraWriteFunction.java +++ b/src/main/java/com/hmsonline/storm/cassandra/trident/TridentCassandraWriteFunction.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 com.hmsonline.storm.cassandra.trident; import java.util.Map; diff --git a/src/test/java/com/hmsonline/storm/cassandra/bolt/AstyanaxComposites.java b/src/test/java/com/hmsonline/storm/cassandra/bolt/AstyanaxComposites.java index 7c2d287..f7d9dd2 100644 --- a/src/test/java/com/hmsonline/storm/cassandra/bolt/AstyanaxComposites.java +++ b/src/test/java/com/hmsonline/storm/cassandra/bolt/AstyanaxComposites.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 com.hmsonline.storm.cassandra.bolt; import static com.hmsonline.storm.cassandra.bolt.AstyanaxUtil.createColumnFamily; diff --git a/src/test/java/com/hmsonline/storm/cassandra/bolt/AstyanaxUtil.java b/src/test/java/com/hmsonline/storm/cassandra/bolt/AstyanaxUtil.java index 51d3d65..7d9b6bb 100644 --- a/src/test/java/com/hmsonline/storm/cassandra/bolt/AstyanaxUtil.java +++ b/src/test/java/com/hmsonline/storm/cassandra/bolt/AstyanaxUtil.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 com.hmsonline.storm.cassandra.bolt; import java.util.HashMap; diff --git a/src/test/java/com/hmsonline/storm/cassandra/bolt/CassandraBoltTest.java b/src/test/java/com/hmsonline/storm/cassandra/bolt/CassandraBoltTest.java index c92e763..9ce98a4 100644 --- a/src/test/java/com/hmsonline/storm/cassandra/bolt/CassandraBoltTest.java +++ b/src/test/java/com/hmsonline/storm/cassandra/bolt/CassandraBoltTest.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 com.hmsonline.storm.cassandra.bolt; import static com.hmsonline.storm.cassandra.bolt.AstyanaxUtil.createColumnFamily; diff --git a/src/test/java/com/hmsonline/storm/cassandra/bolt/CassandraMapStateTest.java b/src/test/java/com/hmsonline/storm/cassandra/bolt/CassandraMapStateTest.java index 60751f4..4083bf8 100644 --- a/src/test/java/com/hmsonline/storm/cassandra/bolt/CassandraMapStateTest.java +++ b/src/test/java/com/hmsonline/storm/cassandra/bolt/CassandraMapStateTest.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 com.hmsonline.storm.cassandra.bolt; import static com.hmsonline.storm.cassandra.bolt.AstyanaxUtil.createColumnFamily; diff --git a/src/test/java/com/hmsonline/storm/cassandra/bolt/CompositeColumnTridentTupleMapper.java b/src/test/java/com/hmsonline/storm/cassandra/bolt/CompositeColumnTridentTupleMapper.java index b6ee6a5..d76ab2c 100644 --- a/src/test/java/com/hmsonline/storm/cassandra/bolt/CompositeColumnTridentTupleMapper.java +++ b/src/test/java/com/hmsonline/storm/cassandra/bolt/CompositeColumnTridentTupleMapper.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 com.hmsonline.storm.cassandra.bolt; import java.util.HashMap; diff --git a/src/test/java/com/hmsonline/storm/cassandra/bolt/CompositeTest.java b/src/test/java/com/hmsonline/storm/cassandra/bolt/CompositeTest.java index 8a76a0c..84f9e24 100644 --- a/src/test/java/com/hmsonline/storm/cassandra/bolt/CompositeTest.java +++ b/src/test/java/com/hmsonline/storm/cassandra/bolt/CompositeTest.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 com.hmsonline.storm.cassandra.bolt; import static com.hmsonline.storm.cassandra.bolt.AstyanaxUtil.createColumnFamily; diff --git a/src/test/java/com/hmsonline/storm/cassandra/bolt/MockTopologyContext.java b/src/test/java/com/hmsonline/storm/cassandra/bolt/MockTopologyContext.java index 4d43230..2389d68 100644 --- a/src/test/java/com/hmsonline/storm/cassandra/bolt/MockTopologyContext.java +++ b/src/test/java/com/hmsonline/storm/cassandra/bolt/MockTopologyContext.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 com.hmsonline.storm.cassandra.bolt; import java.util.ArrayList; diff --git a/src/test/java/com/hmsonline/storm/cassandra/bolt/MockTuple.java b/src/test/java/com/hmsonline/storm/cassandra/bolt/MockTuple.java index 10be3cd..72c61c8 100644 --- a/src/test/java/com/hmsonline/storm/cassandra/bolt/MockTuple.java +++ b/src/test/java/com/hmsonline/storm/cassandra/bolt/MockTuple.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 com.hmsonline.storm.cassandra.bolt; import java.util.List; diff --git a/src/test/java/com/hmsonline/storm/cassandra/bolt/SimpleComposite.java b/src/test/java/com/hmsonline/storm/cassandra/bolt/SimpleComposite.java index 6caa68b..7ff7c52 100644 --- a/src/test/java/com/hmsonline/storm/cassandra/bolt/SimpleComposite.java +++ b/src/test/java/com/hmsonline/storm/cassandra/bolt/SimpleComposite.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 com.hmsonline.storm.cassandra.bolt; import java.io.Serializable; diff --git a/src/test/java/com/hmsonline/storm/cassandra/bolt/SimpleTridentTupleMapper.java b/src/test/java/com/hmsonline/storm/cassandra/bolt/SimpleTridentTupleMapper.java index ea7745a..e2494a1 100644 --- a/src/test/java/com/hmsonline/storm/cassandra/bolt/SimpleTridentTupleMapper.java +++ b/src/test/java/com/hmsonline/storm/cassandra/bolt/SimpleTridentTupleMapper.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 com.hmsonline.storm.cassandra.bolt; import java.util.HashMap; diff --git a/src/test/java/com/hmsonline/storm/cassandra/bolt/SimpleTupleMapper.java b/src/test/java/com/hmsonline/storm/cassandra/bolt/SimpleTupleMapper.java index 871126a..ca54e3d 100644 --- a/src/test/java/com/hmsonline/storm/cassandra/bolt/SimpleTupleMapper.java +++ b/src/test/java/com/hmsonline/storm/cassandra/bolt/SimpleTupleMapper.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 com.hmsonline.storm.cassandra.bolt; import java.util.HashMap; diff --git a/src/test/java/com/hmsonline/storm/cassandra/bolt/SingletonEmbeddedCassandra.java b/src/test/java/com/hmsonline/storm/cassandra/bolt/SingletonEmbeddedCassandra.java index a65fa00..daf0538 100644 --- a/src/test/java/com/hmsonline/storm/cassandra/bolt/SingletonEmbeddedCassandra.java +++ b/src/test/java/com/hmsonline/storm/cassandra/bolt/SingletonEmbeddedCassandra.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 com.hmsonline.storm.cassandra.bolt; import com.netflix.astyanax.test.EmbeddedCassandra; diff --git a/src/test/resources/CassandraBoltTest.yaml b/src/test/resources/CassandraBoltTest.yaml index d66a3db..8634332 100644 --- a/src/test/resources/CassandraBoltTest.yaml +++ b/src/test/resources/CassandraBoltTest.yaml @@ -1,3 +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. name: TestKeyspace columnFamilies: - name: users diff --git a/src/test/resources/cassandra-template.yaml b/src/test/resources/cassandra-template.yaml index 93a1758..fab8208 100644 --- a/src/test/resources/cassandra-template.yaml +++ b/src/test/resources/cassandra-template.yaml @@ -1,3 +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. # Cassandra storage config YAML cluster_name: '$CLUSTER$' initial_token: 0 diff --git a/src/test/resources/log4j.properties b/src/test/resources/log4j.properties index d150cd4..6aad216 100644 --- a/src/test/resources/log4j.properties +++ b/src/test/resources/log4j.properties @@ -1,3 +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. log4j.rootLogger=DEBUG, stdout log4j.appender.stdout=org.apache.log4j.ConsoleAppender