org.apache.samza.job.model

Class TaskModel

java.lang.Object

org.apache.samza.job.model.TaskModel

All Implemented Interfaces:

java.lang.Comparable<TaskModel>

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

This contains metadata about a Samza task, such as the stream partitions that it is consuming.

The hierarchy for a Samza's job data model is that jobs have containers, and containers have tasks.

Constructor Summary

Constructors

Constructor and Description
TaskModel(TaskName taskName, java.util.Set<SystemStreamPartition> systemStreamPartitions, Partition changelogPartition) Create a TaskModel for an active task with the given taskName, SSPs, and changelogPartition.
TaskModel(TaskName taskName, java.util.Set<SystemStreamPartition> systemStreamPartitions, Partition changelogPartition, TaskMode taskMode) Create a TaskModel for an active task with the given taskName, SSPs, and changelogPartition.

Method Summary

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 SystemStreamPartitions that this task is responsible for consuming.
TaskMode	getTaskMode()
TaskName	getTaskName() Returns the name of the task.
int	hashCode()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskModel

public TaskModel(TaskName taskName,
                 java.util.Set<SystemStreamPartition> systemStreamPartitions,
                 Partition changelogPartition,
                 TaskMode taskMode)

Create a TaskModel for an active task with the given taskName, SSPs, and changelogPartition.

Parameters:

taskName - The desired taskName

systemStreamPartitions - SSPs assigned to this task.

changelogPartition - The changelog SSP for this task.

taskMode - The mode of the task

TaskModel

public TaskModel(TaskName taskName,
                 java.util.Set<SystemStreamPartition> systemStreamPartitions,
                 Partition changelogPartition)

Create a TaskModel for an active task with the given taskName, SSPs, and changelogPartition.

Parameters:

taskName - The desired taskName

systemStreamPartitions - SSPs assigned to this task.

changelogPartition - The changelog SSP for this task.

Method Detail

getTaskName

public TaskName getTaskName()

Returns the name of the task.

Returns:

name of the task

getSystemStreamPartitions

public java.util.Set<SystemStreamPartition> getSystemStreamPartitions()

Returns the SystemStreamPartitions that this task is responsible for consuming.

Returns:

SystemStreamPartitions for this task

getChangelogPartition

public Partition getChangelogPartition()

Returns the Partition used for all changelogs for this task.

Returns:

changelog partition for this task

getTaskMode

public TaskMode getTaskMode()

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(TaskModel other)

Specified by:

compareTo in interface java.lang.Comparable<TaskModel>