org.apache.samza.system.descriptors

Interface SimpleInputDescriptorProvider

All Known Implementing Classes:

GenericSystemDescriptor

public interface SimpleInputDescriptorProvider

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

Method Summary

Modifier and Type	Method and Description
<StreamMessageType> InputDescriptor<StreamMessageType,? extends InputDescriptor>	getInputDescriptor(java.lang.String streamId, Serde<StreamMessageType> serde) Gets an InputDescriptor for an input stream on this system.

Method Detail

getInputDescriptor

<StreamMessageType> InputDescriptor<StreamMessageType,? extends InputDescriptor> getInputDescriptor(java.lang.String streamId,
                                                                                                    Serde<StreamMessageType> serde)

Gets an InputDescriptor for an input stream on this system. The stream has the provided stream level serde.

The type of messages in the stream is the type of the provided stream level serde.

Type Parameters:

StreamMessageType - type of messages in this stream

Parameters:

streamId - id of the input stream

serde - stream level serde for the input stream

Returns:

an InputDescriptor for the input stream