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
Hello Aljoscha,
Many thanks for taking this up.
This is the modified code:
--
val uniqueVehicles = envDefault
.fromCollection(readings)
.map(e => MITSIMUtils.preparePositionReport(e))
.assignAscendin
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
For reasons I cannot grasp, I am unable to move ahead.
Here's the code:
-
import org.apache.flink.api.common.functions.FoldFunction
import org.apache.flink.
