- SamzaContainerContext - Class in org.apache.samza.container
-
A SamzaContainerContext maintains per-container information for the tasks it executes.
- SamzaContainerContext(int, Config, Collection<TaskName>) - Constructor for class org.apache.samza.container.SamzaContainerContext
-
An immutable context object that can passed to tasks to give them information
about the container in which they are executing.
- 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
-
- sanitize() - Method in class org.apache.samza.config.Config
-
- sanitize() - Method in class org.apache.samza.config.MapConfig
-
- 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.
- SENSITIVE_MASK - Static variable in class org.apache.samza.config.Config
-
- SENSITIVE_PREFIX - Static variable in class org.apache.samza.config.Config
-
- 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.
- SerdeFactory<T> - Interface in org.apache.samza.serializers
-
Build an instance of
Serde
- 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
-
- setConfig(Config) - Method in class org.apache.samza.job.CommandBuilder
-
- setId(int) - Method in class org.apache.samza.job.CommandBuilder
-
- setIsAtHead(SystemStreamPartition, boolean) - Method in class org.apache.samza.util.BlockingEnvelopeMap
-
- setNoMoreMessages(SystemStreamPartition, boolean) - Method in class org.apache.samza.util.BlockingEnvelopeMap.BlockingEnvelopeMapMetrics
-
- setStartingOffset(SystemStreamPartition, String) - Method in interface org.apache.samza.task.TaskContext
-
- setUrl(URL) - Method in class org.apache.samza.job.CommandBuilder
-
- shutdown(TaskCoordinator.RequestScope) - Method in interface org.apache.samza.task.TaskCoordinator
-
Requests that the container should be shut down.
- 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
-
- 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
-
- 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
-
- Snapshot - Class in org.apache.samza.metrics
-
A statistical snapshot of a collection of values
- Snapshot(Collection<Long>) - Constructor for class org.apache.samza.metrics.Snapshot
-
- start() - Method in interface org.apache.samza.checkpoint.CheckpointManager
-
- 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.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.
- stop() - Method in interface org.apache.samza.checkpoint.CheckpointManager
-
- 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.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.
- stream - Variable in class org.apache.samza.system.SystemStream
-
- StreamJob - Interface in org.apache.samza.job
-
A StreamJob runs Samza
StreamTasks in its specific environment.
- StreamJobFactory - Interface in org.apache.samza.job
-
- StreamTask - Interface in org.apache.samza.task
-
A StreamTask is the basic class on which Samza jobs are implemented.
- 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
-
- system - Variable in class org.apache.samza.system.SystemStream
-
- 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.
- SystemFactory - Interface in org.apache.samza.system
-
- 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.
- 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
-
- 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.
- 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
-
- SystemStreamPartitionIterator(SystemConsumer, SystemStreamPartition) - Constructor for class org.apache.samza.system.SystemStreamPartitionIterator
-
- SystemStreamPartitionIterator(SystemConsumer, SystemStreamPartition, int) - Constructor for class org.apache.samza.system.SystemStreamPartitionIterator
-
- SystemStreamPartitionMetadata(String, String, String) - Constructor for class org.apache.samza.system.SystemStreamMetadata.SystemStreamPartitionMetadata
-