Class Hierarchy (samza-api 1.9.0-SNAPSHOT API)
JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
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.coordinator.lifecycle,
org.apache.samza.drain,
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.blobstore,
org.apache.samza.storage.blobstore.exceptions,
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.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,U>
org.apache.samza.table.remote.BaseTableFunction (implements org.apache.samza.table.remote.TableFunction)
org.apache.samza.table.batching.BatchProvider<K,V,U> (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.system.BoundedSSPIterator (implements java.util.Iterator<E>)
org.apache.samza.system.ChangelogSSPIterator
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.CheckpointId (implements java.lang.Comparable<T>)
org.apache.samza.checkpoint.CheckpointV1 (implements org.apache.samza.checkpoint.Checkpoint)
org.apache.samza.checkpoint.CheckpointV2 (implements 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.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.DrainMessage
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.drain.DrainNotification
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.job.JobCoordinatorMetadata
org.apache.samza.job.model.JobModel
org.apache.samza.coordinator.lifecycle.JobRestartSignalFactoryContext
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.storage.KafkaChangelogRestoreParams
org.apache.samza.operators.KV<K,V>
org.apache.samza.serializers.KVSerde<K,V> (implements org.apache.samza.serializers.Serde<T>)
org.apache.samza.job.model.LocalityModel
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.storage.blobstore.Metadata
org.apache.samza.metrics.MetricsRegistryWithSource
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.job.model.ProcessorLocality
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.storage.blobstore.exceptions.DeletedException
org.apache.samza.table.RecordNotFoundException
org.apache.samza.storage.blobstore.exceptions.RetriableException
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.operators.UpdateMessage<U,V>
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,U>
org.apache.samza.storage.BlobStoreAdminFactory
org.apache.samza.storage.blobstore.BlobStoreManager
org.apache.samza.storage.blobstore.BlobStoreManagerFactory
org.apache.samza.scheduler.CallbackScheduler
org.apache.samza.checkpoint.Checkpoint
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,U>
org.apache.samza.table.remote.TableReadFunction<K,V>
org.apache.samza.table.remote.TableWriteFunction<K,V,U>
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.DrainListenerTask
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.coordinator.lifecycle.JobRestartSignal
org.apache.samza.coordinator.lifecycle.JobRestartSignalFactory
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,U>
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,U>
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.StateBackendAdmin
org.apache.samza.storage.StateBackendFactory
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.AsyncReadWriteUpdateTable<K,V,U>
org.apache.samza.table.ReadWriteTable<K,V>
org.apache.samza.table.ReadWriteUpdateTable<K,V,U>
org.apache.samza.table.ReadWriteTable<K,V>
org.apache.samza.table.ReadWriteTable<K,V>
org.apache.samza.table.ReadWriteUpdateTable<K,V,U>
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,U>
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,U>
org.apache.samza.table.TableProvider
org.apache.samza.table.TableProviderFactory
org.apache.samza.storage.TaskBackupManager
org.apache.samza.task.TaskCallback
org.apache.samza.context.TaskContext
org.apache.samza.task.TaskCoordinator
org.apache.samza.task.TaskExecutorFactory
org.apache.samza.storage.TaskRestoreManager
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)
org.apache.samza.sql.udfs.SamzaSqlUdf (implements java.lang.annotation.Annotation)
org.apache.samza.sql.udfs.SamzaSqlUdfMethod (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.UpdateOptions
org.apache.samza.operators.windows.internal.WindowType
org.apache.samza.operators.windows.AccumulationMode
org.apache.samza.storage.StorageEngineFactory.StoreMode
org.apache.samza.container.placement.ContainerPlacementMessage.StatusCode
org.apache.samza.system.ChangelogSSPIterator.Mode
org.apache.samza.system.SystemStreamMetadata.OffsetType
org.apache.samza.system.MessageType
org.apache.samza.drain.DrainMode
org.apache.samza.task.TaskCoordinator.RequestScope
org.apache.samza.job.JobMetadataChange
org.apache.samza.job.ApplicationStatus.StatusCode
org.apache.samza.job.model.TaskMode
org.apache.samza.application.ApplicationApiType
org.apache.samza.sql.schema.SamzaSqlFieldType
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes