Hierarchy For All Packages

Package Hierarchies:

• org.apache.samza,
• org.apache.samza.annotation,
• org.apache.samza.checkpoint,
• org.apache.samza.config,
• org.apache.samza.container,
• org.apache.samza.container.grouper.stream,
• org.apache.samza.job,
• org.apache.samza.metrics,
• org.apache.samza.operators,
• org.apache.samza.operators.data,
• org.apache.samza.operators.functions,
• org.apache.samza.operators.triggers,
• org.apache.samza.operators.windows,
• org.apache.samza.operators.windows.internal,
• org.apache.samza.serializers,
• org.apache.samza.storage,
• org.apache.samza.storage.kv,
• 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.operators.triggers.AnyTrigger<M> (implements org.apache.samza.operators.triggers.Trigger<M>)
  • 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.operators.triggers.CountTrigger<M> (implements org.apache.samza.operators.triggers.Trigger<M>)
  • org.apache.samza.storage.kv.Entry<K,V>
  • org.apache.samza.metrics.Gauge<T> (implements org.apache.samza.metrics.Metric)
    • org.apache.samza.util.BlockingEnvelopeMap.BufferGauge
    • org.apache.samza.util.BlockingEnvelopeMap.BufferSizeGauge
  • org.apache.samza.system.IncomingMessageEnvelope
  • org.apache.samza.operators.data.IncomingSystemMessageEnvelope (implements org.apache.samza.operators.data.MessageEnvelope<K,M>)
  • org.apache.samza.annotation.InterfaceStability
  • org.apache.samza.storage.kv.KeyValueStore.Extension
  • org.apache.samza.operators.data.LongOffset (implements org.apache.samza.operators.data.Offset)
  • 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 (implements java.lang.Comparable<T>)
  • org.apache.samza.container.SamzaContainerContext
  • org.apache.samza.util.SinglePartitionWithoutOffsetsSystemAdmin (implements org.apache.samza.system.SystemAdmin)
  • org.apache.samza.metrics.SlidingTimeWindowReservoir (implements org.apache.samza.metrics.Reservoir)
  • org.apache.samza.metrics.Snapshot
  • org.apache.samza.storage.StoreProperties
  • org.apache.samza.storage.StoreProperties.StorePropertiesBuilder
  • org.apache.samza.system.SystemStream
    • org.apache.samza.system.SystemStreamPartition (implements java.lang.Comparable<T>)
  • org.apache.samza.system.SystemStreamMetadata
  • org.apache.samza.system.SystemStreamMetadata.SystemStreamPartitionMetadata
  • org.apache.samza.system.SystemStreamPartitionIterator (implements java.util.Iterator<E>)
  • org.apache.samza.container.TaskName (implements java.lang.Comparable<T>)
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • org.apache.samza.metrics.MetricsValidationFailureException
      • java.lang.RuntimeException
        • org.apache.samza.SamzaException
          • org.apache.samza.config.ConfigException
  • org.apache.samza.metrics.Timer (implements org.apache.samza.metrics.Metric)
  • org.apache.samza.operators.triggers.TimeSinceFirstMessageTrigger<M> (implements org.apache.samza.operators.triggers.Trigger<M>)
  • org.apache.samza.operators.triggers.TimeSinceLastMessageTrigger<M> (implements org.apache.samza.operators.triggers.Trigger<M>)
  • org.apache.samza.operators.triggers.TimeTrigger<M> (implements org.apache.samza.operators.triggers.Trigger<M>)
  • org.apache.samza.operators.triggers.Triggers<M>
  • org.apache.samza.operators.windows.internal.WindowInternal<M,K,WV> (implements org.apache.samza.operators.windows.Window<M,K,WV,WM>)
  • org.apache.samza.operators.windows.WindowKey<K>
  • org.apache.samza.operators.windows.WindowPane<K,V> (implements org.apache.samza.operators.data.MessageEnvelope<K,M>)
  • org.apache.samza.operators.windows.Windows

Interface Hierarchy

• org.apache.samza.task.AsyncStreamTask
• org.apache.samza.task.AsyncStreamTaskFactory
• org.apache.samza.checkpoint.CheckpointListener
• org.apache.samza.checkpoint.CheckpointManager
• org.apache.samza.checkpoint.CheckpointManagerFactory
• org.apache.samza.util.Clock
• org.apache.samza.task.ClosableTask
• java.lang.Comparable<T>
  • org.apache.samza.operators.data.Offset
• 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.EndOfStreamListenerTask
• org.apache.samza.operators.functions.FilterFunction<M>
• org.apache.samza.operators.functions.FlatMapFunction<M,OM>
• org.apache.samza.task.InitableTask
• java.util.Iterator<E>
  • org.apache.samza.storage.kv.KeyValueIterator<K,V>
• org.apache.samza.operators.functions.JoinFunction<M,JM,RM>
• org.apache.samza.storage.kv.KeyValueStore<K,V>
• org.apache.samza.operators.functions.MapFunction<M,OM>
• org.apache.samza.system.chooser.MessageChooser
• org.apache.samza.system.chooser.MessageChooserFactory
• org.apache.samza.task.MessageCollector
• org.apache.samza.operators.data.MessageEnvelope<K,M>
• org.apache.samza.operators.MessageStream<M>
• org.apache.samza.metrics.Metric
• org.apache.samza.metrics.MetricsAccessor
• org.apache.samza.metrics.MetricsRegistry
  • org.apache.samza.metrics.ReadableMetricsRegistry
• org.apache.samza.metrics.MetricsReporter
• org.apache.samza.metrics.MetricsReporterFactory
• org.apache.samza.metrics.MetricsValidator
• org.apache.samza.metrics.ReadableMetricsRegistryListener
• org.apache.samza.metrics.Reservoir
• 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.operators.functions.SinkFunction<M>
• 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.operators.StreamOperatorTask
• org.apache.samza.task.StreamTask
• org.apache.samza.task.StreamTaskFactory
• org.apache.samza.system.SystemAdmin
  • org.apache.samza.system.ExtendedSystemAdmin
• org.apache.samza.system.SystemConsumer
• org.apache.samza.system.SystemFactory
• org.apache.samza.system.SystemProducer
• org.apache.samza.container.grouper.stream.SystemStreamPartitionGrouper
• org.apache.samza.container.grouper.stream.SystemStreamPartitionGrouperFactory
• org.apache.samza.system.SystemStreamPartitionMatcher
• org.apache.samza.task.TaskCallback
• org.apache.samza.task.TaskContext
• org.apache.samza.task.TaskCoordinator
• org.apache.samza.operators.triggers.Trigger<M>
• org.apache.samza.operators.windows.Window<M,K,WV,WM>
• org.apache.samza.task.WindowableTask

Annotation Type Hierarchy

• org.apache.samza.annotation.InterfaceStability.Stable (implements java.lang.annotation.Annotation)
• org.apache.samza.annotation.InterfaceStability.Evolving (implements java.lang.annotation.Annotation)
• org.apache.samza.annotation.InterfaceStability.Unstable (implements java.lang.annotation.Annotation)

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.operators.triggers.DurationCharacteristic
    • org.apache.samza.operators.windows.AccumulationMode
    • org.apache.samza.system.SystemStreamMetadata.OffsetType
    • org.apache.samza.task.TaskCoordinator.RequestScope