[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 <[email protected]> Authored: Tue Aug 22 21:19:26 2017 -0700 Committer: Abhishek Tiwari <[email protected]> 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="/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this 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. */"/> + <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;
