gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [5/5] incubator-gobblin git commit: [GOBBLIN-219] Added copyright header check and enforced it for existing files
Date Wed, 23 Aug 2017 04:19:43 GMT
[GOBBLIN-219] Added copyright header check and enforced it for existing files

Closes #2070 from aditya1105/checkstyle


Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/c101493f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/c101493f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/c101493f

Branch: refs/heads/master
Commit: c101493f8cae8558e01f6598162bfb762e4d051d
Parents: 32ca21a
Author: aditya1105 <adsharma@linkedin.com>
Authored: Tue Aug 22 21:19:26 2017 -0700
Committer: Abhishek Tiwari <abhishektiwari.btech@gmail.com>
Committed: Tue Aug 22 21:19:26 2017 -0700

----------------------------------------------------------------------
 config/checkstyle/checkstyle.xml                | 16 ++++++++++++
 config/checkstyle/suppressions.xml              | 10 ++++++++
 .../extractor/CheckpointableWatermark.java      | 26 +++++++++----------
 .../gobblin_scopes/GobblinScopeInstance.java    |  3 +--
 .../gobblin_scopes/GobblinScopeTypes.java       |  3 +--
 .../broker/gobblin_scopes/JobScopeInstance.java |  3 +--
 .../gobblin_scopes/TaskScopeInstance.java       |  3 +--
 .../broker/iface/SubscopedBrokerBuilder.java    |  3 +--
 .../dataset/comparators/package-info.java       | 17 ++++++++++++
 .../org/apache/gobblin/fork/CopyHelper.java     | 27 +++++++++-----------
 .../extractor/CheckpointableWatermark.java      | 27 +++++++++-----------
 .../source/extractor/StreamingExtractor.java    | 27 +++++++++-----------
 .../apache/gobblin/writer/WatermarkStorage.java | 27 +++++++++-----------
 .../java/com/linkedin/gobblin/TestAlias.java    | 19 +++++++++-----
 .../gobblin/ack/HierarchicalAckableTest.java    |  1 -
 .../gobblin_scopes/GobblinScopesTest.java       |  3 +--
 .../org/apache/gobblin/fork/CopyHelperTest.java | 27 +++++++++-----------
 .../gobblin/cluster/GobblinHelixConstants.java  | 26 +++++++++----------
 .../cluster/GobblinHelixMessagingService.java   | 16 ++++++++++++
 .../gobblin/cluster/GobblinHelixTaskDriver.java | 26 +++++++++----------
 .../apache/helix/task/GobblinJobRebalancer.java | 26 +++++++++----------
 .../mapreduce/MRCompactionTaskFactory.java      | 16 ++++++++++++
 .../compaction/verify/CompactionVerifier.java   | 16 ++++++++++++
 .../verify/InputRecordCountHelper.java          | 16 ++++++++++++
 .../mapreduce/RenameSourceDirectoryTest.java    | 16 ++++++++++++
 .../suite/TestCompactionSuiteFactories.java     | 16 ++++++++++++
 .../verify/PinotAuditCountVerifierTest.java     | 16 ++++++++++++
 .../FineGrainedWatermarkTrackerBenchmark.java   | 19 +++++++++-----
 .../java/org/apache/gobblin/async/Callback.java | 16 ++++++++++++
 .../gobblin/converter/SamplingConverter.java    | 27 +++++++++-----------
 ...blinTrackingEventFlattenFilterConverter.java |  1 -
 .../DefaultCheckpointableWatermark.java         | 27 +++++++++-----------
 .../limiter/LimiterConfigurationKeys.java       | 16 ++++++++++++
 .../apache/gobblin/test/AnyToJsonConverter.java | 27 +++++++++-----------
 .../gobblin/test/AnyToStringConverter.java      | 27 +++++++++-----------
 .../org/apache/gobblin/test/TestRecord.java     | 27 +++++++++-----------
 .../writer/AcknowledgableRecordEnvelope.java    | 27 +++++++++-----------
 .../gobblin/writer/AcknowledgableWatermark.java | 27 +++++++++-----------
 .../gobblin/writer/AsyncWriterManager.java      | 27 +++++++++-----------
 .../java/org/apache/gobblin/writer/Batch.java   | 27 +++++++++-----------
 .../apache/gobblin/writer/BatchAccumulator.java | 16 ++++++++++++
 .../gobblin/writer/BatchAsyncDataWriter.java    | 27 +++++++++-----------
 .../gobblin/writer/BufferedAsyncDataWriter.java | 27 +++++++++-----------
 .../gobblin/writer/BytesBoundedBatch.java       | 27 +++++++++-----------
 .../writer/FineGrainedWatermarkTracker.java     | 27 +++++++++-----------
 .../writer/FutureWrappedWriteCallback.java      | 27 +++++++++-----------
 .../gobblin/writer/GenericWriteResponse.java    | 27 +++++++++-----------
 .../writer/GenericWriteResponseWrapper.java     | 27 +++++++++-----------
 .../gobblin/writer/LastWatermarkTracker.java    | 27 +++++++++-----------
 .../writer/MultiWriterWatermarkManager.java     | 27 +++++++++-----------
 .../writer/MultiWriterWatermarkTracker.java     | 27 +++++++++-----------
 .../org/apache/gobblin/writer/RecordFuture.java | 27 +++++++++-----------
 .../apache/gobblin/writer/RecordMetadata.java   | 27 +++++++++-----------
 .../writer/SequentialBasedBatchAccumulator.java | 27 +++++++++-----------
 .../apache/gobblin/writer/SyncDataWriter.java   | 27 +++++++++-----------
 .../writer/TrackerBasedWatermarkManager.java    | 27 +++++++++-----------
 .../gobblin/writer/WatermarkAwareWriter.java    | 27 +++++++++-----------
 .../writer/WatermarkAwareWriterWrapper.java     | 27 +++++++++-----------
 .../apache/gobblin/writer/WatermarkManager.java | 27 +++++++++-----------
 .../apache/gobblin/writer/WatermarkTracker.java | 27 +++++++++-----------
 .../gobblin/writer/WatermarkTrackerFactory.java | 27 +++++++++-----------
 .../apache/gobblin/writer/WriteResponse.java    | 27 +++++++++-----------
 .../gobblin/writer/WriteResponseFuture.java     | 27 +++++++++-----------
 .../gobblin/writer/WriteResponseMapper.java     | 27 +++++++++-----------
 .../converter/SamplingConverterTest.java        | 26 +++++++++----------
 .../writer/FineGrainedWatermarkTrackerTest.java | 26 +++++++++----------
 .../writer/MultiWriterWatermarkManagerTest.java | 26 +++++++++----------
 .../gobblin/writer/WatermarkTrackerTest.java    | 26 +++++++++----------
 .../source/DatePartitionedDailyAvroSource.java  | 19 +++++++++-----
 .../source/extractor/partition/Partition.java   | 16 ++++++++++++
 .../gobblin/async/AsyncDataDispatcherTest.java  | 16 ++++++++++++
 .../avro/FlattenNestedKeyConverterTest.java     | 16 ++++++++++++
 .../string/ObjectToStringConverterTest.java     |  1 -
 .../AvroGenericRecordAccessorTest.java          | 26 +++++++++----------
 .../RecordAccessorProviderFactoryTest.java      | 26 +++++++++----------
 .../security/ssl/SSLContextFactoryTest.java     | 16 ++++++++++++
 .../DatePartitionedAvroFileExtractorTest.java   | 19 +++++++++-----
 .../extract/QueryBasedExtractorTest.java        | 16 ++++++++++++
 .../extractor/partition/PartitionerTest.java    | 16 ++++++++++++
 .../writer/MetadataWriterWrapperTest.java       | 16 ++++++++++++
 .../dataset/DefaultFileSystemGlobFinder.java    | 16 ++++++++++++
 .../hive/CopyPartitionParametersTest.java       | 16 ++++++++++++
 .../hive/HiveMetaStoreClientFactoryTest.java    | 16 ++++++++++++
 .../config/checkstyle/suppressions.xml          | 10 ++++++++
 ...roToJsonRecordWithMetadataConverterTest.java | 16 ++++++++++++
 .../retention/Avro2OrcStaleDatasetCleaner.java  | 16 ++++++++++++
 .../compliance/purger/HivePurgerWriterTest.java | 16 ++++++++++++
 .../converter/AnyToCouchbaseJsonConverter.java  | 26 +++++++++----------
 .../writer/CouchbaseEnvironmentFactory.java     | 26 +++++++++----------
 .../AnyToCouchbaseJsonConverterTest.java        | 26 +++++++++----------
 .../AvroStringFieldEncryptorConverter.java      | 26 +++++++++----------
 ...ordToEncryptedSerializedRecordConverter.java | 26 +++++++++----------
 .../StringFieldEncryptorConverter.java          | 26 +++++++++----------
 .../AvroStringFieldEncryptorConverterTest.java  | 16 ++++++++++++
 .../crypto/GobblinEncryptionProviderTest.java   | 16 ++++++++++++
 ...oEncryptedSerializedRecordConverterBase.java | 26 +++++++++----------
 .../gobblin/eventhub/EventhubMetricNames.java   | 16 ++++++++++++
 .../writer/BatchedEventhubDataWriter.java       | 16 ++++++++++++
 .../writer/EventhubBatchAccumulator.java        | 16 ++++++++++++
 .../eventhub/writer/EventhubDataWriter.java     | 27 +++++++++-----------
 .../writer/EventhubDataWriterBuilder.java       | 26 +++++++++----------
 .../eventhub/writer/EventhubRequest.java        | 26 +++++++++----------
 .../writer/BatchedEventhubDataWriterTest.java   | 26 +++++++++----------
 .../writer/EventhubAccumulatorTest.java         | 16 ++++++++++++
 .../eventhub/writer/EventhubBatchTest.java      | 16 ++++++++++++
 .../eventhub/writer/EventhubDataWriterTest.java | 26 +++++++++----------
 .../converter/AsyncHttpJoinConverter.java       | 16 ++++++++++++
 .../converter/AvroApacheHttpJoinConverter.java  | 16 ++++++++++++
 .../converter/AvroHttpJoinConverter.java        | 16 ++++++++++++
 .../gobblin/converter/AvroR2JoinConverter.java  | 16 ++++++++++++
 .../gobblin/converter/HttpJoinConverter.java    | 16 ++++++++++++
 .../gobblin/http/ApacheHttpAsyncClient.java     | 16 ++++++++++++
 .../apache/gobblin/http/ApacheHttpClient.java   | 16 ++++++++++++
 .../gobblin/http/ApacheHttpRequestBuilder.java  | 16 ++++++++++++
 .../gobblin/http/ApacheHttpResponseHandler.java | 16 ++++++++++++
 .../gobblin/http/ApacheHttpResponseStatus.java  | 16 ++++++++++++
 .../gobblin/http/ThrottledHttpClient.java       | 16 ++++++++++++
 .../org/apache/gobblin/r2/R2ResponseStatus.java | 16 ++++++++++++
 .../apache/gobblin/r2/R2RestRequestBuilder.java | 16 ++++++++++++
 .../gobblin/r2/R2RestResponseHandler.java       | 16 ++++++++++++
 .../org/apache/gobblin/utils/HttpConstants.java | 16 ++++++++++++
 .../org/apache/gobblin/utils/HttpUtils.java     | 16 ++++++++++++
 .../gobblin/writer/AvroHttpWriterBuilder.java   | 16 ++++++++++++
 .../java/org/apache/gobblin/HttpTestUtils.java  | 16 ++++++++++++
 .../org/apache/gobblin/MockGenericRecord.java   | 16 ++++++++++++
 .../http/ApacheHttpRequestBuilderTest.java      | 16 ++++++++++++
 .../apache/gobblin/r2/R2ClientFactoryTest.java  | 16 ++++++++++++
 .../gobblin/r2/R2RestRequestBuilderTest.java    | 16 ++++++++++++
 .../org/apache/gobblin/util/HttpUtilsTest.java  | 16 ++++++++++++
 .../gobblin/writer/AsyncHttpWriterTest.java     | 16 ++++++++++++
 ...thMetadataToEnvelopedRecordWithMetadata.java | 26 +++++++++----------
 .../apache/gobblin/metadata/types/Metadata.java | 16 ++++++++++++
 .../apache/gobblin/type/ContentTypeUtils.java   | 26 +++++++++----------
 .../apache/gobblin/type/RecordWithMetadata.java | 26 +++++++++----------
 .../type/SerializedRecordWithMetadata.java      | 26 +++++++++----------
 .../converter/MetadataConverterWrapperTest.java | 26 +++++++++----------
 ...tadataToEnvelopedRecordWithMetadataTest.java | 26 +++++++++----------
 .../metadata/GlobalMetadataCollectorTest.java   | 16 ++++++++++++
 .../google/AsyncIteratorWithDataSink.java       | 16 ++++++++++++
 .../GoggleIngestionConfigurationKeys.java       | 16 ++++++++++++
 .../ingestion/google/util/SchemaUtil.java       | 16 ++++++++++++
 .../config/checkstyle/suppressions.xml          | 10 ++++++++
 .../config/checkstyle/suppressions.xml          | 10 ++++++++
 .../config/checkstyle/suppressions.xml          | 10 ++++++++
 .../config/checkstyle/suppressions.xml          | 10 ++++++++
 .../config/checkstyle/suppressions.xml          | 10 ++++++++
 .../ThrottlingGuiceServletConfig.java           | 19 +++++++++-----
 .../gobblin/runtime/fork/MockTaskContext.java   | 19 +++++++++-----
 .../main/java/gobblin/runtime/TaskState.java    | 16 ++++++++++++
 .../runtime/CheckpointableWatermarkState.java   | 26 +++++++++----------
 .../apache/gobblin/runtime/ExecutionModel.java  | 26 +++++++++----------
 .../StateStoreBasedWatermarkStorage.java        | 26 +++++++++----------
 .../StateStoreBasedWatermarkStorageCli.java     | 26 +++++++++----------
 .../gobblin/runtime/TaskConfigurationKeys.java  | 26 +++++++++----------
 .../runtime/TaskInstantiationException.java     | 26 +++++++++----------
 .../gobblin/runtime/crypto/DecryptCli.java      | 16 ++++++++++++
 .../gobblin/runtime/fork/AsynchronousFork.java  | 19 +++++++++-----
 .../org/apache/gobblin/runtime/fork/Fork.java   | 19 +++++++++-----
 .../gobblin/runtime/fork/SynchronousFork.java   | 19 +++++++++-----
 .../apache/gobblin/runtime/task/FailedTask.java | 16 ++++++++++++
 .../gobblin/scheduler/BaseGobblinJob.java       | 19 +++++++++-----
 .../gobblin/runtime/JobBrokerInjectionTest.java |  2 +-
 .../gobblin/runtime/LimiterStopEventTest.java   | 16 ++++++++++++
 .../gobblin/runtime/TaskContinuousTest.java     | 26 +++++++++----------
 .../instance/hadoop/TestHadoopConfigLoader.java | 19 +++++++++-----
 .../FileBasedJobLockFactoryManagerTest.java     | 15 ++++++++++-
 .../salesforce/SalesforceSourceTest.java        | 16 ++++++++++++
 .../gobblin/GobblinLocalJobLauncherUtils.java   | 16 ++++++++++++
 .../TaskSkipErrRecordsIntegrationTest.java      | 16 ++++++++++++
 .../org/apache/gobblin/TestAvroConverter.java   | 16 ++++++++++++
 .../org/apache/gobblin/TestAvroExtractor.java   | 16 ++++++++++++
 .../java/org/apache/gobblin/TestAvroSource.java | 16 ++++++++++++
 .../WriterOutputFormatIntegrationTest.java      | 16 ++++++++++++
 .../apache/gobblin/util/DatePartitionType.java  | 20 +++++++++------
 .../java/org/apache/gobblin/util/HostUtils.java | 16 ++++++++++++
 .../java/org/apache/gobblin/util/JvmUtils.java  | 16 ++++++++++++
 .../java/org/apache/gobblin/util/PortUtils.java | 20 +++++++++------
 .../util/executors/MDCPropagatingCallable.java  | 20 +++++++++------
 .../MDCPropagatingExecutorService.java          | 20 +++++++++------
 .../util/executors/MDCPropagatingRunnable.java  | 20 +++++++++------
 .../MDCPropagatingScheduledExecutorService.java | 20 +++++++++------
 .../gobblin/util/limiter/LimiterFactory.java    |  3 +--
 .../gobblin/util/limiter/MultiLimiter.java      |  3 +--
 .../gobblin/util/limiter/NoopLimiter.java       |  3 +--
 .../limiter/broker/SharedLimiterFactory.java    |  3 +--
 .../util/limiter/broker/SharedLimiterKey.java   |  3 +--
 .../org/apache/gobblin/util/PortUtilsTest.java  | 20 +++++++++------
 .../gobblin/util/limiter/MultiLimiterTest.java  |  2 +-
 .../broker/SharedLimiterFactoryTest.java        |  2 +-
 gradle/scripts/testSetup.gradle                 |  5 ++++
 190 files changed, 2368 insertions(+), 1208 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/config/checkstyle/checkstyle.xml
----------------------------------------------------------------------
diff --git a/config/checkstyle/checkstyle.xml b/config/checkstyle/checkstyle.xml
new file mode 100644
index 0000000..3b84bd6
--- /dev/null
+++ b/config/checkstyle/checkstyle.xml
@@ -0,0 +1,16 @@
+<?xml version="1.0"?>
+<!DOCTYPE module PUBLIC
+    "-//Puppy Crawl//DTD Check Configuration 1.3//EN"
+    "http://checkstyle.sourceforge.net/dtds/configuration_1_3.dtd">
+
+<module name="Checker">
+  <module name="Header">
+    <property name="header" value="/*&#10; * Licensed to the Apache Software Foundation (ASF) under one or more&#10; * contributor license agreements.  See the NOTICE file distributed with&#10; * this work for additional information regarding copyright ownership.&#10; * The ASF licenses this file to You under the Apache License, Version 2.0&#10; * (the &quot;License&quot;); you may not use this file except in compliance with&#10; * the License.  You may obtain a copy of the License at&#10; *&#10; *    http://www.apache.org/licenses/LICENSE-2.0&#10; *&#10; * Unless required by applicable law or agreed to in writing, software&#10; * distributed under the License is distributed on an &quot;AS IS&quot; BASIS,&#10; * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.&#10; * See the License for the specific language governing permissions and&#10; * limitations under the License.&#10; */"/>
+    <property name="fileExtensions" value="java"/>
+  </module>
+
+  <module name="SuppressionFilter">
+    <property name="file" value="config/checkstyle/suppressions.xml"/>
+    <property name="optional" value="true"/>
+  </module>
+</module>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/config/checkstyle/suppressions.xml
----------------------------------------------------------------------
diff --git a/config/checkstyle/suppressions.xml b/config/checkstyle/suppressions.xml
new file mode 100644
index 0000000..bee4e86
--- /dev/null
+++ b/config/checkstyle/suppressions.xml
@@ -0,0 +1,10 @@
+<?xml version="1.0"?>
+
+<!DOCTYPE suppressions PUBLIC
+    "-//Puppy Crawl//DTD Suppressions 1.1//EN"
+    "http://checkstyle.sourceforge.net/dtds/suppressions_1_1.dtd">
+
+<suppressions>
+  <suppress checks=".*"
+            files="^(.*gen-java.*)|(.*mainGenerated.*)$"/>
+</suppressions>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-api/src/main/java/gobblin/source/extractor/CheckpointableWatermark.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/gobblin/source/extractor/CheckpointableWatermark.java b/gobblin-api/src/main/java/gobblin/source/extractor/CheckpointableWatermark.java
index 0d46919..6d1eedc 100644
--- a/gobblin-api/src/main/java/gobblin/source/extractor/CheckpointableWatermark.java
+++ b/gobblin-api/src/main/java/gobblin/source/extractor/CheckpointableWatermark.java
@@ -1,20 +1,18 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this 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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
 package gobblin.source.extractor;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java
