You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@metron.apache.org by ce...@apache.org on 2016/02/18 21:57:58 UTC

[4/6] incubator-metron git commit: METRON-38 Add license header to source closes apache/incubator-metron#24

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/ExtractorHandler.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/ExtractorHandler.java b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/ExtractorHandler.java
index cc63c14..b9d270a 100644
--- a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/ExtractorHandler.java
+++ b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/ExtractorHandler.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.metron.dataloads.extractor;
 
 import org.apache.metron.dataloads.extractor.inputformat.Formats;
@@ -11,9 +28,6 @@ import java.nio.charset.Charset;
 import java.nio.charset.StandardCharsets;
 import java.util.Map;
 
-/**
- * Created by cstella on 2/2/16.
- */
 public class ExtractorHandler {
     final static ObjectMapper _mapper = new ObjectMapper();
     private Map<String, Object> config;

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/Extractors.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/Extractors.java b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/Extractors.java
index b11ccd9..bbd4c22 100644
--- a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/Extractors.java
+++ b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/Extractors.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.metron.dataloads.extractor;
 
 import org.apache.metron.dataloads.extractor.csv.CSVExtractor;
@@ -5,9 +22,6 @@ import org.apache.metron.dataloads.extractor.stix.StixExtractor;
 
 import java.util.Map;
 
-/**
- * Created by cstella on 2/2/16.
- */
 public enum Extractors implements ExtractorCreator {
     CSV(new ExtractorCreator() {
 

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/csv/CSVExtractor.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/csv/CSVExtractor.java b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/csv/CSVExtractor.java
index ee85a58..f5ec434 100644
--- a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/csv/CSVExtractor.java
+++ b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/csv/CSVExtractor.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.metron.dataloads.extractor.csv;
 
 import com.google.common.base.Splitter;
@@ -10,9 +27,6 @@ import org.apache.metron.threatintel.ThreatIntelResults;
 import java.io.IOException;
 import java.util.*;
 
-/**
- * Created by cstella on 2/2/16.
- */
 public class CSVExtractor implements Extractor {
     public static final String COLUMNS_KEY="columns";
     public static final String INDICATOR_COLUMN_KEY="indicator_column";

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/inputformat/Formats.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/inputformat/Formats.java b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/inputformat/Formats.java
index 9fb2231..7e58455 100644
--- a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/inputformat/Formats.java
+++ b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/inputformat/Formats.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.metron.dataloads.extractor.inputformat;
 
 import org.apache.hadoop.fs.Path;
@@ -7,9 +24,6 @@ import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
 import java.io.IOException;
 import java.util.Map;
 
-/**
- * Created by cstella on 2/8/16.
- */
 public enum Formats implements InputFormatHandler{
     BY_LINE(new InputFormatHandler() {
         @Override

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/inputformat/InputFormatHandler.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/inputformat/InputFormatHandler.java b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/inputformat/InputFormatHandler.java
index 28cd241..2287969 100644
--- a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/inputformat/InputFormatHandler.java
+++ b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/inputformat/InputFormatHandler.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.metron.dataloads.extractor.inputformat;
 
 import org.apache.hadoop.fs.Path;
@@ -6,9 +23,6 @@ import org.apache.hadoop.mapreduce.Job;
 import java.io.IOException;
 import java.util.Map;
 
-/**
- * Created by cstella on 2/8/16.
- */
 public interface InputFormatHandler {
     void set(Job job, Path input, Map<String, Object> config) throws IOException;
 }

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/inputformat/WholeFileFormat.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/inputformat/WholeFileFormat.java b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/inputformat/WholeFileFormat.java
index 6c694f7..e0a58ef 100644
--- a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/inputformat/WholeFileFormat.java
+++ b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/inputformat/WholeFileFormat.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.metron.dataloads.extractor.inputformat;
 
 import org.apache.hadoop.conf.Configuration;
@@ -15,9 +32,6 @@ import org.apache.hadoop.mapreduce.lib.input.FileSplit;
 import java.io.IOException;
 import java.util.Map;
 
-/**
- * Created by cstella on 2/8/16.
- */
 public class WholeFileFormat implements InputFormatHandler {
 
     public static class WholeFileRecordReader extends RecordReader<NullWritable, Text> {

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/StixExtractor.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/StixExtractor.java b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/StixExtractor.java
index 493adb6..039092f 100644
--- a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/StixExtractor.java
+++ b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/StixExtractor.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.metron.dataloads.extractor.stix;
 
 import com.google.common.base.Splitter;
@@ -19,9 +36,6 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 
-/**
- * Created by cstella on 2/8/16.
- */
 public class StixExtractor implements Extractor {
     Map<String, Object> config;
     @Override

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/AbstractObjectTypeHandler.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/AbstractObjectTypeHandler.java b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/AbstractObjectTypeHandler.java
index 9611150..c84dba9 100644
--- a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/AbstractObjectTypeHandler.java
+++ b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/AbstractObjectTypeHandler.java
@@ -1,11 +1,25 @@
+/**
+ * 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.metron.dataloads.extractor.stix.types;
 
 import org.mitre.cybox.common_2.ObjectPropertiesType;
 import org.mitre.cybox.common_2.StringObjectPropertyType;
 
-/**
- * Created by cstella on 2/9/16.
- */
 public abstract class AbstractObjectTypeHandler<T extends ObjectPropertiesType> implements ObjectTypeHandler<T> {
     protected Class<T> objectPropertiesType;
     public AbstractObjectTypeHandler(Class<T> clazz) {

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/AddressHandler.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/AddressHandler.java b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/AddressHandler.java
index 4a280e1..ee4ff78 100644
--- a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/AddressHandler.java
+++ b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/AddressHandler.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.metron.dataloads.extractor.stix.types;
 
 import com.google.common.base.Splitter;
@@ -13,9 +30,6 @@ import org.mitre.cybox.objects.CategoryTypeEnum;
 import java.io.IOException;
 import java.util.*;
 
-/**
- * Created by cstella on 2/9/16.
- */
 public class AddressHandler extends AbstractObjectTypeHandler<Address> {
     public static final String SPECIFIC_CATEGORY_CONFIG = "stix_address_categories";
     public static final EnumSet<CategoryTypeEnum> SUPPORTED_CATEGORIES = EnumSet.of(CategoryTypeEnum.E_MAIL

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/DomainHandler.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/DomainHandler.java b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/DomainHandler.java
index 51769ff..e0444fb 100644
--- a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/DomainHandler.java
+++ b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/DomainHandler.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.metron.dataloads.extractor.stix.types;
 
 import org.apache.metron.dataloads.extractor.stix.StixExtractor;
@@ -10,9 +27,6 @@ import org.mitre.cybox.objects.DomainNameTypeEnum;
 import java.io.IOException;
 import java.util.*;
 
-/**
- * Created by cstella on 2/9/16.
- */
 public class DomainHandler extends AbstractObjectTypeHandler<DomainName> {
     EnumSet<DomainNameTypeEnum> SUPPORTED_TYPES = EnumSet.of(DomainNameTypeEnum.FQDN);
     public DomainHandler() {

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/HostnameHandler.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/HostnameHandler.java b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/HostnameHandler.java
index d6bfd05..d0c55a9 100644
--- a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/HostnameHandler.java
+++ b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/HostnameHandler.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.metron.dataloads.extractor.stix.types;
 
 import org.apache.metron.dataloads.extractor.stix.StixExtractor;
@@ -12,9 +30,6 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
-/**
- * Created by cstella on 2/9/16.
- */
 public class HostnameHandler  extends AbstractObjectTypeHandler<Hostname>{
     public HostnameHandler() {
         super(Hostname.class);

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/ObjectTypeHandler.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/ObjectTypeHandler.java b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/ObjectTypeHandler.java
index 8de5dd2..f639be0 100644
--- a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/ObjectTypeHandler.java
+++ b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/ObjectTypeHandler.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.metron.dataloads.extractor.stix.types;
 
 import org.apache.metron.dataloads.extractor.Extractor;
@@ -7,9 +24,6 @@ import org.mitre.cybox.common_2.ObjectPropertiesType;
 import java.io.IOException;
 import java.util.Map;
 
-/**
- * Created by cstella on 2/9/16.
- */
 public interface ObjectTypeHandler<T extends ObjectPropertiesType> {
     Iterable<ThreatIntelResults> extract(T type, Map<String, Object> config) throws IOException;
     Class<T> getTypeClass();

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/ObjectTypeHandlers.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/ObjectTypeHandlers.java b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/ObjectTypeHandlers.java
index 85d20b2..06d8cd8 100644
--- a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/ObjectTypeHandlers.java
+++ b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/extractor/stix/types/ObjectTypeHandlers.java
@@ -1,10 +1,24 @@
+/**
+ * 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.metron.dataloads.extractor.stix.types;
 
 import org.mitre.cybox.common_2.ObjectPropertiesType;
 
-/**
- * Created by cstella on 2/9/16.
- */
 public enum ObjectTypeHandlers {
       ADDRESS(new AddressHandler())
     ,HOSTNAME(new HostnameHandler())

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/hbase/mr/BulkLoadMapper.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/hbase/mr/BulkLoadMapper.java b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/hbase/mr/BulkLoadMapper.java
index 84931df..0ad09e6 100644
--- a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/hbase/mr/BulkLoadMapper.java
+++ b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/hbase/mr/BulkLoadMapper.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.metron.dataloads.hbase.mr;
 
 import org.apache.hadoop.conf.Configuration;
@@ -12,9 +29,6 @@ import org.apache.metron.threatintel.hbase.Converter;
 
 import java.io.IOException;
 
-/**
- * Created by cstella on 2/3/16.
- */
 public class BulkLoadMapper extends Mapper<Object, Text, ImmutableBytesWritable, Put>
 {
     public static final String CONFIG_KEY="bl_extractor_config";

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/hbase/mr/PrunerMapper.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/hbase/mr/PrunerMapper.java b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/hbase/mr/PrunerMapper.java
index 0673bb3..3e19b07 100644
--- a/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/hbase/mr/PrunerMapper.java
+++ b/metron-streaming/Metron-DataLoads/src/main/java/org/apache/metron/dataloads/hbase/mr/PrunerMapper.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.metron.dataloads.hbase.mr;
 
 import org.apache.hadoop.fs.FileSystem;
@@ -12,9 +29,6 @@ import org.apache.metron.reference.lookup.accesstracker.AccessTrackerUtil;
 
 import java.io.IOException;
 
-/**
- * Created by cstella on 2/5/16.
- */
 public class PrunerMapper extends TableMapper<ImmutableBytesWritable, Delete> {
     public static final String ACCESS_TRACKER_TABLE_CONF = "access_tracker_table";
     public static final String ACCESS_TRACKER_CF_CONF = "access_tracker_cf";

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/extractor/ExtractorTest.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/extractor/ExtractorTest.java b/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/extractor/ExtractorTest.java
index e949cc7..519b95a 100644
--- a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/extractor/ExtractorTest.java
+++ b/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/extractor/ExtractorTest.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.metron.dataloads.extractor;
 
 import com.google.common.collect.Iterables;
@@ -11,9 +28,6 @@ import java.util.Arrays;
 import java.util.HashMap;
 import java.util.Map;
 
-/**
- * Created by cstella on 2/3/16.
- */
 public class ExtractorTest {
     public static class DummyExtractor implements Extractor
     {

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/extractor/csv/CSVExtractorTest.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/extractor/csv/CSVExtractorTest.java b/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/extractor/csv/CSVExtractorTest.java
index 923cbb5..96d9046 100644
--- a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/extractor/csv/CSVExtractorTest.java
+++ b/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/extractor/csv/CSVExtractorTest.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.metron.dataloads.extractor.csv;
 
 import com.google.common.collect.Iterables;
@@ -8,9 +25,6 @@ import org.junit.Test;
 
 import java.io.IOException;
 
-/**
- * Created by cstella on 2/3/16.
- */
 public class CSVExtractorTest {
     @Test
     public void testCSVExtractorMapColumns() throws Exception {

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/extractor/stix/StixExtractorTest.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/extractor/stix/StixExtractorTest.java b/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/extractor/stix/StixExtractorTest.java
index d362241..f25a5a0 100644
--- a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/extractor/stix/StixExtractorTest.java
+++ b/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/extractor/stix/StixExtractorTest.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.metron.dataloads.extractor.stix;
 
 import com.google.common.collect.Iterables;
@@ -10,9 +27,6 @@ import org.junit.Test;
 
 import java.util.List;
 
-/**
- * Created by cstella on 2/9/16.
- */
 public class StixExtractorTest {
     @Test
     public void testStixAddresses() throws Exception {

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/HBaseConverterTest.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/HBaseConverterTest.java b/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/HBaseConverterTest.java
index 25cdbc7..3587e59 100644
--- a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/HBaseConverterTest.java
+++ b/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/HBaseConverterTest.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.metron.dataloads.hbase;
 
 import org.apache.hadoop.hbase.client.Get;
@@ -14,9 +31,6 @@ import java.util.AbstractMap;
 import java.util.HashMap;
 import java.util.Map;
 
-/**
- * Created by cstella on 2/3/16.
- */
 public class HBaseConverterTest {
     ThreatIntelKey key = new ThreatIntelKey("google");
     Map<String, String> value = new HashMap<String, String>() {{

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/BulkLoadMapperIntegrationTest.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/BulkLoadMapperIntegrationTest.java b/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/BulkLoadMapperIntegrationTest.java
index 179337e..2824de8 100644
--- a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/BulkLoadMapperIntegrationTest.java
+++ b/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/BulkLoadMapperIntegrationTest.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.metron.dataloads.hbase.mr;
 
 import org.apache.hadoop.conf.Configuration;
@@ -22,9 +39,6 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 
-/**
- * Created by cstella on 2/5/16.
- */
 public class BulkLoadMapperIntegrationTest {
   /** The test util. */
   private HBaseTestingUtility testUtil;

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/BulkLoadMapperTest.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/BulkLoadMapperTest.java b/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/BulkLoadMapperTest.java
index 1d30b5c..c98c256 100644
--- a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/BulkLoadMapperTest.java
+++ b/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/BulkLoadMapperTest.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.metron.dataloads.hbase.mr;
 
 import org.apache.hadoop.conf.Configuration;
@@ -14,9 +31,6 @@ import java.io.IOException;
 import java.util.HashMap;
 import java.util.Map;
 
-/**
- * Created by cstella on 2/3/16.
- */
 public class BulkLoadMapperTest {
     @Test
     public void testMapper() throws IOException, InterruptedException {

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/HBaseUtil.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/HBaseUtil.java b/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/HBaseUtil.java
index d243a65..c9c6424 100644
--- a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/HBaseUtil.java
+++ b/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/HBaseUtil.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.metron.dataloads.hbase.mr;
 
 import com.google.common.base.Joiner;
@@ -15,9 +32,6 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 
-/**
- * Created by cstella on 2/5/16.
- */
 public enum HBaseUtil {
     INSTANCE;
     public Map.Entry<HBaseTestingUtility,Configuration> create(boolean startMRCluster) throws Exception {

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/LeastRecentlyUsedPrunerIntegrationTest.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/LeastRecentlyUsedPrunerIntegrationTest.java b/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/LeastRecentlyUsedPrunerIntegrationTest.java
index 3979224..6d5c71c 100644
--- a/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/LeastRecentlyUsedPrunerIntegrationTest.java
+++ b/metron-streaming/Metron-DataLoads/src/test/java/org/apache/metron/dataloads/hbase/mr/LeastRecentlyUsedPrunerIntegrationTest.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.metron.dataloads.hbase.mr;
 
 import com.google.common.collect.Iterables;
@@ -26,9 +43,6 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
-/**
- * Created by cstella on 2/8/16.
- */
 public class LeastRecentlyUsedPrunerIntegrationTest {
     /** The test util. */
     private HBaseTestingUtility testUtil;

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/pom.xml
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/pom.xml b/metron-streaming/Metron-DataServices/pom.xml
index e3e4211..80d526f 100644
--- a/metron-streaming/Metron-DataServices/pom.xml
+++ b/metron-streaming/Metron-DataServices/pom.xml
@@ -1,3 +1,15 @@
+<!--.
+  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..
+  -->
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsCacheReaper.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsCacheReaper.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsCacheReaper.java
index 42dc913..29229a2 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsCacheReaper.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsCacheReaper.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.metron.alerts.server;
 
 import java.util.ArrayList;
@@ -42,4 +59,4 @@ public class AlertsCacheReaper implements Runnable {
 			searcher.alertsFilterCache.remove(key);
 		}
 	}
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsFilterCacheEntry.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsFilterCacheEntry.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsFilterCacheEntry.java
index f161ad3..1a93900 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsFilterCacheEntry.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsFilterCacheEntry.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.metron.alerts.server;
 
 public class AlertsFilterCacheEntry {

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsProcessingServer.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsProcessingServer.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsProcessingServer.java
index 50c3d30..9e99733 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsProcessingServer.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsProcessingServer.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.metron.alerts.server;
 
 import static java.util.concurrent.TimeUnit.SECONDS;
@@ -40,4 +57,4 @@ public class AlertsProcessingServer {
 		scheduler.scheduleAtFixedRate(reaper, 120, 380, SECONDS);
 		
 	}
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsSearcher.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsSearcher.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsSearcher.java
index 9850c41..eca79b8 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsSearcher.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/alerts/server/AlertsSearcher.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.metron.alerts.server;
 
 import java.io.File;
@@ -232,4 +249,4 @@ public class AlertsSearcher implements Runnable {
 		 
 		producer.send(data);		
 	}
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/Main.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/Main.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/Main.java
index c80c6f6..e839c15 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/Main.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/Main.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.metron.dataservices;
 
 import java.io.File;
@@ -285,4 +302,4 @@ public class Main {
         
         server.join();
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/AuthToken.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/AuthToken.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/AuthToken.java
index 8e0e59c..047c8b8 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/AuthToken.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/AuthToken.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.metron.dataservices.auth;
 
 import java.io.FileInputStream;

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/AuthTokenFilter.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/AuthTokenFilter.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/AuthTokenFilter.java
index e68fdc6..53014da 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/AuthTokenFilter.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/AuthTokenFilter.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.metron.dataservices.auth;
 
 import java.lang.annotation.ElementType;

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/CustomDomainADRealm.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/CustomDomainADRealm.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/CustomDomainADRealm.java
index cc86ec7..36d9a43 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/CustomDomainADRealm.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/CustomDomainADRealm.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.metron.dataservices.auth;
 
 import javax.naming.NamingException;

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/RestSecurityInterceptor.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/RestSecurityInterceptor.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/RestSecurityInterceptor.java
index aee019d..44837e8 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/RestSecurityInterceptor.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/auth/RestSecurityInterceptor.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.metron.dataservices.auth;
 
 import java.io.IOException;
@@ -54,4 +71,4 @@ public class RestSecurityInterceptor implements javax.ws.rs.container.ContainerR
 		// if the token is good, just return...
 		
 	}
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/common/MetronService.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/common/MetronService.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/common/MetronService.java
index 1c812ed..476c23e 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/common/MetronService.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/common/MetronService.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.metron.dataservices.common;
 
 public interface MetronService {

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/KafkaClient.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/KafkaClient.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/KafkaClient.java
index ffc5e13..ff1b796 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/KafkaClient.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/KafkaClient.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.metron.dataservices.kafkaclient;
 
 import java.util.HashMap;

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/KafkaConsumer.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/KafkaConsumer.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/KafkaConsumer.java
index 633350c..eb13295 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/KafkaConsumer.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/KafkaConsumer.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.metron.dataservices.kafkaclient;
 
 import java.io.IOException;

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/poll/PollingKafkaClient.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/poll/PollingKafkaClient.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/poll/PollingKafkaClient.java
index 9e0ae15..9cf3337 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/poll/PollingKafkaClient.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/poll/PollingKafkaClient.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.metron.dataservices.kafkaclient.poll;
 
 import java.util.ArrayList;
@@ -98,4 +115,4 @@ public class PollingKafkaClient
         
     	return messages;
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/poll/PollingKafkaConsumer.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/poll/PollingKafkaConsumer.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/poll/PollingKafkaConsumer.java
index 0d40607..ce323ec 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/poll/PollingKafkaConsumer.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/kafkaclient/poll/PollingKafkaConsumer.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.metron.dataservices.kafkaclient.poll;
 
 import java.util.List;
@@ -49,4 +66,4 @@ public class PollingKafkaConsumer implements Runnable
 		
 		logger.warn("Shutting down Thread: " + m_threadNumber);
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/AlertsServerModule.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/AlertsServerModule.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/AlertsServerModule.java
index 2f1e9bf..2435dc4 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/AlertsServerModule.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/AlertsServerModule.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.metron.dataservices.modules.guice;
 
 import java.util.Properties;
@@ -33,4 +50,4 @@ public class AlertsServerModule extends AbstractModule {
 	{
 		return configProps;
 	}
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/DefaultServletModule.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/DefaultServletModule.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/DefaultServletModule.java
index 571e3c2..1d20e18 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/DefaultServletModule.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/DefaultServletModule.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.metron.dataservices.modules.guice;
 
 import java.util.Properties;
@@ -44,4 +61,4 @@ public class DefaultServletModule extends ServletModule {
 		serve( "/logout" ).with( LogoutServlet.class );
 		
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/DefaultShiroWebModule.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/DefaultShiroWebModule.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/DefaultShiroWebModule.java
index 22e9ad9..fb76401 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/DefaultShiroWebModule.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/DefaultShiroWebModule.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.metron.dataservices.modules.guice;
 
 import java.util.HashMap;
@@ -87,4 +104,4 @@ public class DefaultShiroWebModule extends ShiroWebModule {
     	realm.setGroupRolesMap(groupRolesMap);
     	return realm;
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/RestEasyModule.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/RestEasyModule.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/RestEasyModule.java
index 833fb1a..74ff23a 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/RestEasyModule.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/RestEasyModule.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.metron.dataservices.modules.guice;
 
 import org.slf4j.Logger;

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/ServiceModule.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/ServiceModule.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/ServiceModule.java
index 6ae8596..78203b3 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/ServiceModule.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/modules/guice/ServiceModule.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.metron.dataservices.modules.guice;
 
 import javax.inject.Singleton;

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/rest/Index.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/rest/Index.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/rest/Index.java
index 79e6a41..bedbfed 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/rest/Index.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/rest/Index.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.metron.dataservices.rest;
 
 import java.util.List;
@@ -50,4 +67,4 @@ public class Index
 		return Response.status(200).entity( respString1 + respString2 ).build();
 				
 	}
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/rest/RestServices.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/rest/RestServices.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/rest/RestServices.java
index ab6b172..8d9fc6b 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/rest/RestServices.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/rest/RestServices.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.metron.dataservices.rest;
 
 import java.util.HashSet;
@@ -30,4 +47,4 @@ public class RestServices extends Application
 	{
 		return services;
 	}
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/servlet/LoginServlet.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/servlet/LoginServlet.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/servlet/LoginServlet.java
index 0a6fd8a..68f910e 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/servlet/LoginServlet.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/servlet/LoginServlet.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.metron.dataservices.servlet;
 
 import java.io.IOException;
@@ -110,4 +127,4 @@ public class LoginServlet extends HttpServlet
 			return;
 		}
 	}	
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/c4954e8a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/servlet/LogoutServlet.java
----------------------------------------------------------------------
diff --git a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/servlet/LogoutServlet.java b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/servlet/LogoutServlet.java
index 488c25f..0812b47 100644
--- a/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/servlet/LogoutServlet.java
+++ b/metron-streaming/Metron-DataServices/src/main/java/org/apache/metron/dataservices/servlet/LogoutServlet.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.metron.dataservices.servlet;
 
 import java.io.IOException;
@@ -40,4 +57,4 @@ public class LogoutServlet extends HttpServlet
 		
 		resp.sendRedirect( "/login.jsp" );
 	}	
-}
\ No newline at end of file
+}