Index (samza-api 1.9.0-SNAPSHOT API)

A B C D E F G H I J K L M N O P R S T U V W

A

AccumulationMode - Enum in org.apache.samza.operators.windows: Specifies how a Window should process its previously emitted WindowPanes.
acquire(int) - Method in interface org.apache.samza.util.RateLimiter: Attempt to acquire the provided number of credits, blocks indefinitely until all requested credits become available.
acquire(int, long, TimeUnit) - Method in interface org.apache.samza.util.RateLimiter: Attempt to acquire the provided number of credits, blocks for up to provided amount of time for credits to become available.
acquire(Map<String, Integer>) - Method in interface org.apache.samza.util.RateLimiter: Attempt to acquire the provided number of credits for a number of tags, blocks indefinitely until all requested credits become available
acquire(Map<String, Integer>, long, TimeUnit) - Method in interface org.apache.samza.util.RateLimiter: Attempt to acquire the provided number of credits for a number of tags, blocks for up to provided amount of time for credits to become available.
addField(String, SqlFieldSchema) - Method in class org.apache.samza.sql.schema.SqlSchemaBuilder
addOperation(Operation<K, V, U>) - Method in interface org.apache.samza.table.batching.Batch: Add an operation to the batch.
addStoreConfig(String, String, Map<String, String>) - Method in class org.apache.samza.table.descriptors.LocalTableDescriptor: Helper method to add a store level config item to table configuration
addTableConfig(String, String, Map<String, String>) - Method in class org.apache.samza.table.descriptors.BaseTableDescriptor: Helper method to add a config item to table configuration
addTablePartConfig(String, TablePart, Config, Map<String, String>) - Method in class org.apache.samza.table.descriptors.RemoteTableDescriptor: Helper method to add table part config items to table configuration
admin - Variable in class org.apache.samza.system.BoundedSSPIterator
afterCheckpoint(Map<SystemStreamPartition, String>) - Method in interface org.apache.samza.checkpoint.CheckpointListener: Called after writing the checkpoint for each Task in the Container processing SSPs on this system.
afterFailure(Throwable) - Method in interface org.apache.samza.runtime.ProcessorLifecycleListener: User defined callback after a StreamProcessor is stopped with failure
afterStart() - Method in interface org.apache.samza.runtime.ProcessorLifecycleListener: User defined callback after a StreamProcessor is started
afterStop() - Method in interface org.apache.samza.runtime.ProcessorLifecycleListener: User defined callback after a StreamProcessor is stopped successfully
all() - Method in class org.apache.samza.metadatastore.InMemoryMetadataStore
all() - Method in interface org.apache.samza.metadatastore.MetadataStore: Returns all the entries in this metadata store.
all() - Method in interface org.apache.samza.storage.kv.KeyValueStore: Returns an iterator for all entries in this key-value store.
any(Trigger<M>...) - Static method in class org.apache.samza.operators.triggers.Triggers: Creates a trigger that fires when any of the provided triggers fire.
AnyTrigger<M> - Class in org.apache.samza.operators.triggers: A Trigger fires as soon as any of its individual triggers has fired.
ApplicationApiType - Enum in org.apache.samza.application: Enum to denote the possible API types for a samza application.
ApplicationContainerContext - Interface in org.apache.samza.context: An ApplicationContainerContext instance can be used for holding per-container runtime state and objects and managing their lifecycle.
ApplicationContainerContextFactory<T extends ApplicationContainerContext> - Interface in org.apache.samza.context: The factory for creating ApplicationContainerContext instances for a SamzaApplication during container initialization.
ApplicationDescriptor<S extends ApplicationDescriptor> - Interface in org.apache.samza.application.descriptors: An ApplicationDescriptor contains the description of inputs, outputs, state, configuration and the processing logic for a SamzaApplication.
ApplicationRunner - Interface in org.apache.samza.runtime: The primary means of managing execution of the SamzaApplication at runtime.
ApplicationStatus - Class in org.apache.samza.job: Status of a StreamJob during and after its run.
ApplicationStatus.StatusCode - Enum in org.apache.samza.job
ApplicationTaskContext - Interface in org.apache.samza.context: An ApplicationTaskContext instance can be used for holding per-task runtime state and objects and managing their lifecycle in an SamzaApplication
ApplicationTaskContextFactory<T extends ApplicationTaskContext> - Interface in org.apache.samza.context: The factory for creating ApplicationTaskContext instances for a SamzaApplicationduring task initialization.
apply(M) - Method in interface org.apache.samza.operators.functions.AsyncFlatMapFunction: Transforms the provided message into a collection of 0 or more messages.
apply(M) - Method in interface org.apache.samza.operators.functions.FilterFunction: Returns a boolean indicating whether this message should be retained or filtered out.
apply(M) - Method in interface org.apache.samza.operators.functions.FlatMapFunction: Transforms the provided message into a collection of 0 or more messages.
apply(M, WV) - Method in interface org.apache.samza.operators.functions.FoldLeftFunction: Incrementally updates the aggregated value as messages are added.
apply(M, JM) - Method in interface org.apache.samza.operators.functions.JoinFunction: Joins the provided messages and returns the joined message.
apply(M) - Method in interface org.apache.samza.operators.functions.MapFunction: Transforms the provided message into another message.
apply(M, MessageCollector, TaskCoordinator) - Method in interface org.apache.samza.operators.functions.SinkFunction: Allows sending the provided message to an output SystemStream using the provided MessageCollector.
apply(M, R) - Method in interface org.apache.samza.operators.functions.StreamTableJoinFunction: Joins the provided messages and table record, returns the joined message.
apply(IN, StartpointVisitor<IN, OUT>) - Method in class org.apache.samza.startpoint.Startpoint: Applies the StartpointVisitor's visit methods to the Startpoint and returns the result of that operation.
apply(IN, StartpointVisitor<IN, OUT>) - Method in class org.apache.samza.startpoint.StartpointOldest
apply(IN, StartpointVisitor<IN, OUT>) - Method in class org.apache.samza.startpoint.StartpointSpecific
apply(IN, StartpointVisitor<IN, OUT>) - Method in class org.apache.samza.startpoint.StartpointTimestamp
apply(IN, StartpointVisitor<IN, OUT>) - Method in class org.apache.samza.startpoint.StartpointUpcoming
apply(IncomingMessageEnvelope) - Method in interface org.apache.samza.system.descriptors.InputTransformer: Transforms the provided IncomingMessageEnvelope with deserialized key and message into another message which is delivered to the MessageStream.
apply(StreamApplicationDescriptor, InputDescriptor) - Method in interface org.apache.samza.system.descriptors.StreamExpander: Expands the provided InputDescriptor to a sub-DAG of one or more operators on the StreamApplicationDescriptor, and returns a new MessageStream with the combined results.
ASYNC_CALLBACK_POOL_SIZE - Static variable in class org.apache.samza.table.descriptors.RemoteTableDescriptor
AsyncFlatMapFunction<M,OM> - Interface in org.apache.samza.operators.functions: Asynchronous variant of the FlatMapFunction used in tandem with MessageStream.flatMapAsync(AsyncFlatMapFunction) to transform a collection of 0 or more messages.
AsyncReadWriteUpdateTable<K,V,U> - Interface in org.apache.samza.table: A table that supports asynchronous get, put, update and delete by one or more keys
AsyncStreamTask - Interface in org.apache.samza.task: An AsyncStreamTask is the basic class to support multithreading execution in Samza container.
AsyncStreamTaskFactory - Interface in org.apache.samza.task: Build AsyncStreamTask instances.

B

BaseMessageChooser - Class in org.apache.samza.system.chooser: An abstract MessageChooser that implements start/stop/register for choosers that don't use them.
BaseMessageChooser() - Constructor for class org.apache.samza.system.chooser.BaseMessageChooser
BaseTableDescriptor<K,V,D extends BaseTableDescriptor<K,V,D>> - Class in org.apache.samza.table.descriptors: Base class for all table descriptor implementations.
BaseTableDescriptor(String) - Constructor for class org.apache.samza.table.descriptors.BaseTableDescriptor: Constructs a table descriptor instance
BaseTableFunction - Class in org.apache.samza.table.remote: Base class for all table read and write functions.
BaseTableFunction() - Constructor for class org.apache.samza.table.remote.BaseTableFunction
Batch<K,V,U> - Interface in org.apache.samza.table.batching: Manages a sequence of Operations, which will be performed as a batch.
BATCH_PROVIDER - Static variable in class org.apache.samza.table.descriptors.RemoteTableDescriptor
BatchProvider<K,V,U> - Class in org.apache.samza.table.batching
BatchProvider() - Constructor for class org.apache.samza.table.batching.BatchProvider
beforeCheckpoint(Map<SystemStreamPartition, String>) - Method in interface org.apache.samza.checkpoint.CheckpointListener: Called before writing the checkpoint for each Task in the Container processing SSPs on this system.
beforeStart() - Method in interface org.apache.samza.runtime.ProcessorLifecycleListener: User defined initialization before a StreamProcessor is started
BlobStoreAdminFactory - Interface in org.apache.samza.storage: Factory to create instance of StateBackendAdmins that needs to be implemented for every state backend
BlobStoreManager - Interface in org.apache.samza.storage.blobstore: Provides interface for common blob store operations: GET, PUT and DELETE
BlobStoreManagerFactory - Interface in org.apache.samza.storage.blobstore
BLOCK_ON_OUTSTANDING_MESSAGES - Static variable in interface org.apache.samza.system.SystemConsumer: A constant that can be used in the poll method's timeout parameter to denote that the poll invocation should block until at least one message is available for one of the SystemStreamPartitions supplied, or until all SystemStreamPartitions supplied are at head (have no new messages available since the last poll invocation was made for each SystemStreamPartition).
BlockingEnvelopeMap - Class in org.apache.samza.util: BlockingEnvelopeMap is a helper class for SystemConsumer implementations.
BlockingEnvelopeMap() - Constructor for class org.apache.samza.util.BlockingEnvelopeMap
BlockingEnvelopeMap(MetricsRegistry) - Constructor for class org.apache.samza.util.BlockingEnvelopeMap
BlockingEnvelopeMap(MetricsRegistry, Clock) - Constructor for class org.apache.samza.util.BlockingEnvelopeMap
BlockingEnvelopeMap(MetricsRegistry, Clock, String) - Constructor for class org.apache.samza.util.BlockingEnvelopeMap
BlockingEnvelopeMap.BlockingEnvelopeMapMetrics - Class in org.apache.samza.util
BlockingEnvelopeMap.BufferGauge - Class in org.apache.samza.util
BlockingEnvelopeMap.BufferSizeGauge - Class in org.apache.samza.util
BlockingEnvelopeMapMetrics(String, MetricsRegistry) - Constructor for class org.apache.samza.util.BlockingEnvelopeMap.BlockingEnvelopeMapMetrics
BoundedSSPIterator - Class in org.apache.samza.system: Iterates over messages in the provided SystemStreamPartition using the provided SystemConsumer until all messages with offsets up to and including the endOffset have been consumed.
BoundedSSPIterator(SystemConsumer, SystemStreamPartition, String, SystemAdmin) - Constructor for class org.apache.samza.system.BoundedSSPIterator
broadcast(Serde<M>, String) - Method in interface org.apache.samza.operators.MessageStream: Broadcasts messages in this MessageStream to all instances of its downstream operators..
BufferGauge(SystemStreamPartition, String) - Constructor for class org.apache.samza.util.BlockingEnvelopeMap.BufferGauge
BufferSizeGauge(SystemStreamPartition, String) - Constructor for class org.apache.samza.util.BlockingEnvelopeMap.BufferSizeGauge
build(JobRestartSignalFactoryContext) - Method in interface org.apache.samza.coordinator.lifecycle.JobRestartSignalFactory
build() - Method in class org.apache.samza.sql.schema.SqlSchemaBuilder
build() - Method in class org.apache.samza.storage.StoreProperties.StorePropertiesBuilder
buildCommand() - Method in class org.apache.samza.job.CommandBuilder
buildDrainMessage(SystemStreamPartition, String) - Static method in class org.apache.samza.system.IncomingMessageEnvelope
buildEndOfStreamEnvelope(SystemStreamPartition) - Static method in class org.apache.samza.system.IncomingMessageEnvelope: This method is deprecated in favor of WatermarkManager.buildEndOfStreamEnvelope(SystemStreamPartition ssp).
buildEnvironment() - Method in class org.apache.samza.job.CommandBuilder
builder() - Static method in class org.apache.samza.sql.schema.SqlSchemaBuilder
buildKey(String, String) - Static method in class org.apache.samza.config.JavaTableConfig: Build complete config key for a config item
buildWatermarkEnvelope(SystemStreamPartition, long) - Static method in class org.apache.samza.system.IncomingMessageEnvelope
ByteBufferSerde - Class in org.apache.samza.serializers: A serializer for ByteBuffers.
ByteBufferSerde() - Constructor for class org.apache.samza.serializers.ByteBufferSerde
ByteBufferSerdeFactory - Class in org.apache.samza.serializers
ByteBufferSerdeFactory() - Constructor for class org.apache.samza.serializers.ByteBufferSerdeFactory
ByteSerde - Class in org.apache.samza.serializers: A serializer for bytes that is effectively a pass-through, but can be useful for binary messages.
ByteSerde() - Constructor for class org.apache.samza.serializers.ByteSerde
ByteSerdeFactory - Class in org.apache.samza.serializers
ByteSerdeFactory() - Constructor for class org.apache.samza.serializers.ByteSerdeFactory

C

CACHE_SIZE - Static variable in class org.apache.samza.table.descriptors.CachingTableDescriptor
CACHE_TABLE_ID - Static variable in class org.apache.samza.table.descriptors.CachingTableDescriptor
CachingTableDescriptor<K,V> - Class in org.apache.samza.table.descriptors: Table descriptor for a caching table.
CachingTableDescriptor(String, TableDescriptor<K, V, ?>) - Constructor for class org.apache.samza.table.descriptors.CachingTableDescriptor: Constructs a table descriptor instance with internal cache
CachingTableDescriptor(String, TableDescriptor<K, V, ?>, TableDescriptor<K, V, ?>) - Constructor for class org.apache.samza.table.descriptors.CachingTableDescriptor: Constructs a table descriptor instance and specify a cache (as Table descriptor) to be used for caching.
CallbackScheduler - Interface in org.apache.samza.scheduler: Provides a way for applications to register some logic to be executed at a future time.
changelogReplicationFactor - Variable in class org.apache.samza.table.descriptors.LocalTableDescriptor
ChangelogSSPIterator - Class in org.apache.samza.system: Iterates over messages in the provided changelog SystemStreamPartition using the provided SystemConsumer until all messages have been consumed.
ChangelogSSPIterator(SystemConsumer, SystemStreamPartition, String, SystemAdmin, boolean) - Constructor for class org.apache.samza.system.ChangelogSSPIterator
ChangelogSSPIterator(SystemConsumer, SystemStreamPartition, String, SystemAdmin, boolean, String) - Constructor for class org.apache.samza.system.ChangelogSSPIterator
ChangelogSSPIterator.Mode - Enum in org.apache.samza.system
changelogStream - Variable in class org.apache.samza.table.descriptors.LocalTableDescriptor
Checkpoint - Interface in org.apache.samza.checkpoint
checkpoint(CheckpointId) - Method in interface org.apache.samza.storage.kv.KeyValueStore: Create a persistent checkpoint / snapshot of the current store state and return it's path.
checkpoint(CheckpointId) - Method in interface org.apache.samza.storage.StorageEngine: Checkpoint store snapshots.
CHECKPOINT_VERSION - Static variable in class org.apache.samza.checkpoint.CheckpointV1
CHECKPOINT_VERSION - Static variable in class org.apache.samza.checkpoint.CheckpointV2
CheckpointId - Class in org.apache.samza.checkpoint: Checkpoint ID has the format: [currentTimeMillis, last 6 digits of nanotime], separated by a dash.
CheckpointListener - Interface in org.apache.samza.checkpoint: SystemConsumers that want to be notified about checkpoints for their SSPs and potentially modify them may implement this interface.
CheckpointManager - Interface in org.apache.samza.checkpoint: CheckpointManagers read and write Checkpoint to some implementation-specific location.
CheckpointManagerFactory - Interface in org.apache.samza.checkpoint: Build a CheckpointManager.
CheckpointV1 - Class in org.apache.samza.checkpoint: A checkpoint is a mapping of all the streams a job is consuming and the most recent current offset for each.
CheckpointV1(Map<SystemStreamPartition, String>) - Constructor for class org.apache.samza.checkpoint.CheckpointV1: Constructs a new checkpoint based off a map of Samza stream offsets.
CheckpointV2 - Class in org.apache.samza.checkpoint: A checkpoint is a mapping of all the streams a job is consuming and the most recent current offset for each.
CheckpointV2(CheckpointId, Map<SystemStreamPartition, String>, Map<String, Map<String, String>>) - Constructor for class org.apache.samza.checkpoint.CheckpointV2: Constructs the checkpoint with separated input and state offsets
choose() - Method in interface org.apache.samza.system.chooser.MessageChooser: The choose method is invoked when the SamzaContainer is ready to process a new message.
cleanUp(CheckpointId, Map<String, String>) - Method in interface org.apache.samza.storage.TaskBackupManager: Cleanup any local or remote state for checkpoint information that is older than the provided checkpointId This operation is required to be idempotent.
clear() - Method in class org.apache.samza.config.Config
clear() - Method in class org.apache.samza.metrics.Counter
clearCheckpoints() - Method in interface org.apache.samza.checkpoint.CheckpointManager: Clear the checkpoints in the checkpoint stream.
clearStream(StreamSpec) - Method in interface org.apache.samza.system.SystemAdmin: Clear the entire stream described by the spec.
Clock - Interface in org.apache.samza.util: An object that can provide time points (useful for getting the elapsed time between two time points).
ClosableFunction - Interface in org.apache.samza.operators.functions: A function that can be closed after its execution.
ClosableIterator<V> - Interface in org.apache.samza.storage.kv: An iterator that must be closed.
ClosableTask - Interface in org.apache.samza.task: Deprecated.
close() - Method in class org.apache.samza.metadatastore.InMemoryMetadataStore
close() - Method in interface org.apache.samza.metadatastore.MetadataStore: Closes the metadata store, if applicable, relinquishing all the underlying resources and connections.
close() - Method in interface org.apache.samza.operators.functions.ClosableFunction: Frees any resource acquired by the operators in InitableFunction
close() - Method in interface org.apache.samza.storage.blobstore.BlobStoreManager: Cleanly close resources like blob store client
close() - Method in interface org.apache.samza.storage.kv.ClosableIterator: Closes this iterator and frees resources assigned to it.
close() - Method in interface org.apache.samza.storage.kv.KeyValueIterator
close() - Method in interface org.apache.samza.storage.kv.KeyValueSnapshot: Closes this snapshot releasing any associated resources.
close() - Method in interface org.apache.samza.storage.kv.KeyValueStore: Closes this key-value store, if applicable, relinquishing any underlying resources.
close() - Method in interface org.apache.samza.storage.TaskBackupManager: Shutdown hook the backup manager to cleanup any allocated resources
close() - Method in interface org.apache.samza.storage.TaskRestoreManager: Closes all initiated resources include storage engines
close() - Method in interface org.apache.samza.table.AsyncReadWriteUpdateTable: Close the table and release any resources acquired
close() - Method in interface org.apache.samza.table.batching.Batch: Close the bach so that it will not accept more operations.
close() - Method in interface org.apache.samza.table.TableProvider: Shutdown the underlying table
close() - Method in interface org.apache.samza.task.ClosableTask: Deprecated.
CommandBuilder - Class in org.apache.samza.job: CommandBuilders are used to customize the command necessary to launch a Samza Job for a particular framework, such as YARN or the LocalJobRunner.
CommandBuilder() - Constructor for class org.apache.samza.job.CommandBuilder
commandPath - Variable in class org.apache.samza.job.CommandBuilder
commit(TaskCoordinator.RequestScope) - Method in interface org.apache.samza.task.TaskCoordinator: Requests that Samza should write out a checkpoint, from which a task can restart after failure.
compareAndSet(T, T) - Method in class org.apache.samza.metrics.Gauge
compareTo(CheckpointId) - Method in class org.apache.samza.checkpoint.CheckpointId
compareTo(TaskName) - Method in class org.apache.samza.container.TaskName
compareTo(TaskModel) - Method in class org.apache.samza.job.model.TaskModel
compareTo(Partition) - Method in class org.apache.samza.Partition
compareTo(SystemStreamPartition) - Method in class org.apache.samza.system.SystemStreamPartition
complete() - Method in interface org.apache.samza.metrics.MetricsValidator: Complete validation.
complete() - Method in interface org.apache.samza.table.batching.Batch: Change the batch status to be complete.
complete() - Method in interface org.apache.samza.task.TaskCallback: Invoke when the asynchronous process completed with success.
completeExceptionally(Throwable) - Method in interface org.apache.samza.table.batching.Batch: Change the batch status to be complete with exception.
Config - Class in org.apache.samza.config: Store and retrieve named, typed values as configuration for classes implementing this interface.
Config() - Constructor for class org.apache.samza.config.Config
config - Variable in class org.apache.samza.job.CommandBuilder
config - Variable in class org.apache.samza.table.descriptors.BaseTableDescriptor
CONFIG_LOADER_PROPERTIES_PREFIX - Static variable in interface org.apache.samza.config.ConfigLoaderFactory: job.config.loader.properties prefix wraps properties needed for ConfigLoader to loader config.
ConfigException - Exception in org.apache.samza.config: Specific SamzaExceptions thrown from Config
ConfigException(Throwable) - Constructor for exception org.apache.samza.config.ConfigException
ConfigException(String) - Constructor for exception org.apache.samza.config.ConfigException
ConfigException(String, Throwable) - Constructor for exception org.apache.samza.config.ConfigException
ConfigFactory - Interface in org.apache.samza.config: Build a Config
ConfigLoader - Interface in org.apache.samza.config: The primary means of fetching full job Config on LocalApplicationRunner and ClusterBasedJobCoordinator during start up.
ConfigLoaderFactory - Interface in org.apache.samza.config: The factory for an ConfigLoader instance to load full job config.
ConfigRewriter - Interface in org.apache.samza.config: A ConfigRewriter receives the job's config during job startup and may re-write it to provide new configs, remove existing configs or audit and verify the config is correct or permitted.
ContainerContext - Interface in org.apache.samza.context: The framework-provided context for the current container.
ContainerModel - Class in org.apache.samza.job.model: This contains metadata about a Samza container, such as which tasks a Samza container should process.
ContainerModel(String, Map<TaskName, TaskModel>) - Constructor for class org.apache.samza.job.model.ContainerModel
ContainerPlacementMessage - Class in org.apache.samza.container.placement: Encapsulates the request or response payload information between the ContainerPlacementService and external controllers issuing placement actions
ContainerPlacementMessage(UUID, String, String, String, Duration, ContainerPlacementMessage.StatusCode, long) - Constructor for class org.apache.samza.container.placement.ContainerPlacementMessage
ContainerPlacementMessage(UUID, String, String, String, ContainerPlacementMessage.StatusCode, long) - Constructor for class org.apache.samza.container.placement.ContainerPlacementMessage
ContainerPlacementMessage.StatusCode - Enum in org.apache.samza.container.placement
ContainerPlacementRequestMessage - Class in org.apache.samza.container.placement: Encapsulates the request sent from the external controller to the JobCoordinator to take a container placement action
ContainerPlacementRequestMessage(UUID, String, String, String, Duration, long) - Constructor for class org.apache.samza.container.placement.ContainerPlacementRequestMessage
ContainerPlacementRequestMessage(UUID, String, String, String, long) - Constructor for class org.apache.samza.container.placement.ContainerPlacementRequestMessage
ContainerPlacementResponseMessage - Class in org.apache.samza.container.placement: Encapsulates the value for the response sent from the JobCoordinator for a container placement action
ContainerPlacementResponseMessage(UUID, String, String, String, Duration, ContainerPlacementMessage.StatusCode, String, long) - Constructor for class org.apache.samza.container.placement.ContainerPlacementResponseMessage
ContainerPlacementResponseMessage(UUID, String, String, String, ContainerPlacementMessage.StatusCode, String, long) - Constructor for class org.apache.samza.container.placement.ContainerPlacementResponseMessage
containsField(String) - Method in class org.apache.samza.sql.SamzaSqlRelRecord
containsField(String) - Method in class org.apache.samza.sql.schema.SqlSchema
containsKey(Object) - Method in class org.apache.samza.config.MapConfig
containsValue(Object) - Method in class org.apache.samza.config.MapConfig
Context - Interface in org.apache.samza.context: A holder for all framework and application defined contexts at runtime.
ControlMessage - Class in org.apache.samza.system: The abstract class of all control messages, containing the task that produces the control message, the total number of producer tasks, and a version number.
ControlMessage(String) - Constructor for class org.apache.samza.system.ControlMessage
copyWithPartitionCount(int) - Method in class org.apache.samza.system.StreamSpec: Copies this StreamSpec, but applies a new partitionCount.
copyWithPhysicalName(String) - Method in class org.apache.samza.system.StreamSpec
count(long) - Static method in class org.apache.samza.operators.triggers.Triggers: Creates a Trigger that fires when the number of messages in the pane reaches the specified count.
Counter - Class in org.apache.samza.metrics: A counter is a Metric that represents a cumulative value.
Counter(String) - Constructor for class org.apache.samza.metrics.Counter
counter(Counter) - Method in class org.apache.samza.metrics.MetricsVisitor
CountTrigger<M> - Class in org.apache.samza.operators.triggers: A Trigger that fires when the number of messages in the WindowPane reaches the specified count.
create() - Static method in class org.apache.samza.checkpoint.CheckpointId
create(ExternalContext, JobContext, ContainerContext) - Method in interface org.apache.samza.context.ApplicationContainerContextFactory: Creates an instance of the application-defined ApplicationContainerContext.
create(JobContext, ContainerContext) - Method in interface org.apache.samza.context.ApplicationContainerContextFactory: Deprecated.
create(ExternalContext, JobContext, ContainerContext, TaskContext, ApplicationContainerContext) - Method in interface org.apache.samza.context.ApplicationTaskContextFactory: Creates an instance of the application-defined ApplicationTaskContext.
create(JobContext, ContainerContext, TaskContext, ApplicationContainerContext) - Method in interface org.apache.samza.context.ApplicationTaskContextFactory: Deprecated.
create(UUID, String) - Static method in class org.apache.samza.drain.DrainNotification: Creates a DrainNotification in DrainMode.DEFAULT mode.
createArraySchema(SqlFieldSchema, boolean, boolean) - Static method in class org.apache.samza.sql.schema.SqlFieldSchema
createChangeLogStreamSpec(String, String, int) - Static method in class org.apache.samza.system.StreamSpec
createCheckpointStreamSpec(String, String) - Static method in class org.apache.samza.system.StreamSpec
createCoordinatorStreamSpec(String, String) - Static method in class org.apache.samza.system.StreamSpec
createInstance(ProcessorContext, Config) - Method in interface org.apache.samza.runtime.ProcessorLifecycleListenerFactory: Create an instance of ProcessorLifecycleListener for the StreamProcessor
createInstance() - Method in interface org.apache.samza.task.TaskFactory: Create instance of task
createMapSchema(SqlFieldSchema, boolean, boolean) - Static method in class org.apache.samza.sql.schema.SqlFieldSchema
createPrimitiveSchema(SamzaSqlFieldType, boolean, boolean) - Static method in class org.apache.samza.sql.schema.SqlFieldSchema: Create a primitive field schema.
createResources() - Method in interface org.apache.samza.checkpoint.CheckpointManager: Creates checkpoint stream.
createResources() - Method in interface org.apache.samza.storage.StateBackendAdmin: Create all the resources required per job per store state backend
createRowFieldSchema(SqlSchema, boolean, boolean) - Static method in class org.apache.samza.sql.schema.SqlFieldSchema
createStream(StreamSpec) - Method in interface org.apache.samza.system.SystemAdmin: Create a stream described by the spec.
createStreamAppenderStreamSpec(String, String, int) - Static method in class org.apache.samza.system.StreamSpec
currentTimeMillis() - Method in interface org.apache.samza.util.Clock: Returns a time point that can be used to calculate the difference in milliseconds with another time point.

