org.apache.samza.system

Class SystemStreamPartition

java.lang.Object

org.apache.samza.system.SystemStream

org.apache.samza.system.SystemStreamPartition

All Implemented Interfaces:

java.lang.Comparable<SystemStreamPartition>

public class SystemStreamPartition
extends SystemStream
implements java.lang.Comparable<SystemStreamPartition>

Aggregate object representing a both the SystemStream and Partition.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	hash
protected Partition	partition

Fields inherited from class org.apache.samza.system.SystemStream

stream, system

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
int	compareTo(SystemStreamPartition that)
boolean	equals(java.lang.Object obj)
Partition	getPartition()
SystemStream	getSystemStream()
int	hashCode()
java.lang.String	toString()

Methods inherited from class org.apache.samza.system.SystemStream

getStream, getSystem

Methods inherited from class java.lang.Object

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

Field Detail

partition

protected final Partition partition

hash

protected final int hash

Constructor Detail

SystemStreamPartition

public SystemStreamPartition(java.lang.String system,
                             java.lang.String stream,
                             Partition partition)

Constructs a Samza stream partition 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.

partition - The partition in the stream of which this object is associated with.

SystemStreamPartition

public SystemStreamPartition(SystemStreamPartition other)

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

Parameters:

other - Reference to an already existing Samza stream partition.

SystemStreamPartition

public SystemStreamPartition(SystemStream other,
                             Partition partition)

Constructs a Samza stream partition object based upon another Samza stream and a specified partition.

Parameters:

other - Reference to an already existing Samza stream.

partition - Reference to an already existing Samza partition.

Method Detail

getPartition

public Partition getPartition()

getSystemStream

public SystemStream getSystemStream()

hashCode

public int hashCode()

Overrides:

hashCode in class SystemStream

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class SystemStream

toString

public java.lang.String toString()

Overrides:

toString in class SystemStream

compareTo

public int compareTo(SystemStreamPartition that)

Specified by:

compareTo in interface java.lang.Comparable<SystemStreamPartition>