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 <[email protected]> Authored: Sun Feb 19 22:01:34 2017 +0530 Committer: Pramod Immaneni <[email protected]> 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 <[email protected]> * @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 <[email protected]> * @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 <[email protected]> * @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 <[email protected]> * @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 <[email protected]> * @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 <[email protected]> * @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 <[email protected]> * @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 <[email protected]> * @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 <[email protected]> * @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 <[email protected]> * @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 <[email protected]> * @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 <[email protected]> * @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 <[email protected]> */ @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 <[email protected]> */ @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 <[email protected]> + * */ 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 <[email protected]> + * */ 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 <[email protected]> */ 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 <[email protected]> */ 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 <[email protected]> + * */ 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 <[email protected]> */ 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 <[email protected]> + * */ 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 <[email protected]> + * */ 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 <[email protected]> * @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 <[email protected]> + * */ 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 #
