commit a667c75d025a5b7ba40afba5503e88c44a76ad91
author P. Taylor Goetz <ptgoetz@gmail.com> Wed Sep 28 15:11:08 2016 -0400
committer P. Taylor Goetz <ptgoetz@gmail.com> Wed Sep 28 15:11:08 2016 -0400
tree d2d823bf738a3b61841c545ce7ca1998810cb4ff
parent 3654b8caf161768255b77a210d0234a373e86512

SQE: Apply Apache license headers

external/storm-sqe/conf/multi-type-props.yaml

diff --git a/external/storm-sqe/conf/multi-type-props.yaml b/external/storm-sqe/conf/multi-type-props.yaml
index 1a332d4..a30d6af 100644
--- a/external/storm-sqe/conf/multi-type-props.yaml
+++ b/external/storm-sqe/conf/multi-type-props.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.
 none: null
 bool: true
 int: 42

external/storm-sqe/conf/sample-conf.yaml

diff --git a/external/storm-sqe/conf/sample-conf.yaml b/external/storm-sqe/conf/sample-conf.yaml
index 67dcfbc..0805a08 100644
--- a/external/storm-sqe/conf/sample-conf.yaml
+++ b/external/storm-sqe/conf/sample-conf.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.
 Storm:
     topology.workers: 1
 

external/storm-sqe/pom.xml

diff --git a/external/storm-sqe/pom.xml b/external/storm-sqe/pom.xml
index 550e16c..d5b7f4c 100644
--- a/external/storm-sqe/pom.xml
+++ b/external/storm-sqe/pom.xml
@@ -1,4 +1,20 @@
 <?xml version="1.0" encoding="UTF-8"?>
+<!--
+ 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">

external/storm-sqe/src/main/java/com/jwplayer/sqe/QueryEngine.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/QueryEngine.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/QueryEngine.java
index 9358a99..8de1d5a 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/QueryEngine.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/QueryEngine.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.jwplayer.sqe;
 
 import java.io.Serializable;

external/storm-sqe/src/main/java/com/jwplayer/sqe/Topology.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/Topology.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/Topology.java
index f508169..29b3e3a 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/Topology.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/Topology.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.jwplayer.sqe;
 
 import java.io.IOException;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/clause/FromClause.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/clause/FromClause.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/clause/FromClause.java
