org.apache.samza.system.descriptors

Interface TransformingInputDescriptorProvider<InputTransformerType>

Type Parameters:

InputTransformerType - type of the system level InputTransformer results

public interface TransformingInputDescriptorProvider<InputTransformerType>

Interface for advanced SystemDescriptors that constrain the type of returned InputDescriptors to their own InputTransformer function result types.

Method Summary

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

Method Detail

getInputDescriptor

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

Gets a InputDescriptor for an input stream on this system. The stream has the provided stream level serde, and the default system level InputTransformer.

The type of messages in the stream is the type of messages returned by the default system level InputTransformer

Parameters:

streamId - id of the input stream

serde - stream level serde for the input stream

Returns:

an InputDescriptor for the input stream