Re: Compilation Error in WindowStream.fold()

2017-02-27 Thread Aljoscha Krettek
It seems the type of your initial accumulator, which is Map[EWayCoordinates,Set[VehicleID]], does not match the accumulator type on your FoldFunction, which is Map[EWayCoordinates,Set[Int]]. Could you change that? On Sat, 25 Feb 2017 at 04:09 nsengupta wrote: > Hello Aljoscha, > > Many thanks fo

Re: Compilation Error in WindowStream.fold()

2017-02-24 Thread nsengupta
Hello Aljoscha, Many thanks for taking this up. This is the modified code: -- val uniqueVehicles = envDefault .fromCollection(readings) .map(e => MITSIMUtils.preparePositionReport(e)) .assignAscendin

Re: Compilation Error in WindowStream.fold()

2017-02-24 Thread Aljoscha Krettek
Hi Nirmalya, what does the compiler say if you use the variant without explicit TypeInfo? Like this: .fold( // Seed Map[EWayCoordinates,Set[VehicleID]](), // FoldFunction folder, // WindowFunction windower, ) Best, Aljoscha O