Hierarchy For All Packages

Package Hierarchies:

• org.wikimedia.gobblin,
• org.wikimedia.gobblin.compression,
• org.wikimedia.gobblin.converter,
• org.wikimedia.gobblin.copy,
• org.wikimedia.gobblin.kafka,
• org.wikimedia.gobblin.publisher,
• org.wikimedia.gobblin.utils,
• org.wikimedia.gobblin.writer,
• org.wikimedia.gobblin.writer.partitioner

Class Hierarchy

• java.lang.Object
  • org.apache.gobblin.kafka.client.AbstractBaseKafkaConsumerClient (implements org.apache.gobblin.kafka.client.GobblinKafkaConsumerClient)
    • org.wikimedia.gobblin.copy.Kafka1ConsumerClient<K,V>
  • org.apache.gobblin.source.extractor.extract.AbstractSource<S,D> (implements org.apache.gobblin.source.Source<S,D>)
    • org.apache.gobblin.source.extractor.extract.EventBasedSource<S,D>
      • org.wikimedia.gobblin.copy.KafkaSource<S,D>
        • org.wikimedia.gobblin.kafka.WikimediaKafkaSource<S,D>
          • org.wikimedia.gobblin.kafka.Kafka1TimestampedRecordSource
  • org.apache.gobblin.kafka.client.BaseKafkaConsumerRecord (implements org.apache.gobblin.kafka.client.KafkaConsumerRecord)
    • org.wikimedia.gobblin.copy.Kafka1ConsumerClient.Kafka1ConsumerRecord<K,V> (implements org.apache.gobblin.kafka.client.DecodeableKafkaRecord<K,V>)
  • org.wikimedia.gobblin.compression.CompressionFactory
  • org.apache.gobblin.converter.Converter<SI,SO,DI,DO> (implements java.io.Closeable, org.apache.gobblin.util.FinalState, org.apache.gobblin.records.RecordStreamProcessor<SI,SO,DI,DO>)
    • org.wikimedia.gobblin.converter.TimestampedRecordConverterWrapper<I,O>
  • org.apache.gobblin.publisher.DataPublisher (implements org.apache.gobblin.capability.CapabilityAware, java.io.Closeable)
    • org.apache.gobblin.publisher.SingleTaskDataPublisher
      • org.wikimedia.gobblin.copy.BaseDataPublisher
        • org.wikimedia.gobblin.copy.TimePartitionedDataPublisher
          • org.wikimedia.gobblin.publisher.TimePartitionedDataPublisherWithFlag
    • org.wikimedia.gobblin.publisher.TimePartitionedFlagDataPublisher
  • org.apache.gobblin.writer.DataWriterBuilder<S,D>
    • org.apache.gobblin.writer.PartitionAwareDataWriterBuilder<S,D>
      • org.apache.gobblin.writer.FsDataWriterBuilder<S,D>
        • org.wikimedia.gobblin.writer.SimpleStringWriterBuilder
          • org.wikimedia.gobblin.writer.TimestampedStringRecordDataWriterBuilder
  • org.apache.gobblin.writer.FsDataWriter<D> (implements org.apache.gobblin.writer.DataWriter<D>, org.apache.gobblin.util.FinalState, org.apache.gobblin.writer.MetadataAwareWriter, org.apache.gobblin.commit.SpeculativeAttemptAwareConstruct)
    • org.wikimedia.gobblin.writer.SimpleStringWriter
  • org.apache.gobblin.codec.GzipCodec (implements org.apache.gobblin.codec.StreamCodec)
    • org.wikimedia.gobblin.compression.GzipCodec
  • org.apache.gobblin.instrumented.extractor.InstrumentedExtractorBase<S,D> (implements java.io.Closeable, org.apache.gobblin.source.extractor.Extractor<S,D>, org.apache.gobblin.util.FinalState, org.apache.gobblin.instrumented.Instrumentable)
    • org.apache.gobblin.instrumented.extractor.InstrumentedExtractor<S,D>
      • org.apache.gobblin.source.extractor.extract.EventBasedExtractor<S,D>
        • org.apache.gobblin.source.extractor.extract.kafka.KafkaExtractor<S,D>
          • org.wikimedia.gobblin.kafka.Kafka1TimestampedRecordExtractor<P>
  • org.wikimedia.gobblin.utils.JsonStringTimestampExtractor
  • org.wikimedia.gobblin.copy.Kafka1ConsumerClient.Factory (implements org.apache.gobblin.kafka.client.GobblinKafkaConsumerClient.GobblinKafkaConsumerClientFactory)
  • org.apache.gobblin.util.ParallelRunner (implements java.io.Closeable)
    • org.wikimedia.gobblin.publisher.ParallelRunnerWithTouch
  • org.apache.gobblin.writer.partitioner.TimeBasedWriterPartitioner<D> (implements org.apache.gobblin.writer.partitioner.WriterPartitioner<D>)
    • org.wikimedia.gobblin.writer.partitioner.JsonStringTimeBasedWriterPartitioner
    • org.wikimedia.gobblin.writer.partitioner.TimestampedRecordTimeBasedWriterPartitioner<P>
      • org.wikimedia.gobblin.writer.partitioner.TimestampedRecordOrJsonStringTimeBasedWriterPartitioner
  • org.wikimedia.gobblin.TimestampedRecord<P>
  • org.wikimedia.gobblin.writer.TimestampedRecordWriterWrapper<P> (implements org.apache.gobblin.writer.DataWriter<D>)

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.wikimedia.gobblin.utils.JsonStringTimestampExtractor.TimestampFormat