org.apache.samza.system.descriptors

Class GenericOutputDescriptor<StreamMessageType>

java.lang.Object

org.apache.samza.system.descriptors.StreamDescriptor<StreamMessageType,SubClass>

org.apache.samza.system.descriptors.OutputDescriptor<StreamMessageType,GenericOutputDescriptor<StreamMessageType>>

org.apache.samza.system.descriptors.GenericOutputDescriptor<StreamMessageType>

Type Parameters:

StreamMessageType - type of messages in this stream.

public final class GenericOutputDescriptor<StreamMessageType>
extends OutputDescriptor<StreamMessageType,GenericOutputDescriptor<StreamMessageType>>

A GenericOutputDescriptor can be used for specifying Samza and system-specific properties of output streams.

If the system provides its own system and stream descriptor implementations, use them instead. Otherwise, use this GenericOutputDescriptor to specify Samza-specific properties of the stream, and StreamDescriptor.withStreamConfigs(java.util.Map<java.lang.String, java.lang.String>) to specify additional system specific properties.

Use GenericSystemDescriptor.getOutputDescriptor(java.lang.String, org.apache.samza.serializers.Serde<StreamMessageType>) to obtain an instance of this descriptor.

Stream properties provided in configuration override corresponding properties specified using a descriptor.

Method Summary

Methods inherited from class org.apache.samza.system.descriptors.StreamDescriptor

getPhysicalName, getSerde, getStreamId, getSystemDescriptor, getSystemName, toConfig, withPhysicalName, withStreamConfigs

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait