Hierarchy For All Packages

Package Hierarchies:

• org.apache.samza,
• org.apache.samza.annotation,
• org.apache.samza.application,
• org.apache.samza.application.descriptors,
• org.apache.samza.checkpoint,
• org.apache.samza.config,
• org.apache.samza.container,
• org.apache.samza.container.grouper.stream,
• org.apache.samza.context,
• org.apache.samza.job,
• org.apache.samza.job.model,
• org.apache.samza.metadatastore,
• org.apache.samza.metrics,
• org.apache.samza.operators,
• org.apache.samza.operators.functions,
• org.apache.samza.operators.triggers,
• org.apache.samza.operators.windows,
• org.apache.samza.operators.windows.internal,
• org.apache.samza.runtime,
• org.apache.samza.scheduler,
• org.apache.samza.serializers,
• org.apache.samza.sql,
• org.apache.samza.sql.udfs,
• org.apache.samza.storage,
• org.apache.samza.storage.kv,
• org.apache.samza.system,
• org.apache.samza.system.chooser,
• org.apache.samza.system.descriptors,
• org.apache.samza.table,
• org.apache.samza.table.descriptors,
• 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.runtime.ApplicationRunners
  • org.apache.samza.job.ApplicationStatus
  • 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.serializers.ByteBufferSerde (implements org.apache.samza.serializers.Serde<T>)
  • org.apache.samza.serializers.ByteBufferSerdeFactory (implements org.apache.samza.serializers.SerdeFactory<T>)
  • org.apache.samza.serializers.ByteSerde (implements org.apache.samza.serializers.Serde<T>)
  • org.apache.samza.serializers.ByteSerdeFactory (implements org.apache.samza.serializers.SerdeFactory<T>)
  • org.apache.samza.checkpoint.Checkpoint
  • org.apache.samza.job.CommandBuilder
  • org.apache.samza.config.Config (implements java.util.Map<K,V>, java.io.Serializable)
    • org.apache.samza.config.MapConfig
  • org.apache.samza.job.model.ContainerModel
  • org.apache.samza.system.ControlMessage
    • org.apache.samza.system.EndOfStreamMessage
    • org.apache.samza.system.WatermarkMessage
  • 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.serializers.DoubleSerde (implements org.apache.samza.serializers.Serde<T>)
  • org.apache.samza.serializers.DoubleSerdeFactory (implements org.apache.samza.serializers.SerdeFactory<T>)
  • 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.serializers.IntegerSerde (implements org.apache.samza.serializers.Serde<T>)
  • org.apache.samza.serializers.IntegerSerdeFactory (implements org.apache.samza.serializers.SerdeFactory<T>)
  • org.apache.samza.annotation.InterfaceStability
  • org.apache.samza.serializers.JsonSerdeV2<T> (implements org.apache.samza.serializers.Serde<T>)
  • org.apache.samza.serializers.JsonSerdeV2Factory (implements org.apache.samza.serializers.SerdeFactory<T>)
  • org.apache.samza.operators.KV<K,V>
  • org.apache.samza.serializers.KVSerde<K,V> (implements org.apache.samza.serializers.Serde<T>)
  • org.apache.samza.metrics.ListGauge<T> (implements org.apache.samza.metrics.Metric)
  • org.apache.samza.runtime.LocationId
  • org.apache.samza.serializers.LongSerde (implements org.apache.samza.serializers.Serde<T>)
  • org.apache.samza.serializers.LongSerdeFactory (implements org.apache.samza.serializers.SerdeFactory<T>)
  • org.apache.samza.metrics.MetricsVisitor
  • org.apache.samza.util.NoOpMetricsRegistry (implements org.apache.samza.metrics.MetricsRegistry)
  • org.apache.samza.serializers.NoOpSerde<T> (implements org.apache.samza.serializers.Serde<T>)
  • org.apache.samza.system.OutgoingMessageEnvelope
  • org.apache.samza.Partition (implements java.lang.Comparable<T>)
  • org.apache.samza.operators.triggers.RepeatingTrigger<M> (implements org.apache.samza.operators.triggers.Trigger<M>)
  • org.apache.samza.sql.SamzaSqlRelRecord (implements java.io.Serializable)
  • org.apache.samza.serializers.SerializableSerde<T> (implements org.apache.samza.serializers.Serde<T>)
  • org.apache.samza.serializers.SerializableSerdeFactory<T> (implements org.apache.samza.serializers.SerdeFactory<T>)
  • 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.descriptors.StreamDescriptor<StreamMessageType,SubClass>
    • org.apache.samza.system.descriptors.InputDescriptor<StreamMessageType,SubClass>
      • org.apache.samza.system.descriptors.GenericInputDescriptor<StreamMessageType>
    • org.apache.samza.system.descriptors.OutputDescriptor<StreamMessageType,SubClass>
      • org.apache.samza.system.descriptors.GenericOutputDescriptor<StreamMessageType>
  • org.apache.samza.system.StreamSpec (implements java.io.Serializable)
  • org.apache.samza.serializers.StringSerde (implements org.apache.samza.serializers.Serde<T>)
  • org.apache.samza.serializers.StringSerdeFactory (implements org.apache.samza.serializers.SerdeFactory<T>)
  • org.apache.samza.system.descriptors.SystemDescriptor<SubClass>
    • org.apache.samza.system.descriptors.GenericSystemDescriptor (implements org.apache.samza.system.descriptors.OutputDescriptorProvider, org.apache.samza.system.descriptors.SimpleInputDescriptorProvider)
  • 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.table.TableSpec (implements java.io.Serializable)
  • org.apache.samza.job.model.TaskModel (implements java.lang.Comparable<T>)
  • 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.system.StreamValidationException
          • org.apache.samza.system.SystemProducerException
  • org.apache.samza.metrics.Timer (implements org.apache.samza.metrics.Metric)
  • org.apache.samza.operators.triggers.TimeSinceFirstMessageTrigger<M> (implements org.apache.samza.operators.triggers.TimeBasedTrigger<M>, org.apache.samza.operators.triggers.Trigger<M>)
  • org.apache.samza.operators.triggers.TimeSinceLastMessageTrigger<M> (implements org.apache.samza.operators.triggers.TimeBasedTrigger<M>, org.apache.samza.operators.triggers.Trigger<M>)
  • org.apache.samza.util.TimestampedValue<V>
  • org.apache.samza.operators.triggers.TimeTrigger<M> (implements org.apache.samza.operators.triggers.TimeBasedTrigger<M>, org.apache.samza.operators.triggers.Trigger<M>)
  • org.apache.samza.operators.triggers.Triggers
  • org.apache.samza.serializers.UUIDSerde (implements org.apache.samza.serializers.Serde<T>)
  • org.apache.samza.serializers.UUIDSerdeFactory (implements org.apache.samza.serializers.SerdeFactory<T>)
  • org.apache.samza.operators.windows.internal.WindowInternal<M,WK,WV> (implements org.apache.samza.operators.windows.Window<M,K,WV>)
  • org.apache.samza.operators.windows.WindowKey<K>
  • org.apache.samza.operators.windows.WindowPane<K,V>
  • org.apache.samza.operators.windows.Windows

Interface Hierarchy

• org.apache.samza.context.ApplicationContainerContext
• org.apache.samza.application.descriptors.ApplicationDescriptor<S>
  • org.apache.samza.application.descriptors.StreamApplicationDescriptor
  • org.apache.samza.application.descriptors.TaskApplicationDescriptor
• org.apache.samza.runtime.ApplicationRunner
• org.apache.samza.context.ApplicationTaskContext
• org.apache.samza.task.AsyncStreamTask
• org.apache.samza.scheduler.CallbackScheduler
• org.apache.samza.checkpoint.CheckpointListener
• org.apache.samza.checkpoint.CheckpointManager
• org.apache.samza.checkpoint.CheckpointManagerFactory
• org.apache.samza.util.Clock
• org.apache.samza.operators.functions.ClosableFunction
  • org.apache.samza.operators.functions.FilterFunction<M> (also extends org.apache.samza.operators.functions.InitableFunction, java.io.Serializable)
  • org.apache.samza.operators.functions.FlatMapFunction<M,OM> (also extends org.apache.samza.operators.functions.InitableFunction, java.io.Serializable)
  • org.apache.samza.operators.functions.FoldLeftFunction<M,WV> (also extends org.apache.samza.operators.functions.InitableFunction, java.io.Serializable)
  • org.apache.samza.system.descriptors.InputTransformer<OM> (also extends org.apache.samza.operators.functions.InitableFunction, java.io.Serializable)
  • org.apache.samza.operators.functions.JoinFunction<K,M,JM,RM> (also extends org.apache.samza.operators.functions.InitableFunction, java.io.Serializable)
  • org.apache.samza.operators.functions.MapFunction<M,OM> (also extends org.apache.samza.operators.functions.InitableFunction, java.io.Serializable)
  • org.apache.samza.operators.functions.SinkFunction<M> (also extends org.apache.samza.operators.functions.InitableFunction, java.io.Serializable)
  • org.apache.samza.operators.functions.StreamTableJoinFunction<K,M,R,JM> (also extends org.apache.samza.operators.functions.InitableFunction, java.io.Serializable)
  • org.apache.samza.operators.functions.SupplierFunction<T> (also extends org.apache.samza.operators.functions.InitableFunction, java.io.Serializable)
