After aggregation the current implementation needs to run the following map operation:
let stream8: Stream<_, OrdIndexedZSet<(), Tuple1<Option<i32>>, Weight>> = stream1.stream_aggregate(fold);
let flatten0: _ = move |kv: (&(), &Tuple1<Option<i32>>, ), | -> Tuple1<Option<i32>> {
Tuple1::new(kv.1.0)
};
let stream9: Stream<_, OrdZSet<Tuple1<Option<i32>>, Weight>> = stream8.map(flatten0);
How can this map function flatten0 be written in the JIT JSON representation? notice that the argument is a nested tuple.
Is there an alternative way to write this in DBSP?
After aggregation the current implementation needs to run the following map operation:
How can this map function
flatten0be written in the JIT JSON representation? notice that the argument is a nested tuple. Is there an alternative way to write this in DBSP?