apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [13/13] apex-malhar git commit: Licensing changes to make it ready for addition into apex
Date Tue, 23 May 2017 01:24:11 GMT
Licensing changes to make it ready for addition into apex


Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/bb89fe9e
Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/bb89fe9e
Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/bb89fe9e

Branch: refs/heads/master
Commit: bb89fe9ee62537a4228aa649c9b0d899f65cc87e
Parents: 2cfe153
Author: Apex Dev <dev@apex.apache.org>
Authored: Sun Feb 19 22:01:34 2017 +0530
Committer: Pramod Immaneni <pramod@datatorrent.com>
Committed: Mon May 22 16:47:34 2017 -0700

----------------------------------------------------------------------
 flume/pom.xml                                         | 12 +++++++-----
 .../com/datatorrent/flume/discovery/Discovery.java    | 13 +++++++------
 .../flume/discovery/ZKAssistedDiscovery.java          | 13 +++++++------
 .../ColumnFilteringFormattingInterceptor.java         | 13 +++++++------
 .../flume/interceptor/ColumnFilteringInterceptor.java | 13 +++++++------
 .../flume/operator/AbstractFlumeInputOperator.java    | 13 +++++++------
 .../java/com/datatorrent/flume/sink/DTFlumeSink.java  | 13 +++++++------
 .../main/java/com/datatorrent/flume/sink/Server.java  | 13 +++++++------
 .../com/datatorrent/flume/source/HdfsTestSource.java  | 12 +++++++-----
 .../java/com/datatorrent/flume/source/TestSource.java | 12 +++++++-----
 .../com/datatorrent/flume/storage/DebugWrapper.java   | 13 +++++++------
 .../flume/storage/ErrorMaskingEventCodec.java         | 13 +++++++------
 .../com/datatorrent/flume/storage/EventCodec.java     | 13 +++++++------
 .../com/datatorrent/flume/storage/HDFSStorage.java    | 13 +++++++------
 .../java/com/datatorrent/flume/storage/Storage.java   | 13 +++++++------
 .../resources/flume-conf/flume-conf.sample.properties | 12 +++++++-----
 .../src/main/resources/flume-conf/flume-env.sample.sh | 12 +++++++-----
 .../flume/discovery/ZKAssistedDiscoveryTest.java      | 13 +++++++------
 .../flume/integration/ApplicationTest.java            | 13 +++++++------
 .../interceptor/ColumnFilteringInterceptorTest.java   | 14 ++++++++------
 .../flume/interceptor/InterceptorTestHelper.java      | 14 ++++++++------
 .../com/datatorrent/flume/interceptor/RawEvent.java   | 13 +++++++------
 .../operator/AbstractFlumeInputOperatorTest.java      | 13 +++++++------
 .../com/datatorrent/flume/sink/DTFlumeSinkTest.java   | 14 ++++++++------
 .../java/com/datatorrent/flume/sink/ServerTest.java   | 13 +++++++------
 .../flume/storage/HDFSStorageMatching.java            | 14 ++++++++------
 .../flume/storage/HDFSStoragePerformance.java         | 14 ++++++++------
 .../flume/storage/HDFSStoragePerformanceTest.java     | 13 +++++++------
 .../datatorrent/flume/storage/HDFSStorageTest.java    | 14 ++++++++------
 .../test/resources/flume/conf/flume-conf.properties   | 12 +++++++-----
 flume/src/test/resources/flume/conf/flume-env.sh      | 12 +++++++-----
 31 files changed, 223 insertions(+), 179 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/pom.xml
----------------------------------------------------------------------
diff --git a/flume/pom.xml b/flume/pom.xml
index ade05a0..6522148 100644
--- a/flume/pom.xml
+++ b/flume/pom.xml
@@ -1,11 +1,13 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!--
 
-    Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
-
-    Licensed under the Apache License, Version 2.0 (the "License");
-    you may not use this file except in compliance with the License.
-    You may obtain a copy of the License at
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
 
       http://www.apache.org/licenses/LICENSE-2.0
 

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/main/java/com/datatorrent/flume/discovery/Discovery.java
----------------------------------------------------------------------
diff --git a/flume/src/main/java/com/datatorrent/flume/discovery/Discovery.java b/flume/src/main/java/com/datatorrent/flume/discovery/Discovery.java
index d802002..72a1440 100644
--- a/flume/src/main/java/com/datatorrent/flume/discovery/Discovery.java
+++ b/flume/src/main/java/com/datatorrent/flume/discovery/Discovery.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -26,7 +28,6 @@ import java.util.Collection;
  * Interesting parties can call discover method to get the list of addresses where
  * they can find an available DTFlumeSink server instance.
  *
- * @author Chetan Narsude <chetan@datatorrent.com>
  * @param <T> - Type of the objects which can be discovered
  * @since 0.9.3
  */

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/main/java/com/datatorrent/flume/discovery/ZKAssistedDiscovery.java
----------------------------------------------------------------------
diff --git a/flume/src/main/java/com/datatorrent/flume/discovery/ZKAssistedDiscovery.java
b/flume/src/main/java/com/datatorrent/flume/discovery/ZKAssistedDiscovery.java
index 460a478..97ad8f0 100644
--- a/flume/src/main/java/com/datatorrent/flume/discovery/ZKAssistedDiscovery.java
+++ b/flume/src/main/java/com/datatorrent/flume/discovery/ZKAssistedDiscovery.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -48,7 +50,6 @@ import com.datatorrent.api.Component;
 /**
  * <p>ZKAssistedDiscovery class.</p>
  *
- * @author Chetan Narsude <chetan@datatorrent.com>
  * @since 0.9.3
  */
 public class ZKAssistedDiscovery implements Discovery<byte[]>,

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/main/java/com/datatorrent/flume/interceptor/ColumnFilteringFormattingInterceptor.java
----------------------------------------------------------------------
diff --git a/flume/src/main/java/com/datatorrent/flume/interceptor/ColumnFilteringFormattingInterceptor.java
b/flume/src/main/java/com/datatorrent/flume/interceptor/ColumnFilteringFormattingInterceptor.java
index ce92f6d..fd20f99 100644
--- a/flume/src/main/java/com/datatorrent/flume/interceptor/ColumnFilteringFormattingInterceptor.java
+++ b/flume/src/main/java/com/datatorrent/flume/interceptor/ColumnFilteringFormattingInterceptor.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -39,7 +41,6 @@ import static com.datatorrent.flume.interceptor.ColumnFilteringFormattingInterce
 /**
  * <p>ColumnFilteringFormattingInterceptor class.</p>
  *
- * @author Chandni Singh <chandni@datatorrent.com>
  * @since 0.9.4
  */
 public class ColumnFilteringFormattingInterceptor implements Interceptor

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/main/java/com/datatorrent/flume/interceptor/ColumnFilteringInterceptor.java
----------------------------------------------------------------------
diff --git a/flume/src/main/java/com/datatorrent/flume/interceptor/ColumnFilteringInterceptor.java
b/flume/src/main/java/com/datatorrent/flume/interceptor/ColumnFilteringInterceptor.java
index 90c3a04..a2f598f 100644
--- a/flume/src/main/java/com/datatorrent/flume/interceptor/ColumnFilteringInterceptor.java
+++ b/flume/src/main/java/com/datatorrent/flume/interceptor/ColumnFilteringInterceptor.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -35,7 +37,6 @@ import static com.datatorrent.flume.interceptor.ColumnFilteringInterceptor.Const
 /**
  * <p>ColumnFilteringInterceptor class.</p>
  *
- * @author Chetan Narsude <chetan@datatorrent.com>
  * @since 0.9.4
  */
 public class ColumnFilteringInterceptor implements Interceptor

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/main/java/com/datatorrent/flume/operator/AbstractFlumeInputOperator.java
----------------------------------------------------------------------
diff --git a/flume/src/main/java/com/datatorrent/flume/operator/AbstractFlumeInputOperator.java
b/flume/src/main/java/com/datatorrent/flume/operator/AbstractFlumeInputOperator.java
index 1ab7182..d772ff5 100644
--- a/flume/src/main/java/com/datatorrent/flume/operator/AbstractFlumeInputOperator.java
+++ b/flume/src/main/java/com/datatorrent/flume/operator/AbstractFlumeInputOperator.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -62,7 +64,6 @@ import static java.lang.Thread.sleep;
  * Abstract AbstractFlumeInputOperator class.</p>
  *
  * @param <T> Type of the output payload.