D

dec() - Method in class org.apache.samza.metrics.Counter
dec(long) - Method in class org.apache.samza.metrics.Counter
DEFAULT_RATE_LIMITER_CLASS_NAME - Static variable in class org.apache.samza.table.descriptors.RemoteTableDescriptor
delete(String) - Method in class org.apache.samza.metadatastore.InMemoryMetadataStore
delete(String) - Method in interface org.apache.samza.metadatastore.MetadataStore: Deletes the mapping for the specified key from this metadata store (if such mapping exists).
delete(K) - Method in interface org.apache.samza.operators.Scheduler: Delete the scheduled callback for the provided key.
delete(String, Metadata) - Method in interface org.apache.samza.storage.blobstore.BlobStoreManager: Non-blocking call to mark a blob for deletion in the remote blob store
delete(K) - Method in interface org.apache.samza.storage.kv.KeyValueStore: Deletes the mapping for the specified key from this key-value store (if such mapping exists).
delete(K, Object...) - Method in interface org.apache.samza.table.ReadWriteTable: Deletes the mapping for the specified key from this table (if such mapping exists).
delete(K, Object...) - Method in interface org.apache.samza.table.ReadWriteUpdateTable: Deletes the mapping for the specified key from this table (if such mapping exists).
delete(K) - Method in interface org.apache.samza.table.remote.TableWriteFunction: Delete the record with specified key from the remote store.
deleteAll(List<K>) - Method in interface org.apache.samza.storage.kv.KeyValueStore: Deletes the mappings for the specified keys from this key-value store (if such mappings exist).
deleteAll(List<K>, Object...) - Method in interface org.apache.samza.table.ReadWriteTable: Deletes the mappings for the specified keys from this table.
deleteAll(List<K>, Object...) - Method in interface org.apache.samza.table.ReadWriteUpdateTable: Deletes the mappings for the specified keys from this table.
deleteAll(Collection<K>) - Method in interface org.apache.samza.table.remote.TableWriteFunction: Delete all records with the specified keys from the remote store The default implementation calls deleteAllAsync and blocks on the completion afterwards.
deleteAllAsync(List<K>, Object...) - Method in interface org.apache.samza.table.AsyncReadWriteUpdateTable: Asynchronously deletes the mappings for the specified keys from this table.
deleteAllAsync(Collection<K>) - Method in interface org.apache.samza.table.remote.TableWriteFunction: Asynchronously delete all records with the specified keys from the remote store.
deleteAllAsync(Collection<K>, Object...) - Method in interface org.apache.samza.table.remote.TableWriteFunction: Asynchronously delete all records with the specified keys and additional arguments from the remote store.
deleteAsync(K, Object...) - Method in interface org.apache.samza.table.AsyncReadWriteUpdateTable: Asynchronously deletes the mapping for the specified key from this table (if such mapping exists).
deleteAsync(K) - Method in interface org.apache.samza.table.remote.TableWriteFunction: Asynchronously delete the record with specified key from the remote store
deleteAsync(K, Object...) - Method in interface org.apache.samza.table.remote.TableWriteFunction: Asynchronously delete the record with specified key and additional arguments from the remote store
deleteCallback(K) - Method in interface org.apache.samza.scheduler.CallbackScheduler: Delete the scheduled callback for the key.
DeletedException - Exception in org.apache.samza.storage.blobstore.exceptions: Future should complete with this exception to indicate that the exception occurred due to the request for an already deleted blob.
DeletedException(String, Throwable) - Constructor for exception org.apache.samza.storage.blobstore.exceptions.DeletedException
DeletedException(String) - Constructor for exception org.apache.samza.storage.blobstore.exceptions.DeletedException
DeletedException(Throwable) - Constructor for exception org.apache.samza.storage.blobstore.exceptions.DeletedException
DeletedException() - Constructor for exception org.apache.samza.storage.blobstore.exceptions.DeletedException
deleteMessages(Map<SystemStreamPartition, String>) - Method in interface org.apache.samza.system.SystemAdmin: Delete records up to (and including) the provided ssp offsets for all system stream partitions specified in the map
deploymentId - Variable in class org.apache.samza.container.placement.ContainerPlacementMessage: Unique identifier for a deployment so messages can be invalidated across a job restarts for ex yarn bases cluster manager can be set to app attempt id
describe(S) - Method in interface org.apache.samza.application.SamzaApplication: Describes the inputs, outputs, state, configuration and processing logic using the provided appDescriptor.
deserialize(String) - Static method in class org.apache.samza.checkpoint.CheckpointId
deserialize(String, String) - Static method in class org.apache.samza.table.utils.SerdeUtils: Helper method to deserialize Java objects from Base64 strings
Deserializer<T> - Interface in org.apache.samza.serializers: A standard interface for Samza compatible deserializers, used for deserializing serialized objects back to their original form.
destinationHost - Variable in class org.apache.samza.container.placement.ContainerPlacementMessage
DoubleSerde - Class in org.apache.samza.serializers: A serializer for doubles
DoubleSerde() - Constructor for class org.apache.samza.serializers.DoubleSerde
DoubleSerdeFactory - Class in org.apache.samza.serializers
DoubleSerdeFactory() - Constructor for class org.apache.samza.serializers.DoubleSerdeFactory
DrainListenerTask - Interface in org.apache.samza.task: The DrainListenerTask augments StreamTask allowing the method implementor to specify code to be executed when the 'drain' is reached for a task.
DrainMessage - Class in org.apache.samza.system: The DrainMessage is a control message that is sent out to next stage once the task has consumed to the end of a bounded stream.
DrainMessage(String) - Constructor for class org.apache.samza.system.DrainMessage
DrainMessage(String, String) - Constructor for class org.apache.samza.system.DrainMessage
DrainMode - Enum in org.apache.samza.drain: Defines the type of drain operation.
DrainNotification - Class in org.apache.samza.drain: DrainNotification is a custom message used by an external controller to trigger Drain.
DrainNotification(UUID, String, DrainMode) - Constructor for class org.apache.samza.drain.DrainNotification
DurationCharacteristic - Enum in org.apache.samza.operators.triggers: Indicates whether the associated time duration is in event time or processing time.

E

enableChangelog - Variable in class org.apache.samza.table.descriptors.LocalTableDescriptor
END_OF_STREAM_OFFSET - Static variable in class org.apache.samza.system.IncomingMessageEnvelope
EndOfStreamListenerTask - Interface in org.apache.samza.task: The EndOfStreamListenerTask augments StreamTask allowing the method implementor to specify code to be executed when the 'end-of-stream' is reached for all input SSPs.
EndOfStreamMessage - Class in org.apache.samza.system: The EndOfStreamMessage is a control message that is sent out to next stage once the task has consumed to the end of a bounded stream.
EndOfStreamMessage() - Constructor for class org.apache.samza.system.EndOfStreamMessage
EndOfStreamMessage(String) - Constructor for class org.apache.samza.system.EndOfStreamMessage
Entry<K,V> - Class in org.apache.samza.storage.kv: A key and value.
Entry(K, V) - Constructor for class org.apache.samza.storage.kv.Entry
entrySet() - Method in class org.apache.samza.config.MapConfig
equals(Object) - Method in class org.apache.samza.checkpoint.CheckpointId
equals(Object) - Method in class org.apache.samza.checkpoint.CheckpointV1
equals(Object) - Method in class org.apache.samza.checkpoint.CheckpointV2
equals(Object) - Method in class org.apache.samza.config.MapConfig
equals(Object) - Method in class org.apache.samza.container.placement.ContainerPlacementMessage
equals(Object) - Method in class org.apache.samza.container.placement.ContainerPlacementResponseMessage
equals(Object) - Method in class org.apache.samza.container.TaskName
equals(Object) - Method in class org.apache.samza.drain.DrainNotification
equals(Object) - Method in class org.apache.samza.job.ApplicationStatus
equals(Object) - Method in class org.apache.samza.job.JobCoordinatorMetadata
equals(Object) - Method in class org.apache.samza.job.model.ContainerModel
equals(Object) - Method in class org.apache.samza.job.model.JobModel
equals(Object) - Method in class org.apache.samza.job.model.LocalityModel
equals(Object) - Method in class org.apache.samza.job.model.ProcessorLocality
equals(Object) - Method in class org.apache.samza.job.model.TaskModel
equals(Object) - Method in class org.apache.samza.operators.KV
equals(Object) - Method in class org.apache.samza.operators.UpdateMessage
equals(Object) - Method in class org.apache.samza.operators.windows.WindowKey
equals(Object) - Method in class org.apache.samza.Partition
equals(Object) - Method in class org.apache.samza.runtime.LocationId
equals(Object) - Method in class org.apache.samza.sql.SamzaSqlRelRecord
equals(Object) - Method in class org.apache.samza.startpoint.Startpoint
equals(Object) - Method in class org.apache.samza.startpoint.StartpointSpecific
equals(Object) - Method in class org.apache.samza.startpoint.StartpointTimestamp
equals(Object) - Method in class org.apache.samza.storage.blobstore.Metadata
equals(Object) - Method in class org.apache.samza.system.ControlMessage
equals(Object) - Method in class org.apache.samza.system.DrainMessage
equals(Object) - Method in class org.apache.samza.system.IncomingMessageEnvelope
equals(Object) - Method in class org.apache.samza.system.OutgoingMessageEnvelope
equals(Object) - Method in class org.apache.samza.system.StreamSpec
equals(Object) - Method in class org.apache.samza.system.SystemStream
equals(Object) - Method in class org.apache.samza.system.SystemStreamMetadata
equals(Object) - Method in class org.apache.samza.system.SystemStreamMetadata.SystemStreamPartitionMetadata
equals(Object) - Method in class org.apache.samza.system.SystemStreamPartition
equals(Object) - Method in class org.apache.samza.system.WatermarkMessage
equals(Object) - Method in class org.apache.samza.util.TimestampedValue
ExpandingInputDescriptorProvider<StreamExpanderType> - Interface in org.apache.samza.system.descriptors: Interface for advanced SystemDescriptors that constrain the type of returned InputDescriptors to their own StreamExpander function result types.
ExternalContext - Interface in org.apache.samza.context: An ExternalContext can be used to pass components created and managed outside of Samza into a Samza application.

F

failure(Throwable) - Method in interface org.apache.samza.task.TaskCallback: Invoke when the asynchronous process failed with an error.
filter(FilterFunction<? super M>) - Method in interface org.apache.samza.operators.MessageStream: Applies the provided function to messages in this MessageStream and returns the filtered MessageStream.
filter(Set<SystemStreamPartition>, Config) - Method in interface org.apache.samza.system.SystemStreamPartitionMatcher
FilterFunction<M> - Interface in org.apache.samza.operators.functions: Specifies whether a message should be retained for further processing.
FiringType - Enum in org.apache.samza.operators.triggers: The type of the Trigger firing.
flatMap(FlatMapFunction<? super M, ? extends OM>) - Method in interface org.apache.samza.operators.MessageStream: Applies the provided 1:n function to transform a message in this MessageStream to n messages in the transformed MessageStream
flatMapAsync(AsyncFlatMapFunction<? super M, ? extends OM>) - Method in interface org.apache.samza.operators.MessageStream: Applies the provided 1:n transformation asynchronously to this MessageStream.
FlatMapFunction<M,OM> - Interface in org.apache.samza.operators.functions: Transforms an input message into a collection of 0 or more messages, possibly of a different type.
flush() - Method in class org.apache.samza.metadatastore.InMemoryMetadataStore
flush() - Method in interface org.apache.samza.metadatastore.MetadataStore: Flushes the metadata store, if applicable.
flush() - Method in interface org.apache.samza.storage.kv.KeyValueStore: Flushes this key-value store, if applicable.
flush() - Method in interface org.apache.samza.storage.StorageEngine: Flush any cached messages
flush(String) - Method in interface org.apache.samza.system.SystemProducer: If the SystemProducer buffers messages before sending them to its underlying system, it should flush those messages and leave no messages remaining to be sent.
flush() - Method in interface org.apache.samza.table.AsyncReadWriteUpdateTable: Flushes the underlying store of this table, if applicable.
flush() - Method in interface org.apache.samza.table.remote.TableWriteFunction: Flush the remote store (optional)
FoldLeftFunction<M,WV> - Interface in org.apache.samza.operators.functions: Incrementally updates the aggregated value as messages are added.
fromBytes(byte[]) - Method in class org.apache.samza.serializers.ByteBufferSerde
fromBytes(byte[]) - Method in class org.apache.samza.serializers.ByteSerde
fromBytes(byte[]) - Method in interface org.apache.samza.serializers.Deserializer: Deserializes given serialized object from an array of bytes to its original form.
fromBytes(byte[]) - Method in class org.apache.samza.serializers.DoubleSerde
fromBytes(byte[]) - Method in class org.apache.samza.serializers.IntegerSerde
fromBytes(byte[]) - Method in class org.apache.samza.serializers.JsonSerdeV2
fromBytes(byte[]) - Method in class org.apache.samza.serializers.KVSerde
fromBytes(byte[]) - Method in class org.apache.samza.serializers.LongSerde
fromBytes(byte[]) - Method in class org.apache.samza.serializers.NoOpSerde
fromBytes(byte[]) - Method in class org.apache.samza.serializers.SerializableSerde
fromBytes(byte[]) - Method in class org.apache.samza.serializers.StringSerde
fromBytes(byte[]) - Method in class org.apache.samza.serializers.UUIDSerde
fromContainerPlacementRequestMessage(ContainerPlacementRequestMessage, ContainerPlacementMessage.StatusCode, String, long) - Static method in class org.apache.samza.container.placement.ContainerPlacementResponseMessage: Creates a ContainerPlacementResponseMessage using ContainerPlacementRequestMessage status of current request and response associated with status

G