index f4f37f4..ae0b4e7 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java
@@ -6,7 +6,7 @@
  * (the "License"); you may not use this 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://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
@@ -14,7 +14,6 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
 package org.apache.gobblin.broker.gobblin_scopes;
 
 import org.apache.gobblin.broker.SimpleScope;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeTypes.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeTypes.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeTypes.java
index 4a9e010..2e06c10 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeTypes.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeTypes.java
@@ -6,7 +6,7 @@
  * (the "License"); you may not use this 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://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
@@ -14,7 +14,6 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
 package org.apache.gobblin.broker.gobblin_scopes;
 
 import java.util.Collection;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java
index 5449d7d..8bc1100 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java
@@ -6,7 +6,7 @@
  * (the "License"); you may not use this 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://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
@@ -14,7 +14,6 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
 package org.apache.gobblin.broker.gobblin_scopes;
 
 import lombok.Getter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java
index 34c521b..2ef277e 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java
@@ -6,7 +6,7 @@
  * (the "License"); you may not use this 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://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
@@ -14,7 +14,6 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
 package org.apache.gobblin.broker.gobblin_scopes;
 
 import lombok.Getter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SubscopedBrokerBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SubscopedBrokerBuilder.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SubscopedBrokerBuilder.java
index 7bb0d2f..a09ff7f 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SubscopedBrokerBuilder.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SubscopedBrokerBuilder.java
@@ -6,7 +6,7 @@
  * (the "License"); you may not use this 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://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
