org.apache.samza.system.descriptors (samza-api 1.9.0-SNAPSHOT API)
JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev Package
Next Package
Frames
No Frames
All Classes
Package org.apache.samza.system.descriptors
Interface Summary 
Interface
Description
ExpandingInputDescriptorProvider<StreamExpanderType>
Interface for advanced SystemDescriptors that constrain the type of returned InputDescriptors to
their own StreamExpander function result types.
InputTransformer<OM>
Transforms an IncomingMessageEnvelope with deserialized key and message to a message of type OM
which is delivered to the MessageStream.
OutputDescriptorProvider
Interface for simple SystemDescriptors that return OutputDescriptors parameterized by the type of
the provided stream level serde.
SimpleInputDescriptorProvider
Interface for simple SystemDescriptors that return InputDescriptors parameterized by the type of
the provided stream level serde.
StreamExpander<OM>
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.
TransformingInputDescriptorProvider<InputTransformerType>
Interface for advanced SystemDescriptors that constrain the type of returned InputDescriptors to
their own InputTransformer function result types.
Class Summary 
Class
Description
GenericInputDescriptor<StreamMessageType>
A GenericInputDescriptor can be used for specifying Samza and system-specific properties of
input streams.
GenericOutputDescriptor<StreamMessageType>
A GenericOutputDescriptor can be used for specifying Samza and system-specific properties of
output streams.
GenericSystemDescriptor
A GenericSystemDescriptor can be used for specifying Samza and system-specific properties of an
input/output system.
InputDescriptor<StreamMessageType,SubClass extends InputDescriptor<StreamMessageType,SubClass>>
An InputDescriptor can be used for specifying Samza and system-specific properties of input streams.
OutputDescriptor<StreamMessageType,SubClass extends OutputDescriptor<StreamMessageType,SubClass>>
An OutputDescriptor can be used for specifying Samza and system-specific properties of output streams.
StreamDescriptor<StreamMessageType,SubClass extends StreamDescriptor<StreamMessageType,SubClass>>
A StreamDescriptor can be used for specifying Samza and system-specific properties of input/output streams.
SystemDescriptor<SubClass extends SystemDescriptor<SubClass>>
A SystemDescriptor can be used for specifying Samza and system-specific properties of an input/output system.
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev Package
Next Package
Frames
No Frames
All Classes