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.container.placement,
• 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.schema,
• org.apache.samza.sql.udfs,
• org.apache.samza.startpoint,
• 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.batching,
• org.apache.samza.table.descriptors,
• org.apache.samza.table.remote,
• org.apache.samza.table.retry,
• org.apache.samza.table.utils,
• 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.table.descriptors.BaseTableDescriptor<K,V,D> (implements org.apache.samza.table.descriptors.TableDescriptor<K,V,D>)
    • org.apache.samza.table.descriptors.GuavaCacheTableDescriptor<K,V>
    • org.apache.samza.table.descriptors.HybridTableDescriptor<K,V,D>
      • org.apache.samza.table.descriptors.CachingTableDescriptor<K,V>
    • org.apache.samza.table.descriptors.LocalTableDescriptor<K,V,D>
    • org.apache.samza.table.descriptors.RemoteTableDescriptor<K,V>
  • org.apache.samza.table.remote.BaseTableFunction (implements org.apache.samza.table.remote.TableFunction)
  • org.apache.samza.table.batching.BatchProvider<K,V> (implements java.io.Serializable, org.apache.samza.table.remote.TablePart)
  • 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.system.ChangelogSSPIterator
  • org.apache.samza.checkpoint.Checkpoint
  • org.apache.samza.checkpoint.CheckpointedChangelogOffset
  • org.apache.samza.checkpoint.CheckpointId
  • 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.config.JavaTableConfig
  • org.apache.samza.job.model.ContainerModel
  • org.apache.samza.container.placement.ContainerPlacementMessage
    • org.apache.samza.container.placement.ContainerPlacementRequestMessage
    • org.apache.samza.container.placement.ContainerPlacementResponseMessage
  • 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.metadatastore.InMemoryMetadataStore (implements org.apache.samza.metadatastore.MetadataStore)
  • org.apache.samza.metadatastore.InMemoryMetadataStoreFactory (implements org.apache.samza.metadatastore.MetadataStoreFactory)
  • 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.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.metrics.SamzaHistogram
  • org.apache.samza.sql.SamzaSqlRelRecord (implements java.io.Serializable)
  • org.apache.samza.table.utils.SerdeUtils
  • 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.sql.schema.SqlFieldSchema
  • org.apache.samza.sql.schema.SqlSchema
  • org.apache.samza.sql.schema.SqlSchema.SqlField
  • org.apache.samza.sql.schema.SqlSchemaBuilder
  • org.apache.samza.startpoint.Startpoint
    • org.apache.samza.startpoint.StartpointOldest
    • org.apache.samza.startpoint.StartpointSpecific
    • org.apache.samza.startpoint.StartpointTimestamp
    • org.apache.samza.startpoint.StartpointUpcoming
  • 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.remote.TableRateLimiter<K,V>
  • org.apache.samza.table.retry.TableRetryPolicy (implements java.io.Serializable, org.apache.samza.table.remote.TablePart)
  • 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.table.batching.Batch<K,V>
• 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.AsyncFlatMapFunction<M,OM> (also extends org.apache.samza.operators.functions.InitableFunction, java.io.Serializable)
  • 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.table.remote.TableFunction (also extends java.io.Serializable, org.apache.samza.table.remote.TablePart)
    • org.apache.samza.table.remote.TableReadFunction<K,V>
    • org.apache.samza.table.remote.TableWriteFunction<K,V>
  • org.apache.samza.table.remote.TableReadFunction<K,V>
  • org.apache.samza.table.remote.TableWriteFunction<K,V>
• org.apache.samza.task.ClosableTask
• org.apache.samza.config.ConfigFactory
• org.apache.samza.config.ConfigLoader
• org.apache.samza.config.ConfigLoaderFactory
• 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.context.ExternalContext
• org.apache.samza.operators.functions.InitableFunction
  • org.apache.samza.operators.functions.AsyncFlatMapFunction<M,OM> (also extends org.apache.samza.operators.functions.ClosableFunction, java.io.Serializable)
  • 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.table.batching.Operation<K,V>
• org.apache.samza.system.descriptors.OutputDescriptorProvider
• org.apache.samza.operators.OutputStream<M>
• java.util.function.Predicate<T>
  • org.apache.samza.table.retry.TableRetryPolicy.RetryPredicate (also extends java.io.Serializable)
• 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
• 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.AsyncFlatMapFunction<M,OM> (also extends org.apache.samza.operators.functions.ClosableFunction, org.apache.samza.operators.functions.InitableFunction)
  • 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.table.remote.TableFunction (also extends org.apache.samza.operators.functions.ClosableFunction, org.apache.samza.table.remote.TablePart)
    • org.apache.samza.table.remote.TableReadFunction<K,V>
    • org.apache.samza.table.remote.TableWriteFunction<K,V>
  • org.apache.samza.table.remote.TableRateLimiter.CreditFunction<K,V> (also extends org.apache.samza.table.remote.TablePart)
  • org.apache.samza.table.retry.TableRetryPolicy.RetryPredicate (also extends java.util.function.Predicate<T>)
  • org.apache.samza.task.TaskFactory<T>
    • org.apache.samza.task.AsyncStreamTaskFactory
    • org.apache.samza.task.StreamOperatorTaskFactory
    • 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.startpoint.StartpointVisitor<IN,OUT>
• 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.container.grouper.stream.SystemStreamPartitionGrouper
• org.apache.samza.container.grouper.stream.SystemStreamPartitionGrouperFactory
• org.apache.samza.container.grouper.stream.SystemStreamPartitionMapper
• org.apache.samza.container.grouper.stream.SystemStreamPartitionMapperFactory
• org.apache.samza.system.SystemStreamPartitionMatcher
• org.apache.samza.table.Table<R>
  • org.apache.samza.table.AsyncReadWriteTable<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.remote.TablePart
  • org.apache.samza.table.remote.TableFunction (also extends org.apache.samza.operators.functions.ClosableFunction, java.io.Serializable)
    • org.apache.samza.table.remote.TableReadFunction<K,V>
    • org.apache.samza.table.remote.TableWriteFunction<K,V>
  • org.apache.samza.table.remote.TableRateLimiter.CreditFunction<K,V> (also extends java.io.Serializable)
  • org.apache.samza.table.remote.TableReadFunction<K,V>
  • org.apache.samza.table.remote.TableWriteFunction<K,V>
• org.apache.samza.table.TableProvider
• org.apache.samza.table.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.sql.udfs.SamzaSqlUdf (implements java.lang.annotation.Annotation)
• org.apache.samza.sql.udfs.SamzaSqlUdfMethod (implements java.lang.annotation.Annotation)
• 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.task.TaskCoordinator.RequestScope
    • org.apache.samza.storage.StorageEngineFactory.StoreMode
    • org.apache.samza.system.MessageType
    • org.apache.samza.system.SystemStreamMetadata.OffsetType
    • org.apache.samza.system.ChangelogSSPIterator.Mode
    • org.apache.samza.sql.schema.SamzaSqlFieldType
    • org.apache.samza.job.ApplicationStatus.StatusCode
    • org.apache.samza.job.model.TaskMode
    • org.apache.samza.operators.triggers.DurationCharacteristic
    • org.apache.samza.operators.triggers.FiringType
    • org.apache.samza.operators.windows.internal.WindowType
    • org.apache.samza.operators.windows.AccumulationMode
    • org.apache.samza.container.placement.ContainerPlacementMessage.StatusCode