Memory platform counters

Adding summingbird counter support for the Memory platform.
If the jobID is null, we *WANT* an exception. We don't want to catch that.

On Thu, Sep 25, 2014 at 11:44 AM, Ekaterina Gonina <notifications@github.com
> wrote:

> In
> summingbird-core/src/main/scala/com/twitter/summingbird/memory/Memory.scala:
>
> > @@ -98,8 +103,16 @@ class Memory extends Platform[Memory] {
> >          (s.asInstanceOf[Stream[T]], m + (outerProducer -> s))
> >      }
> >
> > -  def plan[T](prod: TailProducer[Memory, T]): Stream[T] =
> > +  def plan[T](prod: TailProducer[Memory, T]): Stream[T] = {
> > +    val registeredCounters: List[(String, String)] =
> > +      Try { JobCounters.registeredCountersForJob.get(jobID).toList }.toOption.getOrElse(Nil)
>
> If jobId is null, the registeredCountersForJob will throw a NPE (
> http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ConcurrentHashMap.html#get(java.lang.Object)
> )
>
> —
> Reply to this email directly or view it on GitHub
> <https://github.com/twitter/summingbird/pull/548/files#r18051145>.
>



-- 
Oscar Boykin :: @posco :: http://twitter.com/posco