Package cz.o2.proxima.beam.core.transforms
-
Class Summary Class Description AssignEventTime<T> BufferUntilCheckpoint<T> Identity transformation which ensures exactly-once output.CalendarWindows Fork of Beam's CalendarWindows.CalendarWindows.DaysWindows AWindowFn
that windows elements into periods measured by days.CalendarWindows.MonthsWindows AWindowFn
that windows elements into periods measured by months.CalendarWindows.YearsWindows AWindowFn
that windows elements into periods measured by years.ExtractKeyToKv Extract key fromStreamElement
into KV.StreamElementFilter Filter inputStreamElement