jar

org.apache.gobblin : gobblin-core

Maven & Gradle

Feb 03, 2022
23 usages

Apache Gobblin · A distributed data integration framework for streaming and batch data ecosystems.

Table Of Contents

Latest Version

Download org.apache.gobblin : gobblin-core JAR file - Latest Versions:

All Versions

Download org.apache.gobblin : gobblin-core JAR file - All Versions:

Version Vulnerabilities Size Updated
0.16.x
0.15.x CVE-2021-36151
0.14.x CVE-2021-36151
0.13.x CVE-2021-36151
0.12.x CVE-2021-36151

View Java Class Source Code in JAR file

  1. Download JD-GUI to open JAR file and explore Java source code file (.class .java)
  2. Click menu "File → Open File..." or just drag-and-drop the JAR file in the JD-GUI window gobblin-core-0.16.0.jar file.
    Once you open a JAR file, all the java classes in the JAR file will be displayed.

org.apache.gobblin.writer

├─ org.apache.gobblin.writer.AbstractAsyncDataWriter.class - [JAR]

├─ org.apache.gobblin.writer.AvroDataWriterBuilder.class - [JAR]

├─ org.apache.gobblin.writer.AvroHdfsDataWriter.class - [JAR]

├─ org.apache.gobblin.writer.CloseOnFlushWriterWrapper.class - [JAR]

├─ org.apache.gobblin.writer.ConsoleWriter.class - [JAR]

├─ org.apache.gobblin.writer.ConsoleWriterBuilder.class - [JAR]

├─ org.apache.gobblin.writer.DataWriterWrapperBuilder.class - [JAR]

├─ org.apache.gobblin.writer.FsDataWriter.class - [JAR]

├─ org.apache.gobblin.writer.FsDataWriterBuilder.class - [JAR]

├─ org.apache.gobblin.writer.HiveWritableHdfsDataWriter.class - [JAR]

├─ org.apache.gobblin.writer.HiveWritableHdfsDataWriterBuilder.class - [JAR]

├─ org.apache.gobblin.writer.MetadataAwareWriter.class - [JAR]

├─ org.apache.gobblin.writer.MetadataWriterWrapper.class - [JAR]

├─ org.apache.gobblin.writer.PartitionedDataWriter.class - [JAR]

├─ org.apache.gobblin.writer.Retriable.class - [JAR]

├─ org.apache.gobblin.writer.RetryWriter.class - [JAR]

├─ org.apache.gobblin.writer.SchemaBasedPartitionedDataWriterBuilder.class - [JAR]

├─ org.apache.gobblin.writer.SimpleDataWriter.class - [JAR]

├─ org.apache.gobblin.writer.SimpleDataWriterBuilder.class - [JAR]

├─ org.apache.gobblin.writer.ThrottleWriter.class - [JAR]

org.apache.gobblin.converter.http

├─ org.apache.gobblin.converter.http.AvroToRestJsonEntryConverter.class - [JAR]

├─ org.apache.gobblin.converter.http.RestEntry.class - [JAR]

org.apache.gobblin.source.extractor.schema

├─ org.apache.gobblin.source.extractor.schema.ArrayDataType.class - [JAR]

├─ org.apache.gobblin.source.extractor.schema.ColumnAttributes.class - [JAR]

├─ org.apache.gobblin.source.extractor.schema.ColumnNameCase.class - [JAR]

├─ org.apache.gobblin.source.extractor.schema.DataType.class - [JAR]

├─ org.apache.gobblin.source.extractor.schema.EnumDataType.class - [JAR]

├─ org.apache.gobblin.source.extractor.schema.MapDataType.class - [JAR]

├─ org.apache.gobblin.source.extractor.schema.Schema.class - [JAR]

org.apache.gobblin.writer.test

├─ org.apache.gobblin.writer.test.GobblinTestEventBusWriter.class - [JAR]

├─ org.apache.gobblin.writer.test.TestingEventBusAsserter.class - [JAR]

├─ org.apache.gobblin.writer.test.TestingEventBuses.class - [JAR]

org.apache.gobblin.converter.initializer

├─ org.apache.gobblin.converter.initializer.ConverterInitializerFactory.class - [JAR]

├─ org.apache.gobblin.converter.initializer.MultiConverterInitializer.class - [JAR]

