org.apache.samza.system.descriptors

Interface OutputDescriptorProvider

All Known Implementing Classes:

GenericSystemDescriptor

public interface OutputDescriptorProvider

Interface for simple SystemDescriptors that return OutputDescriptors parameterized by the type of the provided stream level serde.

Method Summary

Modifier and Type	Method and Description
<StreamMessageType> OutputDescriptor<StreamMessageType,? extends OutputDescriptor>	getOutputDescriptor(java.lang.String streamId, Serde<StreamMessageType> serde) Gets an OutputDescriptor representing an output stream on this system that uses the provided stream specific serde instead of the default system serde.

Method Detail

getOutputDescriptor

<StreamMessageType> OutputDescriptor<StreamMessageType,? extends OutputDescriptor> getOutputDescriptor(java.lang.String streamId,
                                                                                                       Serde<StreamMessageType> serde)

Gets an OutputDescriptor representing an output stream on this system that uses the provided stream specific serde instead of the default system serde.

An OutputStream<KV<K, V>>, obtained using a descriptor with a KVSerde<K, V>, can send messages of type KV<K, V>. An OutputStream<M> with any other Serde<M> can send messages of type M without a key.

A KVSerde<NoOpSerde, NoOpSerde> or NoOpSerde may be used if the SystemProducer serializes the outgoing messages itself, and no prior serialization is required from the framework.

Type Parameters:

StreamMessageType - type of messages in the output stream

Parameters:

streamId - id of the output stream

serde - serde for this output stream that overrides the default system serde, if any.

Returns:

the OutputDescriptor for the output stream