The notion being its a piece of state te objects can pick up submitter side
to be used in th cluster later to find the rift flow process. The job also
sets fields in the job conf so it's a good way to add that state.

Any other place suitable ?

On Saturday, January 25, 2014, Argyris Zymnis <notifications@github.com>
wrote:

> In scalding-core/src/main/scala/com/twitter/scalding/Job.scala:
>
> > @@ -66,6 +67,12 @@ class Job(val args : Args) extends FieldConversions with java.io.Serializable {
> >    // Set specific Mode
> >    implicit def mode: Mode = Mode.getMode(args).getOrElse(sys.error("No Mode defined"))
> >
> > +  // This allows us to register this job in a global space when processing on the cluster
> > +  // and find it again.
> > +  // E.g. stats can all locate the same job back again to find the right flowProcess
> > +  case class UniqueID(get: String)
>
> Why define UniqueID inside Job?
>
> —
> Reply to this email directly or view it on GitHub<https://github.com/twitter/scalding/pull/757/files#r9174008>
> .
>