org.apache.gobblin.qualitychecker.row

├─ org.apache.gobblin.qualitychecker.row.RowLevelErrFileWriter.class - [JAR]

├─ org.apache.gobblin.qualitychecker.row.RowLevelPolicyCheckResults.class - [JAR]

├─ org.apache.gobblin.qualitychecker.row.RowLevelPolicyChecker.class - [JAR]

├─ org.apache.gobblin.qualitychecker.row.RowLevelPolicyCheckerBuilder.class - [JAR]

├─ org.apache.gobblin.qualitychecker.row.RowLevelPolicyCheckerBuilderFactory.class - [JAR]

org.apache.gobblin.initializer

├─ org.apache.gobblin.initializer.MultiInitializer.class - [JAR]

org.apache.gobblin.converter.avro

├─ org.apache.gobblin.converter.avro.AvroFieldRetrieverConverter.class - [JAR]

├─ org.apache.gobblin.converter.avro.AvroRecordToAvroWritableConverter.class - [JAR]

├─ org.apache.gobblin.converter.avro.AvroRecursionEliminatingConverter.class - [JAR]

├─ org.apache.gobblin.converter.avro.AvroToAvroCopyableConverter.class - [JAR]

├─ org.apache.gobblin.converter.avro.AvroToBytesConverter.class - [JAR]

├─ org.apache.gobblin.converter.avro.BytesToAvroConverter.class - [JAR]

├─ org.apache.gobblin.converter.avro.FlattenNestedKeyConverter.class - [JAR]

├─ org.apache.gobblin.converter.avro.JsonElementConversionFactory.class - [JAR]

├─ org.apache.gobblin.converter.avro.JsonElementConversionWithAvroSchemaFactory.class - [JAR]

├─ org.apache.gobblin.converter.avro.JsonIntermediateToAvroConverter.class - [JAR]

├─ org.apache.gobblin.converter.avro.JsonRecordAvroSchemaToAvroConverter.class - [JAR]

├─ org.apache.gobblin.converter.avro.UnsupportedDateTypeException.class - [JAR]

org.apache.gobblin.config

├─ org.apache.gobblin.config.ConfigBuilder.class - [JAR]

org.apache.gobblin.writer.objectstore

├─ org.apache.gobblin.writer.objectstore.ObjectStoreClient.class - [JAR]

├─ org.apache.gobblin.writer.objectstore.ObjectStoreDeleteOperation.class - [JAR]

├─ org.apache.gobblin.writer.objectstore.ObjectStoreOperation.class - [JAR]

├─ org.apache.gobblin.writer.objectstore.ObjectStoreOperationBuilder.class - [JAR]

├─ org.apache.gobblin.writer.objectstore.ObjectStoreWriter.class - [JAR]

org.apache.gobblin.security.ssl

├─ org.apache.gobblin.security.ssl.SSLContextFactory.class - [JAR]

org.apache.gobblin.source.extractor.extract.sftp

├─ org.apache.gobblin.source.extractor.extract.sftp.SftpExtractor.class - [JAR]

├─ org.apache.gobblin.source.extractor.extract.sftp.SftpFsHelper.class - [JAR]

├─ org.apache.gobblin.source.extractor.extract.sftp.SftpLightWeightFileSystem.class - [JAR]

├─ org.apache.gobblin.source.extractor.extract.sftp.SftpSource.class - [JAR]

org.apache.gobblin.qualitychecker.task

├─ org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckResults.class - [JAR]

├─ org.apache.gobblin.qualitychecker.task.TaskLevelPolicyChecker.class - [JAR]

├─ org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckerBuilder.class - [JAR]

├─ org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckerBuilderFactory.class - [JAR]

org.apache.gobblin.source.extractor.partition

├─ org.apache.gobblin.source.extractor.partition.AppendMaxLimitType.class - [JAR]

├─ org.apache.gobblin.source.extractor.partition.Partition.class - [JAR]

├─ org.apache.gobblin.source.extractor.partition.Partitioner.class - [JAR]

org.apache.gobblin.util

├─ org.apache.gobblin.util.TestUtils.class - [JAR]

org.apache.gobblin.converter.filter

├─ org.apache.gobblin.converter.filter.AvroFieldsPickConverter.class - [JAR]

├─ org.apache.gobblin.converter.filter.AvroFilterConverter.class - [JAR]

