org.apache.samza.system.descriptors

Class OutputDescriptor<StreamMessageType,SubClass extends OutputDescriptor<StreamMessageType,SubClass>>

java.lang.Object

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

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

Type Parameters:

StreamMessageType - type of messages in this stream.

SubClass - type of the concrete sub-class

Direct Known Subclasses:

GenericOutputDescriptor

public abstract class OutputDescriptor<StreamMessageType,SubClass extends OutputDescriptor<StreamMessageType,SubClass>>
extends StreamDescriptor<StreamMessageType,SubClass>

An OutputDescriptor can be used for specifying Samza and system-specific properties of output streams.

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

This is the base descriptor for an output stream. Use a system-specific input descriptor (e.g. KafkaOutputDescriptor) obtained from its system descriptor (e.g. KafkaSystemDescriptor) if one is available. Otherwise use the GenericOutputDescriptor obtained from a GenericSystemDescriptor.

Constructor Summary

Constructors

Constructor and Description
OutputDescriptor(java.lang.String streamId, Serde serde, SystemDescriptor systemDescriptor) Constructs an OutputDescriptor instance.

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

Constructor Detail

OutputDescriptor

public OutputDescriptor(java.lang.String streamId,
                        Serde serde,
                        SystemDescriptor systemDescriptor)

Constructs an OutputDescriptor instance.

Parameters:

streamId - id of the stream

serde - serde for messages in the stream

systemDescriptor - system descriptor this stream descriptor was obtained from