public class TaskModel extends java.lang.Object implements java.lang.Comparable<TaskModel>
The hierarchy for a Samza's job data model is that jobs have containers, and containers have tasks.
Constructor and Description |
---|
TaskModel(TaskName taskName,
java.util.Set<SystemStreamPartition> systemStreamPartitions,
Partition changelogPartition) |
Modifier and Type | Method and Description |
---|---|
int |
compareTo(TaskModel other) |
boolean |
equals(java.lang.Object o) |
Partition |
getChangelogPartition()
Returns the
Partition used for all changelogs for this task. |
java.util.Set<SystemStreamPartition> |
getSystemStreamPartitions()
Returns the
SystemStreamPartition s that this task is responsible for consuming. |
TaskName |
getTaskName()
Returns the name of the task.
|
int |
hashCode() |
java.lang.String |
toString() |
public TaskModel(TaskName taskName, java.util.Set<SystemStreamPartition> systemStreamPartitions, Partition changelogPartition)
public TaskName getTaskName()
public java.util.Set<SystemStreamPartition> getSystemStreamPartitions()
SystemStreamPartition
s that this task is responsible for consuming.SystemStreamPartition
s for this taskpublic Partition getChangelogPartition()
Partition
used for all changelogs for this task.public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object