org.apache.gobblin.source.extractor.hadoop

├─ org.apache.gobblin.source.extractor.hadoop.AvroFileExtractor.class - [JAR]

├─ org.apache.gobblin.source.extractor.hadoop.AvroFileSource.class - [JAR]

├─ org.apache.gobblin.source.extractor.hadoop.AvroFsHelper.class - [JAR]

├─ org.apache.gobblin.source.extractor.hadoop.HadoopFileInputExtractor.class - [JAR]

├─ org.apache.gobblin.source.extractor.hadoop.HadoopFileInputSource.class - [JAR]

├─ org.apache.gobblin.source.extractor.hadoop.HadoopFsHelper.class - [JAR]

├─ org.apache.gobblin.source.extractor.hadoop.HadoopTextInputSource.class - [JAR]

├─ org.apache.gobblin.source.extractor.hadoop.OldApiHadoopFileInputExtractor.class - [JAR]

├─ org.apache.gobblin.source.extractor.hadoop.OldApiHadoopFileInputSource.class - [JAR]

├─ org.apache.gobblin.source.extractor.hadoop.OldApiHadoopTextInputSource.class - [JAR]

├─ org.apache.gobblin.source.extractor.hadoop.OldApiWritableFileExtractor.class - [JAR]

├─ org.apache.gobblin.source.extractor.hadoop.OldApiWritableFileSource.class - [JAR]

org.apache.gobblin.source.extractor.exception

├─ org.apache.gobblin.source.extractor.exception.ExtractPrepareException.class - [JAR]

├─ org.apache.gobblin.source.extractor.exception.HighWatermarkException.class - [JAR]

├─ org.apache.gobblin.source.extractor.exception.MetadataException.class - [JAR]

├─ org.apache.gobblin.source.extractor.exception.RecordCountException.class - [JAR]

├─ org.apache.gobblin.source.extractor.exception.RestApiClientException.class - [JAR]

├─ org.apache.gobblin.source.extractor.exception.RestApiConnectionException.class - [JAR]

├─ org.apache.gobblin.source.extractor.exception.RestApiProcessingException.class - [JAR]

├─ org.apache.gobblin.source.extractor.exception.SchemaException.class - [JAR]

org.apache.gobblin.commit

├─ org.apache.gobblin.commit.FsRenameCommitStep.class - [JAR]

├─ org.apache.gobblin.commit.SpeculativeAttemptAwareConstruct.class - [JAR]

org.apache.gobblin.source.extractor.extract

├─ org.apache.gobblin.source.extractor.extract.Command.class - [JAR]

├─ org.apache.gobblin.source.extractor.extract.CommandOutput.class - [JAR]

├─ org.apache.gobblin.source.extractor.extract.CommandType.class - [JAR]

├─ org.apache.gobblin.source.extractor.extract.ExtractType.class - [JAR]

├─ org.apache.gobblin.source.extractor.extract.ProtocolSpecificLayer.class - [JAR]

├─ org.apache.gobblin.source.extractor.extract.QueryBasedExtractor.class - [JAR]

├─ org.apache.gobblin.source.extractor.extract.QueryBasedSource.class - [JAR]

├─ org.apache.gobblin.source.extractor.extract.SourceSpecificLayer.class - [JAR]

org.apache.gobblin.source.extractor.extract.restapi

├─ org.apache.gobblin.source.extractor.extract.restapi.RestApiCommand.class - [JAR]

├─ org.apache.gobblin.source.extractor.extract.restapi.RestApiCommandOutput.class - [JAR]

├─ org.apache.gobblin.source.extractor.extract.restapi.RestApiConnector.class - [JAR]

├─ org.apache.gobblin.source.extractor.extract.restapi.RestApiExtractor.class - [JAR]

├─ org.apache.gobblin.source.extractor.extract.restapi.RestApiSpecificLayer.class - [JAR]

org.apache.gobblin.net

├─ org.apache.gobblin.net.Request.class - [JAR]

org.apache.gobblin.source.extractor.watermark

├─ org.apache.gobblin.source.extractor.watermark.DateWatermark.class - [JAR]

├─ org.apache.gobblin.source.extractor.watermark.HourWatermark.class - [JAR]

├─ org.apache.gobblin.source.extractor.watermark.Predicate.class - [JAR]

