org.apache.samza.operators

Interface StreamSpec

@InterfaceStability.Unstable
public interface StreamSpec

This interface defines the specification of a SystemStream. It will be used by the SystemAdmin to create a SystemStream

Method Summary

Modifier and Type	Method and Description
java.util.Properties	getProperties() Get the physical properties of the SystemStream
SystemStream	getSystemStream() Get the SystemStream

Method Detail

getSystemStream

SystemStream getSystemStream()

Get the SystemStream

Returns:

SystemStream object

getProperties

java.util.Properties getProperties()

Get the physical properties of the SystemStream

Returns:

the properties of this stream