index e076e71..d1fc13c 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/clause/FromClause.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/clause/FromClause.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.jwplayer.sqe.language.clause;
 
 public class FromClause {

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/clause/InsertIntoClause.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/clause/InsertIntoClause.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/clause/InsertIntoClause.java
index e7c757e..4589756 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/clause/InsertIntoClause.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/clause/InsertIntoClause.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.jwplayer.sqe.language.clause;
 
 import org.apache.storm.trident.state.StateType;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/clause/SelectClause.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/clause/SelectClause.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/clause/SelectClause.java
index fe28ee1..dddfd51 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/clause/SelectClause.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/clause/SelectClause.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.jwplayer.sqe.language.clause;
 
 import com.jwplayer.sqe.language.expression.BaseExpression;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/BaseCommand.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/BaseCommand.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/BaseCommand.java
index c29e7b5..1d52c0e 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/BaseCommand.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/BaseCommand.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.jwplayer.sqe.language.command;
 
 import com.google.gson.*;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/CommandType.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/CommandType.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/CommandType.java
index 2e898fd..83ee954 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/CommandType.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/CommandType.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.jwplayer.sqe.language.command;
 
 public enum CommandType {

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/CreateStream.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/CreateStream.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/CreateStream.java
index dddeb3b..8ddacf8 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/CreateStream.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/CreateStream.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.jwplayer.sqe.language.command;
 
 import org.apache.storm.trident.state.StateType;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/Query.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/Query.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/Query.java
index 78879aa..22e9f6d 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/Query.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/Query.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.jwplayer.sqe.language.command;
 
 import com.google.gson.GsonBuilder;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/SetCommand.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/SetCommand.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/SetCommand.java
index 8aba0ec..bd512f8 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/SetCommand.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/command/SetCommand.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.jwplayer.sqe.language.command;
 
 public class SetCommand extends BaseCommand {

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/BaseExpression.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/BaseExpression.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/BaseExpression.java
index ce7ac47..1aa4eca 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/BaseExpression.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/BaseExpression.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.jwplayer.sqe.language.expression;
 
 import com.google.gson.*;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/ConstantExpression.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/ConstantExpression.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/ConstantExpression.java
index c734717..da01064 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/ConstantExpression.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/ConstantExpression.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.jwplayer.sqe.language.expression;
 
 import java.util.ArrayList;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/ExpressionType.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/ExpressionType.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/ExpressionType.java
index d625e09..b20b252 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/ExpressionType.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/ExpressionType.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.jwplayer.sqe.language.expression;
 
 public enum ExpressionType {

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/FieldExpression.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/FieldExpression.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/FieldExpression.java
index e171256..1d16801 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/FieldExpression.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/FieldExpression.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.jwplayer.sqe.language.expression;
 
 import java.util.List;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/FunctionExpression.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/FunctionExpression.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/FunctionExpression.java
index 3e5d0c8..eedbb50 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/FunctionExpression.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/FunctionExpression.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.jwplayer.sqe.language.expression;
 
 import java.util.*;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/FunctionType.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/FunctionType.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/FunctionType.java
index 331b0c2..0ae72df 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/FunctionType.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/FunctionType.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.jwplayer.sqe.language.expression;
 
 public enum FunctionType {

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/AggregationExpression.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/AggregationExpression.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/AggregationExpression.java
index d1c1719..9c6685a 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/AggregationExpression.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/AggregationExpression.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.jwplayer.sqe.language.expression.aggregation;
 
 import com.jwplayer.sqe.language.expression.BaseExpression;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/CreateHll.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/CreateHll.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/CreateHll.java
index 14089ef..0e4f151 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/CreateHll.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/CreateHll.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.jwplayer.sqe.language.expression.aggregation;
 
 import com.jwplayer.sqe.language.expression.BaseExpression;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/CreateHllp.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/CreateHllp.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/CreateHllp.java
index e495af0..0b593c8 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/CreateHllp.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/CreateHllp.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.jwplayer.sqe.language.expression.aggregation;
 
 import com.jwplayer.sqe.trident.aggregator.HllpAggregator;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/Max.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/Max.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/Max.java
index d9a867b..857c65e 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/Max.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/Max.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.jwplayer.sqe.language.expression.aggregation;
 
 import com.jwplayer.sqe.trident.aggregator.GetMaximumAggregator;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/Sum.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/Sum.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/Sum.java
index d4f5748..f6bccaa 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/Sum.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/aggregation/Sum.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.jwplayer.sqe.language.expression.aggregation;
 
 import org.apache.storm.trident.fluent.ChainedFullAggregatorDeclarer;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ArithmeticOperator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ArithmeticOperator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ArithmeticOperator.java
index c11a23f..59ca8d3 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ArithmeticOperator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ArithmeticOperator.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.jwplayer.sqe.language.expression.transform;
 
 import com.jwplayer.sqe.trident.function.ProcessArithmeticOperator;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ArithmeticOperatorType.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ArithmeticOperatorType.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ArithmeticOperatorType.java
index 7f358d4..77cf9a7 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ArithmeticOperatorType.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ArithmeticOperatorType.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.jwplayer.sqe.language.expression.transform;
 
 public enum ArithmeticOperatorType {

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/DivisionArithmeticOperator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/DivisionArithmeticOperator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/DivisionArithmeticOperator.java
index 1dda56c..b675785 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/DivisionArithmeticOperator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/DivisionArithmeticOperator.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.jwplayer.sqe.language.expression.transform;
 
 

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ExpandKeys.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ExpandKeys.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ExpandKeys.java
index 1e08781..d4180ba 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ExpandKeys.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ExpandKeys.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.jwplayer.sqe.language.expression.transform;
 
 import org.apache.storm.trident.Stream;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ExpandValues.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ExpandValues.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ExpandValues.java
index 9c3d331..032df4a 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ExpandValues.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ExpandValues.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.jwplayer.sqe.language.expression.transform;
 
 import org.apache.storm.trident.Stream;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/FormatDate.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/FormatDate.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/FormatDate.java
index dace3f5..c1bb48b 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/FormatDate.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/FormatDate.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.jwplayer.sqe.language.expression.transform;
 
 import org.apache.storm.trident.Stream;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/GetMapValue.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/GetMapValue.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/GetMapValue.java
index 2d50425..819beaa 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/GetMapValue.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/GetMapValue.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.jwplayer.sqe.language.expression.transform;
 
 import org.apache.storm.trident.Stream;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/GetTime.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/GetTime.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/GetTime.java
index 747a71a..f504c08 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/GetTime.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/GetTime.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.jwplayer.sqe.language.expression.transform;
 
 import org.apache.storm.trident.Stream;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/Hash.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/Hash.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/Hash.java
index f354a5f..92cfe64 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/Hash.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/Hash.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.jwplayer.sqe.language.expression.transform;
 
 import org.apache.storm.trident.Stream;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/If.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/If.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/If.java
index fe61093..f90daad 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/If.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/If.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.jwplayer.sqe.language.expression.transform;
 
 import com.jwplayer.sqe.trident.function.GetIf;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ModulusArithmeticOperator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ModulusArithmeticOperator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ModulusArithmeticOperator.java
index 86b077f..59077c9 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ModulusArithmeticOperator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ModulusArithmeticOperator.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.jwplayer.sqe.language.expression.transform;
 
 

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/MultiplicationArithmeticOperator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/MultiplicationArithmeticOperator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/MultiplicationArithmeticOperator.java
index 232cedb..b513070 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/MultiplicationArithmeticOperator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/MultiplicationArithmeticOperator.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.jwplayer.sqe.language.expression.transform;
 
 

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ParseDate.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ParseDate.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ParseDate.java
index be74931..d098981 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ParseDate.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/ParseDate.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.jwplayer.sqe.language.expression.transform;
 
 import org.apache.storm.trident.Stream;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/PlusArithmeticOperator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/PlusArithmeticOperator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/PlusArithmeticOperator.java
index 7268bea..a7c355a 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/PlusArithmeticOperator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/PlusArithmeticOperator.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.jwplayer.sqe.language.expression.transform;
 
 

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/RoundDate.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/RoundDate.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/RoundDate.java
index 5f4c02b..e237f41 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/RoundDate.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/RoundDate.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.jwplayer.sqe.language.expression.transform;
 
 import org.apache.storm.trident.Stream;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/SubtractionArithmeticOperator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/SubtractionArithmeticOperator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/SubtractionArithmeticOperator.java
index c2d0c95..09030b3 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/SubtractionArithmeticOperator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/SubtractionArithmeticOperator.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.jwplayer.sqe.language.expression.transform;
 
 

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/TransformExpression.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/TransformExpression.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/TransformExpression.java
index 2d4bb8c..c4211d3 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/TransformExpression.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/TransformExpression.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.jwplayer.sqe.language.expression.transform;
 
 import com.jwplayer.sqe.language.expression.FunctionExpression;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/AndLogicalOperator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/AndLogicalOperator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/AndLogicalOperator.java
index b8f82fa..bb4b338 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/AndLogicalOperator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/AndLogicalOperator.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.jwplayer.sqe.language.expression.transform.predicate;
 
 

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/CompareNumbers.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/CompareNumbers.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/CompareNumbers.java
index d7e186b..4419fa8 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/CompareNumbers.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/CompareNumbers.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.jwplayer.sqe.language.expression.transform.predicate;
 
 import org.apache.storm.trident.Stream;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/Equals.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/Equals.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/Equals.java
index 7b6c123..60def5e 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/Equals.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/Equals.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.jwplayer.sqe.language.expression.transform.predicate;
 
 import com.jwplayer.sqe.trident.function.CompareObjects;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/GreaterThanCompareNumbers.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/GreaterThanCompareNumbers.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/GreaterThanCompareNumbers.java
index 8431754..858dcf6 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/GreaterThanCompareNumbers.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/GreaterThanCompareNumbers.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.jwplayer.sqe.language.expression.transform.predicate;
 
 

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/GreaterThanEqualCompareNumbers.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/GreaterThanEqualCompareNumbers.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/GreaterThanEqualCompareNumbers.java
index 7663e44..189f122 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/GreaterThanEqualCompareNumbers.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/GreaterThanEqualCompareNumbers.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.jwplayer.sqe.language.expression.transform.predicate;
 
 

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/In.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/In.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/In.java
index 4f9f771..c583401 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/In.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/In.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.jwplayer.sqe.language.expression.transform.predicate;
 
 import com.jwplayer.sqe.trident.function.IsIn;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LessThanCompareNumbers.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LessThanCompareNumbers.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LessThanCompareNumbers.java
index d1e7223..9b62612 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LessThanCompareNumbers.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LessThanCompareNumbers.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.jwplayer.sqe.language.expression.transform.predicate;
 
 

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LessThanEqualCompareNumbers.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LessThanEqualCompareNumbers.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LessThanEqualCompareNumbers.java
index a8ce47c..8107c55 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LessThanEqualCompareNumbers.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LessThanEqualCompareNumbers.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.jwplayer.sqe.language.expression.transform.predicate;
 
 

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LogicalOperator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LogicalOperator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LogicalOperator.java
index f1c64aa..59460c7 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LogicalOperator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LogicalOperator.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.jwplayer.sqe.language.expression.transform.predicate;
 
 import com.jwplayer.sqe.trident.function.ProcessLogicalOperator;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LogicalOperatorType.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LogicalOperatorType.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LogicalOperatorType.java
index cf3e20c..27ee172 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LogicalOperatorType.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/LogicalOperatorType.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.jwplayer.sqe.language.expression.transform.predicate;
 
 public enum LogicalOperatorType {

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/NotEqualCompareNumbers.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/NotEqualCompareNumbers.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/NotEqualCompareNumbers.java
index f4ca8c6..35f3550 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/NotEqualCompareNumbers.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/NotEqualCompareNumbers.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.jwplayer.sqe.language.expression.transform.predicate;
 
 

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/NotLogicalOperator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/NotLogicalOperator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/NotLogicalOperator.java
index 0925144..85ab6ba 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/NotLogicalOperator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/NotLogicalOperator.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.jwplayer.sqe.language.expression.transform.predicate;
 
 

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/NumberComparisonType.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/NumberComparisonType.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/NumberComparisonType.java
index 581cf40..6f801ed 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/NumberComparisonType.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/NumberComparisonType.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.jwplayer.sqe.language.expression.transform.predicate;
 
 public enum NumberComparisonType {

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/OrLogicalOperator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/OrLogicalOperator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/OrLogicalOperator.java
index 80e24d3..08d68dd 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/OrLogicalOperator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/OrLogicalOperator.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.jwplayer.sqe.language.expression.transform.predicate;
 
 

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/PredicateExpression.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/PredicateExpression.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/PredicateExpression.java
index 8523406..c04dcbe 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/PredicateExpression.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/PredicateExpression.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.jwplayer.sqe.language.expression.transform.predicate;
 
 import com.jwplayer.sqe.language.expression.transform.TransformExpression;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/RLike.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/RLike.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/RLike.java
index a4debed..63b808b 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/RLike.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/RLike.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.jwplayer.sqe.language.expression.transform.predicate;
 
 import com.jwplayer.sqe.trident.function.EvaluateRegularExpression;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/XorLogicalOperator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/XorLogicalOperator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/XorLogicalOperator.java
index ae722ce..fe0220e 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/XorLogicalOperator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/expression/transform/predicate/XorLogicalOperator.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.jwplayer.sqe.language.expression.transform.predicate;
 
 

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/BaseDeserializer.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/BaseDeserializer.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/BaseDeserializer.java
index 720ce2d..83e50b5 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/BaseDeserializer.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/BaseDeserializer.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.jwplayer.sqe.language.serde;
 
 import com.jwplayer.sqe.language.serde.avro.AvroDeserializer;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/IdentityDeserializer.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/IdentityDeserializer.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/IdentityDeserializer.java
index 76fc262..1c9a179 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/IdentityDeserializer.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/IdentityDeserializer.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.jwplayer.sqe.language.serde;
 
 

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/avro/AvroDeserializer.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/avro/AvroDeserializer.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/avro/AvroDeserializer.java
index f5868f4..05e2300 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/avro/AvroDeserializer.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/avro/AvroDeserializer.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.jwplayer.sqe.language.serde.avro;
 
 import com.jwplayer.sqe.language.serde.BaseDeserializer;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/avro/AvroDeserializerOptions.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/avro/AvroDeserializerOptions.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/avro/AvroDeserializerOptions.java
index 3abd155..0e4aa91 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/avro/AvroDeserializerOptions.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/serde/avro/AvroDeserializerOptions.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.jwplayer.sqe.language.serde.avro;
 
 import java.util.Map;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/StateAdapter.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/StateAdapter.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/StateAdapter.java
index 0483a5b..2026629 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/StateAdapter.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/StateAdapter.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.jwplayer.sqe.language.state;
 
 import com.jwplayer.sqe.language.state.kafka.KafkaStateAdapter;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/StateOperationType.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/StateOperationType.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/StateOperationType.java
index 4b56fd2..881cbe3 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/StateOperationType.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/StateOperationType.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.jwplayer.sqe.language.state;
 
 public enum StateOperationType {

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/JwTridentKafkaStateFactory.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/JwTridentKafkaStateFactory.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/JwTridentKafkaStateFactory.java
index 9cc927e..24fd18f 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/JwTridentKafkaStateFactory.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/JwTridentKafkaStateFactory.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.jwplayer.sqe.language.state.kafka;
 
 import java.util.HashMap;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/KafkaStateAdapter.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/KafkaStateAdapter.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/KafkaStateAdapter.java
index 71ac874..237f1d3 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/KafkaStateAdapter.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/KafkaStateAdapter.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.jwplayer.sqe.language.state.kafka;
 
 import java.util.ArrayList;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/KafkaStateOptions.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/KafkaStateOptions.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/KafkaStateOptions.java
index 9093c11..5d10b77 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/KafkaStateOptions.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/KafkaStateOptions.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.jwplayer.sqe.language.state.kafka;
 
 import com.google.common.base.Joiner;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/SourcePartitionPartitioner.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/SourcePartitionPartitioner.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/SourcePartitionPartitioner.java
index 38074b2..395b661 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/SourcePartitionPartitioner.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/kafka/SourcePartitionPartitioner.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.jwplayer.sqe.language.state.kafka;
 
 

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/mongodb/MongoDBStateAdapter.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/mongodb/MongoDBStateAdapter.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/mongodb/MongoDBStateAdapter.java
index 6ef1c88..ce7daa7 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/mongodb/MongoDBStateAdapter.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/mongodb/MongoDBStateAdapter.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.jwplayer.sqe.language.state.mongodb;
 
 import com.jwplayer.sqe.language.state.StateAdapter;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/redis/RedisStateAdapter.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/redis/RedisStateAdapter.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/redis/RedisStateAdapter.java
index 986878b..45940cb 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/redis/RedisStateAdapter.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/redis/RedisStateAdapter.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.jwplayer.sqe.language.state.redis;
 
 import com.jwplayer.sqe.trident.state.GsonOpaqueSerializer;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/redis/RedisStateFactory.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/redis/RedisStateFactory.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/redis/RedisStateFactory.java
index 9faa980..b1bcd3b 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/redis/RedisStateFactory.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/redis/RedisStateFactory.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.jwplayer.sqe.language.state.redis;
 
 import java.util.List;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/redis/RedisStateOptions.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/redis/RedisStateOptions.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/redis/RedisStateOptions.java
index 3699480..793eacf 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/redis/RedisStateOptions.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/state/redis/RedisStateOptions.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.jwplayer.sqe.language.state.redis;
 
 import org.apache.storm.redis.trident.state.RedisDataTypeDescription.RedisDataType;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/InputStreamType.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/InputStreamType.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/InputStreamType.java
index 7bebbd6..cd452d0 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/InputStreamType.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/InputStreamType.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.jwplayer.sqe.language.stream;
 
 public enum InputStreamType {

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/StreamAdapter.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/StreamAdapter.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/StreamAdapter.java
index f43c35a..623b5bd 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/StreamAdapter.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/StreamAdapter.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.jwplayer.sqe.language.stream;
 
 import com.clearspring.analytics.hash.MurmurHash;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/StreamContainer.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/StreamContainer.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/StreamContainer.java
index 8f15ac1..c3a0435 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/StreamContainer.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/StreamContainer.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.jwplayer.sqe.language.stream;
 
 import org.apache.storm.trident.Stream;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/kafka/KafkaStreamAdapter.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/kafka/KafkaStreamAdapter.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/kafka/KafkaStreamAdapter.java
index e3e5c91..4e4ea0b 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/kafka/KafkaStreamAdapter.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/kafka/KafkaStreamAdapter.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.jwplayer.sqe.language.stream.kafka;
 
 import com.jwplayer.sqe.language.stream.StreamAdapter;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/kafka/KafkaStreamAdapterOptions.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/kafka/KafkaStreamAdapterOptions.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/kafka/KafkaStreamAdapterOptions.java
index 2c70053..53b9471 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/kafka/KafkaStreamAdapterOptions.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/kafka/KafkaStreamAdapterOptions.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.jwplayer.sqe.language.stream.kafka;
 
 import com.google.common.base.Joiner;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/testing/FixedBatchSpoutOptions.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/testing/FixedBatchSpoutOptions.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/testing/FixedBatchSpoutOptions.java
index defb4db..8a5f0da 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/testing/FixedBatchSpoutOptions.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/testing/FixedBatchSpoutOptions.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.jwplayer.sqe.language.stream.testing;
 
 import org.apache.storm.tuple.Fields;

external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/testing/FixedBatchSpoutStreamAdapter.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/testing/FixedBatchSpoutStreamAdapter.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/testing/FixedBatchSpoutStreamAdapter.java
index 310763e..1233c4f 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/testing/FixedBatchSpoutStreamAdapter.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/language/stream/testing/FixedBatchSpoutStreamAdapter.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.jwplayer.sqe.language.stream.testing;
 
 import com.jwplayer.sqe.language.stream.StreamAdapter;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/ListValuesCollector.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/ListValuesCollector.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/ListValuesCollector.java
index eb638a3..3b71339 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/ListValuesCollector.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/ListValuesCollector.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.jwplayer.sqe.trident;
 
 import org.apache.storm.trident.operation.TridentCollector;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/SingleValuesCollector.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/SingleValuesCollector.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/SingleValuesCollector.java
index 99b6ad3..39d97c7 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/SingleValuesCollector.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/SingleValuesCollector.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.jwplayer.sqe.trident;
 
 import org.apache.storm.trident.operation.TridentCollector;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/StreamMetadata.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/StreamMetadata.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/StreamMetadata.java
index 913ea63..4c10169 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/StreamMetadata.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/StreamMetadata.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.jwplayer.sqe.trident;
 
 import com.google.common.base.Preconditions;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/ValueFilter.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/ValueFilter.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/ValueFilter.java
index fad4651..dcbb3d0 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/ValueFilter.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/ValueFilter.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.jwplayer.sqe.trident;
 
 import org.apache.storm.trident.operation.BaseFilter;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/CardinalityEstimatorAggregator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/CardinalityEstimatorAggregator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/CardinalityEstimatorAggregator.java
index e106aa4..1314f7a 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/CardinalityEstimatorAggregator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/CardinalityEstimatorAggregator.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.jwplayer.sqe.trident.aggregator;
 
 import org.apache.storm.tuple.Values;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/CardinalityEstimatorCombinerAggregator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/CardinalityEstimatorCombinerAggregator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/CardinalityEstimatorCombinerAggregator.java
index 32da432..1647ded 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/CardinalityEstimatorCombinerAggregator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/CardinalityEstimatorCombinerAggregator.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.jwplayer.sqe.trident.aggregator;
 
 import org.apache.storm.trident.operation.CombinerAggregator;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/GetMaximumAggregator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/GetMaximumAggregator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/GetMaximumAggregator.java
index 7505b93..1300938 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/GetMaximumAggregator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/GetMaximumAggregator.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.jwplayer.sqe.trident.aggregator;
 
 import clojure.lang.Numbers;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllAggregator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllAggregator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllAggregator.java
index 0b62dfc..40e3911 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllAggregator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllAggregator.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.jwplayer.sqe.trident.aggregator;
 
 import com.clearspring.analytics.stream.cardinality.HyperLogLog;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllCombinerAggregator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllCombinerAggregator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllCombinerAggregator.java
index ae0ca59..4b2b1b0 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllCombinerAggregator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllCombinerAggregator.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.jwplayer.sqe.trident.aggregator;
 
 import com.clearspring.analytics.stream.cardinality.CardinalityMergeException;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllpAggregator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllpAggregator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllpAggregator.java
index 5fbea2f..9b05b0a 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllpAggregator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllpAggregator.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.jwplayer.sqe.trident.aggregator;
 
 import com.clearspring.analytics.stream.cardinality.HyperLogLogPlus;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllpCombinerAggregator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllpCombinerAggregator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllpCombinerAggregator.java
index 77078c6..e4b9703 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllpCombinerAggregator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/aggregator/HllpCombinerAggregator.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.jwplayer.sqe.trident.aggregator;
 
 import com.clearspring.analytics.stream.cardinality.CardinalityMergeException;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/AddField.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/AddField.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/AddField.java
index fb598a2..4ebbf08 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/AddField.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/AddField.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.jwplayer.sqe.trident.function;
 
 import org.apache.storm.tuple.Values;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/CompareNumbers.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/CompareNumbers.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/CompareNumbers.java
index 8ddb99a..f724372 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/CompareNumbers.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/CompareNumbers.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.jwplayer.sqe.trident.function;
 
 import clojure.lang.Numbers;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/CompareObjects.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/CompareObjects.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/CompareObjects.java
index 5625c7c..4f49503 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/CompareObjects.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/CompareObjects.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.jwplayer.sqe.trident.function;
 
 import com.jwplayer.sqe.language.expression.transform.predicate.NumberComparisonType;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ConvertMetadataToBytes.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ConvertMetadataToBytes.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ConvertMetadataToBytes.java
index e5eb525..fd33a37 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ConvertMetadataToBytes.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ConvertMetadataToBytes.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.jwplayer.sqe.trident.function;
 
 import com.jwplayer.sqe.trident.StreamMetadata;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/EvaluateRegularExpression.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/EvaluateRegularExpression.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/EvaluateRegularExpression.java
index 739879e..06acf03 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/EvaluateRegularExpression.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/EvaluateRegularExpression.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.jwplayer.sqe.trident.function;
 
 import org.apache.storm.trident.operation.BaseFunction;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ExpandKeys.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ExpandKeys.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ExpandKeys.java
index 4178679..0d0ac44 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ExpandKeys.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ExpandKeys.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.jwplayer.sqe.trident.function;
 
 import org.apache.avro.util.Utf8;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ExpandValues.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ExpandValues.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ExpandValues.java
index 4a26d4c..055c698 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ExpandValues.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ExpandValues.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.jwplayer.sqe.trident.function;
 
 import org.apache.avro.util.Utf8;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/FormatDate.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/FormatDate.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/FormatDate.java
index 6b3762b..d298be5 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/FormatDate.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/FormatDate.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.jwplayer.sqe.trident.function;
 
 import org.apache.storm.trident.operation.BaseFunction;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetCardinalityEstimation.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetCardinalityEstimation.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetCardinalityEstimation.java
index 9a5a41f..058128a 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetCardinalityEstimation.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetCardinalityEstimation.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.jwplayer.sqe.trident.function;
 
 import com.clearspring.analytics.stream.cardinality.HyperLogLog;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetIf.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetIf.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetIf.java
index a41d4cf..89c0929 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetIf.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetIf.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.jwplayer.sqe.trident.function;
 
 import org.apache.storm.tuple.Values;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetMapValue.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetMapValue.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetMapValue.java
index 21e7eba..4f48276 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetMapValue.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetMapValue.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.jwplayer.sqe.trident.function;
 
 import java.util.Map;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetTime.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetTime.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetTime.java
index ddbb0a3..14e58b4 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetTime.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetTime.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.jwplayer.sqe.trident.function;
 
 import org.apache.log4j.Logger;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetTupleFromAvro.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetTupleFromAvro.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetTupleFromAvro.java
index 94544e9..8a2b02a 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetTupleFromAvro.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/GetTupleFromAvro.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.jwplayer.sqe.trident.function;
 
 import org.apache.avro.Schema;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/Hash.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/Hash.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/Hash.java
index dfbd85e..71cf23e 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/Hash.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/Hash.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.jwplayer.sqe.trident.function;
 
 import com.clearspring.analytics.hash.MurmurHash;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/IsIn.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/IsIn.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/IsIn.java
index 4d15504..9e27aa9 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/IsIn.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/IsIn.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.jwplayer.sqe.trident.function;
 
 import org.apache.storm.tuple.Values;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/MapField.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/MapField.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/MapField.java
index a2fe0b1..6d7ac09 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/MapField.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/MapField.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.jwplayer.sqe.trident.function;
 
 import org.apache.storm.trident.operation.BaseFunction;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ParseDate.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ParseDate.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ParseDate.java
index e964c6f..2fb8ef7 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ParseDate.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ParseDate.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.jwplayer.sqe.trident.function;
 
 import org.apache.storm.tuple.Values;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ProcessArithmeticOperator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ProcessArithmeticOperator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ProcessArithmeticOperator.java
index c86234e..507db31 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ProcessArithmeticOperator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ProcessArithmeticOperator.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.jwplayer.sqe.trident.function;
 
 import clojure.lang.Numbers;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ProcessLogicalOperator.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ProcessLogicalOperator.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ProcessLogicalOperator.java
index 395eb65..3f035bf 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ProcessLogicalOperator.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/ProcessLogicalOperator.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.jwplayer.sqe.trident.function;
 
 import com.jwplayer.sqe.language.expression.transform.predicate.LogicalOperatorType;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/RoundDate.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/RoundDate.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/RoundDate.java
index 780efb3..18e0c9b 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/RoundDate.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/function/RoundDate.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.jwplayer.sqe.trident.function;
 
 import org.apache.storm.trident.operation.BaseFunction;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredOpaqueTridentKafkaSpout.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredOpaqueTridentKafkaSpout.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredOpaqueTridentKafkaSpout.java
index 9f01628..c4f5cac 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredOpaqueTridentKafkaSpout.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredOpaqueTridentKafkaSpout.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.jwplayer.sqe.trident.spout.kafka;
 
 import org.apache.storm.kafka.Partition;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTransactionalTridentKafkaSpout.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTransactionalTridentKafkaSpout.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTransactionalTridentKafkaSpout.java
index 71e9cca..a908a5d 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTransactionalTridentKafkaSpout.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTransactionalTridentKafkaSpout.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.jwplayer.sqe.trident.spout.kafka;
 
 import org.apache.storm.kafka.Partition;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTridentCollector.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTridentCollector.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTridentCollector.java
index 6ad7174..3667052 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTridentCollector.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTridentCollector.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.jwplayer.sqe.trident.spout.kafka;
 
 import com.jwplayer.sqe.trident.StreamMetadata;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTridentKafkaEmitter.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTridentKafkaEmitter.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTridentKafkaEmitter.java
index d6c5a7a..ca50321 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTridentKafkaEmitter.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTridentKafkaEmitter.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.jwplayer.sqe.trident.spout.kafka;
 
 import org.apache.storm.kafka.Partition;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/SqeRawFullScheme.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/SqeRawFullScheme.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/SqeRawFullScheme.java
index 538176c..0614773 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/SqeRawFullScheme.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/spout/kafka/SqeRawFullScheme.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.jwplayer.sqe.trident.spout.kafka;
 
 import com.jwplayer.sqe.language.stream.StreamAdapter;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/BaseGsonSerializer.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/BaseGsonSerializer.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/BaseGsonSerializer.java
index 0a999f1..959f168 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/BaseGsonSerializer.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/BaseGsonSerializer.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.jwplayer.sqe.trident.state;
 
 

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/GsonOpaqueSerializer.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/GsonOpaqueSerializer.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/GsonOpaqueSerializer.java
index ae8863f..00b8f3e 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/GsonOpaqueSerializer.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/GsonOpaqueSerializer.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.jwplayer.sqe.trident.state;
 
 import com.google.gson.Gson;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/GsonTransactionalSerializer.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/GsonTransactionalSerializer.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/GsonTransactionalSerializer.java
index c522529..4fbbcdc 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/GsonTransactionalSerializer.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/GsonTransactionalSerializer.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.jwplayer.sqe.trident.state;
 
 import com.google.gson.*;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/mongodb/MongoDBState.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/mongodb/MongoDBState.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/mongodb/MongoDBState.java
index 3bd4e3c..76992a9 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/mongodb/MongoDBState.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/mongodb/MongoDBState.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.jwplayer.sqe.trident.state.mongodb;
 
 import com.clearspring.analytics.hash.MurmurHash;

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/mongodb/MongoDBStateOptions.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/mongodb/MongoDBStateOptions.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/mongodb/MongoDBStateOptions.java
index ba6643d..5accde7 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/mongodb/MongoDBStateOptions.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/mongodb/MongoDBStateOptions.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.jwplayer.sqe.trident.state.mongodb;
 
 

external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/redis/RedisKeyFactory.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/redis/RedisKeyFactory.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/redis/RedisKeyFactory.java
index 42881a9..88d95d7 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/redis/RedisKeyFactory.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/trident/state/redis/RedisKeyFactory.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.jwplayer.sqe.trident.state.redis;
 
 import org.apache.storm.redis.trident.state.KeyFactory;

external/storm-sqe/src/main/java/com/jwplayer/sqe/util/FileHelper.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/FileHelper.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/FileHelper.java
index 6e8d7ec..359f478 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/FileHelper.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/FileHelper.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.jwplayer.sqe.util;
 
 import org.apache.commons.io.IOUtils;

external/storm-sqe/src/main/java/com/jwplayer/sqe/util/YamlConfig.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/YamlConfig.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/YamlConfig.java
index deaef02..1102373 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/YamlConfig.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/YamlConfig.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.jwplayer.sqe.util;
 
 import org.apache.log4j.Logger;

external/storm-sqe/src/main/java/com/jwplayer/sqe/util/file/resource/ResourceFileSystem.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/file/resource/ResourceFileSystem.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/file/resource/ResourceFileSystem.java
index 572ccd1..ca9239d 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/file/resource/ResourceFileSystem.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/file/resource/ResourceFileSystem.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.jwplayer.sqe.util.file.resource;
 
 import com.google.common.collect.ImmutableList;

external/storm-sqe/src/main/java/com/jwplayer/sqe/util/file/resource/ResourceFileSystemProvider.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/file/resource/ResourceFileSystemProvider.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/file/resource/ResourceFileSystemProvider.java
index b84f035..2a65606 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/file/resource/ResourceFileSystemProvider.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/file/resource/ResourceFileSystemProvider.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.jwplayer.sqe.util.file.resource;
 
 import java.io.IOException;

external/storm-sqe/src/main/java/com/jwplayer/sqe/util/file/resource/ResourcePath.java

diff --git a/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/file/resource/ResourcePath.java b/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/file/resource/ResourcePath.java
index 0d5960a..16392a1 100644
--- a/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/file/resource/ResourcePath.java
+++ b/external/storm-sqe/src/main/java/com/jwplayer/sqe/util/file/resource/ResourcePath.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.jwplayer.sqe.util.file.resource;
 
 

external/storm-sqe/src/test/java/com/jwplayer/sqe/IntegrationTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/IntegrationTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/IntegrationTest.java
index 768a89f..d670088 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/IntegrationTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/IntegrationTest.java
@@ -1,3 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package com.jwplayer.sqe;
 
 import static org.junit.Assert.*;

external/storm-sqe/src/test/java/com/jwplayer/sqe/KafkaReplaysIntegrationTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/KafkaReplaysIntegrationTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/KafkaReplaysIntegrationTest.java
index 9942ace..ca57cd0 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/KafkaReplaysIntegrationTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/KafkaReplaysIntegrationTest.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.jwplayer.sqe;
 
 import com.jwplayer.sqe.trident.StreamMetadata;

external/storm-sqe/src/test/java/com/jwplayer/sqe/language/command/CommandDeserializationTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/language/command/CommandDeserializationTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/language/command/CommandDeserializationTest.java
index 8b5ee25..ddfbd79 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/language/command/CommandDeserializationTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/language/command/CommandDeserializationTest.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.jwplayer.sqe.language.command;
 
 import static org.junit.Assert.*;

external/storm-sqe/src/test/java/com/jwplayer/sqe/language/expression/ExpressionDeserializationTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/language/expression/ExpressionDeserializationTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/language/expression/ExpressionDeserializationTest.java
index b483443..7f67b2e 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/language/expression/ExpressionDeserializationTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/language/expression/ExpressionDeserializationTest.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.jwplayer.sqe.language.expression;
 
 import com.google.gson.GsonBuilder;

external/storm-sqe/src/test/java/com/jwplayer/sqe/language/expression/FunctionExpressionTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/language/expression/FunctionExpressionTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/language/expression/FunctionExpressionTest.java
index 52ee8ef..9c2cbe9 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/language/expression/FunctionExpressionTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/language/expression/FunctionExpressionTest.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.jwplayer.sqe.language.expression;
 
 import java.util.ArrayList;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/GetTuplesFilter.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/GetTuplesFilter.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/GetTuplesFilter.java
index 46361ae..906d6bd 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/GetTuplesFilter.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/GetTuplesFilter.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.jwplayer.sqe.trident;
 
 import org.apache.storm.trident.operation.BaseFilter;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/GetMaximumAggregatorTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/GetMaximumAggregatorTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/GetMaximumAggregatorTest.java
index 5dc7eb6..8f88adb 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/GetMaximumAggregatorTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/GetMaximumAggregatorTest.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.jwplayer.sqe.trident.aggregator;
 
 import static org.junit.Assert.*;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllAggregatorTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllAggregatorTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllAggregatorTest.java
index 7d8e826..fc74b98 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllAggregatorTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllAggregatorTest.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.jwplayer.sqe.trident.aggregator;
 
 import static org.junit.Assert.*;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllCombinerAggregatorTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllCombinerAggregatorTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllCombinerAggregatorTest.java
index c616a7a..2ba5663 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllCombinerAggregatorTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllCombinerAggregatorTest.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.jwplayer.sqe.trident.aggregator;
 
 import static org.junit.Assert.*;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllpAggregatorTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllpAggregatorTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllpAggregatorTest.java
index 03705b2..378fc57 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllpAggregatorTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllpAggregatorTest.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.jwplayer.sqe.trident.aggregator;
 
 import static org.junit.Assert.*;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllpCombinerAggregatorTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllpCombinerAggregatorTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllpCombinerAggregatorTest.java
index 5e59af5..daa42ee 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllpCombinerAggregatorTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/aggregator/HllpCombinerAggregatorTest.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.jwplayer.sqe.trident.aggregator;
 
 import static org.junit.Assert.*;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/AddFieldTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/AddFieldTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/AddFieldTest.java
index 0767e55..ee7dad9 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/AddFieldTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/AddFieldTest.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.jwplayer.sqe.trident.function;
 
 import static org.junit.Assert.*;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/CompareNumbersTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/CompareNumbersTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/CompareNumbersTest.java
index 137689d..3cdd2ea 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/CompareNumbersTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/CompareNumbersTest.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.jwplayer.sqe.trident.function;
 
 import static org.junit.Assert.*;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/CompareObjectsTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/CompareObjectsTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/CompareObjectsTest.java
index 07c84ae..89b8853 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/CompareObjectsTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/CompareObjectsTest.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.jwplayer.sqe.trident.function;
 
 import static org.junit.Assert.*;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/EvaluateRegularExpressionTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/EvaluateRegularExpressionTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/EvaluateRegularExpressionTest.java
index e081bce..69650ad 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/EvaluateRegularExpressionTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/EvaluateRegularExpressionTest.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.jwplayer.sqe.trident.function;
 
 import static org.junit.Assert.*;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ExpandKeysTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ExpandKeysTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ExpandKeysTest.java
index 3688b78..1cd4f9e 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ExpandKeysTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ExpandKeysTest.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.jwplayer.sqe.trident.function;
 
 import com.jwplayer.sqe.trident.ListValuesCollector;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ExpandValuesTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ExpandValuesTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ExpandValuesTest.java
index 45e374c..5604152 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ExpandValuesTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ExpandValuesTest.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.jwplayer.sqe.trident.function;
 
 import com.jwplayer.sqe.trident.ListValuesCollector;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/FormatDateTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/FormatDateTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/FormatDateTest.java
index 776a9c2..e12ea4d 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/FormatDateTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/FormatDateTest.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.jwplayer.sqe.trident.function;
 
 import static org.junit.Assert.*;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetCardinalityEstimationTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetCardinalityEstimationTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetCardinalityEstimationTest.java
index 73ab2d3..7984fdb 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetCardinalityEstimationTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetCardinalityEstimationTest.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.jwplayer.sqe.trident.function;
 
 import com.clearspring.analytics.stream.cardinality.HyperLogLog;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetIfTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetIfTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetIfTest.java
index 730a8b8..8a408d8 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetIfTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetIfTest.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.jwplayer.sqe.trident.function;
 
 import com.jwplayer.sqe.trident.SingleValuesCollector;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetMapValueTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetMapValueTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetMapValueTest.java
index e5420e4..bef57ac 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetMapValueTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetMapValueTest.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.jwplayer.sqe.trident.function;
 
 import static org.junit.Assert.assertEquals;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetTimeTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetTimeTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetTimeTest.java
index 57dc090..007a20c 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetTimeTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/GetTimeTest.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.jwplayer.sqe.trident.function;
 
 import com.jwplayer.sqe.trident.SingleValuesCollector;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/HashTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/HashTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/HashTest.java
index 98ff587..3c84d80 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/HashTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/HashTest.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.jwplayer.sqe.trident.function;
 
 import com.google.common.primitives.Longs;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/IsInTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/IsInTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/IsInTest.java
index aecb919..0df18ea 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/IsInTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/IsInTest.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.jwplayer.sqe.trident.function;
 
 import com.jwplayer.sqe.trident.SingleValuesCollector;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ParseDateTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ParseDateTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ParseDateTest.java
index 9f8b351..36991ce 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ParseDateTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ParseDateTest.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.jwplayer.sqe.trident.function;
 
 import static org.junit.Assert.*;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ProcessArithmeticOperatorTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ProcessArithmeticOperatorTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ProcessArithmeticOperatorTest.java
index c480dea..f432e76 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ProcessArithmeticOperatorTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ProcessArithmeticOperatorTest.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.jwplayer.sqe.trident.function;
 
 import static org.junit.Assert.*;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ProcessLogicalOperatorTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ProcessLogicalOperatorTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ProcessLogicalOperatorTest.java
index bfd641d..2411bac 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ProcessLogicalOperatorTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/ProcessLogicalOperatorTest.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.jwplayer.sqe.trident.function;
 
 import static org.junit.Assert.*;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/RoundDateTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/RoundDateTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/RoundDateTest.java
index 2914b89..e7bcd10 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/RoundDateTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/function/RoundDateTest.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.jwplayer.sqe.trident.function;
 
 import static org.junit.Assert.*;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTridentCollectorTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTridentCollectorTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTridentCollectorTest.java
index ff9b466..2218339 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTridentCollectorTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/spout/kafka/FilteredTridentCollectorTest.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.jwplayer.sqe.trident.spout.kafka;
 
 import static org.junit.Assert.*;

external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/spout/kafka/SqeRawFullSchemeTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/spout/kafka/SqeRawFullSchemeTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/spout/kafka/SqeRawFullSchemeTest.java
index 0ddb1f3..a67d02b 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/spout/kafka/SqeRawFullSchemeTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/trident/spout/kafka/SqeRawFullSchemeTest.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.jwplayer.sqe.trident.spout.kafka;
 
 

external/storm-sqe/src/test/java/com/jwplayer/sqe/util/FileHelperTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/util/FileHelperTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/util/FileHelperTest.java
index bca7ec8..bb88214 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/util/FileHelperTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/util/FileHelperTest.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.jwplayer.sqe.util;
 
 import org.junit.Test;

external/storm-sqe/src/test/java/com/jwplayer/sqe/util/KafkaTestServer.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/util/KafkaTestServer.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/util/KafkaTestServer.java
index e7bd2ac..e065cc9 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/util/KafkaTestServer.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/util/KafkaTestServer.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.jwplayer.sqe.util;
 
 import kafka.admin.AdminUtils;

external/storm-sqe/src/test/java/com/jwplayer/sqe/util/YamlConfigTest.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/util/YamlConfigTest.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/util/YamlConfigTest.java
index 2da8086..6dec769 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/util/YamlConfigTest.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/util/YamlConfigTest.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.jwplayer.sqe.util;
 
 import org.junit.Before;

external/storm-sqe/src/test/java/com/jwplayer/sqe/util/ZookeeperTestServer.java

diff --git a/external/storm-sqe/src/test/java/com/jwplayer/sqe/util/ZookeeperTestServer.java b/external/storm-sqe/src/test/java/com/jwplayer/sqe/util/ZookeeperTestServer.java
index b532686..8d6e30e 100644
--- a/external/storm-sqe/src/test/java/com/jwplayer/sqe/util/ZookeeperTestServer.java
+++ b/external/storm-sqe/src/test/java/com/jwplayer/sqe/util/ZookeeperTestServer.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.jwplayer.sqe.util;
 
 import kafka.utils.ZkUtils;