├─ org.apache.gobblin.source.extractor.watermark.SimpleWatermark.class - [JAR]

├─ org.apache.gobblin.source.extractor.watermark.TimestampWatermark.class - [JAR]

├─ org.apache.gobblin.source.extractor.watermark.Watermark.class - [JAR]

├─ org.apache.gobblin.source.extractor.watermark.WatermarkPredicate.class - [JAR]

├─ org.apache.gobblin.source.extractor.watermark.WatermarkType.class - [JAR]

org.apache.gobblin.policies.avro

├─ org.apache.gobblin.policies.avro.AvroHeaderGuidPolicy.class - [JAR]

├─ org.apache.gobblin.policies.avro.AvroHeaderTimestampPolicy.class - [JAR]

├─ org.apache.gobblin.policies.avro.AvroRecordTimestampLowerBoundPolicy.class - [JAR]

org.apache.gobblin.source.extractor.resultset

├─ org.apache.gobblin.source.extractor.resultset.RecordSet.class - [JAR]

├─ org.apache.gobblin.source.extractor.resultset.RecordSetList.class - [JAR]

org.apache.gobblin.converter.serde

├─ org.apache.gobblin.converter.serde.HiveSerDeConverter.class - [JAR]

org.apache.gobblin.source.workunit

├─ org.apache.gobblin.source.workunit.MultiWorkUnitWeightedQueue.class - [JAR]

org.apache.gobblin.converter.csv

├─ org.apache.gobblin.converter.csv.CsvToJsonConverter.class - [JAR]

├─ org.apache.gobblin.converter.csv.CsvToJsonConverterV2.class - [JAR]

org.apache.gobblin.policies.time

├─ org.apache.gobblin.policies.time.RecordTimestampLowerBoundPolicy.class - [JAR]

org.apache.gobblin.async

├─ org.apache.gobblin.async.AsyncDataDispatcher.class - [JAR]

├─ org.apache.gobblin.async.AsyncRequest.class - [JAR]

├─ org.apache.gobblin.async.AsyncRequestBuilder.class - [JAR]

├─ org.apache.gobblin.async.BufferedRecord.class - [JAR]

├─ org.apache.gobblin.async.DispatchException.class - [JAR]

org.apache.gobblin.http

├─ org.apache.gobblin.http.DefaultHttpClientConfigurator.class - [JAR]

├─ org.apache.gobblin.http.HttpClientConfigurator.class - [JAR]

├─ org.apache.gobblin.http.HttpClientConfiguratorLoader.class - [JAR]

org.apache.gobblin.recordaccess

├─ org.apache.gobblin.recordaccess.AvroGenericRecordAccessor.class - [JAR]

├─ org.apache.gobblin.recordaccess.CoreRecordAccessProvider.class - [JAR]

├─ org.apache.gobblin.recordaccess.RecordAccessorProviderFactory.class - [JAR]

org.apache.gobblin.converter.objectstore

├─ org.apache.gobblin.converter.objectstore.ObjectStoreConverter.class - [JAR]

├─ org.apache.gobblin.converter.objectstore.ObjectStoreDeleteConverter.class - [JAR]

org.apache.gobblin.writer.initializer

├─ org.apache.gobblin.writer.initializer.MultiWriterInitializer.class - [JAR]

├─ org.apache.gobblin.writer.initializer.WriterInitializerFactory.class - [JAR]

gobblin.state

├─ gobblin.state.ConstructState.class - [JAR]

org.apache.gobblin.policies.count

├─ org.apache.gobblin.policies.count.RowCountPolicy.class - [JAR]

├─ org.apache.gobblin.policies.count.RowCountRangePolicy.class - [JAR]

org.apache.gobblin.state

├─ org.apache.gobblin.state.ConstructState.class - [JAR]

org.apache.gobblin.policies.schema

├─ org.apache.gobblin.policies.schema.SchemaCompatibilityPolicy.class - [JAR]

├─ org.apache.gobblin.policies.schema.SchemaRowCheckPolicy.class - [JAR]

org.apache.gobblin.converter

├─ org.apache.gobblin.converter.EmptyIterable.class - [JAR]

├─ org.apache.gobblin.converter.GobblinMetricsPinotFlattenerConverter.class - [JAR]