Gauge<T> - Class in org.apache.samza.metrics: A Gauge is a Metric that wraps some instance of T in a thread-safe reference and allows it to be set or retrieved.
Gauge(String, T) - Constructor for class org.apache.samza.metrics.Gauge
gauge(Gauge<T>) - Method in class org.apache.samza.metrics.MetricsVisitor
generateProcessorId(Config) - Method in interface org.apache.samza.runtime.ProcessorIdGenerator: Generates a String representation to identify a single instance of StreamProcessor.
GenericInputDescriptor<StreamMessageType> - Class in org.apache.samza.system.descriptors: A GenericInputDescriptor can be used for specifying Samza and system-specific properties of input streams.
GenericOutputDescriptor<StreamMessageType> - Class in org.apache.samza.system.descriptors: A GenericOutputDescriptor can be used for specifying Samza and system-specific properties of output streams.
GenericSystemDescriptor - Class in org.apache.samza.system.descriptors: A GenericSystemDescriptor can be used for specifying Samza and system-specific properties of an input/output system.
GenericSystemDescriptor(String, String) - Constructor for class org.apache.samza.system.descriptors.GenericSystemDescriptor: Constructs a GenericSystemDescriptor instance with no system level serde.
get(String, String) - Method in class org.apache.samza.config.Config
get(Object) - Method in class org.apache.samza.config.MapConfig
get(String) - Method in class org.apache.samza.metadatastore.InMemoryMetadataStore
get(String) - Method in interface org.apache.samza.metadatastore.MetadataStore: Gets the value associated with the specified key.
get() - Method in interface org.apache.samza.operators.functions.SupplierFunction: Returns a value of type T
get(String, OutputStream, Metadata) - Method in interface org.apache.samza.storage.blobstore.BlobStoreManager: Non-blocking GET call to remote blob store
get(K) - Method in interface org.apache.samza.storage.kv.KeyValueStore: Gets the value associated with the specified key.
get(String) - Method in class org.apache.samza.system.StreamSpec
get(K, Object...) - Method in interface org.apache.samza.table.ReadWriteTable: Gets the value associated with the specified key.
get(K, Object...) - Method in interface org.apache.samza.table.ReadWriteUpdateTable: Gets the value associated with the specified key.
get(K) - Method in interface org.apache.samza.table.remote.TableReadFunction: Fetch single table record for a specified key.
getAccumulationMode() - Method in class org.apache.samza.operators.windows.internal.WindowInternal
getAdmin(JobModel, Config) - Method in interface org.apache.samza.storage.StateBackendFactory
getAdmin(String, Config) - Method in interface org.apache.samza.system.SystemFactory: Deprecated.
getAdmin(String, Config, String) - Method in interface org.apache.samza.system.SystemFactory: This function provides an extra input parameter to SystemFactory.getAdmin(java.lang.String, org.apache.samza.config.Config), which can be used to provide extra information for the admin instance, e.g.
getAll(List<K>) - Method in interface org.apache.samza.storage.kv.KeyValueStore: Gets the values with which the specified keys are associated.
getAll(List<K>, Object...) - Method in interface org.apache.samza.table.ReadWriteTable: Gets the values with which the specified keys are associated.
getAll(List<K>, Object...) - Method in interface org.apache.samza.table.ReadWriteUpdateTable: Gets the values with which the specified keys are associated.
getAll(Collection<K>) - Method in interface org.apache.samza.table.remote.TableReadFunction: Fetch the table records for specified keys.
getAllAsync(List<K>, Object...) - Method in interface org.apache.samza.table.AsyncReadWriteUpdateTable: Asynchronously gets the values with which the specified keys are associated.
getAllAsync(Collection<K>) - Method in interface org.apache.samza.table.remote.TableReadFunction: Asynchronously fetch the table records for specified keys.
getAllAsync(Collection<K>, Object...) - Method in interface org.apache.samza.table.remote.TableReadFunction: Asynchronously fetch the table records for specified keys and additional arguments.
getAllSystemStreams() - Method in interface org.apache.samza.system.SystemAdmin: Fetch the set of all available streams
getApplicationContainerContext() - Method in interface org.apache.samza.context.Context: Gets the application-defined context for the current container.
getApplicationTaskContext() - Method in interface org.apache.samza.context.Context: Gets the application-defined task context for the current task.
getArgs() - Method in interface org.apache.samza.table.batching.Operation
getArrivalTime() - Method in class org.apache.samza.system.IncomingMessageEnvelope: Getter for arrival time
getAsync(K, Object...) - Method in interface org.apache.samza.table.AsyncReadWriteUpdateTable: Asynchronously gets the value associated with the specified key.
getAsync(K) - Method in interface org.apache.samza.table.remote.TableReadFunction: Asynchronously fetch single table record for a specified key.
getAsync(K, Object...) - Method in interface org.apache.samza.table.remote.TableReadFunction: Asynchronously fetch single table record for a specified key with additional arguments.
getAverage() - Method in class org.apache.samza.metrics.Snapshot: Get the average of the values in the collection
getBackoffType() - Method in class org.apache.samza.table.retry.TableRetryPolicy
getBackupBlobStoreManager(Config, ExecutorService) - Method in interface org.apache.samza.storage.blobstore.BlobStoreManagerFactory
getBackupManager(JobContext, ContainerModel, TaskModel, Map<String, SystemAdmin>, ExecutorService, MetricsRegistry, Config, Clock, File, File) - Method in interface org.apache.samza.storage.StateBackendFactory
getBatch() - Method in class org.apache.samza.table.batching.BatchProvider
getBoolean(String, boolean) - Method in class org.apache.samza.config.Config
getBoolean(String) - Method in class org.apache.samza.config.Config
getCallbackScheduler() - Method in interface org.apache.samza.context.TaskContext: Gets the CallbackScheduler for this task, which can be used to schedule a callback to be executed at a future time.
getChangelogPartition() - Method in class org.apache.samza.job.model.TaskModel: Returns the Partition used for all changelogs for this task.
getCharacteristic() - Method in class org.apache.samza.operators.triggers.TimeSinceFirstMessageTrigger
getCharacteristic() - Method in class org.apache.samza.operators.triggers.TimeSinceLastMessageTrigger
getCharacteristic() - Method in class org.apache.samza.operators.triggers.TimeTrigger
getCheckpointId() - Method in class org.apache.samza.checkpoint.CheckpointV2: Gets the checkpoint id for the checkpoint
getCheckpointManager(Config, MetricsRegistry) - Method in interface org.apache.samza.checkpoint.CheckpointManagerFactory
getChooser(Config, MetricsRegistry) - Method in interface org.apache.samza.system.chooser.MessageChooserFactory
getClass(String) - Method in class org.apache.samza.config.Config
getCollector() - Method in class org.apache.samza.storage.KafkaChangelogRestoreParams
getConfig() - Method in interface org.apache.samza.application.descriptors.ApplicationDescriptor: Get the configuration for the application.
getConfig(URI) - Method in interface org.apache.samza.config.ConfigFactory: Build a specific Config.
getConfig() - Method in interface org.apache.samza.config.ConfigLoader
getConfig() - Method in interface org.apache.samza.context.JobContext: Gets the final configuration for this job.
getConfig() - Method in class org.apache.samza.coordinator.lifecycle.JobRestartSignalFactoryContext: Config used to build a JobRestartSignal.
getConfig() - Method in class org.apache.samza.job.model.JobModel
getConfig() - Method in class org.apache.samza.system.StreamSpec
getConfigId() - Method in class org.apache.samza.job.JobCoordinatorMetadata
getConsumer(String, Config, MetricsRegistry) - Method in interface org.apache.samza.system.SystemFactory: Deprecated.
getConsumer(String, Config, MetricsRegistry, String) - Method in interface org.apache.samza.system.SystemFactory: This function provides an extra input parameter to SystemFactory.getConsumer(java.lang.String, org.apache.samza.config.Config, org.apache.samza.metrics.MetricsRegistry), which can be used to provide extra information for the consumer instance, e.g.
getContainerContext() - Method in interface org.apache.samza.context.Context: Gets the framework-provided context for the current container.
getContainerMetricsRegistry() - Method in interface org.apache.samza.context.ContainerContext: Gets the MetricsRegistry for this container, which can be used to register metrics that are reported per container.
getContainerModel() - Method in interface org.apache.samza.context.ContainerContext: Gets the ContainerModel for this container, which contains this container's id and its TaskModel.
getContainers() - Method in class org.apache.samza.job.model.JobModel
getCount() - Method in class org.apache.samza.metrics.Counter
getCount() - Method in class org.apache.samza.operators.triggers.CountTrigger
getCounterValues(String, String) - Method in interface org.apache.samza.metrics.MetricsAccessor: Get the values of a counter
getCreationTimestamp() - Method in class org.apache.samza.startpoint.Startpoint: The timestamp when this Startpoint was written to the storage layer.
getCredits(K, V, Object...) - Method in interface org.apache.samza.table.remote.TableRateLimiter.CreditFunction: Get the number of credits required for the key and value pair.
getCredits(int, Object...) - Method in interface org.apache.samza.table.remote.TableRateLimiter.CreditFunction: Get the number of credits required for the opId and associated args.
getDate(String) - Method in class org.apache.samza.config.Config
getDate(String, String) - Method in class org.apache.samza.config.Config
getDate(String, SimpleDateFormat) - Method in class org.apache.samza.config.Config
getDate(String, Date) - Method in class org.apache.samza.config.Config
getDate(String, String, Date) - Method in class org.apache.samza.config.Config
getDate(String, SimpleDateFormat, Date) - Method in class org.apache.samza.config.Config
getDefault() - Method in class org.apache.samza.operators.UpdateMessage
getDefaultTrigger() - Method in class org.apache.samza.operators.windows.internal.WindowInternal
getDeploymentId() - Method in class org.apache.samza.container.placement.ContainerPlacementMessage
getDestinationHost() - Method in class org.apache.samza.container.placement.ContainerPlacementMessage
getDouble(String, double) - Method in class org.apache.samza.config.Config
getDouble(String) - Method in class org.apache.samza.config.Config
getDrainMode() - Method in class org.apache.samza.drain.DrainNotification
getDuration() - Method in interface org.apache.samza.operators.triggers.TimeBasedTrigger
getDuration() - Method in class org.apache.samza.operators.triggers.TimeSinceFirstMessageTrigger
getDuration() - Method in class org.apache.samza.operators.triggers.TimeSinceLastMessageTrigger
getDuration() - Method in class org.apache.samza.operators.triggers.TimeTrigger
getEarlyTrigger() - Method in class org.apache.samza.operators.windows.internal.WindowInternal
getElementSchema() - Method in class org.apache.samza.sql.schema.SqlFieldSchema: Get the element schema if the field type is SamzaSqlFieldType.ARRAY
getEpochId() - Method in class org.apache.samza.job.JobCoordinatorMetadata
getEventTime() - Method in class org.apache.samza.system.IncomingMessageEnvelope: Getter for event time
getEventTimeExtractor() - Method in class org.apache.samza.operators.windows.internal.WindowInternal
getExpander() - Method in class org.apache.samza.system.descriptors.SystemDescriptor
getExponentialFactor() - Method in class org.apache.samza.table.retry.TableRetryPolicy
getExponentialMaxSleep() - Method in class org.apache.samza.table.retry.TableRetryPolicy
getExternalContext() - Method in interface org.apache.samza.context.Context: Gets the ExternalContext that was created outside of the application.
getField(String) - Method in class org.apache.samza.sql.SamzaSqlRelRecord: Get the value of the field corresponding to the field name.
getFieldName() - Method in class org.apache.samza.sql.schema.SqlSchema.SqlField
getFieldNames() - Method in class org.apache.samza.sql.SamzaSqlRelRecord: Get the field names of all the columns in the relational message.
getFields() - Method in class org.apache.samza.sql.schema.SqlSchema
getFieldSchema() - Method in class org.apache.samza.sql.schema.SqlSchema.SqlField
getFieldType() - Method in class org.apache.samza.sql.schema.SqlFieldSchema: Get the Type of the Samza SQL Field.
getFieldValues() - Method in class org.apache.samza.sql.SamzaSqlRelRecord: Get the field values of all the columns in the relational message.
getFiringType() - Method in class org.apache.samza.operators.windows.WindowPane
getFirstKey(M) - Method in interface org.apache.samza.operators.functions.JoinFunction: Get the join key for messages in the first input stream.
getFoldLeftFunction() - Method in class org.apache.samza.operators.windows.internal.WindowInternal
getForTable(String, String, String) - Method in class org.apache.samza.config.JavaTableConfig: Get table config value for a key
getForTable(String, String) - Method in class org.apache.samza.config.JavaTableConfig: Get table config value for a key
getGaugeValues(String, String) - Method in interface org.apache.samza.metrics.MetricsAccessor: Get the values of a gauge
getGroup(String) - Method in interface org.apache.samza.metrics.ReadableMetricsRegistry
getGroups() - Method in interface org.apache.samza.metrics.ReadableMetricsRegistry
getId() - Method in class org.apache.samza.job.model.ContainerModel: Returns the id for the container associated with this model.
getId() - Method in class org.apache.samza.runtime.LocationId
getId() - Method in class org.apache.samza.system.StreamSpec
getInitializer() - Method in class org.apache.samza.operators.windows.internal.WindowInternal
getInMemoryStores() - Method in class org.apache.samza.storage.KafkaChangelogRestoreParams
getInputDescriptor(String, Serde) - Method in interface org.apache.samza.system.descriptors.ExpandingInputDescriptorProvider: Gets a InputDescriptor for an input stream on this system.
getInputDescriptor(String, Serde<StreamMessageType>) - Method in class org.apache.samza.system.descriptors.GenericSystemDescriptor
getInputDescriptor(String, Serde<StreamMessageType>) - Method in interface org.apache.samza.system.descriptors.SimpleInputDescriptorProvider: Gets an InputDescriptor for an input stream on this system.
getInputDescriptor(String, Serde) - Method in interface org.apache.samza.system.descriptors.TransformingInputDescriptorProvider: Gets a InputDescriptor for an input stream on this system.
getInputStream(InputDescriptor<M, ?>) - Method in interface org.apache.samza.application.descriptors.StreamApplicationDescriptor: Gets the input MessageStream corresponding to the inputDescriptor.
getInt(String, int) - Method in class org.apache.samza.config.Config
getInt(String) - Method in class org.apache.samza.config.Config
getJitter() - Method in class org.apache.samza.table.retry.TableRetryPolicy: Introduce randomness to the sleepTime time.
getJob(Config) - Method in interface org.apache.samza.job.StreamJobFactory
getJobContext() - Method in interface org.apache.samza.context.Context: Gets the framework-provided context for the job.
getJobId() - Method in interface org.apache.samza.context.JobContext: Gets the id for this job.
getJobId() - Method in class org.apache.samza.storage.blobstore.Metadata
getJobModel() - Method in interface org.apache.samza.context.JobContext
getJobModelId() - Method in class org.apache.samza.job.JobCoordinatorMetadata
getJobName() - Method in interface org.apache.samza.context.JobContext: Gets the name of the job.
getJobName() - Method in class org.apache.samza.storage.blobstore.Metadata
getKey() - Method in class org.apache.samza.operators.KV
getKey() - Method in class org.apache.samza.operators.windows.WindowKey
getKey() - Method in class org.apache.samza.operators.windows.WindowPane
getKey() - Method in class org.apache.samza.storage.kv.Entry
getKey() - Method in class org.apache.samza.system.IncomingMessageEnvelope
getKey() - Method in class org.apache.samza.system.OutgoingMessageEnvelope
getKey() - Method in interface org.apache.samza.table.batching.Operation
getKeyBucket() - Method in class org.apache.samza.system.SystemStreamPartition
getKeyExtractor() - Method in class org.apache.samza.operators.windows.internal.WindowInternal
getKeySerde(String) - Method in class org.apache.samza.config.JavaTableConfig: Get registry keys of key serde for this table
getKeySerde() - Method in class org.apache.samza.operators.windows.internal.WindowInternal
getKeySerde() - Method in class org.apache.samza.serializers.KVSerde
getKeySerializerName() - Method in class org.apache.samza.system.OutgoingMessageEnvelope
getLateTrigger() - Method in class org.apache.samza.operators.windows.internal.WindowInternal
getList(String, List<String>) - Method in class org.apache.samza.config.Config
getList(String) - Method in class org.apache.samza.config.Config
getLoader(Config) - Method in interface org.apache.samza.config.ConfigLoaderFactory: Get an instance of ConfigLoader
getLocationId() - Method in interface org.apache.samza.runtime.LocationIdProvider
getLocationIdProvider(Config) - Method in interface org.apache.samza.runtime.LocationIdProviderFactory
getLong(String, long) - Method in class org.apache.samza.config.Config
getLong(String) - Method in class org.apache.samza.config.Config
getMax() - Method in class org.apache.samza.metrics.Snapshot: Get the maximum value in the collection
getMaxAttempts() - Method in class org.apache.samza.table.retry.TableRetryPolicy: Termination after a fix number of attempts.
getMaxBatchDelay() - Method in interface org.apache.samza.table.batching.Batch
getMaxBatchDelay() - Method in class org.apache.samza.table.batching.BatchProvider
getMaxBatchSize() - Method in interface org.apache.samza.table.batching.Batch
getMaxBatchSize() - Method in class org.apache.samza.table.batching.BatchProvider
getMaxChangeLogStreamPartitions() - Method in class org.apache.samza.job.model.JobModel
getMaxDuration() - Method in class org.apache.samza.table.retry.TableRetryPolicy: Termination after a fixed duration.
getMessage() - Method in class org.apache.samza.operators.windows.WindowPane
getMessage() - Method in class org.apache.samza.system.IncomingMessageEnvelope
getMessage() - Method in class org.apache.samza.system.OutgoingMessageEnvelope
getMessageKey(M) - Method in interface org.apache.samza.operators.functions.StreamTableJoinFunction: Retrieve the join key from incoming messages
getMessageSerializerName() - Method in class org.apache.samza.system.OutgoingMessageEnvelope
getMessagesSizeInQueue(SystemStreamPartition) - Method in class org.apache.samza.util.BlockingEnvelopeMap
getMetadataStore(String, Config, MetricsRegistry) - Method in class org.apache.samza.metadatastore.InMemoryMetadataStoreFactory
getMetadataStore(String, Config, MetricsRegistry) - Method in interface org.apache.samza.metadatastore.MetadataStoreFactory
getMetricsReporter(String, String, Config) - Method in interface org.apache.samza.metrics.MetricsReporterFactory
getMillis() - Method in class org.apache.samza.checkpoint.CheckpointId
getMin() - Method in class org.apache.samza.metrics.Snapshot: Get the minimum value in the collection
getMode() - Method in class org.apache.samza.operators.windows.internal.WindowInternal
getMode() - Method in class org.apache.samza.system.ChangelogSSPIterator
getMsgSerde(String) - Method in class org.apache.samza.config.JavaTableConfig: Get registry keys of value serde for this table
getMsgSerde() - Method in class org.apache.samza.operators.windows.internal.WindowInternal
getName() - Method in class org.apache.samza.metrics.Counter
getName() - Method in class org.apache.samza.metrics.Gauge
getName() - Method in class org.apache.samza.metrics.Timer: Get the name of the timer
getNanoId() - Method in class org.apache.samza.checkpoint.CheckpointId
getNewestOffset() - Method in class org.apache.samza.system.SystemStreamMetadata.SystemStreamPartitionMetadata
getNewInstance(String) - Method in class org.apache.samza.config.Config
getNumMessagesInQueue(SystemStreamPartition) - Method in class org.apache.samza.util.BlockingEnvelopeMap
getOffset() - Method in class org.apache.samza.system.IncomingMessageEnvelope: Offset associated with this message, provided by the system consumer that consumed the message.
getOffset(SystemStreamMetadata.OffsetType) - Method in class org.apache.samza.system.SystemStreamMetadata.SystemStreamPartitionMetadata
getOffsets() - Method in interface org.apache.samza.checkpoint.Checkpoint: Gets a unmodifiable view of the last processed offsets for SystemStreamPartitions.
getOffsets() - Method in class org.apache.samza.checkpoint.CheckpointV1: Gets a unmodifiable view of the current Samza input stream offsets.
getOffsets() - Method in class org.apache.samza.checkpoint.CheckpointV2: Gets a unmodifiable view of the current input SystemStreamPartition offsets.
getOffsetsAfter(Map<SystemStreamPartition, String>) - Method in interface org.apache.samza.system.SystemAdmin: Fetches the offsets for the messages immediately after the supplied offsets for a group of SystemStreamPartitions.
getOffsetsAfter(Map<SystemStreamPartition, String>) - Method in class org.apache.samza.util.SinglePartitionWithoutOffsetsSystemAdmin
getOldestOffset() - Method in class org.apache.samza.system.SystemStreamMetadata.SystemStreamPartitionMetadata
getOperations() - Method in interface org.apache.samza.table.batching.Batch
getOrDefault(String, String) - Method in class org.apache.samza.system.StreamSpec
getOutputDescriptor(String, Serde<StreamMessageType>) - Method in class org.apache.samza.system.descriptors.GenericSystemDescriptor
getOutputDescriptor(String, Serde<StreamMessageType>) - Method in interface org.apache.samza.system.descriptors.OutputDescriptorProvider: Gets an OutputDescriptor representing an output stream on this system that uses the provided stream specific serde instead of the default system serde.
getOutputStream(OutputDescriptor<M, ?>) - Method in interface org.apache.samza.application.descriptors.StreamApplicationDescriptor: Gets the OutputStream corresponding to the outputDescriptor.
getOutputWatermark() - Method in interface org.apache.samza.operators.functions.WatermarkFunction: Returns the output watermark.
getPaneId() - Method in class org.apache.samza.operators.windows.WindowKey
getPartition() - Method in class org.apache.samza.system.SystemStreamPartition
getPartitionCount() - Method in class org.apache.samza.system.StreamSpec
getPartitionId() - Method in class org.apache.samza.Partition
getPartitionKey() - Method in class org.apache.samza.system.OutgoingMessageEnvelope
getPayloadPath() - Method in class org.apache.samza.storage.blobstore.Metadata
getPayloadSize() - Method in class org.apache.samza.storage.blobstore.Metadata
getPhysicalName() - Method in class org.apache.samza.system.descriptors.StreamDescriptor
getPhysicalName() - Method in class org.apache.samza.system.StreamSpec
getPosition() - Method in class org.apache.samza.sql.schema.SqlSchema.SqlField
getPreviousSSP(SystemStreamPartition, int, int) - Method in interface org.apache.samza.container.grouper.stream.SystemStreamPartitionMapper: Determines the previous SystemStreamPartition for a SystemStreamPartition of a input stream after the stream expansion or contraction.
getProcessorId() - Method in class org.apache.samza.container.placement.ContainerPlacementMessage
getProcessorLocalities() - Method in class org.apache.samza.job.model.LocalityModel
getProcessorLocality(String) - Method in class org.apache.samza.job.model.LocalityModel
getProducer(String, Config, MetricsRegistry) - Method in interface org.apache.samza.system.SystemFactory: Deprecated.
getProducer(String, Config, MetricsRegistry, String) - Method in interface org.apache.samza.system.SystemFactory: This function provides an extra input parameter to SystemFactory.getProducer(java.lang.String, org.apache.samza.config.Config, org.apache.samza.metrics.MetricsRegistry), which can be used to provide extra information for the producer instance, e.g.
getProviderFactoryClassName() - Method in class org.apache.samza.table.descriptors.BaseTableDescriptor: Return the fully qualified class name of the TableProviderFactory
getProviderFactoryClassName() - Method in class org.apache.samza.table.descriptors.CachingTableDescriptor
getProviderFactoryClassName() - Method in class org.apache.samza.table.descriptors.GuavaCacheTableDescriptor
getProviderFactoryClassName() - Method in class org.apache.samza.table.descriptors.RemoteTableDescriptor
getRandomMax() - Method in class org.apache.samza.table.retry.TableRetryPolicy
getRandomMin() - Method in class org.apache.samza.table.retry.TableRetryPolicy
getRecordKey(R) - Method in interface org.apache.samza.operators.functions.StreamTableJoinFunction: Retrieve the join key from table record
getRegistry() - Method in class org.apache.samza.metrics.MetricsRegistryWithSource
getRequestExpiry() - Method in class org.apache.samza.container.placement.ContainerPlacementMessage
getResponseMessage() - Method in class org.apache.samza.container.placement.ContainerPlacementResponseMessage
getRestoreBlobStoreManager(Config, ExecutorService) - Method in interface org.apache.samza.storage.blobstore.BlobStoreManagerFactory
getRestoreManager(JobContext, ContainerContext, TaskModel, ExecutorService, MetricsRegistry, Set<String>, Config, Clock, File, File, KafkaChangelogRestoreParams) - Method in interface org.apache.samza.storage.StateBackendFactory
getRetryPredicate() - Method in class org.apache.samza.table.retry.TableRetryPolicy
getRowSchema() - Method in class org.apache.samza.sql.schema.SqlFieldSchema: Get the row schema if the field type is SamzaSqlFieldType.ROW
getRunId() - Method in class org.apache.samza.drain.DrainNotification
getRunId() - Method in class org.apache.samza.system.DrainMessage
getSecondKey(JM) - Method in interface org.apache.samza.operators.functions.JoinFunction: Get the join key for messages in the second input stream.
getSerde(String, Config) - Method in class org.apache.samza.serializers.ByteBufferSerdeFactory
getSerde(String, Config) - Method in class org.apache.samza.serializers.ByteSerdeFactory
getSerde(String, Config) - Method in class org.apache.samza.serializers.DoubleSerdeFactory
getSerde(String, Config) - Method in class org.apache.samza.serializers.IntegerSerdeFactory
getSerde(String, Config) - Method in class org.apache.samza.serializers.JsonSerdeV2Factory
getSerde(String, Config) - Method in class org.apache.samza.serializers.LongSerdeFactory
getSerde(String, Config) - Method in interface org.apache.samza.serializers.SerdeFactory
getSerde(String, Config) - Method in class org.apache.samza.serializers.SerializableSerdeFactory
getSerde(String, Config) - Method in class org.apache.samza.serializers.StringSerdeFactory
getSerde(String, Config) - Method in class org.apache.samza.serializers.UUIDSerdeFactory
getSerde() - Method in class org.apache.samza.system.descriptors.StreamDescriptor
getSerde() - Method in class org.apache.samza.table.descriptors.LocalTableDescriptor: Get the serde assigned to this TableDescriptor
getSerdes() - Method in class org.apache.samza.storage.KafkaChangelogRestoreParams
getShort(String, short) - Method in class org.apache.samza.config.Config
getShort(String) - Method in class org.apache.samza.config.Config
getSideInputs() - Method in class org.apache.samza.table.descriptors.LocalTableDescriptor: Get side input stream names
getSideInputsProcessor(Config, MetricsRegistry) - Method in interface org.apache.samza.storage.SideInputsProcessorFactory: Creates a new instance of a SideInputsProcessor.
getSize() - Method in class org.apache.samza.metrics.Snapshot: Get the number of values in the collection
getSize() - Method in class org.apache.samza.system.IncomingMessageEnvelope
getSleepTime() - Method in class org.apache.samza.table.retry.TableRetryPolicy
getSnapshot() - Method in interface org.apache.samza.metrics.Reservoir: Return a Snapshot of this reservoir
getSnapshot() - Method in class org.apache.samza.metrics.SlidingTimeWindowReservoir
getSnapshot() - Method in class org.apache.samza.metrics.Timer: Get the Snapshot
getSource() - Method in class org.apache.samza.metrics.MetricsRegistryWithSource
getSpecificOffset() - Method in class org.apache.samza.startpoint.StartpointSpecific: Getter for the specific offset.
getSSPMetadata(Set<SystemStreamPartition>) - Method in interface org.apache.samza.system.SystemAdmin: Fetch metadata from a system for a set of SSPs.
getStateBackendAdmin(Config, JobModel) - Method in interface org.apache.samza.storage.BlobStoreAdminFactory: Returns an instance of StateBackendAdmin
getStateCheckpointMarkers() - Method in class org.apache.samza.checkpoint.CheckpointV2: Gets the state checkpoint markers for all stores for each configured state backend.
getStatus() - Method in interface org.apache.samza.job.StreamJob: Get current ApplicationStatus of the job
getStatusCode() - Method in class org.apache.samza.container.placement.ContainerPlacementMessage
getStatusCode() - Method in class org.apache.samza.job.ApplicationStatus
getStorageEngine(String, File, Serde<K>, Serde<V>, MessageCollector, MetricsRegistry, SystemStreamPartition, JobContext, ContainerContext, StorageEngineFactory.StoreMode) - Method in interface org.apache.samza.storage.StorageEngineFactory: Create an instance of the given storage engine.
getStorageEngineFactories() - Method in class org.apache.samza.storage.KafkaChangelogRestoreParams
getStore(String) - Method in interface org.apache.samza.context.TaskContext: Gets the KeyValueStore associated with storeName for this task.
getStoreConsumers() - Method in class org.apache.samza.storage.KafkaChangelogRestoreParams
getStoreName() - Method in class org.apache.samza.storage.blobstore.Metadata
getStoreProperties() - Method in interface org.apache.samza.storage.StorageEngine: Get store properties
getStream() - Method in class org.apache.samza.system.SystemStream
getStreamId() - Method in class org.apache.samza.system.descriptors.StreamDescriptor
getStreamName() - Method in class org.apache.samza.system.SystemStreamMetadata
getStreamPartitionMapper(Config, MetricsRegistry) - Method in interface org.apache.samza.container.grouper.stream.SystemStreamPartitionMapperFactory
getSum() - Method in class org.apache.samza.metrics.Snapshot: Get the sum of values in the collection
getSupportedTags() - Method in interface org.apache.samza.util.RateLimiter: Get the entire set of tags for which we have configured credits for rate limiting.
getSystem() - Method in class org.apache.samza.system.SystemStream
getSystemAdmins() - Method in class org.apache.samza.storage.KafkaChangelogRestoreParams
getSystemDescriptor() - Method in class org.apache.samza.system.descriptors.StreamDescriptor
getSystemName() - Method in class org.apache.samza.system.descriptors.StreamDescriptor
getSystemName() - Method in class org.apache.samza.system.descriptors.SystemDescriptor
getSystemName() - Method in class org.apache.samza.system.StreamSpec
getSystemStream() - Method in class org.apache.samza.system.OutgoingMessageEnvelope
getSystemStream() - Method in class org.apache.samza.system.SystemStreamPartition
getSystemStreamMetadata(Set<String>) - Method in interface org.apache.samza.system.SystemAdmin: Fetch metadata from a system for a set of streams.
getSystemStreamMetadata(Set<String>) - Method in class org.apache.samza.util.SinglePartitionWithoutOffsetsSystemAdmin
getSystemStreamPartition() - Method in class org.apache.samza.system.IncomingMessageEnvelope
getSystemStreamPartition(int) - Method in class org.apache.samza.system.IncomingMessageEnvelope: fetches the SSP (with keybucket) for the envelope based on elasticity factor.
getSystemStreamPartitionCounts(Set<String>, long) - Method in interface org.apache.samza.system.SystemAdmin: Get partitions counts only.
getSystemStreamPartitionGrouper(Config) - Method in interface org.apache.samza.container.grouper.stream.SystemStreamPartitionGrouperFactory
getSystemStreamPartitionMetadata() - Method in class org.apache.samza.system.SystemStreamMetadata
getSystemStreamPartitions() - Method in class org.apache.samza.job.model.TaskModel: Returns the SystemStreamPartitions that this task is responsible for consuming.
getTable(TableDescriptor<K, V, ?>) - Method in interface org.apache.samza.application.descriptors.StreamApplicationDescriptor: Gets the Table corresponding to the TableDescriptor.
getTable(String) - Method in interface org.apache.samza.context.TaskContext: Gets the ReadWriteTable corresponding to the tableId for this task.
getTable() - Method in interface org.apache.samza.table.TableProvider: Get an instance of the ReadWriteUpdateTable
getTableDescriptors() - Method in class org.apache.samza.table.descriptors.CachingTableDescriptor: Retrieve user-defined table descriptors contained in this table
getTableDescriptors() - Method in class org.apache.samza.table.descriptors.HybridTableDescriptor: Get tables contained within this table.
getTableId() - Method in class org.apache.samza.table.descriptors.BaseTableDescriptor
getTableId() - Method in interface org.apache.samza.table.descriptors.TableDescriptor: Get the id of the table
getTableIds() - Method in class org.apache.samza.config.JavaTableConfig: Get Id's of all tables
getTableProvider(String) - Method in interface org.apache.samza.table.TableProviderFactory: Construct a table provider based on job configuration
getTableProviderFactory(String) - Method in class org.apache.samza.config.JavaTableConfig: Get the TableProviderFactory class name for a table
getTaskContext() - Method in interface org.apache.samza.context.Context: Gets the framework-provided context for the current task.
getTaskExecutor(Config) - Method in interface org.apache.samza.task.TaskExecutorFactory
getTaskMetricsRegistry() - Method in interface org.apache.samza.context.TaskContext: Gets the MetricsRegistry for this task, which can be used to register metrics that are reported per task.
getTaskMode() - Method in class org.apache.samza.job.model.TaskModel
getTaskModel() - Method in interface org.apache.samza.context.TaskContext: Gets the TaskModel for this task, which contains this task's name and its SystemStreamPartitions.
getTaskName() - Method in class org.apache.samza.container.TaskName
getTaskName() - Method in class org.apache.samza.job.model.TaskModel: Returns the name of the task.
getTaskName() - Method in class org.apache.samza.storage.blobstore.Metadata
getTaskName() - Method in class org.apache.samza.system.ControlMessage
getTasks() - Method in class org.apache.samza.job.model.ContainerModel: Returns a map for all tasks in this container.
getThrowable() - Method in class org.apache.samza.job.ApplicationStatus
getTimerValues(String, String) - Method in interface org.apache.samza.metrics.MetricsAccessor: Get the values of a timer
getTimestamp() - Method in class org.apache.samza.container.placement.ContainerPlacementMessage
getTimestamp() - Method in class org.apache.samza.system.WatermarkMessage
getTimestamp() - Method in class org.apache.samza.util.TimestampedValue
getTimestampOffset() - Method in class org.apache.samza.startpoint.StartpointTimestamp: Getter for the timestamp offset.
getTransformer() - Method in class org.apache.samza.system.descriptors.InputDescriptor
getTransformer() - Method in class org.apache.samza.system.descriptors.SystemDescriptor
getTrigger() - Method in class org.apache.samza.operators.triggers.RepeatingTrigger
getTriggers() - Method in class org.apache.samza.operators.triggers.AnyTrigger
getUpcomingOffset() - Method in class org.apache.samza.system.SystemStreamMetadata.SystemStreamPartitionMetadata
getUpdatableTable(String) - Method in interface org.apache.samza.context.TaskContext: Gets the ReadWriteUpdateTable corresponding to the tableId for this task.
getUpdate() - Method in class org.apache.samza.operators.UpdateMessage
getUpdate() - Method in interface org.apache.samza.table.batching.Operation
getUuid() - Method in class org.apache.samza.container.placement.ContainerPlacementMessage
getUuid() - Method in class org.apache.samza.drain.DrainNotification
getValue() - Method in class org.apache.samza.metrics.Gauge
getValue() - Method in class org.apache.samza.operators.KV
getValue() - Method in class org.apache.samza.storage.kv.Entry
getValue() - Method in interface org.apache.samza.table.batching.Operation
getValue() - Method in class org.apache.samza.util.BlockingEnvelopeMap.BufferGauge
getValue() - Method in class org.apache.samza.util.BlockingEnvelopeMap.BufferSizeGauge
getValue() - Method in class org.apache.samza.util.TimestampedValue
getValues() - Method in class org.apache.samza.metrics.Snapshot: Return the entire list of values
getValueSchema() - Method in class org.apache.samza.sql.schema.SqlFieldSchema: Get the schema of the value if the field type is SamzaSqlFieldType.MAP
getValueSerde() - Method in class org.apache.samza.serializers.KVSerde
getVersion() - Method in interface org.apache.samza.checkpoint.Checkpoint: Gets the version number of the Checkpoint
getVersion() - Method in class org.apache.samza.checkpoint.CheckpointV1
getVersion() - Method in class org.apache.samza.checkpoint.CheckpointV2
getVersion() - Method in class org.apache.samza.system.ControlMessage
getWindowType() - Method in class org.apache.samza.operators.windows.internal.WindowInternal
getWindowValSerde() - Method in class org.apache.samza.operators.windows.internal.WindowInternal
group(Set<SystemStreamPartition>) - Method in interface org.apache.samza.container.grouper.stream.SystemStreamPartitionGrouper: Groups the input systemStreamPartitions into the logical taskNames.
GUAVA_CACHE - Static variable in class org.apache.samza.table.descriptors.GuavaCacheTableDescriptor
GuavaCacheTableDescriptor<K,V> - Class in org.apache.samza.table.descriptors: Table descriptor for Guava-based caching table.
GuavaCacheTableDescriptor(String) - Constructor for class org.apache.samza.table.descriptors.GuavaCacheTableDescriptor: Constructs a table descriptor instance

