Hierarchy For All Packages

Package Hierarchies:

• org.apache.samza,
• org.apache.samza.checkpoint,
• org.apache.samza.config,
• org.apache.samza.container,
• org.apache.samza.job,
• org.apache.samza.metrics,
• org.apache.samza.serializers,
• org.apache.samza.storage,
• org.apache.samza.system,
• org.apache.samza.system.chooser,
• org.apache.samza.task,
• org.apache.samza.util

Class Hierarchy

• java.lang.Object
  • org.apache.samza.system.chooser.BaseMessageChooser (implements org.apache.samza.system.chooser.MessageChooser)
  • org.apache.samza.util.BlockingEnvelopeMap (implements org.apache.samza.system.SystemConsumer)
  • org.apache.samza.util.BlockingEnvelopeMap.BlockingEnvelopeMapMetrics
  • org.apache.samza.checkpoint.Checkpoint
  • org.apache.samza.job.CommandBuilder
  • org.apache.samza.config.Config (implements java.util.Map<K,V>)
    • org.apache.samza.config.MapConfig
  • org.apache.samza.metrics.Counter (implements org.apache.samza.metrics.Metric)
  • org.apache.samza.metrics.Gauge<T> (implements org.apache.samza.metrics.Metric)
    • org.apache.samza.util.BlockingEnvelopeMap.BufferGauge
  • org.apache.samza.system.IncomingMessageEnvelope
  • org.apache.samza.metrics.MetricsVisitor
  • org.apache.samza.util.NoOpMetricsRegistry (implements org.apache.samza.metrics.MetricsRegistry)
  • org.apache.samza.system.OutgoingMessageEnvelope
  • org.apache.samza.Partition
  • org.apache.samza.container.SamzaContainerContext
  • org.apache.samza.util.SinglePartitionWithoutOffsetsSystemAdmin (implements org.apache.samza.system.SystemAdmin)
  • org.apache.samza.system.SystemStream
    • org.apache.samza.system.SystemStreamPartition
  • org.apache.samza.system.SystemStreamMetadata
  • org.apache.samza.system.SystemStreamMetadata.SystemStreamPartitionMetadata
  • org.apache.samza.system.SystemStreamPartitionIterator (implements java.util.Iterator<E>)
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • org.apache.samza.SamzaException
          • org.apache.samza.config.ConfigException

Interface Hierarchy

• org.apache.samza.checkpoint.CheckpointManager
• org.apache.samza.checkpoint.CheckpointManagerFactory
• org.apache.samza.util.Clock
• org.apache.samza.task.ClosableTask
• org.apache.samza.config.ConfigFactory
• org.apache.samza.config.ConfigRewriter
• org.apache.samza.serializers.Deserializer<T>
  • org.apache.samza.serializers.Serde<T> (also extends org.apache.samza.serializers.Serializer<T>)
• org.apache.samza.task.InitableTask
• org.apache.samza.system.chooser.MessageChooser
• org.apache.samza.system.chooser.MessageChooserFactory
• org.apache.samza.task.MessageCollector
• org.apache.samza.metrics.Metric
• org.apache.samza.metrics.MetricsRegistry
  • org.apache.samza.metrics.ReadableMetricsRegistry
• org.apache.samza.metrics.MetricsReporter
• org.apache.samza.metrics.MetricsReporterFactory
• org.apache.samza.metrics.ReadableMetricsRegistryListener
• org.apache.samza.serializers.SerdeFactory<T>
• org.apache.samza.serializers.Serializer<T>
  • org.apache.samza.serializers.Serde<T> (also extends org.apache.samza.serializers.Deserializer<T>)
• org.apache.samza.storage.StorageEngine
• org.apache.samza.storage.StorageEngineFactory<K,V>
• org.apache.samza.job.StreamJob
• org.apache.samza.job.StreamJobFactory
• org.apache.samza.task.StreamTask
• org.apache.samza.system.SystemAdmin
• org.apache.samza.system.SystemConsumer
• org.apache.samza.system.SystemFactory
• org.apache.samza.system.SystemProducer
• org.apache.samza.task.TaskContext
• org.apache.samza.task.TaskCoordinator
• org.apache.samza.task.TaskLifecycleListener
• org.apache.samza.task.TaskLifecycleListenerFactory
• org.apache.samza.task.WindowableTask

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.samza.job.ApplicationStatus
    • org.apache.samza.system.SystemStreamMetadata.OffsetType
    • org.apache.samza.task.TaskCoordinator.RequestScope