- * @author Chetan Narsude <chetan@datatorrent.com>
  * @since 0.9.2
  */
 public abstract class AbstractFlumeInputOperator<T>

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/main/java/com/datatorrent/flume/sink/DTFlumeSink.java
----------------------------------------------------------------------
diff --git a/flume/src/main/java/com/datatorrent/flume/sink/DTFlumeSink.java b/flume/src/main/java/com/datatorrent/flume/sink/DTFlumeSink.java
index 35d0c5f..55d3d61 100644
--- a/flume/src/main/java/com/datatorrent/flume/sink/DTFlumeSink.java
+++ b/flume/src/main/java/com/datatorrent/flume/sink/DTFlumeSink.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -65,7 +67,6 @@ import com.datatorrent.netlet.util.Slice;
  * maximumEventsPerTransaction - integer value indicating the maximum number of events per
transaction. This value can
  * not be more than channel's transaction capacity.<br />
  *
- * @author Chetan Narsude <chetan@datatorrent.com>
  * @since 0.9.2
  */
 public class DTFlumeSink extends AbstractSink implements Configurable

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/main/java/com/datatorrent/flume/sink/Server.java
----------------------------------------------------------------------
diff --git a/flume/src/main/java/com/datatorrent/flume/sink/Server.java b/flume/src/main/java/com/datatorrent/flume/sink/Server.java
index 14d9ff4..03c1ff0 100644
--- a/flume/src/main/java/com/datatorrent/flume/sink/Server.java
+++ b/flume/src/main/java/com/datatorrent/flume/sink/Server.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -37,7 +39,6 @@ import com.datatorrent.netlet.util.Slice;
  * <p>
  * Server class.</p>
  *