├─ org.apache.gobblin.converter.StringSchemaInjector.class - [JAR]

org.apache.gobblin.source.extractor.utils

├─ org.apache.gobblin.source.extractor.utils.InputStreamCSVReader.class - [JAR]

├─ org.apache.gobblin.source.extractor.utils.ProxyFsInput.class - [JAR]

├─ org.apache.gobblin.source.extractor.utils.Utils.class - [JAR]

org.apache.gobblin.converter.string

├─ org.apache.gobblin.converter.string.ObjectToStringConverter.class - [JAR]

├─ org.apache.gobblin.converter.string.StringFilterConverter.class - [JAR]

├─ org.apache.gobblin.converter.string.StringSplitterConverter.class - [JAR]

├─ org.apache.gobblin.converter.string.StringSplitterToListConverter.class - [JAR]

├─ org.apache.gobblin.converter.string.StringToBytesConverter.class - [JAR]

├─ org.apache.gobblin.converter.string.TextToStringConverter.class - [JAR]

org.apache.gobblin.destination

├─ org.apache.gobblin.destination.DestinationDatasetHandler.class - [JAR]

├─ org.apache.gobblin.destination.DestinationDatasetHandlerFactory.class - [JAR]

├─ org.apache.gobblin.destination.DestinationDatasetHandlerService.class - [JAR]

org.apache.gobblin.publisher

├─ org.apache.gobblin.publisher.BaseDataPublisher.class - [JAR]

├─ org.apache.gobblin.publisher.BaseDataPublisherWithHiveRegistration.class - [JAR]

├─ org.apache.gobblin.publisher.CommitSequencePublisher.class - [JAR]

├─ org.apache.gobblin.publisher.DataPublisherFactory.class - [JAR]

├─ org.apache.gobblin.publisher.DataPublisherKey.class - [JAR]

├─ org.apache.gobblin.publisher.HiveRegistrationPublisher.class - [JAR]

├─ org.apache.gobblin.publisher.NoopPublisher.class - [JAR]

├─ org.apache.gobblin.publisher.TaskPublisher.class - [JAR]

├─ org.apache.gobblin.publisher.TaskPublisherBuilder.class - [JAR]

├─ org.apache.gobblin.publisher.TaskPublisherBuilderFactory.class - [JAR]

├─ org.apache.gobblin.publisher.TimePartitionedDataPublisher.class - [JAR]

├─ org.apache.gobblin.publisher.TimePartitionedStreamingDataPublisher.class - [JAR]

├─ org.apache.gobblin.publisher.TimestampDataPublisher.class - [JAR]

├─ org.apache.gobblin.publisher.TimestampDataPublisherWithHiveRegistration.class - [JAR]

org.apache.gobblin.converter.json

├─ org.apache.gobblin.converter.json.BytesToJsonConverter.class - [JAR]

├─ org.apache.gobblin.converter.json.JsonSchema.class - [JAR]

├─ org.apache.gobblin.converter.json.JsonStringToJsonIntermediateConverter.class - [JAR]

├─ org.apache.gobblin.converter.json.JsonToStringConverter.class - [JAR]

org.apache.gobblin.fork

├─ org.apache.gobblin.fork.CopyableGenericRecord.class - [JAR]

├─ org.apache.gobblin.fork.CopyableSchema.class - [JAR]

├─ org.apache.gobblin.fork.IdentityForkOperator.class - [JAR]

gobblin.converter.serde

├─ gobblin.converter.serde.OrcSerDeWrapper.class - [JAR]

org.apache.gobblin.writer.objectstore.response

├─ org.apache.gobblin.writer.objectstore.response.DeleteResponse.class - [JAR]

├─ org.apache.gobblin.writer.objectstore.response.GetObjectResponse.class - [JAR]

org.apache.gobblin.source.extractor

├─ org.apache.gobblin.source.extractor.DatePartitionedAvroFileExtractor.class - [JAR]

├─ org.apache.gobblin.source.extractor.DatePartitionedJsonFileExtractor.class - [JAR]

├─ org.apache.gobblin.source.extractor.DummyExtractor.class - [JAR]

├─ org.apache.gobblin.source.extractor.SimpleJsonExtractor.class - [JAR]

org.apache.gobblin.source.extractor.filebased

├─ org.apache.gobblin.source.extractor.filebased.CsvFileDownloader.class - [JAR]