H

hasDefault() - Method in class org.apache.samza.operators.UpdateMessage
hash - Variable in class org.apache.samza.system.SystemStreamPartition
hashCode() - Method in class org.apache.samza.checkpoint.CheckpointId
hashCode() - Method in class org.apache.samza.checkpoint.CheckpointV1
hashCode() - Method in class org.apache.samza.checkpoint.CheckpointV2
hashCode() - Method in class org.apache.samza.config.MapConfig
hashCode() - Method in class org.apache.samza.container.placement.ContainerPlacementMessage
hashCode() - Method in class org.apache.samza.container.placement.ContainerPlacementResponseMessage
hashCode() - Method in class org.apache.samza.container.TaskName
hashCode() - Method in class org.apache.samza.drain.DrainNotification
hashCode() - Method in class org.apache.samza.job.ApplicationStatus
hashCode() - Method in class org.apache.samza.job.JobCoordinatorMetadata
hashCode() - Method in class org.apache.samza.job.model.ContainerModel
hashCode() - Method in class org.apache.samza.job.model.JobModel
hashCode() - Method in class org.apache.samza.job.model.LocalityModel
hashCode() - Method in class org.apache.samza.job.model.ProcessorLocality
hashCode() - Method in class org.apache.samza.job.model.TaskModel
hashCode() - Method in class org.apache.samza.operators.KV
hashCode() - Method in class org.apache.samza.operators.UpdateMessage
hashCode() - Method in class org.apache.samza.operators.windows.WindowKey
hashCode() - Method in class org.apache.samza.Partition
hashCode() - Method in class org.apache.samza.runtime.LocationId
hashCode() - Method in class org.apache.samza.sql.SamzaSqlRelRecord
hashCode() - Method in class org.apache.samza.startpoint.Startpoint
hashCode() - Method in class org.apache.samza.startpoint.StartpointSpecific
hashCode() - Method in class org.apache.samza.startpoint.StartpointTimestamp
hashCode() - Method in class org.apache.samza.storage.blobstore.Metadata
hashCode() - Method in class org.apache.samza.system.ControlMessage
hashCode() - Method in class org.apache.samza.system.DrainMessage
hashCode() - Method in class org.apache.samza.system.IncomingMessageEnvelope
hashCode() - Method in class org.apache.samza.system.OutgoingMessageEnvelope
hashCode() - Method in class org.apache.samza.system.StreamSpec
hashCode() - Method in class org.apache.samza.system.SystemStream
hashCode() - Method in class org.apache.samza.system.SystemStreamMetadata
hashCode() - Method in class org.apache.samza.system.SystemStreamMetadata.SystemStreamPartitionMetadata
hashCode() - Method in class org.apache.samza.system.SystemStreamPartition
hashCode() - Method in class org.apache.samza.system.WatermarkMessage
hashCode() - Method in class org.apache.samza.util.TimestampedValue
hasNext() - Method in class org.apache.samza.system.BoundedSSPIterator
hasNext() - Method in class org.apache.samza.system.SystemStreamPartitionIterator
host() - Method in class org.apache.samza.job.model.ProcessorLocality
HybridTableDescriptor<K,V,D extends HybridTableDescriptor<K,V,D>> - Class in org.apache.samza.table.descriptors: Base class for hybrid table descriptors.
HybridTableDescriptor(String) - Constructor for class org.apache.samza.table.descriptors.HybridTableDescriptor: Constructs a table descriptor instance

I