@@ -14,7 +14,6 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
 package org.apache.gobblin.broker.iface;
 
 import com.typesafe.config.Config;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-api/src/main/java/org/apache/gobblin/dataset/comparators/package-info.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/dataset/comparators/package-info.java b/gobblin-api/src/main/java/org/apache/gobblin/dataset/comparators/package-info.java
index fc8fe18..1248b7f 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/dataset/comparators/package-info.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/dataset/comparators/package-info.java
@@ -1,3 +1,20 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 /**
  * Contains common dataset orders that {@link org.apache.gobblin.dataset.DatasetsFinder}s can push down.
  */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyHelper.java b/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyHelper.java
index e145937..71d6ed2 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyHelper.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyHelper.java
@@ -1,22 +1,19 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
-
 package org.apache.gobblin.fork;
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/CheckpointableWatermark.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/CheckpointableWatermark.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/CheckpointableWatermark.java
index 38673b8..d257e5c 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/CheckpointableWatermark.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/CheckpointableWatermark.java
@@ -1,22 +1,19 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
-
 package org.apache.gobblin.source.extractor;
 
 import org.apache.gobblin.annotation.Alpha;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/StreamingExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/StreamingExtractor.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/StreamingExtractor.java
index 035bcdc..6a1ade4 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/StreamingExtractor.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/StreamingExtractor.java
@@ -1,22 +1,19 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
-
 package org.apache.gobblin.source.extractor;
 
 import java.io.IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-api/src/main/java/org/apache/gobblin/writer/WatermarkStorage.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/WatermarkStorage.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/WatermarkStorage.java
