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	A WindowFn that windows elements into periods measured by days.
CalendarWindows.MonthsWindows	A WindowFn that windows elements into periods measured by months.
CalendarWindows.YearsWindows	A WindowFn that windows elements into periods measured by years.
ExtractKeyToKv	Extract key from StreamElement into KV.
FilterLatecomers<T>	Split input PCollection on late and on-time elements.
StreamElementFilter	Filter input StreamElement
WatermarkShift<T>	Shift watermark of input PCollection by given duration back in time.