Hi,
Ńo worries :) You probably need to write your own process function to do
exactly that, maybe something like this:
DataStream> test;
DataStream> max = test.keyBy(0)
.process(new KeyedProcessFunction,
Tuple3>() {
public ValueState max;
@Override
public void
I’m sure I’m being a complete idiot, since this seems so trivial but if someone
could point me in the right direction I’d be very grateful.
I have a simple data stream [(Int, Double)] keyed on the Int. I can calculate
the running max of the stream no problem using “.max(2)”. But I want to