index eab115a..a5e2df0 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/writer/WatermarkStorage.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/WatermarkStorage.java
@@ -1,22 +1,19 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
-
 package org.apache.gobblin.writer;
 
 import java.io.IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-api/src/test/java/com/linkedin/gobblin/TestAlias.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/com/linkedin/gobblin/TestAlias.java b/gobblin-api/src/test/java/com/linkedin/gobblin/TestAlias.java
index 51b92d6..4033c07 100644
--- a/gobblin-api/src/test/java/com/linkedin/gobblin/TestAlias.java
+++ b/gobblin-api/src/test/java/com/linkedin/gobblin/TestAlias.java
@@ -1,13 +1,18 @@
 /*
- * Copyright (C) 2014-2016 LinkedIn Corp. All rights reserved.
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.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 under the Apache License, Version 2.0 (the "License"); you may not use
- * this 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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing, software distributed
- * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
- * CONDITIONS OF ANY KIND, either express or implied.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
 package com.linkedin.gobblin;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-api/src/test/java/org/apache/gobblin/ack/HierarchicalAckableTest.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/org/apache/gobblin/ack/HierarchicalAckableTest.java b/gobblin-api/src/test/java/org/apache/gobblin/ack/HierarchicalAckableTest.java
index 589e6aa..0558485 100644
--- a/gobblin-api/src/test/java/org/apache/gobblin/ack/HierarchicalAckableTest.java
+++ b/gobblin-api/src/test/java/org/apache/gobblin/ack/HierarchicalAckableTest.java
@@ -14,7 +14,6 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
 package org.apache.gobblin.ack;
 
 import org.testng.Assert;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-api/src/test/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopesTest.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopesTest.java b/gobblin-api/src/test/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopesTest.java
index 78b11f0..3d446a0 100644
--- a/gobblin-api/src/test/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopesTest.java
+++ b/gobblin-api/src/test/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopesTest.java
@@ -6,7 +6,7 @@
  * (the "License"); you may not use this 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://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
@@ -14,7 +14,6 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
 package org.apache.gobblin.broker.gobblin_scopes;
 
 import org.testng.Assert;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-api/src/test/java/org/apache/gobblin/fork/CopyHelperTest.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/org/apache/gobblin/fork/CopyHelperTest.java b/gobblin-api/src/test/java/org/apache/gobblin/fork/CopyHelperTest.java
index 58e9fae..6a7c6d6 100644
--- a/gobblin-api/src/test/java/org/apache/gobblin/fork/CopyHelperTest.java
+++ b/gobblin-api/src/test/java/org/apache/gobblin/fork/CopyHelperTest.java
@@ -1,22 +1,19 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
-
 package org.apache.gobblin.fork;
 
 import java.io.ByteArrayInputStream;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixConstants.java
----------------------------------------------------------------------
diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixConstants.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixConstants.java
index bbb8d2e..00b31a8 100644
--- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixConstants.java
+++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixConstants.java
@@ -1,20 +1,18 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this 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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
 
 package org.apache.gobblin.cluster;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixMessagingService.java
----------------------------------------------------------------------
diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixMessagingService.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixMessagingService.java
index 3bc0fd3..cdced1b 100644
--- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixMessagingService.java
+++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixMessagingService.java
@@ -1,3 +1,19 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.apache.gobblin.cluster;
 
 import com.google.common.base.Strings;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskDriver.java
----------------------------------------------------------------------
diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskDriver.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskDriver.java
index c56f8e2..9160610 100644
--- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskDriver.java
+++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskDriver.java
@@ -1,20 +1,18 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this 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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
 package org.apache.gobblin.cluster;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-cluster/src/main/java/org/apache/helix/task/GobblinJobRebalancer.java
----------------------------------------------------------------------
diff --git a/gobblin-cluster/src/main/java/org/apache/helix/task/GobblinJobRebalancer.java b/gobblin-cluster/src/main/java/org/apache/helix/task/GobblinJobRebalancer.java
index e8f16a8..25241d5 100644
--- a/gobblin-cluster/src/main/java/org/apache/helix/task/GobblinJobRebalancer.java
+++ b/gobblin-cluster/src/main/java/org/apache/helix/task/GobblinJobRebalancer.java
@@ -1,20 +1,18 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this 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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
 
 package org.apache.helix.task;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactionTaskFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactionTaskFactory.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactionTaskFactory.java
index 42b5493..ff8b012 100644
--- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactionTaskFactory.java
+++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactionTaskFactory.java
@@ -1,3 +1,19 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.apache.gobblin.compaction.mapreduce;
 
 import java.io.IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/CompactionVerifier.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/CompactionVerifier.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/CompactionVerifier.java
index 20a8cd6..09e996a 100644
--- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/CompactionVerifier.java
+++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/CompactionVerifier.java
@@ -1,3 +1,19 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.apache.gobblin.compaction.verify;
 
 import org.apache.gobblin.dataset.Dataset;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/InputRecordCountHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/InputRecordCountHelper.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/InputRecordCountHelper.java
index 53fd05d..661fa47 100644
--- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/InputRecordCountHelper.java
+++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/InputRecordCountHelper.java
@@ -1,3 +1,19 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.apache.gobblin.compaction.verify;
 
 import com.google.common.base.Charsets;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/RenameSourceDirectoryTest.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/RenameSourceDirectoryTest.java b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/RenameSourceDirectoryTest.java
index e5207aa..517b609 100644
--- a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/RenameSourceDirectoryTest.java
+++ b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/RenameSourceDirectoryTest.java
@@ -1,3 +1,19 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.apache.gobblin.compaction.mapreduce;
 import org.apache.gobblin.compaction.dataset.Dataset;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/suite/TestCompactionSuiteFactories.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/suite/TestCompactionSuiteFactories.java b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/suite/TestCompactionSuiteFactories.java
index 6354d5d..7cfdb92 100644
--- a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/suite/TestCompactionSuiteFactories.java
+++ b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/suite/TestCompactionSuiteFactories.java
@@ -1,3 +1,19 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.apache.gobblin.compaction.suite;
 
 import org.apache.gobblin.annotation.Alias;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/verify/PinotAuditCountVerifierTest.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/verify/PinotAuditCountVerifierTest.java b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/verify/PinotAuditCountVerifierTest.java
index 4160100..6bda9f4 100644
--- a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/verify/PinotAuditCountVerifierTest.java
+++ b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/verify/PinotAuditCountVerifierTest.java
@@ -1,3 +1,19 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.apache.gobblin.compaction.verify;
 
 import com.google.common.collect.ImmutableMap;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-core-base/src/jmh/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerBenchmark.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/jmh/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerBenchmark.java b/gobblin-core-base/src/jmh/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerBenchmark.java
index 8787b2e..be73962 100644
--- a/gobblin-core-base/src/jmh/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerBenchmark.java
+++ b/gobblin-core-base/src/jmh/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerBenchmark.java
@@ -1,13 +1,18 @@
 /*
- * Copyright (C) 2014-2016 LinkedIn Corp. All rights reserved.
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.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 under the Apache License, Version 2.0 (the "License"); you may not use
- * this 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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing, software distributed
- * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
- * CONDITIONS OF ANY KIND, either express or implied.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
 
 package org.apache.gobblin.writer;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-core-base/src/main/java/org/apache/gobblin/async/Callback.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/async/Callback.java b/gobblin-core-base/src/main/java/org/apache/gobblin/async/Callback.java
index 03abc5b..7cae1b8 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/async/Callback.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/async/Callback.java
@@ -1,3 +1,19 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.apache.gobblin.async;
 
 public interface Callback<T> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-core-base/src/main/java/org/apache/gobblin/converter/SamplingConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/SamplingConverter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/SamplingConverter.java
index db1c9d8..7afe9e1 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/SamplingConverter.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/SamplingConverter.java
@@ -1,22 +1,19 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
-
 package org.apache.gobblin.converter;
 
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.java
index a160883..00c1baa 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.java
@@ -14,7 +14,6 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
 package org.apache.gobblin.converter.filter;
 
 import java.io.IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/DefaultCheckpointableWatermark.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/DefaultCheckpointableWatermark.java b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/DefaultCheckpointableWatermark.java
index c7da8f1..ddbba22 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/DefaultCheckpointableWatermark.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/DefaultCheckpointableWatermark.java
@@ -1,22 +1,19 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
-
 package org.apache.gobblin.source.extractor;
 
 import com.google.gson.Gson;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/limiter/LimiterConfigurationKeys.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/limiter/LimiterConfigurationKeys.java b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/limiter/LimiterConfigurationKeys.java
index d06c146..ba5a8e2 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/limiter/LimiterConfigurationKeys.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/limiter/LimiterConfigurationKeys.java
@@ -1,3 +1,19 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.apache.gobblin.source.extractor.limiter;
 
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToJsonConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToJsonConverter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToJsonConverter.java
index e33f562..c6acc06 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToJsonConverter.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToJsonConverter.java
@@ -1,22 +1,19 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
-
 package org.apache.gobblin.test;
 
 import java.util.Collections;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToStringConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToStringConverter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToStringConverter.java
index b7f5f97..adc801e 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToStringConverter.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToStringConverter.java
@@ -1,22 +1,19 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
-
 package org.apache.gobblin.test;
 
 import org.apache.gobblin.configuration.WorkUnitState;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-core-base/src/main/java/org/apache/gobblin/test/TestRecord.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/test/TestRecord.java b/gobblin-core-base/src/main/java/org/apache/gobblin/test/TestRecord.java
index b52d9e4..eb07977 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/test/TestRecord.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/test/TestRecord.java
@@ -1,22 +1,19 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
-
 package org.apache.gobblin.test;
 
 import lombok.AllArgsConstructor;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableRecordEnvelope.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableRecordEnvelope.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableRecordEnvelope.java
index 97e9d91..82e41ec 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableRecordEnvelope.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableRecordEnvelope.java
@@ -1,22 +1,19 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
-
 package org.apache.gobblin.writer;
 
 import org.apache.gobblin.ack.Ackable;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableWatermark.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableWatermark.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableWatermark.java
index 165783d..1daa567 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableWatermark.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableWatermark.java
@@ -1,22 +1,19 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
-
 package org.apache.gobblin.writer;
 
 import java.util.concurrent.atomic.AtomicInteger;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncWriterManager.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncWriterManager.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncWriterManager.java
index ac30c7b..39740ac 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncWriterManager.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncWriterManager.java
@@ -1,22 +1,19 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
-
 package org.apache.gobblin.writer;
 
 import java.io.Closeable;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-core-base/src/main/java/org/apache/gobblin/writer/Batch.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/Batch.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/Batch.java
index f209c98..ff16590 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/Batch.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/Batch.java
@@ -1,22 +1,19 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.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://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
-
 package org.apache.gobblin.writer;
 import java.util.List;
 import java.util.ArrayList;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/c101493f/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BatchAccumulator.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BatchAccumulator.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BatchAccumulator.java
index 80c1652..03430ed 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BatchAccumulator.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BatchAccumulator.java
@@ -1,3 +1,19 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.apache.gobblin.writer;
 
 import java.io.Closeable;


Mime
View raw message