| 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 | 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. |