Hierarchy For All Packages

Package Hierarchies:

• io.aiven.kafka.connect.common,
• io.aiven.kafka.connect.common.config,
• io.aiven.kafka.connect.common.config.enums,
• io.aiven.kafka.connect.common.config.validators,
• io.aiven.kafka.connect.common.grouper,
• io.aiven.kafka.connect.common.output,
• io.aiven.kafka.connect.common.output.avro,
• io.aiven.kafka.connect.common.output.jsonwriter,
• io.aiven.kafka.connect.common.output.parquet,
• io.aiven.kafka.connect.common.output.plainwriter,
• io.aiven.kafka.connect.common.source,
• io.aiven.kafka.connect.common.source.input,
• io.aiven.kafka.connect.common.source.input.parquet,
• io.aiven.kafka.connect.common.source.input.utils,
• io.aiven.kafka.connect.common.source.task,
• io.aiven.kafka.connect.common.templating

Class Hierarchy

• java.lang.Object
  • org.apache.kafka.common.config.AbstractConfig
    • io.aiven.kafka.connect.common.config.CommonConfig
      • io.aiven.kafka.connect.common.config.SinkCommonConfig
        • io.aiven.kafka.connect.common.config.AivenCommonConfig
      • io.aiven.kafka.connect.common.config.SourceCommonConfig
  • io.aiven.kafka.connect.common.config.AbstractFragmentSetter<T>
    • io.aiven.kafka.connect.common.config.CommonConfigFragment.Setter
    • io.aiven.kafka.connect.common.config.FileNameFragment.Setter
    • io.aiven.kafka.connect.common.config.KafkaFragment.Setter
    • io.aiven.kafka.connect.common.config.OutputFormatFragment.Setter
    • io.aiven.kafka.connect.common.config.SourceConfigFragment.Setter
    • io.aiven.kafka.connect.common.config.TransformerFragment.Setter
  • io.aiven.kafka.connect.common.output.jsonwriter.AbstractJsonOutputStreamWriter (implements io.aiven.kafka.connect.common.output.OutputStreamWriter)
    • io.aiven.kafka.connect.common.output.jsonwriter.JsonLinesOutputStreamWriter
  • io.aiven.kafka.connect.common.source.AbstractSourceRecord<K,N,O,T>
  • io.aiven.kafka.connect.common.source.AbstractSourceRecordIterator<K,N,O,T> (implements java.util.Iterator<E>)
  • io.aiven.kafka.connect.common.source.AbstractSourceTask.Backoff
  • io.aiven.kafka.connect.common.output.plainwriter.AbstractValuePlainWriter (implements io.aiven.kafka.connect.common.output.plainwriter.OutputFieldPlainWriter)
    • io.aiven.kafka.connect.common.output.plainwriter.Base64ValuePlainWriter
    • io.aiven.kafka.connect.common.output.plainwriter.ValuePlainWriter
  • org.apache.kafka.common.config.ConfigDef.NonEmptyString (implements org.apache.kafka.common.config.ConfigDef.Validator)
    • io.aiven.kafka.connect.common.config.TransformerFragment.InputFormatValidator
  • io.aiven.kafka.connect.common.config.ConfigFragment
    • io.aiven.kafka.connect.common.config.BackoffPolicyConfig
    • io.aiven.kafka.connect.common.config.CommonConfigFragment
    • io.aiven.kafka.connect.common.config.CompressionFragment
    • io.aiven.kafka.connect.common.config.FileNameFragment
    • io.aiven.kafka.connect.common.config.OutputFormatFragment
    • io.aiven.kafka.connect.common.config.SourceConfigFragment
    • io.aiven.kafka.connect.common.config.TransformerFragment
  • io.aiven.kafka.connect.common.source.task.Context<K>
  • io.aiven.kafka.connect.common.source.task.DistributionStrategy
  • io.aiven.kafka.connect.common.config.validators.FileCompressionTypeValidator (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • io.aiven.kafka.connect.common.config.validators.FilenameTemplateValidator (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • io.aiven.kafka.connect.common.config.FilenameTemplateVariable.ParameterDescriptor
  • io.aiven.kafka.connect.common.source.input.utils.FilePatternUtils
  • io.aiven.kafka.connect.common.config.FixedSetRecommender (implements org.apache.kafka.common.config.ConfigDef.Recommender)
  • io.aiven.kafka.connect.common.output.plainwriter.HeadersPlainWriter (implements io.aiven.kafka.connect.common.output.plainwriter.OutputFieldPlainWriter)
  • io.aiven.kafka.connect.common.output.jsonwriter.JsonOutputFieldComposer
  • io.aiven.kafka.connect.common.config.KafkaFragment
  • io.aiven.kafka.connect.common.grouper.KeyAndTopicPartitionRecordGrouper (implements io.aiven.kafka.connect.common.grouper.RecordGrouper)
  • io.aiven.kafka.connect.common.output.plainwriter.KeyPlainWriter (implements io.aiven.kafka.connect.common.output.plainwriter.OutputFieldPlainWriter)
  • io.aiven.kafka.connect.common.grouper.KeyRecordGrouper (implements io.aiven.kafka.connect.common.grouper.RecordGrouper)
  • io.aiven.kafka.connect.common.source.input.parquet.LocalInputFile (implements org.apache.parquet.io.InputFile)
  • io.aiven.kafka.connect.common.config.validators.NonEmptyPassword (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • io.aiven.kafka.connect.common.output.jsonwriter.ObjectMapperProvider
  • io.aiven.kafka.connect.common.source.OffsetManager<E>
  • io.aiven.kafka.connect.common.output.plainwriter.OffsetPlainWriter (implements io.aiven.kafka.connect.common.output.plainwriter.OutputFieldPlainWriter)
  • io.aiven.kafka.connect.common.config.OutputField
  • io.aiven.kafka.connect.common.config.validators.OutputFieldsEncodingValidator (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • io.aiven.kafka.connect.common.config.validators.OutputFieldsValidator (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • io.aiven.kafka.connect.common.config.validators.OutputTypeValidator (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • io.aiven.kafka.connect.common.output.OutputWriter (implements java.lang.AutoCloseable)
    • io.aiven.kafka.connect.common.output.avro.AvroOutputWriter
    • io.aiven.kafka.connect.common.output.jsonwriter.JsonLinesOutputWriter
    • io.aiven.kafka.connect.common.output.jsonwriter.JsonOutputWriter
    • io.aiven.kafka.connect.common.output.parquet.ParquetOutputWriter
    • io.aiven.kafka.connect.common.output.plainwriter.PlainOutputWriter
  • io.aiven.kafka.connect.common.output.OutputWriter.Builder
  • io.aiven.kafka.connect.common.grouper.RecordGrouperFactory
  • io.aiven.kafka.connect.common.output.SinkRecordConverter
  • io.aiven.kafka.connect.common.output.SinkSchemaBuilder
    • io.aiven.kafka.connect.common.output.avro.AvroSchemaBuilder
    • io.aiven.kafka.connect.common.output.parquet.ParquetSchemaBuilder
  • io.aiven.kafka.connect.common.config.validators.SourcenameTemplateValidator (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • org.apache.kafka.connect.source.SourceTask (implements org.apache.kafka.connect.connector.Task)
    • io.aiven.kafka.connect.common.source.AbstractSourceTask
  • io.aiven.kafka.connect.common.config.StableTimeFormatter
  • org.apache.commons.lang3.time.StopWatch
    • io.aiven.kafka.connect.common.source.AbstractSourceTask.Timer
  • org.apache.commons.collections4.collection.SynchronizedCollection<E> (implements java.util.Collection<E>, java.io.Serializable)
    • org.apache.commons.collections4.queue.SynchronizedQueue<E> (implements java.util.Queue<E>)
      • io.aiven.kafka.connect.common.source.RingBuffer<K>
  • io.aiven.kafka.connect.common.templating.Template
  • io.aiven.kafka.connect.common.templating.Template.Extractor
  • io.aiven.kafka.connect.common.templating.Template.Instance
  • io.aiven.kafka.connect.common.templating.TemplateParser
  • io.aiven.kafka.connect.common.templating.TextTemplatePart (implements io.aiven.kafka.connect.common.templating.TemplatePart)
  • io.aiven.kafka.connect.common.output.plainwriter.TimestampPlainWriter (implements io.aiven.kafka.connect.common.output.plainwriter.OutputFieldPlainWriter)
  • io.aiven.kafka.connect.common.config.TimestampSource.EventTimestampSource (implements io.aiven.kafka.connect.common.config.TimestampSource)
  • io.aiven.kafka.connect.common.config.TimestampSource.WallclockTimestampSource (implements io.aiven.kafka.connect.common.config.TimestampSource)
  • io.aiven.kafka.connect.common.config.validators.TimestampSourceValidator (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • io.aiven.kafka.connect.common.config.validators.TimeZoneValidator (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • io.aiven.kafka.connect.common.grouper.TopicPartitionKeyRecordGrouper (implements io.aiven.kafka.connect.common.grouper.RecordGrouper)
  • io.aiven.kafka.connect.common.grouper.TopicPartitionKeyRecordGrouper.TopicPartitionKey
  • io.aiven.kafka.connect.common.source.input.Transformer
    • io.aiven.kafka.connect.common.source.input.AvroTransformer
    • io.aiven.kafka.connect.common.source.input.ByteArrayTransformer
    • io.aiven.kafka.connect.common.source.input.JsonTransformer
    • io.aiven.kafka.connect.common.source.input.ParquetTransformer
  • io.aiven.kafka.connect.common.source.input.Transformer.StreamSpliterator (implements java.util.Spliterator<T>)
  • io.aiven.kafka.connect.common.source.input.TransformerFactory
  • io.aiven.kafka.connect.common.config.validators.UrlValidator (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • io.aiven.kafka.connect.common.templating.VariableTemplatePart (implements io.aiven.kafka.connect.common.templating.TemplatePart)
  • io.aiven.kafka.connect.common.templating.VariableTemplatePart.Parameter

Interface Hierarchy

• io.aiven.kafka.connect.common.source.AbstractSourceTask.AbortTrigger
• io.aiven.kafka.connect.common.source.AbstractSourceTask.BackoffConfig
• io.aiven.kafka.connect.common.source.AbstractSourceTask.SupplierOfLong
• java.lang.Comparable<T>
  • io.aiven.kafka.connect.common.source.OffsetManager.OffsetManagerEntry<T>
• io.aiven.kafka.connect.common.NativeInfo<K,N>
• io.aiven.kafka.connect.common.source.NativeSourceData<K,N,O,T>
• io.aiven.kafka.connect.common.source.OffsetManager.OffsetManagerKey
• io.aiven.kafka.connect.common.output.plainwriter.OutputFieldPlainWriter
• io.aiven.kafka.connect.common.output.OutputStreamWriter
• io.aiven.kafka.connect.common.grouper.RecordGrouper
• io.aiven.kafka.connect.common.grouper.RecordGrouper.Rotator<T>
• io.aiven.kafka.connect.common.templating.TemplatePart
• io.aiven.kafka.connect.common.config.TimestampSource

Enum Class Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)
    • io.aiven.kafka.connect.common.config.CompressionType
    • io.aiven.kafka.connect.common.source.task.DistributionType
    • io.aiven.kafka.connect.common.config.enums.ErrorsTolerance
    • io.aiven.kafka.connect.common.config.FilenameTemplateVariable
    • io.aiven.kafka.connect.common.config.FormatType
    • io.aiven.kafka.connect.common.source.input.InputFormat
    • io.aiven.kafka.connect.common.config.KafkaFragment.PluginDiscovery
    • io.aiven.kafka.connect.common.config.OutputFieldEncodingType
    • io.aiven.kafka.connect.common.config.OutputFieldType
    • io.aiven.kafka.connect.common.config.TimestampSource.Type