Search Java Classes and Packages

Search Java Frameworks and Libraries

255581 classes and counting ...
Search Tips Index Status

# Classes and Interfaces in #Apache Samza - 52 results found.
ApplicationStatusenum ApplicationStatusStatus of a StreamJob during and after its run.Classorg.apache.samza.jobApache Samzajavadoc
BaseMessageChooserAn abstract MessageChooser that implements start/stop/register for choosers that don't use them.Classorg.apache.samza.system.chooserApache Samzajavadoc
BlockingEnvelopeMap BlockingEnvelopeMap is a helper class for SystemConsumer implementations.Classorg.apache.samza.utilApache Samzajavadoc
CheckpointA checkpoint is a mapping of all the streams a job is consuming and the most recent current offset for each.Classorg.apache.samza.checkpointApache Samzajavadoc
CheckpointManagerCheckpointManagers read and write Checkpoint to some implementation-specific location.Interfaceorg.apache.samza.checkpointApache Samzajavadoc
CheckpointManagerFactoryBuild a CheckpointManager.Interfaceorg.apache.samza.checkpointApache Samzajavadoc
ClosableTaskA ClosableTask augments StreamTask, allowing the method implementer to specify code that will be called when the StreamTask is being shut down by the framework, providing to emit final metrics,Interfaceorg.apache.samza.taskApache Samzajavadoc
CommandBuilderCommandBuilders are used to customize the command necessary to launch a Samza Job for a particular framework, such as YARN or the LocalJobRunner.Classorg.apache.samza.jobApache Samzajavadoc
ConfigStore and retrieve named, typed values as configuration for classes implementing this interface.Classorg.apache.samza.configApache Samzajavadoc
ConfigExceptionSpecific SamzaExceptions thrown from ConfigSee Also:Serialized FormClassorg.apache.samza.configApache Samzajavadoc
ConfigFactoryInterfaceorg.apache.samza.configApache Samzajavadoc
ConfigRewriterA 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.Interfaceorg.apache.samza.configApache Samzajavadoc
CounterA counter is a Metric that represents a cumulative value.Classorg.apache.samza.metricsApache Samzajavadoc
DeserializerInterfaceorg.apache.samza.serializersApache Samzajavadoc
GaugeA Gauge is a Metric that wraps some instance of T in a thread-safe reference and allows it to be set or retrieved.Classorg.apache.samza.metricsApache Samzajavadoc
IncomingMessageEnvelopeThis 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.Classorg.apache.samza.systemApache Samzajavadoc
InitableTaskUsed as an interface for user processing StreamTasks that need to have specific functionality performed as their StreamTasks are instantiated by TaskRunner.Interfaceorg.apache.samza.taskApache Samzajavadoc
MapConfigClassorg.apache.samza.configApache Samzajavadoc
MessageChooserMessageChooser is an interface for programmatic fine-grain control over stream consumption.Interfaceorg.apache.samza.system.chooserApache Samzajavadoc
MessageChooserFactoryInterfaceorg.apache.samza.system.chooserApache Samzajavadoc
MessageCollectorUsed as an interface for the means of sending message envelopes to an output stream.Interfaceorg.apache.samza.taskApache Samzajavadoc
MetricsRegistryA MetricsRegistry allows its users to create new Metrics and have those metrics wired to specific metrics systems, such as JMX, provided by MetricsReporters.Interfaceorg.apache.samza.metricsApache Samzajavadoc
MetricsReporterA MetricsReporter is the interface that different metrics sinks, such as JMX, implement to receive metrics from the Samza framework and Samza jobs.Interfaceorg.apache.samza.metricsApache Samzajavadoc
MetricsReporterFactoryInterfaceorg.apache.samza.metricsApache Samzajavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from
Enter your email address:
Delivered by FeedBurner