• org.apache.samza.task.ClosableTask
• org.apache.samza.config.ConfigFactory
• org.apache.samza.config.ConfigRewriter
• org.apache.samza.context.ContainerContext
• org.apache.samza.context.Context
• org.apache.samza.serializers.Deserializer<T>
  • org.apache.samza.serializers.Serde<T> (also extends java.io.Serializable, org.apache.samza.serializers.Serializer<T>)
• org.apache.samza.task.EndOfStreamListenerTask
• org.apache.samza.system.descriptors.ExpandingInputDescriptorProvider<StreamExpanderType>
• org.apache.samza.operators.functions.InitableFunction
  • org.apache.samza.operators.functions.FilterFunction<M> (also extends org.apache.samza.operators.functions.ClosableFunction, java.io.Serializable)
  • org.apache.samza.operators.functions.FlatMapFunction<M,OM> (also extends org.apache.samza.operators.functions.ClosableFunction, java.io.Serializable)
  • org.apache.samza.operators.functions.FoldLeftFunction<M,WV> (also extends org.apache.samza.operators.functions.ClosableFunction, java.io.Serializable)
  • org.apache.samza.system.descriptors.InputTransformer<OM> (also extends org.apache.samza.operators.functions.ClosableFunction, java.io.Serializable)
  • org.apache.samza.operators.functions.JoinFunction<K,M,JM,RM> (also extends org.apache.samza.operators.functions.ClosableFunction, java.io.Serializable)
  • org.apache.samza.operators.functions.MapFunction<M,OM> (also extends org.apache.samza.operators.functions.ClosableFunction, java.io.Serializable)
  • org.apache.samza.operators.functions.SinkFunction<M> (also extends org.apache.samza.operators.functions.ClosableFunction, java.io.Serializable)
  • org.apache.samza.operators.functions.StreamTableJoinFunction<K,M,R,JM> (also extends org.apache.samza.operators.functions.ClosableFunction, java.io.Serializable)
  • org.apache.samza.operators.functions.SupplierFunction<T> (also extends org.apache.samza.operators.functions.ClosableFunction, java.io.Serializable)
• org.apache.samza.task.InitableTask
• java.util.Iterator<E>
  • org.apache.samza.storage.kv.ClosableIterator<V>
  • org.apache.samza.storage.kv.KeyValueIterator<K,V>
• org.apache.samza.context.JobContext
• org.apache.samza.storage.kv.KeyValueSnapshot<K,V>
• org.apache.samza.storage.kv.KeyValueStore<K,V>
• org.apache.samza.runtime.LocationIdProvider
• org.apache.samza.runtime.LocationIdProviderFactory
• org.apache.samza.system.chooser.MessageChooser
• org.apache.samza.system.chooser.MessageChooserFactory
• org.apache.samza.task.MessageCollector
• org.apache.samza.operators.MessageStream<M>
• org.apache.samza.metadatastore.MetadataStore
• org.apache.samza.metadatastore.MetadataStoreFactory
• 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.MetricsValidator
• org.apache.samza.system.descriptors.OutputDescriptorProvider
• org.apache.samza.operators.OutputStream<M>
• org.apache.samza.runtime.ProcessorContext
• org.apache.samza.runtime.ProcessorIdGenerator
• org.apache.samza.runtime.ProcessorLifecycleListener
• org.apache.samza.metrics.ReadableMetricsRegistryListener
• org.apache.samza.metrics.Reservoir
• org.apache.samza.application.SamzaApplication<S>
  • org.apache.samza.application.StreamApplication
  • org.apache.samza.application.TaskApplication
