org.apache.samza.job.model

Class JobModel

java.lang.Object

org.apache.samza.job.model.JobModel

public class JobModel
extends java.lang.Object

The data model used to represent a Samza job. The model is used in the job coordinator and SamzaContainer to determine how to execute Samza jobs.

The hierarchy for a Samza's job data model is that jobs have containers, and containers have tasks. Each data model contains relevant information, such as an id, partition information, etc.

Field Summary

Fields

Modifier and Type	Field and Description
int	maxChangeLogStreamPartitions

Constructor Summary

Constructors

Constructor and Description
JobModel(Config config, java.util.Map<java.lang.String,ContainerModel> containers)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object obj)
Config	getConfig()
java.util.Map<java.lang.String,ContainerModel>	getContainers()
int	getMaxChangeLogStreamPartitions()
int	hashCode()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

maxChangeLogStreamPartitions

public int maxChangeLogStreamPartitions

Constructor Detail

JobModel

public JobModel(Config config,
                java.util.Map<java.lang.String,ContainerModel> containers)

Method Detail

getMaxChangeLogStreamPartitions

public int getMaxChangeLogStreamPartitions()

getConfig

public Config getConfig()

getContainers

public java.util.Map<java.lang.String,ContainerModel> getContainers()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object