org.apache.samza.rest.model

Class Partition

java.lang.Object

org.apache.samza.rest.model.Partition

public class Partition
extends java.lang.Object

Provides a client view of the samza system stream partition. Includes the system name, stream name and partition id

Constructor Summary

Constructors

Constructor and Description
Partition()
Partition(java.lang.String system, java.lang.String stream, int partitionId)
Partition(org.apache.samza.system.SystemStreamPartition systemStreamPartition)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object o)
int	getPartitionId()
java.lang.String	getStream()
java.lang.String	getSystem()
int	hashCode()
void	setPartitionId(int partitionId)
void	setStream(java.lang.String stream)
void	setSystem(java.lang.String system)

Methods inherited from class java.lang.Object

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

Constructor Detail

Partition

public Partition()

Partition

public Partition(java.lang.String system,
                 java.lang.String stream,
                 int partitionId)

Partition

public Partition(org.apache.samza.system.SystemStreamPartition systemStreamPartition)

Method Detail

getSystem

public java.lang.String getSystem()

setSystem

public void setSystem(java.lang.String system)

getStream

public java.lang.String getStream()

setStream

public void setStream(java.lang.String stream)

getPartitionId

public int getPartitionId()

setPartitionId

public void setPartitionId(int partitionId)

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object