org.apache.samza.container

Class TaskName

java.lang.Object

org.apache.samza.container.TaskName

All Implemented Interfaces:

java.lang.Comparable<TaskName>

public class TaskName
extends java.lang.Object
implements java.lang.Comparable<TaskName>

A unique identifier of a set of a SystemStreamPartitions that have been grouped by a SystemStreamPartitionGrouper. The SystemStreamPartitionGrouper determines the TaskName for each set it creates. The TaskName class should only contain the taskName. This is necessary because the ChangelogManager assumes that the taskName is unique enough to identify this class, and uses it to store it in the underlying coordinator stream (as a key).

Constructor Summary

Constructors

Constructor and Description
TaskName(java.lang.String taskName)

Method Summary

Methods

Modifier and Type	Method and Description
int	compareTo(TaskName that)
boolean	equals(java.lang.Object o)
java.lang.String	getTaskName()
int	hashCode()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskName

public TaskName(java.lang.String taskName)

Method Detail

getTaskName

public java.lang.String getTaskName()

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

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

compareTo

public int compareTo(TaskName that)

Specified by:

compareTo in interface java.lang.Comparable<TaskName>