├─ org.apache.gobblin.source.extractor.filebased.FileBasedExtractor.class - [JAR]

├─ org.apache.gobblin.source.extractor.filebased.FileBasedHelper.class - [JAR]

├─ org.apache.gobblin.source.extractor.filebased.FileBasedHelperException.class - [JAR]

├─ org.apache.gobblin.source.extractor.filebased.FileBasedSource.class - [JAR]

├─ org.apache.gobblin.source.extractor.filebased.FileByteIterator.class - [JAR]

├─ org.apache.gobblin.source.extractor.filebased.FileDownloader.class - [JAR]

├─ org.apache.gobblin.source.extractor.filebased.GZIPFileDownloader.class - [JAR]

├─ org.apache.gobblin.source.extractor.filebased.SingleFileDownloader.class - [JAR]

├─ org.apache.gobblin.source.extractor.filebased.SizeAwareFileBasedHelper.class - [JAR]

├─ org.apache.gobblin.source.extractor.filebased.SizeAwareFileBasedHelperDecorator.class - [JAR]

├─ org.apache.gobblin.source.extractor.filebased.TextFileBasedSource.class - [JAR]

├─ org.apache.gobblin.source.extractor.filebased.TimestampAwareFileBasedHelper.class - [JAR]

├─ org.apache.gobblin.source.extractor.filebased.TokenBasedFileInputStreamExtractor.class - [JAR]

├─ org.apache.gobblin.source.extractor.filebased.TokenizedFileDownloader.class - [JAR]

org.apache.gobblin.writer.http

├─ org.apache.gobblin.writer.http.AbstractHttpWriter.class - [JAR]

├─ org.apache.gobblin.writer.http.AbstractHttpWriterBuilder.class - [JAR]

├─ org.apache.gobblin.writer.http.DelegatingHttpClientConnectionManager.class - [JAR]

├─ org.apache.gobblin.writer.http.HttpWriter.class - [JAR]

├─ org.apache.gobblin.writer.http.HttpWriterBuilder.class - [JAR]

├─ org.apache.gobblin.writer.http.HttpWriterDecoration.class - [JAR]

├─ org.apache.gobblin.writer.http.HttpWriterDecorator.class - [JAR]

├─ org.apache.gobblin.writer.http.RestJsonWriter.class - [JAR]

├─ org.apache.gobblin.writer.http.RestJsonWriterBuilder.class - [JAR]

├─ org.apache.gobblin.writer.http.RestWriter.class - [JAR]

├─ org.apache.gobblin.writer.http.RestWriterBuilder.class - [JAR]

├─ org.apache.gobblin.writer.http.SalesForceRestWriterBuilder.class - [JAR]

├─ org.apache.gobblin.writer.http.SalesforceRestWriter.class - [JAR]

├─ org.apache.gobblin.writer.http.UnexpectedResponseException.class - [JAR]

org.apache.gobblin.source

├─ org.apache.gobblin.source.DatePartitionedAvroFileSource.class - [JAR]

├─ org.apache.gobblin.source.DatePartitionedDailyAvroSource.class - [JAR]

├─ org.apache.gobblin.source.DatePartitionedJsonFileSource.class - [JAR]

├─ org.apache.gobblin.source.DatePartitionedNestedRetriever.class - [JAR]

├─ org.apache.gobblin.source.PartitionAwareFileRetriever.class - [JAR]

├─ org.apache.gobblin.source.PartitionAwareFileRetrieverUtils.class - [JAR]

├─ org.apache.gobblin.source.PartitionedFileSourceBase.class - [JAR]

├─ org.apache.gobblin.source.RegexBasedPartitionedRetriever.class - [JAR]

├─ org.apache.gobblin.source.RegexPartitionedAvroFileSource.class - [JAR]

org.apache.gobblin.writer.partitioner

├─ org.apache.gobblin.writer.partitioner.SchemaBasedWriterPartitioner.class - [JAR]

├─ org.apache.gobblin.writer.partitioner.TimeBasedAvroWriterPartitioner.class - [JAR]

├─ org.apache.gobblin.writer.partitioner.TimeBasedWriterPartitioner.class - [JAR]

├─ org.apache.gobblin.writer.partitioner.WorkUnitStateWriterPartitioner.class - [JAR]

Advertisement