org.apache.samza.system

Class SystemStream

java.lang.Object

org.apache.samza.system.SystemStream

Direct Known Subclasses:

SystemStreamPartition

public class SystemStream
extends java.lang.Object

Streams in Samza consist of both the stream name and the system to which the stream belongs. Systems are defined through the job config and have corresponding serdes, producers and consumers in order to deserialize, send to and retrieve from them. A stream name is dependent on its system, and may be the topic, queue name, file name, etc. as makes sense for a particular system.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	stream
protected java.lang.String	system

Constructor Summary

Constructors

Constructor and Description
SystemStream(java.lang.String system, java.lang.String stream) Constructs a Samza stream object from specified components.
SystemStream(SystemStream other) Constructs a Samza stream object based upon an existing Samza stream.

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object obj)
java.lang.String	getStream()
java.lang.String	getSystem()
int	hashCode()
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

system

protected final java.lang.String system

stream

protected final java.lang.String stream

Constructor Detail

SystemStream

public SystemStream(java.lang.String system,
                    java.lang.String stream)

Constructs a Samza stream object from specified components.

Parameters:

system - The name of the system of which this stream is associated with.

stream - The name of the stream as specified in the stream configuration file.

SystemStream

public SystemStream(SystemStream other)

Constructs a Samza stream object based upon an existing Samza stream.

Parameters:

other - Reference to an already existing Samza stream.

Method Detail

getSystem

public java.lang.String getSystem()

getStream

public java.lang.String getStream()

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object