ASF Git Repos - gobblin.git/commit

author	aditya1105 <adsharma@linkedin.com>
	Wed, 23 Aug 2017 04:19:26 +0000 (21:19 -0700)
committer	Abhishek Tiwari <abhishektiwari.btech@gmail.com>
	Wed, 23 Aug 2017 04:19:26 +0000 (21:19 -0700)
commit	c101493f8cae8558e01f6598162bfb762e4d051d
tree	ecf09b2e573572b0ff9d01902b1954def35175f4	tree \| snapshot
parent	32ca21a5c3b0cd697759431b0db34d0dfe26b0f6	commit \| diff

[GOBBLIN-219] Added copyright header check and enforced it for existing files

Closes #2070 from aditya1105/checkstyle

190 files changed:

config/checkstyle/checkstyle.xml	[new file with mode: 0644]	blob
config/checkstyle/suppressions.xml	[new file with mode: 0644]	blob
gobblin-api/src/main/java/gobblin/source/extractor/CheckpointableWatermark.java		diff \| blob \| history
gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java		diff \| blob \| history
gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeTypes.java		diff \| blob \| history
gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java		diff \| blob \| history
gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java		diff \| blob \| history
gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SubscopedBrokerBuilder.java		diff \| blob \| history
gobblin-api/src/main/java/org/apache/gobblin/dataset/comparators/package-info.java		diff \| blob \| history
gobblin-api/src/main/java/org/apache/gobblin/fork/CopyHelper.java		diff \| blob \| history
gobblin-api/src/main/java/org/apache/gobblin/source/extractor/CheckpointableWatermark.java		diff \| blob \| history
gobblin-api/src/main/java/org/apache/gobblin/source/extractor/StreamingExtractor.java		diff \| blob \| history
gobblin-api/src/main/java/org/apache/gobblin/writer/WatermarkStorage.java		diff \| blob \| history
gobblin-api/src/test/java/com/linkedin/gobblin/TestAlias.java		diff \| blob \| history
gobblin-api/src/test/java/org/apache/gobblin/ack/HierarchicalAckableTest.java		diff \| blob \| history
gobblin-api/src/test/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopesTest.java		diff \| blob \| history
gobblin-api/src/test/java/org/apache/gobblin/fork/CopyHelperTest.java		diff \| blob \| history
gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixConstants.java		diff \| blob \| history
gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixMessagingService.java		diff \| blob \| history
gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskDriver.java		diff \| blob \| history
gobblin-cluster/src/main/java/org/apache/helix/task/GobblinJobRebalancer.java		diff \| blob \| history
gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactionTaskFactory.java		diff \| blob \| history
gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/CompactionVerifier.java		diff \| blob \| history
gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/InputRecordCountHelper.java		diff \| blob \| history
gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/RenameSourceDirectoryTest.java		diff \| blob \| history
gobblin-compaction/src/test/java/org/apache/gobblin/compaction/suite/TestCompactionSuiteFactories.java		diff \| blob \| history
gobblin-compaction/src/test/java/org/apache/gobblin/compaction/verify/PinotAuditCountVerifierTest.java		diff \| blob \| history
gobblin-core-base/src/jmh/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerBenchmark.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/async/Callback.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/converter/SamplingConverter.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/DefaultCheckpointableWatermark.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/limiter/LimiterConfigurationKeys.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToJsonConverter.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToStringConverter.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/test/TestRecord.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableRecordEnvelope.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableWatermark.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncWriterManager.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/Batch.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/BatchAccumulator.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/BatchAsyncDataWriter.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/BufferedAsyncDataWriter.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/BytesBoundedBatch.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/FineGrainedWatermarkTracker.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/FutureWrappedWriteCallback.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/GenericWriteResponse.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/GenericWriteResponseWrapper.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/LastWatermarkTracker.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/MultiWriterWatermarkManager.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/MultiWriterWatermarkTracker.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/RecordFuture.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/RecordMetadata.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/SequentialBasedBatchAccumulator.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/SyncDataWriter.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/TrackerBasedWatermarkManager.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriter.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriterWrapper.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkManager.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTracker.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTrackerFactory.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponse.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseFuture.java		diff \| blob \| history
gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseMapper.java		diff \| blob \| history
gobblin-core-base/src/test/java/org/apache/gobblin/converter/SamplingConverterTest.java		diff \| blob \| history
gobblin-core-base/src/test/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerTest.java		diff \| blob \| history
gobblin-core-base/src/test/java/org/apache/gobblin/writer/MultiWriterWatermarkManagerTest.java		diff \| blob \| history
gobblin-core-base/src/test/java/org/apache/gobblin/writer/WatermarkTrackerTest.java		diff \| blob \| history
gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedDailyAvroSource.java		diff \| blob \| history
gobblin-core/src/main/java/org/apache/gobblin/source/extractor/partition/Partition.java		diff \| blob \| history
gobblin-core/src/test/java/org/apache/gobblin/async/AsyncDataDispatcherTest.java		diff \| blob \| history
gobblin-core/src/test/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverterTest.java		diff \| blob \| history
gobblin-core/src/test/java/org/apache/gobblin/converter/string/ObjectToStringConverterTest.java		diff \| blob \| history
gobblin-core/src/test/java/org/apache/gobblin/recordaccess/AvroGenericRecordAccessorTest.java		diff \| blob \| history
gobblin-core/src/test/java/org/apache/gobblin/recordaccess/RecordAccessorProviderFactoryTest.java		diff \| blob \| history
gobblin-core/src/test/java/org/apache/gobblin/security/ssl/SSLContextFactoryTest.java		diff \| blob \| history
gobblin-core/src/test/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractorTest.java		diff \| blob \| history
gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedExtractorTest.java		diff \| blob \| history
gobblin-core/src/test/java/org/apache/gobblin/source/extractor/partition/PartitionerTest.java		diff \| blob \| history
gobblin-core/src/test/java/org/apache/gobblin/writer/MetadataWriterWrapperTest.java		diff \| blob \| history
gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DefaultFileSystemGlobFinder.java		diff \| blob \| history
gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/CopyPartitionParametersTest.java		diff \| blob \| history
gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/HiveMetaStoreClientFactoryTest.java		diff \| blob \| history
gobblin-metrics-libs/gobblin-metrics-base/config/checkstyle/suppressions.xml	[new file with mode: 0644]	blob
gobblin-modules/gobblin-avro-json/src/test/java/org/apache/gobblin/converter/avro/AvroToJsonRecordWithMetadataConverterTest.java		diff \| blob \| history
gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/Avro2OrcStaleDatasetCleaner.java		diff \| blob \| history
gobblin-modules/gobblin-compliance/src/test/java/org/apache/gobblin/compliance/purger/HivePurgerWriterTest.java		diff \| blob \| history
gobblin-modules/gobblin-couchbase/src/main/java/org/apache/gobblin/couchbase/converter/AnyToCouchbaseJsonConverter.java		diff \| blob \| history
gobblin-modules/gobblin-couchbase/src/main/java/org/apache/gobblin/couchbase/writer/CouchbaseEnvironmentFactory.java		diff \| blob \| history
gobblin-modules/gobblin-couchbase/src/test/java/org/apache/gobblin/couchbase/converter/AnyToCouchbaseJsonConverterTest.java		diff \| blob \| history
gobblin-modules/gobblin-crypto-provider/src/main/java/org/apache/gobblin/converter/AvroStringFieldEncryptorConverter.java		diff \| blob \| history
gobblin-modules/gobblin-crypto-provider/src/main/java/org/apache/gobblin/converter/SerializedRecordToEncryptedSerializedRecordConverter.java		diff \| blob \| history
gobblin-modules/gobblin-crypto-provider/src/main/java/org/apache/gobblin/converter/StringFieldEncryptorConverter.java		diff \| blob \| history
gobblin-modules/gobblin-crypto-provider/src/test/java/org/apache/gobblin/converter/AvroStringFieldEncryptorConverterTest.java		diff \| blob \| history
gobblin-modules/gobblin-crypto-provider/src/test/java/org/apache/gobblin/crypto/GobblinEncryptionProviderTest.java		diff \| blob \| history
gobblin-modules/gobblin-crypto/src/main/java/org/apache/gobblin/converter/SerializedRecordToEncryptedSerializedRecordConverterBase.java		diff \| blob \| history
gobblin-modules/gobblin-eventhub/src/main/java/org/apache/gobblin/eventhub/EventhubMetricNames.java		diff \| blob \| history
gobblin-modules/gobblin-eventhub/src/main/java/org/apache/gobblin/eventhub/writer/BatchedEventhubDataWriter.java		diff \| blob \| history
gobblin-modules/gobblin-eventhub/src/main/java/org/apache/gobblin/eventhub/writer/EventhubBatchAccumulator.java		diff \| blob \| history
gobblin-modules/gobblin-eventhub/src/main/java/org/apache/gobblin/eventhub/writer/EventhubDataWriter.java		diff \| blob \| history
gobblin-modules/gobblin-eventhub/src/main/java/org/apache/gobblin/eventhub/writer/EventhubDataWriterBuilder.java		diff \| blob \| history
gobblin-modules/gobblin-eventhub/src/main/java/org/apache/gobblin/eventhub/writer/EventhubRequest.java		diff \| blob \| history
gobblin-modules/gobblin-eventhub/src/test/java/org/apache/gobblin/eventhub/writer/BatchedEventhubDataWriterTest.java		diff \| blob \| history
gobblin-modules/gobblin-eventhub/src/test/java/org/apache/gobblin/eventhub/writer/EventhubAccumulatorTest.java		diff \| blob \| history
gobblin-modules/gobblin-eventhub/src/test/java/org/apache/gobblin/eventhub/writer/EventhubBatchTest.java		diff \| blob \| history
gobblin-modules/gobblin-eventhub/src/test/java/org/apache/gobblin/eventhub/writer/EventhubDataWriterTest.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/converter/AsyncHttpJoinConverter.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/converter/AvroApacheHttpJoinConverter.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/converter/AvroHttpJoinConverter.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/converter/AvroR2JoinConverter.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/converter/HttpJoinConverter.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpAsyncClient.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpClient.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpRequestBuilder.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpResponseHandler.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpResponseStatus.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ThrottledHttpClient.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2ResponseStatus.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2RestRequestBuilder.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2RestResponseHandler.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/utils/HttpConstants.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/utils/HttpUtils.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/AvroHttpWriterBuilder.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/HttpTestUtils.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/MockGenericRecord.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/http/ApacheHttpRequestBuilderTest.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/r2/R2ClientFactoryTest.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/r2/R2RestRequestBuilderTest.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/util/HttpUtilsTest.java		diff \| blob \| history
gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/writer/AsyncHttpWriterTest.java		diff \| blob \| history
gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/converter/RecordWithMetadataToEnvelopedRecordWithMetadata.java		diff \| blob \| history
gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/Metadata.java		diff \| blob \| history
gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/type/ContentTypeUtils.java		diff \| blob \| history
gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/type/RecordWithMetadata.java		diff \| blob \| history
gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/type/SerializedRecordWithMetadata.java		diff \| blob \| history
gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/converter/MetadataConverterWrapperTest.java		diff \| blob \| history
gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/converter/RecordWithMetadataToEnvelopedRecordWithMetadataTest.java		diff \| blob \| history
gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/metadata/GlobalMetadataCollectorTest.java		diff \| blob \| history
gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/AsyncIteratorWithDataSink.java		diff \| blob \| history
gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/GoggleIngestionConfigurationKeys.java		diff \| blob \| history
gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/util/SchemaUtil.java		diff \| blob \| history
gobblin-rest-service/gobblin-rest-api/config/checkstyle/suppressions.xml	[new file with mode: 0644]	blob
gobblin-rest-service/gobblin-rest-server/config/checkstyle/suppressions.xml	[new file with mode: 0644]	blob
gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/config/checkstyle/suppressions.xml	[new file with mode: 0644]	blob
gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/config/checkstyle/suppressions.xml	[new file with mode: 0644]	blob
gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/config/checkstyle/suppressions.xml	[new file with mode: 0644]	blob
gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingGuiceServletConfig.java		diff \| blob \| history
gobblin-runtime/src/jmh/java/org/apache/gobblin/runtime/fork/MockTaskContext.java		diff \| blob \| history
gobblin-runtime/src/main/java/gobblin/runtime/TaskState.java		diff \| blob \| history
gobblin-runtime/src/main/java/org/apache/gobblin/runtime/CheckpointableWatermarkState.java		diff \| blob \| history
gobblin-runtime/src/main/java/org/apache/gobblin/runtime/ExecutionModel.java		diff \| blob \| history
gobblin-runtime/src/main/java/org/apache/gobblin/runtime/StateStoreBasedWatermarkStorage.java		diff \| blob \| history
gobblin-runtime/src/main/java/org/apache/gobblin/runtime/StateStoreBasedWatermarkStorageCli.java		diff \| blob \| history
gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskConfigurationKeys.java		diff \| blob \| history
gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskInstantiationException.java		diff \| blob \| history
gobblin-runtime/src/main/java/org/apache/gobblin/runtime/crypto/DecryptCli.java		diff \| blob \| history
gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/AsynchronousFork.java		diff \| blob \| history
gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/Fork.java		diff \| blob \| history
gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/SynchronousFork.java		diff \| blob \| history
gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/FailedTask.java		diff \| blob \| history
gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/BaseGobblinJob.java		diff \| blob \| history
gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobBrokerInjectionTest.java		diff \| blob \| history
gobblin-runtime/src/test/java/org/apache/gobblin/runtime/LimiterStopEventTest.java		diff \| blob \| history
gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContinuousTest.java		diff \| blob \| history
gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/hadoop/TestHadoopConfigLoader.java		diff \| blob \| history
gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactoryManagerTest.java		diff \| blob \| history
gobblin-salesforce/src/test/java/org/apache/gobblin/salesforce/SalesforceSourceTest.java		diff \| blob \| history
gobblin-test-harness/src/test/java/org/apache/gobblin/GobblinLocalJobLauncherUtils.java		diff \| blob \| history
gobblin-test-harness/src/test/java/org/apache/gobblin/TaskSkipErrRecordsIntegrationTest.java		diff \| blob \| history
gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroConverter.java		diff \| blob \| history
gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroExtractor.java		diff \| blob \| history
gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroSource.java		diff \| blob \| history
gobblin-test-harness/src/test/java/org/apache/gobblin/WriterOutputFormatIntegrationTest.java		diff \| blob \| history
gobblin-utility/src/main/java/org/apache/gobblin/util/DatePartitionType.java		diff \| blob \| history
gobblin-utility/src/main/java/org/apache/gobblin/util/HostUtils.java		diff \| blob \| history
gobblin-utility/src/main/java/org/apache/gobblin/util/JvmUtils.java		diff \| blob \| history
gobblin-utility/src/main/java/org/apache/gobblin/util/PortUtils.java		diff \| blob \| history
gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingCallable.java		diff \| blob \| history
gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingExecutorService.java		diff \| blob \| history
gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingRunnable.java		diff \| blob \| history
gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingScheduledExecutorService.java		diff \| blob \| history
gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/LimiterFactory.java		diff \| blob \| history
gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/MultiLimiter.java		diff \| blob \| history
gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NoopLimiter.java		diff \| blob \| history
gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactory.java		diff \| blob \| history
gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterKey.java		diff \| blob \| history
gobblin-utility/src/test/java/org/apache/gobblin/util/PortUtilsTest.java		diff \| blob \| history
gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/MultiLimiterTest.java		diff \| blob \| history
gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactoryTest.java		diff \| blob \| history
gradle/scripts/testSetup.gradle		diff \| blob \| history

A distributed data integration framework that simplifies common aspects of big data integration such as data ingestion, replication, organization and lifecycle management for both streaming and batch data ecosystems.

RSS Atom