update to 2.5.4
Updated c.t.p.PartitionCollector in c.t.p.BasePartitionTap to be public.
Fixed issue where c.p.a.FirstBy only accepted a single field name.
Fixed issue where a c.p.Merge could hide the streamed/accumulated nature of a stream when leading to a c.p.Group pipe. This could result in duplicate data passed to the c.p.GroupBy or c.p.CoGroup within a MapReduce job.
Updated c.p.a.AggregateBy$CompositeFunction to not use the threshold in #equals or #hashCode.
Fixed an issue where c.t.h.Hfs#getChildIdentifiers() could throw an j.l.StringIndexOutOfBoundsException.
version 2.5.4