MetricsVisitorA 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.Classorg.apache.samza.metricsApache Samzajavadoc
NoOpMetricsRegistryMetricsRegistry implementation for when no actual metrics need to be recorded but a registry is still required.Classorg.apache.samza.utilApache Samzajavadoc
OutgoingMessageEnvelopeAn OutgoingMessageEnvelope is sent to a specified SystemStream via the appropriate SystemProducer from the user's StreamTask.Classorg.apache.samza.systemApache Samzajavadoc
PartitionA numbered, ordered partition of a stream.Classorg.apache.samzaApache Samzajavadoc
ReadableMetricsRegistryA ReadableMetricsRegistry is a MetricsRegistry that also allows read access to the metrics for which it is responsible.Interfaceorg.apache.samza.metricsApache Samzajavadoc
ReadableMetricsRegistryListenerInterfaceorg.apache.samza.metricsApache Samzajavadoc
SamzaContainerContextA SamzaContainerContext maintains per-container information for the tasks it executes.Classorg.apache.samza.containerApache Samzajavadoc
SamzaExceptionUnchecked exception that Samza throws when something goes wrong.Classorg.apache.samzaApache Samzajavadoc
SerdeA Serde is a convenience type that implements both the Serializer and Deserializer interfaces, allowing it to both read and write dataInterfaceorg.apache.samza.serializersApache Samzajavadoc
SerializerA standard interface for Samza compatible serializers, used for serializing objects to bytes.Interfaceorg.apache.samza.serializersApache Samzajavadoc
SinglePartitionWithoutOffsetsSystemAdminA simple helper admin class that defines a single partition (partition 0) for a given system.Classorg.apache.samza.utilApache Samzajavadoc
StorageEngineA storage engine for managing state maintained by a stream processor.Interfaceorg.apache.samza.storageApache Samzajavadoc
StorageEngineFactoryAn object provided by the storage engine implementation to create instances of the given storage engine type.Interfaceorg.apache.samza.storageApache Samzajavadoc
StreamJobA StreamJob runs Samza StreamTasks in its specific environment.Interfaceorg.apache.samza.jobApache Samzajavadoc
StreamTaskA StreamTask is the basic class on which Samza jobs are implemented.Interfaceorg.apache.samza.taskApache Samzajavadoc
SystemAdminHelper interface attached to an underlying system to fetch information about streams, partitions, offsets, etc.Interfaceorg.apache.samza.systemApache Samzajavadoc
SystemConsumer SystemConsumer is the interface that must be implemented by any system that wishes to integrate with Samza.Interfaceorg.apache.samza.systemApache Samzajavadoc
SystemFactoryBuild the SystemConsumer and SystemProducer for a particular system, as well as the accompanying SystemAdmin.Interfaceorg.apache.samza.systemApache Samzajavadoc
SystemProducerSystemProducers are how Samza writes messages from StreamTasks to outside systems, such as messaging systems like Kafka, or file systems.Interfaceorg.apache.samza.systemApache Samzajavadoc
SystemStreamStreams in Samza consist of both the stream name and the system to which the stream belongs.Classorg.apache.samza.systemApache Samzajavadoc
SystemStreamMetadataSystemAdmins use this class to return useful metadata about a stream's offset and partition information.Classorg.apache.samza.systemApache Samzajavadoc
SystemStreamPartitionAggregate object representing a both the SystemStream and Partition.Classorg.apache.samza.systemApache Samzajavadoc
SystemStreamPartitionIteratorIterator that wraps a SystemConsumer to iterate over the messages the consumer provides for the specified SystemStreamPartition.Classorg.apache.samza.systemApache Samzajavadoc
TaskContextA TaskContext provides resources about the StreamTask, particularly during initialization in an InitableTask and during calls to TaskLifecycleListeners.Interfaceorg.apache.samza.taskApache Samzajavadoc
TaskCoordinatorTaskCoordinators 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 checkpointsInterfaceorg.apache.samza.taskApache Samzajavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from
Enter your email address:
Delivered by FeedBurner

TaskLifecycleListenerUsed to get before/after notifications before initializing/closing all tasks in a given container (JVM/process).Interfaceorg.apache.samza.taskApache Samzajavadoc
TaskLifecycleListenerFactoryInterfaceorg.apache.samza.taskApache Samzajavadoc
WindowableTaskAdd-on interface to StreamTask implementations to add code which will be run on a specified time interval (via configuration).Interfaceorg.apache.samza.taskApache Samzajavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from
Enter your email address:
Delivered by FeedBurner

comments powered by Disqus