• org.apache.samza.sql.udfs.ScalarUdf<T>
• org.apache.samza.scheduler.ScheduledCallback<K>
• org.apache.samza.operators.functions.ScheduledFunction<K,OM>
• org.apache.samza.operators.Scheduler<K>
• org.apache.samza.serializers.SerdeFactory<T>
• java.io.Serializable
  • org.apache.samza.context.ApplicationContainerContextFactory<T>
  • org.apache.samza.context.ApplicationTaskContextFactory<T>
  • org.apache.samza.operators.functions.FilterFunction<M> (also extends org.apache.samza.operators.functions.ClosableFunction, org.apache.samza.operators.functions.InitableFunction)
  • org.apache.samza.operators.functions.FlatMapFunction<M,OM> (also extends org.apache.samza.operators.functions.ClosableFunction, org.apache.samza.operators.functions.InitableFunction)
  • org.apache.samza.operators.functions.FoldLeftFunction<M,WV> (also extends org.apache.samza.operators.functions.ClosableFunction, org.apache.samza.operators.functions.InitableFunction)
  • org.apache.samza.system.descriptors.InputTransformer<OM> (also extends org.apache.samza.operators.functions.ClosableFunction, org.apache.samza.operators.functions.InitableFunction)
  • org.apache.samza.operators.functions.JoinFunction<K,M,JM,RM> (also extends org.apache.samza.operators.functions.ClosableFunction, org.apache.samza.operators.functions.InitableFunction)
  • org.apache.samza.operators.functions.MapFunction<M,OM> (also extends org.apache.samza.operators.functions.ClosableFunction, org.apache.samza.operators.functions.InitableFunction)
  • org.apache.samza.metrics.MetricsReporterFactory
  • org.apache.samza.runtime.ProcessorLifecycleListenerFactory
  • org.apache.samza.util.RateLimiter
  • org.apache.samza.serializers.Serde<T> (also extends org.apache.samza.serializers.Deserializer<T>, org.apache.samza.serializers.Serializer<T>)
  • org.apache.samza.storage.SideInputsProcessor
  • org.apache.samza.storage.SideInputsProcessorFactory
  • org.apache.samza.operators.functions.SinkFunction<M> (also extends org.apache.samza.operators.functions.ClosableFunction, org.apache.samza.operators.functions.InitableFunction)
  • org.apache.samza.system.descriptors.StreamExpander<OM>
  • org.apache.samza.operators.functions.StreamTableJoinFunction<K,M,R,JM> (also extends org.apache.samza.operators.functions.ClosableFunction, org.apache.samza.operators.functions.InitableFunction)
  • org.apache.samza.operators.functions.SupplierFunction<T> (also extends org.apache.samza.operators.functions.ClosableFunction, org.apache.samza.operators.functions.InitableFunction)
  • org.apache.samza.task.TaskFactory<T>
    • org.apache.samza.task.AsyncStreamTaskFactory
    • org.apache.samza.task.StreamTaskFactory
  • org.apache.samza.operators.triggers.Trigger<M>
    • org.apache.samza.operators.triggers.TimeBasedTrigger<M>
  • org.apache.samza.operators.windows.Window<M,K,WV>
• org.apache.samza.serializers.Serializer<T>
  • org.apache.samza.serializers.Serde<T> (also extends org.apache.samza.serializers.Deserializer<T>, java.io.Serializable)
• org.apache.samza.system.descriptors.SimpleInputDescriptorProvider
• 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.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.table.Table<R>
  • org.apache.samza.table.ReadableTable<K,V>
    • org.apache.samza.table.ReadWriteTable<K,V>
  • org.apache.samza.table.ReadWriteTable<K,V>
• org.apache.samza.table.descriptors.TableDescriptor<K,V,D>
• org.apache.samza.table.descriptors.TableProvider
• org.apache.samza.table.descriptors.TableProviderFactory
• org.apache.samza.task.TaskCallback
• org.apache.samza.context.TaskContext
• org.apache.samza.task.TaskCoordinator
• org.apache.samza.system.descriptors.TransformingInputDescriptorProvider<InputTransformerType>
• org.apache.samza.operators.functions.WatermarkFunction<T>
• 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.operators.triggers.DurationCharacteristic
    • org.apache.samza.operators.triggers.FiringType
    • org.apache.samza.operators.windows.AccumulationMode
    • org.apache.samza.operators.windows.internal.WindowType
    • org.apache.samza.system.SystemStreamMetadata.OffsetType
    • org.apache.samza.system.MessageType
    • org.apache.samza.task.TaskCoordinator.RequestScope
    • org.apache.samza.job.ApplicationStatus.StatusCode