- * @author Chetan Narsude <chetan@datatorrent.com>
  * @since 0.9.2
  */
 public class Server extends AbstractServer

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/main/java/com/datatorrent/flume/source/HdfsTestSource.java
----------------------------------------------------------------------
diff --git a/flume/src/main/java/com/datatorrent/flume/source/HdfsTestSource.java b/flume/src/main/java/com/datatorrent/flume/source/HdfsTestSource.java
index 18aac37..72e1913 100644
--- a/flume/src/main/java/com/datatorrent/flume/source/HdfsTestSource.java
+++ b/flume/src/main/java/com/datatorrent/flume/source/HdfsTestSource.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/main/java/com/datatorrent/flume/source/TestSource.java
----------------------------------------------------------------------
diff --git a/flume/src/main/java/com/datatorrent/flume/source/TestSource.java b/flume/src/main/java/com/datatorrent/flume/source/TestSource.java
index 490ac35..5773de3 100644
--- a/flume/src/main/java/com/datatorrent/flume/source/TestSource.java
+++ b/flume/src/main/java/com/datatorrent/flume/source/TestSource.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/main/java/com/datatorrent/flume/storage/DebugWrapper.java
----------------------------------------------------------------------
diff --git a/flume/src/main/java/com/datatorrent/flume/storage/DebugWrapper.java b/flume/src/main/java/com/datatorrent/flume/storage/DebugWrapper.java
index c416418..da94154 100644
--- a/flume/src/main/java/com/datatorrent/flume/storage/DebugWrapper.java
+++ b/flume/src/main/java/com/datatorrent/flume/storage/DebugWrapper.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -28,7 +30,6 @@ import com.datatorrent.netlet.util.Slice;
 /**
  * <p>DebugWrapper class.</p>
  *
- * @author Chetan Narsude <chetan@datatorrent.com>
  * @since 0.9.4
  */
 public class DebugWrapper implements Storage, Configurable, Component<com.datatorrent.api.Context>

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/main/java/com/datatorrent/flume/storage/ErrorMaskingEventCodec.java
----------------------------------------------------------------------
diff --git a/flume/src/main/java/com/datatorrent/flume/storage/ErrorMaskingEventCodec.java
b/flume/src/main/java/com/datatorrent/flume/storage/ErrorMaskingEventCodec.java
index 59c7fd3..76f663c 100644
--- a/flume/src/main/java/com/datatorrent/flume/storage/ErrorMaskingEventCodec.java
+++ b/flume/src/main/java/com/datatorrent/flume/storage/ErrorMaskingEventCodec.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -26,7 +28,6 @@ import com.datatorrent.netlet.util.Slice;
 /**
  * <p>ErrorMaskingEventCodec class.</p>
  *
- * @author Chetan Narsude <chetan@datatorrent.com>
  * @since 1.0.4
  */
 public class ErrorMaskingEventCodec extends EventCodec

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/main/java/com/datatorrent/flume/storage/EventCodec.java
----------------------------------------------------------------------
diff --git a/flume/src/main/java/com/datatorrent/flume/storage/EventCodec.java b/flume/src/main/java/com/datatorrent/flume/storage/EventCodec.java
index 03d0d87..0ece548 100644
--- a/flume/src/main/java/com/datatorrent/flume/storage/EventCodec.java
+++ b/flume/src/main/java/com/datatorrent/flume/storage/EventCodec.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -37,7 +39,6 @@ import com.datatorrent.netlet.util.Slice;
 /**
  * <p>EventCodec class.</p>
  *
- * @author Chetan Narsude <chetan@datatorrent.com>
  * @since 0.9.4
  */
 public class EventCodec implements StreamCodec<Event>

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/main/java/com/datatorrent/flume/storage/HDFSStorage.java
----------------------------------------------------------------------
diff --git a/flume/src/main/java/com/datatorrent/flume/storage/HDFSStorage.java b/flume/src/main/java/com/datatorrent/flume/storage/HDFSStorage.java
index 74849e9..4dcddcd 100644
--- a/flume/src/main/java/com/datatorrent/flume/storage/HDFSStorage.java
+++ b/flume/src/main/java/com/datatorrent/flume/storage/HDFSStorage.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -54,7 +56,6 @@ import com.datatorrent.netlet.util.Slice;
  * restore - This is used to restore the application from previous failure <br />
  * blockSize - The maximum size of the each file to created. <br />
  *
- * @author Gaurav Gupta <gaurav@datatorrent.com>
  * @since 0.9.3
  */
 public class HDFSStorage implements Storage, Configurable, Component<com.datatorrent.api.Context>

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/main/java/com/datatorrent/flume/storage/Storage.java
----------------------------------------------------------------------
diff --git a/flume/src/main/java/com/datatorrent/flume/storage/Storage.java b/flume/src/main/java/com/datatorrent/flume/storage/Storage.java
index 9f3a010..5130f3c 100644
--- a/flume/src/main/java/com/datatorrent/flume/storage/Storage.java
+++ b/flume/src/main/java/com/datatorrent/flume/storage/Storage.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -21,7 +23,6 @@ import com.datatorrent.netlet.util.Slice;
 /**
  * <p>Storage interface.</p>
  *
- * @author Gaurav Gupta  <gaurav@datatorrent.com>
  * @since 0.9.2
  */
 public interface Storage

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/main/resources/flume-conf/flume-conf.sample.properties
----------------------------------------------------------------------
diff --git a/flume/src/main/resources/flume-conf/flume-conf.sample.properties b/flume/src/main/resources/flume-conf/flume-conf.sample.properties
index 9d3e430..1782d4a 100644
--- a/flume/src/main/resources/flume-conf/flume-conf.sample.properties
+++ b/flume/src/main/resources/flume-conf/flume-conf.sample.properties
@@ -1,9 +1,11 @@
 #
-# Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
 #
 #   http://www.apache.org/licenses/LICENSE-2.0
 #

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/main/resources/flume-conf/flume-env.sample.sh
----------------------------------------------------------------------
diff --git a/flume/src/main/resources/flume-conf/flume-env.sample.sh b/flume/src/main/resources/flume-conf/flume-env.sample.sh
index aca341c..570411b 100644
--- a/flume/src/main/resources/flume-conf/flume-env.sample.sh
+++ b/flume/src/main/resources/flume-conf/flume-env.sample.sh
@@ -1,10 +1,12 @@
 #!/bin/bash
 #
-# Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
 #
 #   http://www.apache.org/licenses/LICENSE-2.0
 #

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/test/java/com/datatorrent/flume/discovery/ZKAssistedDiscoveryTest.java
----------------------------------------------------------------------
diff --git a/flume/src/test/java/com/datatorrent/flume/discovery/ZKAssistedDiscoveryTest.java
b/flume/src/test/java/com/datatorrent/flume/discovery/ZKAssistedDiscoveryTest.java
index 4acf764..f182edc 100644
--- a/flume/src/test/java/com/datatorrent/flume/discovery/ZKAssistedDiscoveryTest.java
+++ b/flume/src/test/java/com/datatorrent/flume/discovery/ZKAssistedDiscoveryTest.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -32,7 +34,6 @@ import static org.junit.Assert.assertNotNull;
 
 /**
  *
- * @author Chetan Narsude <chetan@datatorrent.com>
  */
 @Ignore
 public class ZKAssistedDiscoveryTest

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/test/java/com/datatorrent/flume/integration/ApplicationTest.java
----------------------------------------------------------------------
diff --git a/flume/src/test/java/com/datatorrent/flume/integration/ApplicationTest.java b/flume/src/test/java/com/datatorrent/flume/integration/ApplicationTest.java
index 41364c8..8256916 100644
--- a/flume/src/test/java/com/datatorrent/flume/integration/ApplicationTest.java
+++ b/flume/src/test/java/com/datatorrent/flume/integration/ApplicationTest.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -36,7 +38,6 @@ import com.datatorrent.flume.storage.EventCodec;
 
 /**
  *
- * @author Chetan Narsude <chetan@datatorrent.com>
  */
 @Ignore
 public class ApplicationTest implements StreamingApplication

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/test/java/com/datatorrent/flume/interceptor/ColumnFilteringInterceptorTest.java
----------------------------------------------------------------------
diff --git a/flume/src/test/java/com/datatorrent/flume/interceptor/ColumnFilteringInterceptorTest.java
b/flume/src/test/java/com/datatorrent/flume/interceptor/ColumnFilteringInterceptorTest.java
index 464df42..11ee23f 100644
--- a/flume/src/test/java/com/datatorrent/flume/interceptor/ColumnFilteringInterceptorTest.java
+++ b/flume/src/test/java/com/datatorrent/flume/interceptor/ColumnFilteringInterceptorTest.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -29,7 +31,7 @@ import org.apache.flume.interceptor.Interceptor;
 import static org.junit.Assert.assertArrayEquals;
 
 /**
- * @author Chetan Narsude <chetan@datatorrent.com>
+ *
  */
 public class ColumnFilteringInterceptorTest
 {

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/test/java/com/datatorrent/flume/interceptor/InterceptorTestHelper.java
----------------------------------------------------------------------
diff --git a/flume/src/test/java/com/datatorrent/flume/interceptor/InterceptorTestHelper.java
b/flume/src/test/java/com/datatorrent/flume/interceptor/InterceptorTestHelper.java
index 739184f..dc95f08 100644
--- a/flume/src/test/java/com/datatorrent/flume/interceptor/InterceptorTestHelper.java
+++ b/flume/src/test/java/com/datatorrent/flume/interceptor/InterceptorTestHelper.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -42,7 +44,7 @@ import static org.junit.Assert.assertArrayEquals;
 import static org.junit.Assert.assertNotNull;
 
 /**
- * @author Chetan Narsude <chetan@datatorrent.com>
+ *
  */
 public class InterceptorTestHelper
 {

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/test/java/com/datatorrent/flume/interceptor/RawEvent.java
----------------------------------------------------------------------
diff --git a/flume/src/test/java/com/datatorrent/flume/interceptor/RawEvent.java b/flume/src/test/java/com/datatorrent/flume/interceptor/RawEvent.java
index 049609b..c029cd0 100644
--- a/flume/src/test/java/com/datatorrent/flume/interceptor/RawEvent.java
+++ b/flume/src/test/java/com/datatorrent/flume/interceptor/RawEvent.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -27,7 +29,6 @@ import com.datatorrent.netlet.util.Slice;
 
 /**
  *
- * @author Chetan Narsude <chetan@datatorrent.com>
  */
 public class RawEvent implements Serializable
 {

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/test/java/com/datatorrent/flume/operator/AbstractFlumeInputOperatorTest.java
----------------------------------------------------------------------
diff --git a/flume/src/test/java/com/datatorrent/flume/operator/AbstractFlumeInputOperatorTest.java
b/flume/src/test/java/com/datatorrent/flume/operator/AbstractFlumeInputOperatorTest.java
index a615496..2f162a8 100644
--- a/flume/src/test/java/com/datatorrent/flume/operator/AbstractFlumeInputOperatorTest.java
+++ b/flume/src/test/java/com/datatorrent/flume/operator/AbstractFlumeInputOperatorTest.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -25,7 +27,6 @@ import static org.junit.Assert.assertTrue;
 
 /**
  *
- * @author Chetan Narsude <chetan@datatorrent.com>
  */
 public class AbstractFlumeInputOperatorTest
 {

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/test/java/com/datatorrent/flume/sink/DTFlumeSinkTest.java
----------------------------------------------------------------------
diff --git a/flume/src/test/java/com/datatorrent/flume/sink/DTFlumeSinkTest.java b/flume/src/test/java/com/datatorrent/flume/sink/DTFlumeSinkTest.java
index 833a353..7949e63 100644
--- a/flume/src/test/java/com/datatorrent/flume/sink/DTFlumeSinkTest.java
+++ b/flume/src/test/java/com/datatorrent/flume/sink/DTFlumeSinkTest.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -35,7 +37,7 @@ import com.datatorrent.netlet.DefaultEventLoop;
 import com.datatorrent.netlet.util.Slice;
 
 /**
- * @author Chetan Narsude <chetan@datatorrent.com>
+ *
  */
 public class DTFlumeSinkTest
 {

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/test/java/com/datatorrent/flume/sink/ServerTest.java
----------------------------------------------------------------------
diff --git a/flume/src/test/java/com/datatorrent/flume/sink/ServerTest.java b/flume/src/test/java/com/datatorrent/flume/sink/ServerTest.java
index 64495db..8c225d1 100644
--- a/flume/src/test/java/com/datatorrent/flume/sink/ServerTest.java
+++ b/flume/src/test/java/com/datatorrent/flume/sink/ServerTest.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -23,7 +25,6 @@ import org.junit.Test;
 
 /**
  *
- * @author Chetan Narsude <chetan@datatorrent.com>
  */
 public class ServerTest
 {

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/test/java/com/datatorrent/flume/storage/HDFSStorageMatching.java
----------------------------------------------------------------------
diff --git a/flume/src/test/java/com/datatorrent/flume/storage/HDFSStorageMatching.java b/flume/src/test/java/com/datatorrent/flume/storage/HDFSStorageMatching.java
index 05eeb4e..6b6adcb 100644
--- a/flume/src/test/java/com/datatorrent/flume/storage/HDFSStorageMatching.java
+++ b/flume/src/test/java/com/datatorrent/flume/storage/HDFSStorageMatching.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -24,7 +26,7 @@ import com.google.common.primitives.Ints;
 import com.datatorrent.netlet.util.Slice;
 
 /**
- * @author Gaurav Gupta  <gaurav@datatorrent.com>
+ *
  */
 public class HDFSStorageMatching
 {

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/test/java/com/datatorrent/flume/storage/HDFSStoragePerformance.java
----------------------------------------------------------------------
diff --git a/flume/src/test/java/com/datatorrent/flume/storage/HDFSStoragePerformance.java
b/flume/src/test/java/com/datatorrent/flume/storage/HDFSStoragePerformance.java
index 394ce0e..098f3f7 100644
--- a/flume/src/test/java/com/datatorrent/flume/storage/HDFSStoragePerformance.java
+++ b/flume/src/test/java/com/datatorrent/flume/storage/HDFSStoragePerformance.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -22,7 +24,7 @@ import org.slf4j.LoggerFactory;
 import com.datatorrent.netlet.util.Slice;
 
 /**
- * @author Gaurav Gupta  <gaurav@datatorrent.com>
+ *
  */
 public class HDFSStoragePerformance
 {

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/test/java/com/datatorrent/flume/storage/HDFSStoragePerformanceTest.java
----------------------------------------------------------------------
diff --git a/flume/src/test/java/com/datatorrent/flume/storage/HDFSStoragePerformanceTest.java
b/flume/src/test/java/com/datatorrent/flume/storage/HDFSStoragePerformanceTest.java
index 08476c2..97e9aa8 100644
--- a/flume/src/test/java/com/datatorrent/flume/storage/HDFSStoragePerformanceTest.java
+++ b/flume/src/test/java/com/datatorrent/flume/storage/HDFSStoragePerformanceTest.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -26,7 +28,6 @@ import com.datatorrent.netlet.util.Slice;
 /**
  * <p>HDFSStoragePerformanceTest class.</p>
  *
- * @author Gaurav Gupta  <gaurav@datatorrent.com>
  * @since 1.0.1
  */
 public class HDFSStoragePerformanceTest

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/test/java/com/datatorrent/flume/storage/HDFSStorageTest.java
----------------------------------------------------------------------
diff --git a/flume/src/test/java/com/datatorrent/flume/storage/HDFSStorageTest.java b/flume/src/test/java/com/datatorrent/flume/storage/HDFSStorageTest.java
index b348c8f..0cb9935 100644
--- a/flume/src/test/java/com/datatorrent/flume/storage/HDFSStorageTest.java
+++ b/flume/src/test/java/com/datatorrent/flume/storage/HDFSStorageTest.java
@@ -1,9 +1,11 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
@@ -40,7 +42,7 @@ import org.apache.hadoop.fs.Path;
 import com.datatorrent.netlet.util.Slice;
 
 /**
- * @author Gaurav Gupta <gaurav@datatorrent.com>
+ *
  */
 public class HDFSStorageTest
 {

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/test/resources/flume/conf/flume-conf.properties
----------------------------------------------------------------------
diff --git a/flume/src/test/resources/flume/conf/flume-conf.properties b/flume/src/test/resources/flume/conf/flume-conf.properties
index c892c53..29c81c0 100644
--- a/flume/src/test/resources/flume/conf/flume-conf.properties
+++ b/flume/src/test/resources/flume/conf/flume-conf.properties
@@ -1,9 +1,11 @@
 #
-# Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
 #
 #   http://www.apache.org/licenses/LICENSE-2.0
 #

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/bb89fe9e/flume/src/test/resources/flume/conf/flume-env.sh
----------------------------------------------------------------------
diff --git a/flume/src/test/resources/flume/conf/flume-env.sh b/flume/src/test/resources/flume/conf/flume-env.sh
index c2232ea..436e670 100644
--- a/flume/src/test/resources/flume/conf/flume-env.sh
+++ b/flume/src/test/resources/flume/conf/flume-env.sh
@@ -1,10 +1,12 @@
 #!/bin/bash
 #
-# Copyright (c) 2016 DataTorrent, Inc. ALL Rights Reserved.
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
 #
 #   http://www.apache.org/licenses/LICENSE-2.0
 #


Mime
View raw message