id - Variable in class org.apache.samza.job.CommandBuilder
id() - Method in class org.apache.samza.job.model.ProcessorLocality
inc() - Method in class org.apache.samza.metrics.Counter
inc(long) - Method in class org.apache.samza.metrics.Counter
incBlockingPoll(SystemStreamPartition) - Method in class org.apache.samza.util.BlockingEnvelopeMap.BlockingEnvelopeMapMetrics
incBlockingTimeoutPoll(SystemStreamPartition) - Method in class org.apache.samza.util.BlockingEnvelopeMap.BlockingEnvelopeMapMetrics
IncomingMessageEnvelope - Class in org.apache.samza.system: This class represents a message envelope that is received by a StreamTask for each message that is received from a partition of a specific input stream.
IncomingMessageEnvelope(SystemStreamPartition, String, Object, Object) - Constructor for class org.apache.samza.system.IncomingMessageEnvelope: Constructs a new IncomingMessageEnvelope from specified components.
IncomingMessageEnvelope(SystemStreamPartition, String, Object, Object, int) - Constructor for class org.apache.samza.system.IncomingMessageEnvelope: Constructs a new IncomingMessageEnvelope from specified components.
IncomingMessageEnvelope(SystemStreamPartition, String, Object, Object, int, long, long) - Constructor for class org.apache.samza.system.IncomingMessageEnvelope: Constructs a new IncomingMessageEnvelope from specified components
incPoll() - Method in class org.apache.samza.util.BlockingEnvelopeMap.BlockingEnvelopeMapMetrics
init() - Method in class org.apache.samza.metadatastore.InMemoryMetadataStore
init() - Method in interface org.apache.samza.metadatastore.MetadataStore: Initializes the metadata store, if applicable, setting up the underlying resources and connections to the store endpoints.
init(Config) - Method in interface org.apache.samza.metrics.MetricsValidator: Initialize with config.
init(Context) - Method in interface org.apache.samza.operators.functions.InitableFunction: Initializes the function before any messages are processed.
init(Config, Context) - Method in interface org.apache.samza.sql.udfs.ScalarUdf: Udfs can implement this method to perform any initialization that they may need.
init() - Method in interface org.apache.samza.storage.blobstore.BlobStoreManager: Initialize underlying blob store client, if necessary.
init(Context) - Method in interface org.apache.samza.storage.kv.KeyValueStore: Optional lifecycle management method for each KV store, storage engine invokes this initialization during org.apache.samza.storage.StorageEngine#init
init(Context) - Method in interface org.apache.samza.storage.StorageEngine: Use for lifecycle management for StorageEngine, ContainerStorageManager after restoring each store issues init on each configured storage engine
init(Checkpoint) - Method in interface org.apache.samza.storage.TaskBackupManager: Initializes the TaskBackupManager instance.
init(Checkpoint) - Method in interface org.apache.samza.storage.TaskRestoreManager: Initialize state resources such as store directories.
init(Context) - Method in interface org.apache.samza.table.AsyncReadWriteUpdateTable: Initializes the table during container initialization.
init(Context, AsyncReadWriteUpdateTable) - Method in class org.apache.samza.table.remote.BaseTableFunction
init(Context, AsyncReadWriteUpdateTable) - Method in interface org.apache.samza.table.remote.TableFunction: Initializes the function before any operation.
init(Context) - Method in interface org.apache.samza.table.TableProvider: Initialize TableProvider with container and task context
init(Context) - Method in interface org.apache.samza.task.InitableTask: Called by TaskRunner each time an implementing task is created.
init(Context) - Method in interface org.apache.samza.util.RateLimiter: Initialize this rate limiter, this method should be called during container initialization.
InitableFunction - Interface in org.apache.samza.operators.functions: A function that can be initialized before execution.
InitableTask - Interface in org.apache.samza.task: Used as an interface for user processing StreamTasks that need to have specific functionality performed as their StreamTasks are instantiated by TaskRunner.
initMetrics(SystemStreamPartition) - Method in class org.apache.samza.util.BlockingEnvelopeMap.BlockingEnvelopeMapMetrics
InMemoryMetadataStore - Class in org.apache.samza.metadatastore: In-memory MetadataStore with no persistence on disk.
InMemoryMetadataStore() - Constructor for class org.apache.samza.metadatastore.InMemoryMetadataStore
InMemoryMetadataStoreFactory - Class in org.apache.samza.metadatastore: Factory for an in-memory MetadataStore.
InMemoryMetadataStoreFactory() - Constructor for class org.apache.samza.metadatastore.InMemoryMetadataStoreFactory
InputDescriptor<StreamMessageType,SubClass extends InputDescriptor<StreamMessageType,SubClass>> - Class in org.apache.samza.system.descriptors: An InputDescriptor can be used for specifying Samza and system-specific properties of input streams.
InputDescriptor(String, Serde, SystemDescriptor, InputTransformer) - Constructor for class org.apache.samza.system.descriptors.InputDescriptor: Constructs an InputDescriptor instance.
InputTransformer<OM> - Interface in org.apache.samza.system.descriptors: Transforms an IncomingMessageEnvelope with deserialized key and message to a message of type OM which is delivered to the MessageStream.
IntegerSerde - Class in org.apache.samza.serializers: A serializer for integers
IntegerSerde() - Constructor for class org.apache.samza.serializers.IntegerSerde
IntegerSerdeFactory - Class in org.apache.samza.serializers
IntegerSerdeFactory() - Constructor for class org.apache.samza.serializers.IntegerSerdeFactory
InterfaceStability - Class in org.apache.samza.annotation: Annotation to inform users of how much to rely on a particular package, class or method not changing over time.
InterfaceStability() - Constructor for class org.apache.samza.annotation.InterfaceStability
InterfaceStability.Evolving - Annotation Type in org.apache.samza.annotation: Evolving, but can break compatibility at minor release (i.e.
InterfaceStability.Stable - Annotation Type in org.apache.samza.annotation: Can evolve while retaining compatibility for minor release boundaries.; can break compatibility only at major release (ie.
InterfaceStability.Unstable - Annotation Type in org.apache.samza.annotation: No guarantee is provided as to reliability or stability across any level of release granularity.
isAtHead(SystemStreamPartition) - Method in class org.apache.samza.util.BlockingEnvelopeMap
isBounded() - Method in class org.apache.samza.system.descriptors.InputDescriptor: If set, this stream will be considered a bounded stream.
isChangeLogStream() - Method in class org.apache.samza.system.StreamSpec
isCheckpointStream() - Method in class org.apache.samza.system.StreamSpec
isClosed() - Method in interface org.apache.samza.table.batching.Batch
isCoordinatorStream() - Method in class org.apache.samza.system.StreamSpec
isDrain() - Method in class org.apache.samza.system.IncomingMessageEnvelope
isDurableStore() - Method in class org.apache.samza.storage.StoreProperties: Flag to indicate whether a store is durable, that is, it's contents are available cross container restarts or host reallocation.
isEmpty() - Method in class org.apache.samza.config.MapConfig
isEmpty() - Method in interface org.apache.samza.table.batching.Batch
isEndOfStream() - Method in class org.apache.samza.system.IncomingMessageEnvelope
isLoggedStore() - Method in class org.apache.samza.storage.StoreProperties: Flag to indicate whether a store is associated with a changelog (used for recovery) or not
isNullable() - Method in class org.apache.samza.sql.schema.SqlFieldSchema: Get if the field type is nullable.
isOptional() - Method in class org.apache.samza.sql.schema.SqlFieldSchema: Get if the field type is optional.
isPersistedToDisk() - Method in class org.apache.samza.storage.StoreProperties: Flag to indicate whether a store can be persisted to disk or not
isPrimitiveField() - Method in class org.apache.samza.sql.schema.SqlFieldSchema
isRetriable(Throwable) - Method in interface org.apache.samza.table.remote.TableFunction: Determine whether the current operation can be retried with the last thrown exception.
isStopped() - Method in interface org.apache.samza.system.SystemAdmin: To give the status of current systemAdmin
isWatermark() - Method in class org.apache.samza.system.IncomingMessageEnvelope
iterator() - Method in interface org.apache.samza.storage.kv.KeyValueSnapshot: Creates a new iterator for this snapshot.

J

JavaTableConfig - Class in org.apache.samza.config: A helper class for handling table configuration
JavaTableConfig(Map<String, String>) - Constructor for class org.apache.samza.config.JavaTableConfig
jmxTunnelingUrl() - Method in class org.apache.samza.job.model.ProcessorLocality
jmxUrl() - Method in class org.apache.samza.job.model.ProcessorLocality
JobContext - Interface in org.apache.samza.context: The framework-provided context for the job.
JobCoordinatorMetadata - Class in org.apache.samza.job: A data model to represent the metadata of the job coordinator.
JobCoordinatorMetadata(String, String, String) - Constructor for class org.apache.samza.job.JobCoordinatorMetadata
JobMetadataChange - Enum in org.apache.samza.job: Provides granularity into changes in job metadata (e.g.
JobModel - Class in org.apache.samza.job.model: The data model used to represent a Samza job.
JobModel(Config, Map<String, ContainerModel>) - Constructor for class org.apache.samza.job.model.JobModel
JobRestartSignal - Interface in org.apache.samza.coordinator.lifecycle: Interface for defining how to trigger a restart of a Samza job.
JobRestartSignalFactory - Interface in org.apache.samza.coordinator.lifecycle: See JobRestartSignal.
JobRestartSignalFactoryContext - Class in org.apache.samza.coordinator.lifecycle: Contains objects that are needed to build a JobRestartSignal.
JobRestartSignalFactoryContext(Config) - Constructor for class org.apache.samza.coordinator.lifecycle.JobRestartSignalFactoryContext
join(MessageStream<OM>, JoinFunction<? extends K, ? super M, ? super OM, ? extends JM>, Serde<K>, Serde<M>, Serde<OM>, Duration, String) - Method in interface org.apache.samza.operators.MessageStream: Joins this MessageStream with another MessageStream using the provided pairwise JoinFunction.
join(Table<R>, StreamTableJoinFunction<? extends K, ? super M, ? super R, ? extends JM>, Object...) - Method in interface org.apache.samza.operators.MessageStream: Joins this MessageStream with another Table using the provided pairwise StreamTableJoinFunction.
JoinFunction<K,M,JM,RM> - Interface in org.apache.samza.operators.functions: Joins incoming messages in two streams by key.
JsonSerdeV2<T> - Class in org.apache.samza.serializers: A serializer for UTF-8 encoded JSON strings.
JsonSerdeV2() - Constructor for class org.apache.samza.serializers.JsonSerdeV2: Constructs a JsonSerdeV2 that returns a LinkedHashMap<String, Object< upon deserialization.
JsonSerdeV2(Class<T>) - Constructor for class org.apache.samza.serializers.JsonSerdeV2: Constructs a JsonSerdeV2 that (de)serializes POJOs of class clazz.
JsonSerdeV2Factory - Class in org.apache.samza.serializers
JsonSerdeV2Factory() - Constructor for class org.apache.samza.serializers.JsonSerdeV2Factory

K

KafkaChangelogRestoreParams - Class in org.apache.samza.storage: Provides the required for Kafka Changelog restore managers
KafkaChangelogRestoreParams(Map<String, SystemConsumer>, Map<String, StorageEngine>, Map<String, SystemAdmin>, Map<String, StorageEngineFactory<Object, Object>>, Map<String, Serde<Object>>, MessageCollector) - Constructor for class org.apache.samza.storage.KafkaChangelogRestoreParams
key - Variable in class org.apache.samza.operators.KV
keyBucket - Variable in class org.apache.samza.system.SystemStreamPartition
keyedSessionWindow(MapFunction<? super M, ? extends K>, Duration, SupplierFunction<? extends WV>, FoldLeftFunction<? super M, WV>, Serde<K>, Serde<WV>) - Static method in class org.apache.samza.operators.windows.Windows: Creates a Window that groups incoming messages into sessions per-key based on the provided sessionGap and applies the provided fold function to them.
keyedSessionWindow(MapFunction<? super M, ? extends K>, Duration, Serde<K>, Serde<M>) - Static method in class org.apache.samza.operators.windows.Windows: Creates a Window that groups incoming messages into sessions per-key based on the provided sessionGap.
keyedTumblingWindow(MapFunction<? super M, ? extends K>, Duration, SupplierFunction<? extends WV>, FoldLeftFunction<? super M, WV>, Serde<K>, Serde<WV>) - Static method in class org.apache.samza.operators.windows.Windows: Creates a Window that groups incoming messages into fixed-size, non-overlapping processing time based windows based on the provided keyFn and applies the provided fold function to them.
keyedTumblingWindow(MapFunction<M, K>, Duration, Serde<K>, Serde<M>) - Static method in class org.apache.samza.operators.windows.Windows: Creates a Window that groups incoming messages into fixed-size, non-overlapping processing time based windows using the provided keyFn.
keySet() - Method in class org.apache.samza.config.MapConfig
KeyValueIterator<K,V> - Interface in org.apache.samza.storage.kv
KeyValueSnapshot<K,V> - Interface in org.apache.samza.storage.kv: An immutable view of the KeyValueStore at a point-in-time.
KeyValueStore<K,V> - Interface in org.apache.samza.storage.kv: A key-value store that supports put, get, delete, and range queries.
kill() - Method in interface org.apache.samza.job.StreamJob: Kill this job immediately.
kill() - Method in interface org.apache.samza.runtime.ApplicationRunner: Kill the Samza jobs represented by SamzaApplication It is non-blocking so it doesn't wait for the application stopping.
KV<K,V> - Class in org.apache.samza.operators: A key and value pair.
KV(K, V) - Constructor for class org.apache.samza.operators.KV
KVSerde<K,V> - Class in org.apache.samza.serializers: A serializer that serves one of the following two purposes: When used for input/output streams, serves as an indication to the framework that messages are keyed and should be deserialized as K-V pairs. When used for a key or value of type KV, serializes the key and value pair using the provided serdes.
KVSerde(Serde<K>, Serde<V>) - Constructor for class org.apache.samza.serializers.KVSerde

L

listen(ReadableMetricsRegistryListener) - Method in interface org.apache.samza.metrics.ReadableMetricsRegistry
LocalityModel - Class in org.apache.samza.job.model: A model to represent the locality information of an application.
LocalityModel(Map<String, ProcessorLocality>) - Constructor for class org.apache.samza.job.model.LocalityModel: Construct locality model for the job from the input map of processor localities.
LocalTableDescriptor<K,V,D extends LocalTableDescriptor<K,V,D>> - Class in org.apache.samza.table.descriptors: Table descriptor for store backed tables.
LocalTableDescriptor(String, KVSerde<K, V>) - Constructor for class org.apache.samza.table.descriptors.LocalTableDescriptor: Constructs a table descriptor instance
LocationId - Class in org.apache.samza.runtime: Represents the physical execution environment of the StreamProcessor.
LocationId(String) - Constructor for class org.apache.samza.runtime.LocationId
LocationIdProvider - Interface in org.apache.samza.runtime: Generates LocationId that uniquely identifies the execution environment of a stream processor.
LocationIdProviderFactory - Interface in org.apache.samza.runtime: Builds the LocationIdProvider.
LOG - Static variable in interface org.apache.samza.storage.kv.KeyValueStore
LongSerde - Class in org.apache.samza.serializers: A serializer for longs
LongSerde() - Constructor for class org.apache.samza.serializers.LongSerde
LongSerdeFactory - Class in org.apache.samza.serializers
LongSerdeFactory() - Constructor for class org.apache.samza.serializers.LongSerdeFactory

M

map(MapFunction<? super M, ? extends OM>) - Method in interface org.apache.samza.operators.MessageStream: Applies the provided 1:1 function to messages in this MessageStream and returns the transformed MessageStream.
MapConfig - Class in org.apache.samza.config: A Config backed by a Java Map
MapConfig() - Constructor for class org.apache.samza.config.MapConfig
MapConfig(Map<String, String>) - Constructor for class org.apache.samza.config.MapConfig
MapConfig(List<Map<String, String>>) - Constructor for class org.apache.samza.config.MapConfig
MapConfig(Map<String, String>...) - Constructor for class org.apache.samza.config.MapConfig
MapFunction<M,OM> - Interface in org.apache.samza.operators.functions: Transforms an input message into another message, possibly of a different type.
maxChangeLogStreamPartitions - Variable in class org.apache.samza.job.model.JobModel
merge(Collection<? extends MessageStream<? extends M>>) - Method in interface org.apache.samza.operators.MessageStream: Merges all otherStreams with this MessageStream.
mergeAll(Collection<? extends MessageStream<? extends T>>) - Static method in interface org.apache.samza.operators.MessageStream: Merges all streams.
MessageChooser - Interface in org.apache.samza.system.chooser: MessageChooser is an interface for programmatic fine-grain control over stream consumption.
MessageChooserFactory - Interface in org.apache.samza.system.chooser: Build an instance of a MessageChooser
MessageCollector - Interface in org.apache.samza.task: Used as an interface for the means of sending message envelopes to an output stream.
MessageStream<M> - Interface in org.apache.samza.operators: A stream of messages that can be transformed into another MessageStream.
MessageType - Enum in org.apache.samza.system: The type of the intermediate stream message.
Metadata - Class in org.apache.samza.storage.blobstore: Metadata associated with every BlobStore request.
Metadata(String, Optional<Long>, String, String, String, String) - Constructor for class org.apache.samza.storage.blobstore.Metadata
MetadataStore - Interface in org.apache.samza.metadatastore: Store abstraction responsible for managing the metadata of a Samza job.
MetadataStoreFactory - Interface in org.apache.samza.metadatastore: Builds the MetadataStore based upon the provided namespace, Config and MetricsRegistry.
Metric - Interface in org.apache.samza.metrics: Metric class that allows metric visitors to visit it to get its information.
MetricsAccessor - Interface in org.apache.samza.metrics: A MetricsAccessor allows users to retrieve metric values, based on group name and metric name, though specific metrics system, such as JMX.
MetricsRegistry - Interface in org.apache.samza.metrics: A MetricsRegistry allows its users to create new Metrics and have those metrics wired to specific metrics systems, such as JMX, provided by MetricsReporters.
MetricsRegistryWithSource - Class in org.apache.samza.metrics: Simple holder for ReadableMetricsRegistry and its source, used for implementations of MetricsReporter.
MetricsRegistryWithSource(String, ReadableMetricsRegistry) - Constructor for class org.apache.samza.metrics.MetricsRegistryWithSource
MetricsReporter - Interface in org.apache.samza.metrics: A MetricsReporter is the interface that different metrics sinks, such as JMX, implement to receive metrics from the Samza framework and Samza jobs.
MetricsReporterFactory - Interface in org.apache.samza.metrics: Build a MetricsReporter
MetricsValidationFailureException - Exception in org.apache.samza.metrics: Thrown when the metrics validation fails.
MetricsValidationFailureException(String) - Constructor for exception org.apache.samza.metrics.MetricsValidationFailureException
MetricsValidationFailureException(String, Throwable) - Constructor for exception org.apache.samza.metrics.MetricsValidationFailureException
MetricsValidator - Interface in org.apache.samza.metrics: A MetricsValidator reads the job's metrics values by using the MetricsAccessor, and validate them.
MetricsVisitor - Class in org.apache.samza.metrics: A MetricsVisitor can be used to process each metric in a ReadableMetricsRegistry, encapsulating the logic of what to be done with each metric in the counter and gauge methods.
MetricsVisitor() - Constructor for class org.apache.samza.metrics.MetricsVisitor
mode - Variable in enum org.apache.samza.storage.StorageEngineFactory.StoreMode

N

New - Static variable in class org.apache.samza.job.ApplicationStatus
newBlockingQueue() - Method in class org.apache.samza.util.BlockingEnvelopeMap
newCounter(String, String) - Method in interface org.apache.samza.metrics.MetricsRegistry: Create and register a new Counter
newCounter(String, Counter) - Method in interface org.apache.samza.metrics.MetricsRegistry: Register existing Counter with this registry
newCounter(String, String) - Method in class org.apache.samza.util.NoOpMetricsRegistry
newCounter(String, Counter) - Method in class org.apache.samza.util.NoOpMetricsRegistry
newGauge(String, String, T) - Method in interface org.apache.samza.metrics.MetricsRegistry: Create and register a new Gauge
newGauge(String, Gauge<T>) - Method in interface org.apache.samza.metrics.MetricsRegistry: Register an existing Gauge
newGauge(String, String, T) - Method in class org.apache.samza.util.NoOpMetricsRegistry
newGauge(String, Gauge<T>) - Method in class org.apache.samza.util.NoOpMetricsRegistry
newTimer(String, String) - Method in interface org.apache.samza.metrics.MetricsRegistry: Create and Register a new Timer
newTimer(String, Timer) - Method in interface org.apache.samza.metrics.MetricsRegistry: Register existing Timer with this registry
newTimer(String, String) - Method in class org.apache.samza.util.NoOpMetricsRegistry
newTimer(String, Timer) - Method in class org.apache.samza.util.NoOpMetricsRegistry
next() - Method in class org.apache.samza.system.BoundedSSPIterator
next() - Method in class org.apache.samza.system.ChangelogSSPIterator
next() - Method in class org.apache.samza.system.SystemStreamPartitionIterator
NoOpMetricsRegistry - Class in org.apache.samza.util: MetricsRegistry implementation for when no actual metrics need to be recorded but a registry is still required.
NoOpMetricsRegistry() - Constructor for class org.apache.samza.util.NoOpMetricsRegistry
NoOpSerde<T> - Class in org.apache.samza.serializers: A marker serde class to indicate that messages should not be serialized or deserialized.
NoOpSerde() - Constructor for class org.apache.samza.serializers.NoOpSerde

O

of(K, V) - Static method in class org.apache.samza.operators.KV
of(U, V) - Static method in class org.apache.samza.operators.UpdateMessage
of(U) - Static method in class org.apache.samza.operators.UpdateMessage
of(Class<T>) - Static method in class org.apache.samza.serializers.JsonSerdeV2
of(Serde<K>, Serde<V>) - Static method in class org.apache.samza.serializers.KVSerde
of(Object) - Static method in enum org.apache.samza.system.MessageType: Returns the MessageType of a particular intermediate stream message.
offsetComparator(String, String) - Method in interface org.apache.samza.system.SystemAdmin: Compare the two offsets.
offsetComparator(String, String) - Method in class org.apache.samza.util.SinglePartitionWithoutOffsetsSystemAdmin
onCallback(K, long) - Method in interface org.apache.samza.operators.functions.ScheduledFunction: Returns the output from the scheduling logic corresponding to the key that was triggered.
onCallback(K, MessageCollector, TaskCoordinator) - Method in interface org.apache.samza.scheduler.ScheduledCallback: Invoked when the corresponding schedule time is reached.
onCheckpoint(Map<SystemStreamPartition, String>) - Method in interface org.apache.samza.checkpoint.CheckpointListener: Deprecated.
onCounter(String, Counter) - Method in interface org.apache.samza.metrics.ReadableMetricsRegistryListener
onDrain(MessageCollector, TaskCoordinator) - Method in interface org.apache.samza.task.DrainListenerTask: Guaranteed to be invoked when all SSPs processed by this task have drained.
onEndOfStream(MessageCollector, TaskCoordinator) - Method in interface org.apache.samza.task.EndOfStreamListenerTask: Guaranteed to be invoked when all SSPs processed by this task have reached their end-of-stream.
onGauge(String, Gauge<?>) - Method in interface org.apache.samza.metrics.ReadableMetricsRegistryListener
onTimer(String, Timer) - Method in interface org.apache.samza.metrics.ReadableMetricsRegistryListener
Operation<K,V,U> - Interface in org.apache.samza.table.batching: Interface for table operations that can be batched.
org.apache.samza - package org.apache.samza
org.apache.samza.annotation - package org.apache.samza.annotation
org.apache.samza.application - package org.apache.samza.application
org.apache.samza.application.descriptors - package org.apache.samza.application.descriptors
org.apache.samza.checkpoint - package org.apache.samza.checkpoint
org.apache.samza.config - package org.apache.samza.config
org.apache.samza.container - package org.apache.samza.container
org.apache.samza.container.grouper.stream - package org.apache.samza.container.grouper.stream
org.apache.samza.container.placement - package org.apache.samza.container.placement
org.apache.samza.context - package org.apache.samza.context
org.apache.samza.coordinator.lifecycle - package org.apache.samza.coordinator.lifecycle
org.apache.samza.drain - package org.apache.samza.drain
org.apache.samza.job - package org.apache.samza.job
org.apache.samza.job.model - package org.apache.samza.job.model
org.apache.samza.metadatastore - package org.apache.samza.metadatastore
org.apache.samza.metrics - package org.apache.samza.metrics
org.apache.samza.operators - package org.apache.samza.operators
org.apache.samza.operators.functions - package org.apache.samza.operators.functions
org.apache.samza.operators.triggers - package org.apache.samza.operators.triggers
org.apache.samza.operators.windows - package org.apache.samza.operators.windows
org.apache.samza.operators.windows.internal - package org.apache.samza.operators.windows.internal
org.apache.samza.runtime - package org.apache.samza.runtime
org.apache.samza.scheduler - package org.apache.samza.scheduler
org.apache.samza.serializers - package org.apache.samza.serializers
org.apache.samza.sql - package org.apache.samza.sql
org.apache.samza.sql.schema - package org.apache.samza.sql.schema
org.apache.samza.sql.udfs - package org.apache.samza.sql.udfs
org.apache.samza.startpoint - package org.apache.samza.startpoint
org.apache.samza.storage - package org.apache.samza.storage
org.apache.samza.storage.blobstore - package org.apache.samza.storage.blobstore
org.apache.samza.storage.blobstore.exceptions - package org.apache.samza.storage.blobstore.exceptions
org.apache.samza.storage.kv - package org.apache.samza.storage.kv
org.apache.samza.system - package org.apache.samza.system
org.apache.samza.system.chooser - package org.apache.samza.system.chooser
org.apache.samza.system.descriptors - package org.apache.samza.system.descriptors
org.apache.samza.table - package org.apache.samza.table
org.apache.samza.table.batching - package org.apache.samza.table.batching
org.apache.samza.table.descriptors - package org.apache.samza.table.descriptors
org.apache.samza.table.remote - package org.apache.samza.table.remote
org.apache.samza.table.retry - package org.apache.samza.table.retry
org.apache.samza.table.utils - package org.apache.samza.table.utils
org.apache.samza.task - package org.apache.samza.task
org.apache.samza.util - package org.apache.samza.util
OutgoingMessageEnvelope - Class in org.apache.samza.system: An OutgoingMessageEnvelope is sent to a specified SystemStream via the appropriate SystemProducer from the user's StreamTask.
OutgoingMessageEnvelope(SystemStream, String, String, Object, Object, Object) - Constructor for class org.apache.samza.system.OutgoingMessageEnvelope: Constructs a new OutgoingMessageEnvelope from specified components.
OutgoingMessageEnvelope(SystemStream, Object, Object, Object) - Constructor for class org.apache.samza.system.OutgoingMessageEnvelope: Constructs a new OutgoingMessageEnvelope from specified components.
OutgoingMessageEnvelope(SystemStream, Object, Object) - Constructor for class org.apache.samza.system.OutgoingMessageEnvelope: Constructs a new OutgoingMessageEnvelope from specified components.
OutgoingMessageEnvelope(SystemStream, Object) - Constructor for class org.apache.samza.system.OutgoingMessageEnvelope: Constructs a new OutgoingMessageEnvelope from specified components.
OutputDescriptor<StreamMessageType,SubClass extends OutputDescriptor<StreamMessageType,SubClass>> - Class in org.apache.samza.system.descriptors: An OutputDescriptor can be used for specifying Samza and system-specific properties of output streams.
OutputDescriptor(String, Serde, SystemDescriptor) - Constructor for class org.apache.samza.system.descriptors.OutputDescriptor: Constructs an OutputDescriptor instance.
OutputDescriptorProvider - Interface in org.apache.samza.system.descriptors: Interface for simple SystemDescriptors that return OutputDescriptors parameterized by the type of the provided stream level serde.
OutputStream<M> - Interface in org.apache.samza.operators: An output stream to send messages to.

P

Partition - Class in org.apache.samza: A numbered, ordered partition of a stream.
Partition(int) - Constructor for class org.apache.samza.Partition: Constructs a new Samza stream partition from a specified partition number.
partition - Variable in class org.apache.samza.system.SystemStreamPartition
partitionBy(MapFunction<? super M, ? extends K>, MapFunction<? super M, ? extends V>, KVSerde<K, V>, String) - Method in interface org.apache.samza.operators.MessageStream: Re-partitions this MessageStream using keys from the keyExtractor by creating a new intermediate stream on the default system provided via ApplicationDescriptor.withDefaultSystem(org.apache.samza.system.descriptors.SystemDescriptor<?>).
poll(Set<SystemStreamPartition>, long) - Method in interface org.apache.samza.system.SystemConsumer: Poll the SystemConsumer to get any available messages from the underlying system.
poll(Set<SystemStreamPartition>, long) - Method in class org.apache.samza.util.BlockingEnvelopeMap: Poll the SystemConsumer to get any available messages from the underlying system.
process(IncomingMessageEnvelope, KeyValueStore) - Method in interface org.apache.samza.storage.SideInputsProcessor: Process the incoming side input message for the store.
process(IncomingMessageEnvelope, MessageCollector, TaskCoordinator) - Method in interface org.apache.samza.task.StreamTask: Called once for each message that this StreamTask receives.
processAsync(IncomingMessageEnvelope, MessageCollector, TaskCoordinator, TaskCallback) - Method in interface org.apache.samza.task.AsyncStreamTask: Called once for each message that this AsyncStreamTask receives.
ProcessorContext - Interface in org.apache.samza.runtime: The context for a StreamProcessor.
processorId - Variable in class org.apache.samza.container.placement.ContainerPlacementMessage
ProcessorIdGenerator - Interface in org.apache.samza.runtime
ProcessorLifecycleListener - Interface in org.apache.samza.runtime: This interface defines methods that are invoked in different stages of StreamProcessor's lifecycle in local process (i.e.
ProcessorLifecycleListenerFactory - Interface in org.apache.samza.runtime: This interface class defines the factory method to create an instance of ProcessorLifecycleListener.
ProcessorLocality - Class in org.apache.samza.job.model: A data model to represent the processor locality information.
ProcessorLocality(String, String) - Constructor for class org.apache.samza.job.model.ProcessorLocality
ProcessorLocality(String, String, String, String) - Constructor for class org.apache.samza.job.model.ProcessorLocality
processWatermark(long) - Method in interface org.apache.samza.operators.functions.WatermarkFunction: Processes the input watermark coming from upstream operators.
PROVIDER_FACTORY_CLASS_NAME - Static variable in class org.apache.samza.table.descriptors.CachingTableDescriptor
PROVIDER_FACTORY_CLASS_NAME - Static variable in class org.apache.samza.table.descriptors.GuavaCacheTableDescriptor
PROVIDER_FACTORY_CLASS_NAME - Static variable in class org.apache.samza.table.descriptors.RemoteTableDescriptor
put(String, String) - Method in class org.apache.samza.config.Config
put(String, byte[]) - Method in class org.apache.samza.metadatastore.InMemoryMetadataStore
put(String, byte[]) - Method in interface org.apache.samza.metadatastore.MetadataStore: Updates the mapping of the specified key-value pair.
put(InputStream, Metadata) - Method in interface org.apache.samza.storage.blobstore.BlobStoreManager: Non-blocking PUT call to remote blob store with supplied metadata
put(K, V) - Method in interface org.apache.samza.storage.kv.KeyValueStore: Updates the mapping of the specified key-value pair; Associates the specified key with the specified value.
put(K, V, Object...) - Method in interface org.apache.samza.table.ReadWriteTable: Updates the mapping of the specified key-value pair; Associates the specified key with the specified value.
put(K, V, Object...) - Method in interface org.apache.samza.table.ReadWriteUpdateTable: Updates the mapping of the specified key-value pair; Associates the specified key with the specified value.
put(K, V) - Method in interface org.apache.samza.table.remote.TableWriteFunction: Store single table record with specified key.
put(SystemStreamPartition, IncomingMessageEnvelope) - Method in class org.apache.samza.util.BlockingEnvelopeMap: Place a new IncomingMessageEnvelope on the queue for the specified SystemStreamPartition.
putAll(Map<? extends String, ? extends String>) - Method in class org.apache.samza.config.Config
putAll(Map<String, byte[]>) - Method in interface org.apache.samza.metadatastore.MetadataStore: Updates the mapping with the specified map.
putAll(List<Entry<K, V>>) - Method in interface org.apache.samza.storage.kv.KeyValueStore: Updates the mappings of the specified key-value entries.
putAll(List<Entry<K, V>>, Object...) - Method in interface org.apache.samza.table.ReadWriteTable: Updates the mappings of the specified key-value entries.
putAll(List<Entry<K, V>>, Object...) - Method in interface org.apache.samza.table.ReadWriteUpdateTable: Updates the mappings of the specified key-value entries.
putAll(List<Entry<K, V>>) - Method in interface org.apache.samza.table.remote.TableWriteFunction: Store the table records with specified keys.
putAll(SystemStreamPartition, List<IncomingMessageEnvelope>) - Method in class org.apache.samza.util.BlockingEnvelopeMap: Place a collection of IncomingMessageEnvelope on the queue for the specified SystemStreamPartition.
putAllAsync(List<Entry<K, V>>, Object...) - Method in interface org.apache.samza.table.AsyncReadWriteUpdateTable: Asynchronously updates the mappings of the specified key-value entries.
putAllAsync(Collection<Entry<K, V>>) - Method in interface org.apache.samza.table.remote.TableWriteFunction: Asynchronously store the table records with specified keys.
putAllAsync(Collection<Entry<K, V>>, Object...) - Method in interface org.apache.samza.table.remote.TableWriteFunction: Asynchronously store the table records with specified keys and additional arguments.
putAsync(K, V, Object...) - Method in interface org.apache.samza.table.AsyncReadWriteUpdateTable: Asynchronously updates the mapping of the specified key-value pair; Associates the specified key with the specified value.
putAsync(K, V) - Method in interface org.apache.samza.table.remote.TableWriteFunction: Asynchronously store single table record with specified key.
putAsync(K, V, Object...) - Method in interface org.apache.samza.table.remote.TableWriteFunction: Asynchronously store single table record with specified key and additional arguments.

R

range(K, K) - Method in interface org.apache.samza.storage.kv.KeyValueStore: Returns an iterator for a sorted range of entries specified by [from, to).
RATE_LIMITER - Static variable in class org.apache.samza.table.descriptors.RemoteTableDescriptor
RateLimiter - Interface in org.apache.samza.util: A rate limiter interface used by Samza components to limit throughput of operations against a resource.
read(int, Object...) - Method in interface org.apache.samza.table.ReadWriteTable: Executes a read operation.
read(int, Object...) - Method in interface org.apache.samza.table.ReadWriteUpdateTable: Executes a read operation.
READ_CREDIT_FN - Static variable in class org.apache.samza.table.descriptors.RemoteTableDescriptor
READ_CREDITS - Static variable in class org.apache.samza.table.descriptors.RemoteTableDescriptor
READ_FN - Static variable in class org.apache.samza.table.descriptors.RemoteTableDescriptor
READ_RETRY_POLICY - Static variable in class org.apache.samza.table.descriptors.RemoteTableDescriptor
READ_TTL_MS - Static variable in class org.apache.samza.table.descriptors.CachingTableDescriptor
ReadableMetricsRegistry - Interface in org.apache.samza.metrics: A ReadableMetricsRegistry is a MetricsRegistry that also allows read access to the metrics for which it is responsible.
ReadableMetricsRegistryListener - Interface in org.apache.samza.metrics
readAsync(int, Object...) - Method in interface org.apache.samza.table.AsyncReadWriteUpdateTable: Asynchronously executes a read operation.
readAsync(int, Object...) - Method in interface org.apache.samza.table.remote.TableReadFunction: Asynchronously read data from table for specified opId and additional arguments.
readLastCheckpoint(TaskName) - Method in interface org.apache.samza.checkpoint.CheckpointManager: Returns the last recorded checkpoint for a specified taskName.
ReadWriteTable<K,V> - Interface in org.apache.samza.table: A table that supports synchronous and asynchronous get, put and delete by one or more keys
ReadWriteUpdateTable<K,V,U> - Interface in org.apache.samza.table: A table that supports synchronous and asynchronous get, put, update and delete by one or more keys
REAL_TABLE_ID - Static variable in class org.apache.samza.table.descriptors.CachingTableDescriptor
RecordNotFoundException - Exception in org.apache.samza.table: Custom exception which can be thrown by implementations of TableWriteFunction when AsyncReadWriteUpdateTable.updateAsync(Object, Object) fails due an existing record not being present for the given key.
RecordNotFoundException() - Constructor for exception org.apache.samza.table.RecordNotFoundException
RecordNotFoundException(String, Throwable) - Constructor for exception org.apache.samza.table.RecordNotFoundException
RecordNotFoundException(String) - Constructor for exception org.apache.samza.table.RecordNotFoundException
RecordNotFoundException(Throwable) - Constructor for exception org.apache.samza.table.RecordNotFoundException
regexSubset(String) - Method in class org.apache.samza.config.Config
register(TaskName) - Method in interface org.apache.samza.checkpoint.CheckpointManager: Registers this manager to write checkpoints of a specific Samza stream partition.
register(String, ReadableMetricsRegistry) - Method in interface org.apache.samza.metrics.MetricsReporter
register(SystemStreamPartition, String) - Method in class org.apache.samza.system.chooser.BaseMessageChooser
register(SystemStreamPartition, String) - Method in interface org.apache.samza.system.chooser.MessageChooser: Called before start, to let the chooser know that it will be handling envelopes from the given SystemStreamPartition.
register(SystemStreamPartition, String) - Method in interface org.apache.samza.system.SystemConsumer: Register a SystemStreamPartition to this SystemConsumer.
register(String) - Method in interface org.apache.samza.system.SystemProducer: Registers this producer to send messages from a specified Samza source, such as a StreamTask.
register(SystemStreamPartition, String) - Method in class org.apache.samza.util.BlockingEnvelopeMap: Register a SystemStreamPartition to this SystemConsumer.
RemoteTableDescriptor<K,V,U> - Class in org.apache.samza.table.descriptors: Table descriptor for remote store backed tables
RemoteTableDescriptor(String) - Constructor for class org.apache.samza.table.descriptors.RemoteTableDescriptor: Constructs a table descriptor instance
remove(Object) - Method in class org.apache.samza.config.Config
remove() - Method in class org.apache.samza.system.SystemStreamPartitionIterator
removeTTL(String, Metadata) - Method in interface org.apache.samza.storage.blobstore.BlobStoreManager: Non-blocking call to remove the Time-To-Live (TTL) for a blob and make it permanent.
repeat(Trigger<M>) - Static method in class org.apache.samza.operators.triggers.Triggers: Repeats the provided trigger forever.
RepeatingTrigger<M> - Class in org.apache.samza.operators.triggers: A Trigger that repeats its underlying trigger forever.
replaceAll(BiFunction<? super String, ? super String, ? extends String>) - Method in class org.apache.samza.config.Config
requestExpiry - Variable in class org.apache.samza.container.placement.ContainerPlacementMessage
Reservoir - Interface in org.apache.samza.metrics: A reservoir interface to store, update and display values
resolveStartpointToOffset(SystemStreamPartition, Startpoint) - Method in interface org.apache.samza.system.SystemAdmin: Resolves the startpoint to a system specific offset.
restartJob() - Method in interface org.apache.samza.coordinator.lifecycle.JobRestartSignal: Trigger a restart of the Samza job.
restore(ChangelogSSPIterator) - Method in interface org.apache.samza.storage.StorageEngine: Restore the content of this StorageEngine from the changelog.
restore() - Method in interface org.apache.samza.storage.TaskRestoreManager: Restore state from checkpoints, state snapshots and changelogs.
RetriableException - Exception in org.apache.samza.storage.blobstore.exceptions
RetriableException(String, Throwable) - Constructor for exception org.apache.samza.storage.blobstore.exceptions.RetriableException
RetriableException(String) - Constructor for exception org.apache.samza.storage.blobstore.exceptions.RetriableException
RetriableException(Throwable) - Constructor for exception org.apache.samza.storage.blobstore.exceptions.RetriableException
RetriableException() - Constructor for exception org.apache.samza.storage.blobstore.exceptions.RetriableException
rewrite(String, Config) - Method in interface org.apache.samza.config.ConfigRewriter
RL_READ_TAG - Static variable in class org.apache.samza.table.descriptors.RemoteTableDescriptor: Tag to be used for provision credits for rate limiting read operations from the remote table.
RL_WRITE_TAG - Static variable in class org.apache.samza.table.descriptors.RemoteTableDescriptor: Tag to be used for provision credits for rate limiting write operations into the remote table.
run() - Method in interface org.apache.samza.runtime.ApplicationRunner: This is like ApplicationRunner.run(ExternalContext), except it provides a null ExternalContext.
run(ExternalContext) - Method in interface org.apache.samza.runtime.ApplicationRunner: Deploy and run the Samza jobs to execute SamzaApplication.
Running - Static variable in class org.apache.samza.job.ApplicationStatus

S

SamzaApplication<S extends ApplicationDescriptor> - Interface in org.apache.samza.application: A SamzaApplication describes the inputs, outputs, state, configuration and the logic for processing data from one or more streaming sources.
SamzaException - Exception in org.apache.samza: Unchecked exception that Samza throws when something goes wrong.
SamzaException() - Constructor for exception org.apache.samza.SamzaException
SamzaException(String, Throwable) - Constructor for exception org.apache.samza.SamzaException
SamzaException(String) - Constructor for exception org.apache.samza.SamzaException
SamzaException(Throwable) - Constructor for exception org.apache.samza.SamzaException
SamzaHistogram - Class in org.apache.samza.metrics: Creates a Histogram metric using ExponentiallyDecayingReservoir Keeps a Gauge for each percentile
SamzaHistogram(MetricsRegistry, String, String) - Constructor for class org.apache.samza.metrics.SamzaHistogram
SamzaHistogram(MetricsRegistry, String, String, List<Double>) - Constructor for class org.apache.samza.metrics.SamzaHistogram
SamzaSqlFieldType - Enum in org.apache.samza.sql.schema: Type of the Samza SQL field
SamzaSqlRelRecord - Class in org.apache.samza.sql: Samza sql relational record.
SamzaSqlRelRecord(List<String>, List<Object>) - Constructor for class org.apache.samza.sql.SamzaSqlRelRecord: Creates a SamzaSqlRelRecord from the list of relational fields and values.
SamzaSqlUdf - Annotation Type in org.apache.samza.sql.udfs: Java annotation to identity a Samza SQL Udf
SamzaSqlUdfMethod - Annotation Type in org.apache.samza.sql.udfs: Java annotation to identity the Samza SQL Udf method and it's argument types and return types.
sanitize() - Method in class org.apache.samza.config.Config
sanitize() - Method in class org.apache.samza.config.MapConfig
ScalarUdf - Interface in org.apache.samza.sql.udfs: The base class for the Scalar UDFs.
schedule(Scheduler<K>) - Method in interface org.apache.samza.operators.functions.ScheduledFunction: Allows scheduling the initial callback(s) and saving the scheduler for later use for recurring callbacks.
schedule(K, long) - Method in interface org.apache.samza.operators.Scheduler: Schedule a callback for the key to be invoked at timestamp.
scheduleCallback(K, long, ScheduledCallback<K>) - Method in interface org.apache.samza.scheduler.CallbackScheduler: Schedule the callback for the provided key to be invoked at epoch-time timestamp.
ScheduledCallback<K> - Interface in org.apache.samza.scheduler: The callback that is invoked when its corresponding schedule time registered via CallbackScheduler is reached.
ScheduledFunction<K,OM> - Interface in org.apache.samza.operators.functions: Allows scheduling a callback for a specific epoch-time.
Scheduler<K> - Interface in org.apache.samza.operators: Allows scheduling ScheduledFunction callbacks to be invoked later.
send(String, OutgoingMessageEnvelope) - Method in interface org.apache.samza.system.SystemProducer: Sends a specified message envelope from a specified Samza source.
send(OutgoingMessageEnvelope) - Method in interface org.apache.samza.task.MessageCollector: Sends message envelope out onto specified stream.
sendTo(OutputStream<M>) - Method in interface org.apache.samza.operators.MessageStream: Allows sending messages in this MessageStream to an OutputStream and then propagates this MessageStream to the next chained operator
sendTo(Table<KV<K, V>>) - Method in interface org.apache.samza.operators.MessageStream: Allows sending messages in this MessageStream to a Table and then propagates this MessageStream to the next chained operator.
sendTo(Table<KV<K, V>>, UpdateOptions) - Method in interface org.apache.samza.operators.MessageStream: Allows sending update messages in this MessageStream to a Table and then propagates this MessageStream to the next chained operator.
SENSITIVE_MASK - Static variable in class org.apache.samza.config.Config
SENSITIVE_PREFIX - Static variable in class org.apache.samza.config.Config
SEPARATOR - Static variable in class org.apache.samza.checkpoint.CheckpointId
Serde<T> - Interface in org.apache.samza.serializers: A Serde is a convenience type that implements both the Serializer and Deserializer interfaces, allowing it to both read and write data in its value type, T.
serde - Variable in class org.apache.samza.table.descriptors.LocalTableDescriptor
SerdeFactory<T> - Interface in org.apache.samza.serializers: Build an instance of Serde
SerdeUtils - Class in org.apache.samza.table.utils
SerdeUtils() - Constructor for class org.apache.samza.table.utils.SerdeUtils
SerializableSerde<T extends java.io.Serializable> - Class in org.apache.samza.serializers: A serializer for Serializable objects
SerializableSerde() - Constructor for class org.apache.samza.serializers.SerializableSerde
SerializableSerdeFactory<T extends java.io.Serializable> - Class in org.apache.samza.serializers
SerializableSerdeFactory() - Constructor for class org.apache.samza.serializers.SerializableSerdeFactory
serialize() - Method in class org.apache.samza.checkpoint.CheckpointId: Serialization of CheckpointId as part of task checkpoints, in conjunction with CheckpointId.deserialize(String).
serialize(String, T) - Static method in class org.apache.samza.table.utils.SerdeUtils: Helper method to serialize Java objects as Base64 strings
Serializer<T> - Interface in org.apache.samza.serializers: A standard interface for Samza compatible serializers, used for serializing objects to bytes.
set(long) - Method in class org.apache.samza.metrics.Counter
set(T) - Method in class org.apache.samza.metrics.Gauge
setAccumulationMode(AccumulationMode) - Method in class org.apache.samza.operators.windows.internal.WindowInternal
setAccumulationMode(AccumulationMode) - Method in interface org.apache.samza.operators.windows.Window: Specify how a Window should process its previously emitted WindowPanes.
setCommandPath(String) - Method in class org.apache.samza.job.CommandBuilder
setConfig(Config) - Method in class org.apache.samza.job.CommandBuilder
setEarlyTrigger(Trigger<M>) - Method in class org.apache.samza.operators.windows.internal.WindowInternal
setEarlyTrigger(Trigger<M>) - Method in interface org.apache.samza.operators.windows.Window: Set the early triggers for this Window.
setFailureCause(Throwable) - Method in class org.apache.samza.util.BlockingEnvelopeMap
setFieldName(String) - Method in class org.apache.samza.sql.schema.SqlSchema.SqlField
setFieldSchema(SqlFieldSchema) - Method in class org.apache.samza.sql.schema.SqlSchema.SqlField
setId(String) - Method in class org.apache.samza.job.CommandBuilder
setIsAtHead(SystemStreamPartition, boolean) - Method in class org.apache.samza.util.BlockingEnvelopeMap
setIsDurable(boolean) - Method in class org.apache.samza.storage.StoreProperties.StorePropertiesBuilder
setLateTrigger(Trigger<M>) - Method in class org.apache.samza.operators.windows.internal.WindowInternal
setLateTrigger(Trigger<M>) - Method in interface org.apache.samza.operators.windows.Window: Set the late triggers for this Window.
setLoggedStore(boolean) - Method in class org.apache.samza.storage.StoreProperties.StorePropertiesBuilder
setNoMoreMessages(SystemStreamPartition, boolean) - Method in class org.apache.samza.util.BlockingEnvelopeMap.BlockingEnvelopeMapMetrics
setPersistedToDisk(boolean) - Method in class org.apache.samza.storage.StoreProperties.StorePropertiesBuilder
setPosition(int) - Method in class org.apache.samza.sql.schema.SqlSchema.SqlField
setStartingOffset(SystemStreamPartition, String) - Method in interface org.apache.samza.context.TaskContext: Sets the starting offset for the given SystemStreamPartition.
setTimerMetric(Timer) - Method in class org.apache.samza.table.remote.TableRateLimiter: Set up waitTimeMetric metric for latency reporting due to throttling.
setUrl(URL) - Method in class org.apache.samza.job.CommandBuilder
setVersion(int) - Method in class org.apache.samza.system.ControlMessage
shouldBootstrap() - Method in class org.apache.samza.system.descriptors.InputDescriptor: If set, this stream will be processed as a bootstrap stream.
shouldDeleteCommittedMessages() - Method in class org.apache.samza.system.descriptors.InputDescriptor: If set, and supported by the system implementation, messages older than the latest checkpointed offset for this stream may be deleted after the commit.
shouldResetOffset() - Method in class org.apache.samza.system.descriptors.InputDescriptor: If set, when a Samza container starts up, it ignores any checkpointed offset for this particular input stream.
shutdown(TaskCoordinator.RequestScope) - Method in interface org.apache.samza.task.TaskCoordinator: Requests that the container should be shut down.
sideInputs - Variable in class org.apache.samza.table.descriptors.LocalTableDescriptor
SideInputsProcessor - Interface in org.apache.samza.storage: The processing logic for store side inputs.
sideInputsProcessor - Variable in class org.apache.samza.table.descriptors.LocalTableDescriptor
SideInputsProcessorFactory - Interface in org.apache.samza.storage: A factory to build SideInputsProcessors.
SimpleInputDescriptorProvider - Interface in org.apache.samza.system.descriptors: Interface for simple SystemDescriptors that return InputDescriptors parameterized by the type of the provided stream level serde.
SinglePartitionWithoutOffsetsSystemAdmin - Class in org.apache.samza.util: A simple helper admin class that defines a single partition (partition 0) for a given system.
SinglePartitionWithoutOffsetsSystemAdmin() - Constructor for class org.apache.samza.util.SinglePartitionWithoutOffsetsSystemAdmin
sink(SinkFunction<? super M>) - Method in interface org.apache.samza.operators.MessageStream: Allows sending messages in this MessageStream to an output system using the provided SinkFunction.
SinkFunction<M> - Interface in org.apache.samza.operators.functions: Allows sending a message to an output system.
size() - Method in class org.apache.samza.config.MapConfig
size() - Method in interface org.apache.samza.metrics.Reservoir: Return the number of values in this reservoir
size() - Method in class org.apache.samza.metrics.SlidingTimeWindowReservoir
size() - Method in interface org.apache.samza.table.batching.Batch
SlidingTimeWindowReservoir - Class in org.apache.samza.metrics: An implemented Reservoir used to store values that appear in a sliding time window
SlidingTimeWindowReservoir() - Constructor for class org.apache.samza.metrics.SlidingTimeWindowReservoir: Default constructor using default window size
SlidingTimeWindowReservoir(long) - Constructor for class org.apache.samza.metrics.SlidingTimeWindowReservoir: Construct the SlidingTimeWindowReservoir with window size
SlidingTimeWindowReservoir(long, Clock) - Constructor for class org.apache.samza.metrics.SlidingTimeWindowReservoir
SlidingTimeWindowReservoir(long, int, Clock) - Constructor for class org.apache.samza.metrics.SlidingTimeWindowReservoir
Snapshot - Class in org.apache.samza.metrics: A statistical snapshot of a collection of values
snapshot(K, K) - Method in interface org.apache.samza.storage.kv.KeyValueStore: Returns a snapshot of this store for a sorted range of entries specified by [from, to).
snapshot(CheckpointId) - Method in interface org.apache.samza.storage.TaskBackupManager: Snapshot is used to capture the current state of the stores in order to persist it to the backup manager in the TaskBackupManager.upload(CheckpointId, Map) (CheckpointId, Map)} phase.
SNAPSHOT_INDEX_PAYLOAD_PATH - Static variable in class org.apache.samza.storage.blobstore.Metadata
SqlField(int, String, SqlFieldSchema) - Constructor for class org.apache.samza.sql.schema.SqlSchema.SqlField
SqlFieldSchema - Class in org.apache.samza.sql.schema: Schema for the Samza SQL Field.
SqlSchema - Class in org.apache.samza.sql.schema: Representation of SQL schema which is used by Samza SQL.
SqlSchema(List<String>, List<SqlFieldSchema>) - Constructor for class org.apache.samza.sql.schema.SqlSchema
SqlSchema.SqlField - Class in org.apache.samza.sql.schema
SqlSchemaBuilder - Class in org.apache.samza.sql.schema: Builder class to build the SqlSchema.
start() - Method in interface org.apache.samza.checkpoint.CheckpointManager: Perform startup operations.
start() - Method in interface org.apache.samza.context.ApplicationContainerContext: Starts this ApplicationContainerContext before any tasks in the container are initialized and before processing begins.
start() - Method in interface org.apache.samza.context.ApplicationTaskContext: Starts this ApplicationTaskContext after its task is initialized but before any messages are processed.
start() - Method in interface org.apache.samza.metrics.MetricsReporter
start() - Method in class org.apache.samza.system.chooser.BaseMessageChooser
start() - Method in interface org.apache.samza.system.chooser.MessageChooser: Called after all SystemStreamPartitions have been registered.
start() - Method in interface org.apache.samza.system.SystemAdmin
start() - Method in interface org.apache.samza.system.SystemConsumer: Tells the SystemConsumer to connect to the underlying system, and prepare to begin serving messages when poll is invoked.
start() - Method in interface org.apache.samza.system.SystemProducer: Start the SystemProducer.
Startpoint - Class in org.apache.samza.startpoint: Startpoint represents a position in a stream partition.
StartpointOldest - Class in org.apache.samza.startpoint: A Startpoint that represents the earliest offset in a stream partition.
StartpointOldest() - Constructor for class org.apache.samza.startpoint.StartpointOldest: Constructs a Startpoint that represents the earliest offset in a stream partition.
StartpointSpecific - Class in org.apache.samza.startpoint: A Startpoint that represents a specific offset in a stream partition.
StartpointSpecific(String) - Constructor for class org.apache.samza.startpoint.StartpointSpecific: Constructs a Startpoint that represents a specific offset in a stream partition.
StartpointTimestamp - Class in org.apache.samza.startpoint: A Startpoint that represents a timestamp offset in a stream partition.
StartpointTimestamp(Long) - Constructor for class org.apache.samza.startpoint.StartpointTimestamp: Constructs a Startpoint that represents a timestamp offset in a stream partition.
StartpointUpcoming - Class in org.apache.samza.startpoint: A Startpoint that represents the latest offset in a stream partition.
StartpointUpcoming() - Constructor for class org.apache.samza.startpoint.StartpointUpcoming: Constructs a Startpoint that represents the latest offset in a stream partition.
StartpointVisitor<IN,OUT> - Interface in org.apache.samza.startpoint: A SystemAdmin implementation should implement this abstraction to support Startpoint.
StateBackendAdmin - Interface in org.apache.samza.storage: Admin responsible for loading any resources related to state backend
StateBackendFactory - Interface in org.apache.samza.storage: Factory to build the Samza TaskBackupManager, TaskRestoreManager and StateBackendAdmin for a particular state storage backend, which are used to durably backup the Samza task state.
status() - Method in interface org.apache.samza.runtime.ApplicationRunner: Get the collective status of the Samza jobs represented by SamzaApplication.
statusCode - Variable in class org.apache.samza.container.placement.ContainerPlacementMessage
stop() - Method in interface org.apache.samza.checkpoint.CheckpointManager: Perform teardown operations for the Manager.
stop() - Method in interface org.apache.samza.context.ApplicationContainerContext: Stops this ApplicationContainerContext after processing ends and after all tasks in the container are closed.
stop() - Method in interface org.apache.samza.context.ApplicationTaskContext: Stops this ApplicationTaskContext after processing ends but before its task is closed.
stop() - Method in interface org.apache.samza.metrics.MetricsReporter
stop() - Method in interface org.apache.samza.storage.StorageEngine: Close the storage engine
stop() - Method in class org.apache.samza.system.chooser.BaseMessageChooser
stop() - Method in interface org.apache.samza.system.chooser.MessageChooser: Called when the chooser is about to be discarded.
stop() - Method in interface org.apache.samza.system.SystemAdmin
stop() - Method in interface org.apache.samza.system.SystemConsumer: Tells the SystemConsumer to close all connections, release all resource, and shut down everything.
stop() - Method in interface org.apache.samza.system.SystemProducer: Stop the SystemProducer.
StorageEngine - Interface in org.apache.samza.storage: A storage engine for managing state maintained by a stream processor.
StorageEngineFactory<K,V> - Interface in org.apache.samza.storage: An object provided by the storage engine implementation to create instances of the given storage engine type.
StorageEngineFactory.StoreMode - Enum in org.apache.samza.storage: Enum to describe different modes a StorageEngine can be created in.
STORE_KEY_SERDE - Static variable in class org.apache.samza.config.JavaTableConfig
STORE_MSG_SERDE - Static variable in class org.apache.samza.config.JavaTableConfig
StoreProperties - Class in org.apache.samza.storage: Immutable class that defines the properties of a Store
StoreProperties.StorePropertiesBuilder - Class in org.apache.samza.storage
StorePropertiesBuilder() - Constructor for class org.apache.samza.storage.StoreProperties.StorePropertiesBuilder
stream - Variable in class org.apache.samza.system.SystemStream
StreamApplication - Interface in org.apache.samza.application: A StreamApplication describes the inputs, outputs, state, configuration and the processing logic for the application in Samza's High Level API.
StreamApplicationDescriptor - Interface in org.apache.samza.application.descriptors: A StreamApplicationDescriptor contains the description of inputs, outputs, state, configuration and the processing logic for a Samza High Level API StreamApplication.
StreamDescriptor<StreamMessageType,SubClass extends StreamDescriptor<StreamMessageType,SubClass>> - Class in org.apache.samza.system.descriptors: A StreamDescriptor can be used for specifying Samza and system-specific properties of input/output streams.
StreamExpander<OM> - Interface in org.apache.samza.system.descriptors: Expands the provided InputDescriptor to a sub-DAG of one or more operators on the StreamApplicationDescriptor, and returns a new MessageStream with the combined results.
StreamJob - Interface in org.apache.samza.job: A StreamJob runs Samza StreamTasks in its specific environment.
StreamJobFactory - Interface in org.apache.samza.job: Build a StreamJob
StreamOperatorTaskFactory - Interface in org.apache.samza.task: Build AsyncStreamTask instances.
StreamSpec - Class in org.apache.samza.system: StreamSpec is a blueprint for creating, validating, or simply describing a stream in the runtime environment.
StreamSpec(String, String, String) - Constructor for class org.apache.samza.system.StreamSpec
StreamSpec(String, String, String, int) - Constructor for class org.apache.samza.system.StreamSpec
StreamSpec(String, String, String, Map<String, String>) - Constructor for class org.apache.samza.system.StreamSpec
StreamSpec(String, String, String, int, Map<String, String>) - Constructor for class org.apache.samza.system.StreamSpec
StreamTableJoinFunction<K,M,R,JM> - Interface in org.apache.samza.operators.functions: Joins incoming messages with records from a table by the join key.
StreamTask - Interface in org.apache.samza.task: A StreamTask is the basic class on which Samza jobs are implemented.
StreamTaskFactory - Interface in org.apache.samza.task: Build StreamTask instances.
StreamValidationException - Exception in org.apache.samza.system
StreamValidationException(String) - Constructor for exception org.apache.samza.system.StreamValidationException
StringSerde - Class in org.apache.samza.serializers: A serializer for strings
StringSerde(String) - Constructor for class org.apache.samza.serializers.StringSerde
StringSerde() - Constructor for class org.apache.samza.serializers.StringSerde
StringSerdeFactory - Class in org.apache.samza.serializers
StringSerdeFactory() - Constructor for class org.apache.samza.serializers.StringSerdeFactory
submit() - Method in interface org.apache.samza.job.StreamJob: Submit this job to be run.
subset(String) - Method in class org.apache.samza.config.Config
subset(String, boolean) - Method in class org.apache.samza.config.Config
SuccessfulFinish - Static variable in class org.apache.samza.job.ApplicationStatus
SupplierFunction<T> - Interface in org.apache.samza.operators.functions: A supplier to return a new value at each invocation
system - Variable in class org.apache.samza.system.SystemStream
SYSTEM_STREAM_NAME_PATTERN - Static variable in class org.apache.samza.table.descriptors.LocalTableDescriptor
SystemAdmin - Interface in org.apache.samza.system: Helper interface attached to an underlying system to fetch information about streams, partitions, offsets, etc.
SystemConsumer - Interface in org.apache.samza.system: SystemConsumer is the interface that must be implemented by any system that wishes to integrate with Samza.
SystemDescriptor<SubClass extends SystemDescriptor<SubClass>> - Class in org.apache.samza.system.descriptors: A SystemDescriptor can be used for specifying Samza and system-specific properties of an input/output system.
SystemDescriptor(String, String, InputTransformer, StreamExpander) - Constructor for class org.apache.samza.system.descriptors.SystemDescriptor: Constructs a SystemDescriptor instance.
SystemFactory - Interface in org.apache.samza.system: Build the SystemConsumer and SystemProducer for a particular system, as well as the accompanying SystemAdmin.
SystemProducer - Interface in org.apache.samza.system: SystemProducers are how Samza writes messages from StreamTasks to outside systems, such as messaging systems like Kafka, or file systems.
SystemProducerException - Exception in org.apache.samza.system
SystemProducerException(String) - Constructor for exception org.apache.samza.system.SystemProducerException
SystemProducerException(Throwable) - Constructor for exception org.apache.samza.system.SystemProducerException
SystemProducerException(String, Throwable) - Constructor for exception org.apache.samza.system.SystemProducerException
SystemStream - Class in org.apache.samza.system: Streams in Samza consist of both the stream name and the system to which the stream belongs.
SystemStream(String, String) - Constructor for class org.apache.samza.system.SystemStream: Constructs a Samza stream object from specified components.
SystemStream(SystemStream) - Constructor for class org.apache.samza.system.SystemStream: Constructs a Samza stream object based upon an existing Samza stream.
SystemStreamMetadata - Class in org.apache.samza.system: SystemAdmins use this class to return useful metadata about a stream's offset and partition information.
SystemStreamMetadata(String, Map<Partition, SystemStreamMetadata.SystemStreamPartitionMetadata>) - Constructor for class org.apache.samza.system.SystemStreamMetadata
SystemStreamMetadata.OffsetType - Enum in org.apache.samza.system: OffsetType is an enum used to define which offset should be used when reading from a SystemStreamPartition for the first time.
SystemStreamMetadata.SystemStreamPartitionMetadata - Class in org.apache.samza.system: Provides offset information for a given SystemStreamPartition.
SystemStreamPartition - Class in org.apache.samza.system: Aggregate object representing a both the SystemStream and Partition.
SystemStreamPartition(String, String, Partition) - Constructor for class org.apache.samza.system.SystemStreamPartition: Constructs a Samza stream partition object from specified components.
SystemStreamPartition(SystemStreamPartition) - Constructor for class org.apache.samza.system.SystemStreamPartition: Constructs a Samza stream partition object based upon an existing Samza stream partition.
SystemStreamPartition(SystemStream, Partition) - Constructor for class org.apache.samza.system.SystemStreamPartition: Constructs a Samza stream partition object based upon another Samza stream and a specified partition.
SystemStreamPartition(String, String, Partition, int) - Constructor for class org.apache.samza.system.SystemStreamPartition
SystemStreamPartition(SystemStreamPartition, int) - Constructor for class org.apache.samza.system.SystemStreamPartition
SystemStreamPartitionGrouper - Interface in org.apache.samza.container.grouper.stream: Group a set of SystemStreamPartitions into logical taskNames that share a common characteristic, defined by the implementation.
SystemStreamPartitionGrouperFactory - Interface in org.apache.samza.container.grouper.stream: Return an instance a SystemStreamPartitionGrouper per the particular implementation
SystemStreamPartitionIterator - Class in org.apache.samza.system: Iterator that wraps a SystemConsumer to iterate over the messages the consumer provides for the specified SystemStreamPartition.
SystemStreamPartitionIterator(SystemConsumer, SystemStreamPartition) - Constructor for class org.apache.samza.system.SystemStreamPartitionIterator
SystemStreamPartitionIterator(SystemConsumer, SystemStreamPartition, int) - Constructor for class org.apache.samza.system.SystemStreamPartitionIterator
SystemStreamPartitionMapper - Interface in org.apache.samza.container.grouper.stream: Input streams of a samza job can be either expanded or contracted by the user.
SystemStreamPartitionMapperFactory - Interface in org.apache.samza.container.grouper.stream
SystemStreamPartitionMatcher - Interface in org.apache.samza.system
SystemStreamPartitionMetadata(String, String, String) - Constructor for class org.apache.samza.system.SystemStreamMetadata.SystemStreamPartitionMetadata

T

table - Variable in class org.apache.samza.table.remote.BaseTableFunction
Table<R> - Interface in org.apache.samza.table: A Table is an abstraction for data sources that support random access by key.
TABLE_ID_PREFIX - Static variable in class org.apache.samza.config.JavaTableConfig
TABLE_PROVIDER_FACTORY - Static variable in class org.apache.samza.config.JavaTableConfig
TABLE_PROVIDER_FACTORY_SUFFIX - Static variable in class org.apache.samza.config.JavaTableConfig
TableDescriptor<K,V,D extends TableDescriptor<K,V,D>> - Interface in org.apache.samza.table.descriptors: A TableDescriptor can be used for specifying Samza and implementation-specific properties of a Table.
TableFunction - Interface in org.apache.samza.table.remote: The root interface for table read and write function.
tableId - Variable in class org.apache.samza.table.descriptors.BaseTableDescriptor
TablePart - Interface in org.apache.samza.table.remote: A building block of a remote table
TableProvider - Interface in org.apache.samza.table: A table provider provides the implementation for a table.
TableProviderFactory - Interface in org.apache.samza.table: Factory of a table provider object
TableRateLimiter<K,V> - Class in org.apache.samza.table.remote: Helper class for remote table to throttle table IO requests with the configured rate limiter.
TableRateLimiter(String, RateLimiter, TableRateLimiter.CreditFunction<K, V>, String) - Constructor for class org.apache.samza.table.remote.TableRateLimiter
TableRateLimiter.CreditFunction<K,V> - Interface in org.apache.samza.table.remote: Function interface for providing rate limiting credits for each table record.
TableReadFunction<K,V> - Interface in org.apache.samza.table.remote: A function object to be used with a remote readable table implementation.
TableRetryPolicy - Class in org.apache.samza.table.retry: Common retry policy parameters for table IO.
TableRetryPolicy() - Constructor for class org.apache.samza.table.retry.TableRetryPolicy
TableRetryPolicy.RetryPredicate - Interface in org.apache.samza.table.retry: Serializable adapter interface for Predicate.
TABLES_PREFIX - Static variable in class org.apache.samza.config.JavaTableConfig
TableWriteFunction<K,V,U> - Interface in org.apache.samza.table.remote: A function object to be used with a remote read/write table implementation.
TaskApplication - Interface in org.apache.samza.application: A TaskApplication describes the inputs, outputs, state, configuration and the processing logic for the application in Samza's Low Level API.
TaskApplicationDescriptor - Interface in org.apache.samza.application.descriptors: A TaskApplicationDescriptor contains the description of inputs, outputs, state, configuration and the processing logic for a Samza Low Level API TaskApplication.
TaskBackupManager - Interface in org.apache.samza.storage: TaskBackupManager is the interface that must be implemented for any remote system that Samza persists its state to during the task commit operation.
TaskCallback - Interface in org.apache.samza.task: A TaskCallback is fired by a AsyncStreamTask to notify when an asynchronous process has completed.
TaskContext - Interface in org.apache.samza.context: The framework-provided context for the current task.
TaskCoordinator - Interface in org.apache.samza.task: TaskCoordinators are provided to the process methods of StreamTask implementations to allow the user code to request actions from the Samza framework, including committing the current checkpoints to configured org.apache.samza.checkpoint.CheckpointManager or shutting down the task or all tasks within a container.
TaskCoordinator.RequestScope - Enum in org.apache.samza.task: A task can make requests to the Samza framework while processing messages, such as TaskCoordinator.commit(RequestScope) and TaskCoordinator.shutdown(RequestScope).
TaskExecutorFactory - Interface in org.apache.samza.task: Factory for creating the executor used when running tasks in multi-thread mode.
TaskFactory<T> - Interface in org.apache.samza.task: The base interface for all task factories (i.e.
TaskMode - Enum in org.apache.samza.job.model: This defines the logical mode of a taskInstance.
TaskModel - Class in org.apache.samza.job.model: This contains metadata about a Samza task, such as the stream partitions that it is consuming.
TaskModel(TaskName, Set<SystemStreamPartition>, Partition, TaskMode) - Constructor for class org.apache.samza.job.model.TaskModel: Create a TaskModel for an active task with the given taskName, SSPs, and changelogPartition.
TaskModel(TaskName, Set<SystemStreamPartition>, Partition) - Constructor for class org.apache.samza.job.model.TaskModel: Create a TaskModel for an active task with the given taskName, SSPs, and changelogPartition.
TaskName - Class in org.apache.samza.container: A unique identifier of a set of a SystemStreamPartitions that have been grouped by a SystemStreamPartitionGrouper.
TaskName(String) - Constructor for class org.apache.samza.container.TaskName
TaskRestoreManager - Interface in org.apache.samza.storage: The helper interface restores task state.
throttle(K, Object...) - Method in class org.apache.samza.table.remote.TableRateLimiter: Throttle a request with a key argument if necessary.
throttle(K, V, Object...) - Method in class org.apache.samza.table.remote.TableRateLimiter: Throttle a request with both the key and value arguments if necessary.
throttle(int, Object...) - Method in class org.apache.samza.table.remote.TableRateLimiter: Throttle a request with opId and associated arguments
throttle(Collection<K>, Object...) - Method in class org.apache.samza.table.remote.TableRateLimiter: Throttle a request with a collection of keys as the argument if necessary.
throttleRecords(Collection<Entry<K, V>>, Object...) - Method in class org.apache.samza.table.remote.TableRateLimiter: Throttle a request with a collection of table records as the argument if necessary.
TimeBasedTrigger<M> - Interface in org.apache.samza.operators.triggers: A Trigger whose firing logic is determined by a time duration.
timer(Timer) - Method in class org.apache.samza.metrics.MetricsVisitor
Timer - Class in org.apache.samza.metrics: A timer metric that stores time duration and provides Snapshot of the durations.
Timer(String) - Constructor for class org.apache.samza.metrics.Timer: Default constructor.
Timer(String, long, Clock) - Constructor for class org.apache.samza.metrics.Timer: Construct a Timer with given window size
Timer(String, long, int, Clock) - Constructor for class org.apache.samza.metrics.Timer: Construct a Timer with given window size and collision buffer
Timer(String, Reservoir) - Constructor for class org.apache.samza.metrics.Timer: Construct a Timer with given Reservoir
timeSinceFirstMessage(Duration) - Static method in class org.apache.samza.operators.triggers.Triggers: Creates a trigger that fires after the specified duration has passed since the first message in the pane.
TimeSinceFirstMessageTrigger<M> - Class in org.apache.samza.operators.triggers
timeSinceLastMessage(Duration) - Static method in class org.apache.samza.operators.triggers.Triggers: Creates a trigger that fires when there is no new message for the specified duration in the pane.
TimeSinceLastMessageTrigger<M> - Class in org.apache.samza.operators.triggers
timestamp - Variable in class org.apache.samza.container.placement.ContainerPlacementMessage
TimestampedValue<V> - Class in org.apache.samza.util: An immutable pair of a value, and its corresponding timestamp.
TimestampedValue(V, long) - Constructor for class org.apache.samza.util.TimestampedValue
TimeTrigger<M> - Class in org.apache.samza.operators.triggers
TimeTrigger(Duration) - Constructor for class org.apache.samza.operators.triggers.TimeTrigger
toBytes(ByteBuffer) - Method in class org.apache.samza.serializers.ByteBufferSerde
toBytes(byte[]) - Method in class org.apache.samza.serializers.ByteSerde
toBytes(Double) - Method in class org.apache.samza.serializers.DoubleSerde
toBytes(Integer) - Method in class org.apache.samza.serializers.IntegerSerde
toBytes(T) - Method in class org.apache.samza.serializers.JsonSerdeV2
toBytes(KV<K, V>) - Method in class org.apache.samza.serializers.KVSerde
toBytes(Long) - Method in class org.apache.samza.serializers.LongSerde
toBytes(T) - Method in class org.apache.samza.serializers.NoOpSerde
toBytes(T) - Method in class org.apache.samza.serializers.SerializableSerde
toBytes(T) - Method in interface org.apache.samza.serializers.Serializer: Serializes given object to an array of bytes.
toBytes(String) - Method in class org.apache.samza.serializers.StringSerde
toBytes(UUID) - Method in class org.apache.samza.serializers.UUIDSerde
toConfig() - Method in class org.apache.samza.system.descriptors.InputDescriptor
toConfig() - Method in class org.apache.samza.system.descriptors.StreamDescriptor
toConfig() - Method in class org.apache.samza.system.descriptors.SystemDescriptor
toConfig(Config) - Method in class org.apache.samza.table.descriptors.BaseTableDescriptor
toConfig(Config) - Method in class org.apache.samza.table.descriptors.CachingTableDescriptor
toConfig(Config) - Method in class org.apache.samza.table.descriptors.GuavaCacheTableDescriptor
toConfig(Config) - Method in class org.apache.samza.table.descriptors.LocalTableDescriptor: Generate configuration for this table descriptor, the generated configuration should be the complete configuration for this table that can be directly included in the job configuration.
toConfig(Config) - Method in class org.apache.samza.table.descriptors.RemoteTableDescriptor
toConfig(Config) - Method in interface org.apache.samza.table.descriptors.TableDescriptor: Generate configuration for this table descriptor, the generated configuration should be the complete configuration for this table that can be directly included in the job configuration.
toConfig(Config, Config) - Method in interface org.apache.samza.table.remote.TablePart: Generate configuration for this building block.
toConfig(Config, Config) - Method in class org.apache.samza.table.retry.TableRetryPolicy: Generate configuration for this building block.
toJson(String, Object) - Static method in class org.apache.samza.table.utils.SerdeUtils: Helper method to serialize Java objects as json strings
toString() - Method in class org.apache.samza.checkpoint.CheckpointId
toString() - Method in class org.apache.samza.checkpoint.CheckpointV1
toString() - Method in class org.apache.samza.checkpoint.CheckpointV2
toString() - Method in class org.apache.samza.config.MapConfig
toString() - Method in class org.apache.samza.container.placement.ContainerPlacementRequestMessage
toString() - Method in class org.apache.samza.container.placement.ContainerPlacementResponseMessage
toString() - Method in class org.apache.samza.container.TaskName
toString() - Method in class org.apache.samza.drain.DrainNotification
toString() - Method in class org.apache.samza.job.ApplicationStatus
toString() - Method in class org.apache.samza.job.JobCoordinatorMetadata
toString() - Method in class org.apache.samza.job.model.ContainerModel
toString() - Method in class org.apache.samza.job.model.JobModel
toString() - Method in enum org.apache.samza.job.model.TaskMode
toString() - Method in class org.apache.samza.job.model.TaskModel
toString() - Method in class org.apache.samza.metrics.Counter
toString() - Method in class org.apache.samza.metrics.Gauge
toString() - Method in class org.apache.samza.operators.KV
toString() - Method in class org.apache.samza.operators.UpdateMessage
toString() - Method in class org.apache.samza.operators.windows.WindowKey
toString() - Method in class org.apache.samza.Partition
toString() - Method in class org.apache.samza.runtime.LocationId
toString() - Method in class org.apache.samza.sql.SamzaSqlRelRecord
toString() - Method in class org.apache.samza.startpoint.Startpoint
toString() - Method in class org.apache.samza.startpoint.StartpointOldest
toString() - Method in class org.apache.samza.startpoint.StartpointSpecific
toString() - Method in class org.apache.samza.startpoint.StartpointTimestamp
toString() - Method in class org.apache.samza.startpoint.StartpointUpcoming
toString() - Method in class org.apache.samza.storage.blobstore.Metadata
toString() - Method in class org.apache.samza.system.IncomingMessageEnvelope
toString() - Method in class org.apache.samza.system.OutgoingMessageEnvelope
toString() - Method in class org.apache.samza.system.StreamSpec
toString() - Method in class org.apache.samza.system.SystemStream
toString() - Method in class org.apache.samza.system.SystemStreamMetadata.SystemStreamPartitionMetadata
toString() - Method in class org.apache.samza.system.SystemStreamMetadata
toString() - Method in class org.apache.samza.system.SystemStreamPartition
toSystemStream() - Method in class org.apache.samza.system.StreamSpec
TransformingInputDescriptorProvider<InputTransformerType> - Interface in org.apache.samza.system.descriptors: Interface for advanced SystemDescriptors that constrain the type of returned InputDescriptors to their own InputTransformer function result types.
Trigger<M> - Interface in org.apache.samza.operators.triggers: Marker interface for all triggers.
Triggers - Class in org.apache.samza.operators.triggers: API for creating Trigger instances to be used with a Window.
tumblingWindow(Duration, SupplierFunction<? extends WV>, FoldLeftFunction<? super M, WV>, Serde<WV>) - Static method in class org.apache.samza.operators.windows.Windows: Creates a Window that windows values into fixed-size processing time based windows and aggregates them applying the provided function.
tumblingWindow(Duration, Serde<M>) - Static method in class org.apache.samza.operators.windows.Windows: Creates a Window that groups incoming messages into fixed-size, non-overlapping processing time based windows.

U

unlisten(ReadableMetricsRegistryListener) - Method in interface org.apache.samza.metrics.ReadableMetricsRegistry
UnsuccessfulFinish - Static variable in class org.apache.samza.job.ApplicationStatus
unsuccessfulFinish(Throwable) - Static method in class org.apache.samza.job.ApplicationStatus
update(long) - Method in interface org.apache.samza.metrics.Reservoir: Update the reservoir with the new value
update(long) - Method in class org.apache.samza.metrics.SamzaHistogram
update(long) - Method in class org.apache.samza.metrics.SlidingTimeWindowReservoir
update(long) - Method in class org.apache.samza.metrics.Timer: Add the time duration
update(IncomingMessageEnvelope) - Method in interface org.apache.samza.system.chooser.MessageChooser: Notify the chooser that a new envelope is available for a processing.
update(K, Void) - Method in interface org.apache.samza.table.ReadWriteTable: Updates the record associated with a given key with the specified update.
update(K, U) - Method in interface org.apache.samza.table.ReadWriteUpdateTable: Updates the record associated with a given key with the specified update.
updateAll(List<Entry<K, Void>>) - Method in interface org.apache.samza.table.ReadWriteTable: Updates the mappings of the given keys with the corresponding updates.
updateAll(List<Entry<K, U>>) - Method in interface org.apache.samza.table.ReadWriteUpdateTable: Updates the mappings of the given keys with the corresponding updates.
updateAllAsync(List<Entry<K, U>>) - Method in interface org.apache.samza.table.AsyncReadWriteUpdateTable: Asynchronously updates the existing records for the given keys with their corresponding updates.
updateAllAsync(Collection<Entry<K, U>>) - Method in interface org.apache.samza.table.remote.TableWriteFunction: Asynchronously updates the table with multiple updates.
updateAsync(K, U) - Method in interface org.apache.samza.table.AsyncReadWriteUpdateTable: Asynchronously updates an existing record for a given key with the specified update.
updateAsync(K, U) - Method in interface org.apache.samza.table.remote.TableWriteFunction: Asynchronously update the resource for a given key with the update.
updateGaugeValues(double) - Method in class org.apache.samza.metrics.SamzaHistogram
UpdateMessage<U,V> - Class in org.apache.samza.operators: Represents an update and an optional default record to be inserted for a key, if the update is applied to a non-existent record.
UpdateOptions - Enum in org.apache.samza.operators: This class defines the update contract used in the send-to-table-with-update operator.
upload(CheckpointId, Map<String, String>) - Method in interface org.apache.samza.storage.TaskBackupManager: Upload is used to persist the state provided by the TaskBackupManager.snapshot(CheckpointId) to the underlying backup system.
url - Variable in class org.apache.samza.job.CommandBuilder
uuid - Variable in class org.apache.samza.container.placement.ContainerPlacementMessage: Unique identifier of a request or response message.
UUIDSerde - Class in org.apache.samza.serializers: A serializer for UUID
UUIDSerde() - Constructor for class org.apache.samza.serializers.UUIDSerde
UUIDSerdeFactory - Class in org.apache.samza.serializers
UUIDSerdeFactory() - Constructor for class org.apache.samza.serializers.UUIDSerdeFactory

V

validate(MetricsAccessor) - Method in interface org.apache.samza.metrics.MetricsValidator: Validate the metrics values of a job
validate() - Method in class org.apache.samza.table.descriptors.BaseTableDescriptor: Validate that this table descriptor is constructed properly; this method is used internally.
validate() - Method in class org.apache.samza.table.descriptors.CachingTableDescriptor
validate() - Method in class org.apache.samza.table.descriptors.GuavaCacheTableDescriptor
validate() - Method in class org.apache.samza.table.descriptors.LocalTableDescriptor
validate() - Method in class org.apache.samza.table.descriptors.RemoteTableDescriptor
validateResources() - Method in interface org.apache.samza.storage.StateBackendAdmin: Validate all resources required per job per state for state backend
validateStream(StreamSpec) - Method in interface org.apache.samza.system.SystemAdmin: Validates the stream described by the streamSpec on the system.
value - Variable in class org.apache.samza.operators.KV
valueOf(String) - Static method in enum org.apache.samza.application.ApplicationApiType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.samza.container.placement.ContainerPlacementMessage.StatusCode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.samza.drain.DrainMode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.samza.job.ApplicationStatus.StatusCode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.samza.job.JobMetadataChange: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.samza.job.model.TaskMode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.samza.operators.triggers.DurationCharacteristic: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.samza.operators.triggers.FiringType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.samza.operators.UpdateOptions: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.samza.operators.windows.AccumulationMode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.samza.operators.windows.internal.WindowType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.samza.sql.schema.SamzaSqlFieldType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.samza.storage.StorageEngineFactory.StoreMode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.samza.system.ChangelogSSPIterator.Mode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.samza.system.MessageType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.samza.system.SystemStreamMetadata.OffsetType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.samza.task.TaskCoordinator.RequestScope: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.samza.application.ApplicationApiType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Method in class org.apache.samza.config.MapConfig
values() - Static method in enum org.apache.samza.container.placement.ContainerPlacementMessage.StatusCode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.samza.drain.DrainMode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.samza.job.ApplicationStatus.StatusCode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.samza.job.JobMetadataChange: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.samza.job.model.TaskMode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.samza.operators.triggers.DurationCharacteristic: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.samza.operators.triggers.FiringType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.samza.operators.UpdateOptions: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.samza.operators.windows.AccumulationMode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.samza.operators.windows.internal.WindowType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.samza.sql.schema.SamzaSqlFieldType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.samza.storage.StorageEngineFactory.StoreMode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.samza.system.ChangelogSSPIterator.Mode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.samza.system.MessageType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.samza.system.SystemStreamMetadata.OffsetType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.samza.task.TaskCoordinator.RequestScope: Returns an array containing the constants of this enum type, in the order they are declared.
visit(MetricsVisitor) - Method in class org.apache.samza.metrics.Counter
visit(MetricsVisitor) - Method in class org.apache.samza.metrics.Gauge
visit(MetricsVisitor) - Method in interface org.apache.samza.metrics.Metric
visit(Metric) - Method in class org.apache.samza.metrics.MetricsVisitor
visit(MetricsVisitor) - Method in class org.apache.samza.metrics.Timer
visit(IN, StartpointSpecific) - Method in interface org.apache.samza.startpoint.StartpointVisitor: Performs a sequence of operations using IN and StartpointSpecific and returns the result of the execution.
visit(IN, StartpointTimestamp) - Method in interface org.apache.samza.startpoint.StartpointVisitor: Performs a sequence of operations using IN and StartpointTimestamp and returns the result of the execution.
visit(IN, StartpointOldest) - Method in interface org.apache.samza.startpoint.StartpointVisitor: Performs a sequence of operations using IN and StartpointOldest and returns the result of the execution.
visit(IN, StartpointUpcoming) - Method in interface org.apache.samza.startpoint.StartpointVisitor: Performs a sequence of operations using IN and StartpointUpcoming and returns the result of the execution.

W

waitForFinish(long) - Method in interface org.apache.samza.job.StreamJob: Block on this job until either it finishes or reaches its timeout value
waitForFinish() - Method in interface org.apache.samza.runtime.ApplicationRunner: Waits until the application finishes.
waitForFinish(Duration) - Method in interface org.apache.samza.runtime.ApplicationRunner: Waits for timeout duration for the application to finish.
waitForStatus(ApplicationStatus, long) - Method in interface org.apache.samza.job.StreamJob: Block on this job until either it transitions to the specified status or reaches it timeout value
WatermarkFunction<T> - Interface in org.apache.samza.operators.functions: Allows handling of watermarks.
WatermarkMessage - Class in org.apache.samza.system: The WatermarkMessage is a control message that is sent out to next stage with a watermark timestamp and the task that produces the watermark.
WatermarkMessage(long) - Constructor for class org.apache.samza.system.WatermarkMessage
WatermarkMessage(long, String) - Constructor for class org.apache.samza.system.WatermarkMessage
window(Window<M, K, WV>, String) - Method in interface org.apache.samza.operators.MessageStream: Groups the messages in this MessageStream according to the provided Window semantics (e.g.
Window<M,K,WV> - Interface in org.apache.samza.operators.windows: Groups incoming messages in the MessageStream into finite windows for processing.
window(MessageCollector, TaskCoordinator) - Method in interface org.apache.samza.task.WindowableTask: Called by TaskRunner for each implementing task at the end of every specified window.
WindowableTask - Interface in org.apache.samza.task: Add-on interface to StreamTask implementations to add code which will be run on a specified time interval (via configuration).
WindowInternal<M,WK,WV> - Class in org.apache.samza.operators.windows.internal: Internal representation of a Window.
WindowInternal(Trigger<M>, SupplierFunction<WV>, FoldLeftFunction<M, WV>, MapFunction<M, WK>, MapFunction<M, Long>, WindowType, Serde<WK>, Serde<WV>, Serde<M>) - Constructor for class org.apache.samza.operators.windows.internal.WindowInternal
WindowKey<K> - Class in org.apache.samza.operators.windows: Key for a WindowPane emitted from a Window.
WindowKey(K, String) - Constructor for class org.apache.samza.operators.windows.WindowKey
WindowPane<K,V> - Class in org.apache.samza.operators.windows: Specifies the result emitted from a Window.
WindowPane(WindowKey<K>, V, AccumulationMode, FiringType) - Constructor for class org.apache.samza.operators.windows.WindowPane
Windows - Class in org.apache.samza.operators.windows: APIs for creating different types of Windows.
WindowType - Enum in org.apache.samza.operators.windows.internal
withApplicationContainerContextFactory(ApplicationContainerContextFactory<?>) - Method in interface org.apache.samza.application.descriptors.ApplicationDescriptor: Sets the ApplicationContainerContextFactory for this application.
withApplicationTaskContextFactory(ApplicationTaskContextFactory<?>) - Method in interface org.apache.samza.application.descriptors.ApplicationDescriptor: Sets the ApplicationTaskContextFactory for this application.
withAsyncCallbackExecutorPoolSize(int) - Method in class org.apache.samza.table.descriptors.RemoteTableDescriptor: Specify the size of the thread pool for the executor used to execute callbacks of CompletableFutures of async Table operations.
withBatchProvider(BatchProvider<K, V, U>) - Method in class org.apache.samza.table.descriptors.RemoteTableDescriptor: Specifies a batch provider inorder to batch Table operations.
withCache(Cache<K, V>) - Method in class org.apache.samza.table.descriptors.GuavaCacheTableDescriptor: Specify a pre-configured Guava cache instance to be used for caching table.
withCacheSize(long) - Method in class org.apache.samza.table.descriptors.CachingTableDescriptor: Specify the max cache size for size-based eviction.
withChangelogEnabled() - Method in class org.apache.samza.table.descriptors.LocalTableDescriptor: Enable changelog for this table, by default changelog is disabled.
withChangelogReplicationFactor(int) - Method in class org.apache.samza.table.descriptors.LocalTableDescriptor: The property defines the number of replicas to use for the change log stream.
withChangelogStream(String) - Method in class org.apache.samza.table.descriptors.LocalTableDescriptor: Samza stores are local to a container.
withConfig(String, String) - Method in class org.apache.samza.table.descriptors.BaseTableDescriptor: Add a configuration entry for the table
withDefaultStreamConfigs(Map<String, String>) - Method in class org.apache.samza.system.descriptors.SystemDescriptor: Default properties for any stream obtained using this system descriptor.
withDefaultStreamOffsetDefault(SystemStreamMetadata.OffsetType) - Method in class org.apache.samza.system.descriptors.SystemDescriptor: If a container starts up without a checkpoint, this property determines where in the input stream we should start consuming.
withDefaultSystem(SystemDescriptor<?>) - Method in interface org.apache.samza.application.descriptors.ApplicationDescriptor: Sets the SystemDescriptor for the default system for the application.
withExponentialBackoff(Duration, Duration, double) - Method in class org.apache.samza.table.retry.TableRetryPolicy: Set the parameters for the exponential backoff policy.
withFixedBackoff(Duration) - Method in class org.apache.samza.table.retry.TableRetryPolicy: Set the sleepTime time for the fixed backoff policy.
withInputStream(InputDescriptor) - Method in interface org.apache.samza.application.descriptors.TaskApplicationDescriptor: Adds the input stream to the application.
withJitter(Duration) - Method in class org.apache.samza.table.retry.TableRetryPolicy: Set the jitter for the backoff policy to provide additional randomness.
withMaxBatchDelay(Duration) - Method in class org.apache.samza.table.batching.BatchProvider
withMaxBatchSize(int) - Method in class org.apache.samza.table.batching.BatchProvider
withMetricsReporterFactories(Map<String, MetricsReporterFactory>) - Method in interface org.apache.samza.application.descriptors.ApplicationDescriptor: Sets the MetricsReporterFactorys for creating the MetricsReporters to use for the application.
withOffsetDefault(SystemStreamMetadata.OffsetType) - Method in class org.apache.samza.system.descriptors.InputDescriptor: If a container starts up without a checkpoint, this property determines where in the input stream we should start consuming.
withOutputStream(OutputDescriptor) - Method in interface org.apache.samza.application.descriptors.TaskApplicationDescriptor: Adds the output stream to the application.
withPhysicalName(String) - Method in class org.apache.samza.system.descriptors.StreamDescriptor: The physical name of the stream on the system on which this stream will be accessed.
withPriority(int) - Method in class org.apache.samza.system.descriptors.InputDescriptor: If one or more streams have a priority set (any positive integer), they will be processed with higher priority than the other streams.
withProcessorLifecycleListenerFactory(ProcessorLifecycleListenerFactory) - Method in interface org.apache.samza.application.descriptors.ApplicationDescriptor: Sets the ProcessorLifecycleListenerFactory for this application.
withRandomBackoff(Duration, Duration) - Method in class org.apache.samza.table.retry.TableRetryPolicy: Set the sleepTime time for the random backoff policy.
withRateLimiter(RateLimiter, TableRateLimiter.CreditFunction<K, V>, TableRateLimiter.CreditFunction<K, V>) - Method in class org.apache.samza.table.descriptors.RemoteTableDescriptor: Specify a rate limiter along with credit functions to map a table record (as KV) to the amount of credits to be charged from the rate limiter for table read and write operations.
withRateLimiterDisabled() - Method in class org.apache.samza.table.descriptors.RemoteTableDescriptor: Disable both read and write rate limiter.
withReadFunction(TableReadFunction<K, V>) - Method in class org.apache.samza.table.descriptors.RemoteTableDescriptor: Use specified TableReadFunction with remote table and a retry policy.
withReadRateLimit(int) - Method in class org.apache.samza.table.descriptors.RemoteTableDescriptor: Specify the rate limit for table read operations.
withReadRateLimiterDisabled() - Method in class org.apache.samza.table.descriptors.RemoteTableDescriptor: Disable the read rate limiter.
withReadRetryPolicy(TableRetryPolicy) - Method in class org.apache.samza.table.descriptors.RemoteTableDescriptor: Use specified TableRetryPolicy with the TableReadFunction.
withReadTtl(Duration) - Method in class org.apache.samza.table.descriptors.CachingTableDescriptor: Specify the TTL for each read access, ie.
withRetryPredicate(TableRetryPolicy.RetryPredicate) - Method in class org.apache.samza.table.retry.TableRetryPolicy: Set the predicate to use for identifying retriable exceptions.
withSideInputs(List<String>) - Method in class org.apache.samza.table.descriptors.LocalTableDescriptor: Add side inputs to the table.
withSideInputsProcessor(SideInputsProcessor) - Method in class org.apache.samza.table.descriptors.LocalTableDescriptor: Provide the SideInputsProcessor for this table.
withStopAfterAttempts(int) - Method in class org.apache.samza.table.retry.TableRetryPolicy: Set maximum number of attempts before terminating the operation.
withStopAfterDelay(Duration) - Method in class org.apache.samza.table.retry.TableRetryPolicy: Set maximum total delay (sleepTime + execution) before terminating the operation.
withStreamConfigs(Map<String, String>) - Method in class org.apache.samza.system.descriptors.StreamDescriptor: Additional system-specific properties for this stream.
withSystemConfigs(Map<String, String>) - Method in class org.apache.samza.system.descriptors.SystemDescriptor: Additional system-specific properties for this system.
withTable(TableDescriptor) - Method in interface org.apache.samza.application.descriptors.TaskApplicationDescriptor: Adds the TableDescriptor used in the application
withTaskFactory(TaskFactory) - Method in interface org.apache.samza.application.descriptors.TaskApplicationDescriptor: Sets the StreamTaskFactory or AsyncStreamTaskFactory for the StreamTask or AsyncStreamTask implementation that contains the processing logic for the TaskApplication.
withWriteAround() - Method in class org.apache.samza.table.descriptors.CachingTableDescriptor: Specify if write-around policy should be used to bypass writing to cache for put operations.
withWriteFunction(TableWriteFunction<K, V, U>) - Method in class org.apache.samza.table.descriptors.RemoteTableDescriptor: Use specified TableWriteFunction with remote table and a retry policy.
withWriteRateLimit(int) - Method in class org.apache.samza.table.descriptors.RemoteTableDescriptor: Specify the rate limit for table write operations.
withWriteRateLimiterDisabled() - Method in class org.apache.samza.table.descriptors.RemoteTableDescriptor: Disable the write rate limiter.
withWriteRetryPolicy(TableRetryPolicy) - Method in class org.apache.samza.table.descriptors.RemoteTableDescriptor: Use specified TableRetryPolicy with the TableWriteFunction.
withWriteTtl(Duration) - Method in class org.apache.samza.table.descriptors.CachingTableDescriptor: Specify the TTL for each write access, ie.
write(int, Object...) - Method in interface org.apache.samza.table.ReadWriteTable: Executes a write operation.
write(int, Object...) - Method in interface org.apache.samza.table.ReadWriteUpdateTable: Executes a write operation.
WRITE_AROUND - Static variable in class org.apache.samza.table.descriptors.CachingTableDescriptor
WRITE_CREDIT_FN - Static variable in class org.apache.samza.table.descriptors.RemoteTableDescriptor
WRITE_CREDITS - Static variable in class org.apache.samza.table.descriptors.RemoteTableDescriptor
WRITE_FN - Static variable in class org.apache.samza.table.descriptors.RemoteTableDescriptor
WRITE_RETRY_POLICY - Static variable in class org.apache.samza.table.descriptors.RemoteTableDescriptor
WRITE_TTL_MS - Static variable in class org.apache.samza.table.descriptors.CachingTableDescriptor
writeAsync(int, Object...) - Method in interface org.apache.samza.table.AsyncReadWriteUpdateTable: Asynchronously executes a write operation.
writeAsync(int, Object...) - Method in interface org.apache.samza.table.remote.TableWriteFunction: Asynchronously write data to table for specified opId and additional arguments.
writeCheckpoint(TaskName, Checkpoint) - Method in interface org.apache.samza.checkpoint.CheckpointManager: Writes a checkpoint based on the current state of a Samza stream partition.

A B C D E F G H I J K L M N O P R S T U V W