Not sure atm.
It seems you are printing the timestamp extracted from the payload:
out.setStrTime(TimestampLongToString.getTime(tr.getTimestamp()));
Does this timestamp really map to the window?
You remove the window information so maybe you are looking at the wrong
data?
.map((Windowed k
@Matthias J. Sax / All
Have added below line :
> .suppress(Suppressed.untilWindowCloses(Suppressed.BufferConfig.unbounded()))
>
>
Here is the output : (for uuid (*2cbef750-325b-4a2f-ac39-b2c23fa0313f)*,
expecting single output but that is not the case here. Which 1 is the final
output from those
Emitting intermediate result is by-design.
If you don't want to get intermediate result, you can add `suppress()`
after the aggregation and configure it to only "emit on window close".
-Matthias
On 5/17/22 3:20 AM, Shankar Mane wrote:
Hi All,
Our use case is to use sliding window. (for e.g.
Hi All,
Our use case is to use sliding window. (for e.g. at any point, whenever
> user performs any actions at time [ t1 ], we would like to see his activity
> in [ t1 - last 24 hours]. Using this, to show the user some recommendations.
-- I have code ready and it works without any errors.
-- a
