The Java Embedded Aggregator Class PrdAggregate

 
    public static class PrdAggregate implements Aggregate<Number>
    {
        public void initialize(Number val) 
        {
            prd = val.doubleValue();
        }
 
        public void accumulate(Number val) 
        {
            prd *= val.doubleValue();
        }
         
        public Object result() 
        {
            return new Double(prd);
        }
         
        public void merge(Aggregate<Number> other) 
        {
            prd *= ((PrdAggregate)other).prd;
        }
 
        double prd;
    }