Class CalendarWindows
- java.lang.Object
-
- cz.o2.proxima.beam.core.transforms.CalendarWindows
-
public class CalendarWindows extends java.lang.Object
Fork of Beam's CalendarWindows. To be removed after Flink 1.18 runner is implemented.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
CalendarWindows.DaysWindows
AWindowFn
that windows elements into periods measured by days.static class
CalendarWindows.MonthsWindows
AWindowFn
that windows elements into periods measured by months.static class
CalendarWindows.YearsWindows
AWindowFn
that windows elements into periods measured by years.
-
Constructor Summary
Constructors Constructor Description CalendarWindows()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static CalendarWindows.DaysWindows
days(int number)
Returns aWindowFn
that windows elements into periods measured by days.static CalendarWindows.MonthsWindows
months(int number)
Returns aWindowFn
that windows elements into periods measured by months.static CalendarWindows.DaysWindows
weeks(int number, int startDayOfWeek)
Returns aWindowFn
that windows elements into periods measured by weeks.static CalendarWindows.YearsWindows
years(int number)
Returns aWindowFn
that windows elements into periods measured by years.
-
-
-
Method Detail
-
days
public static CalendarWindows.DaysWindows days(int number)
Returns aWindowFn
that windows elements into periods measured by days.For example,
CalendarWindows.days(1)
will window elements into separate windows for each day.
-
weeks
public static CalendarWindows.DaysWindows weeks(int number, int startDayOfWeek)
Returns aWindowFn
that windows elements into periods measured by weeks.For example,
CalendarWindows.weeks(1, DateTimeConstants.TUESDAY)
will window elements into week-long windows starting on Tuesdays.
-
months
public static CalendarWindows.MonthsWindows months(int number)
Returns aWindowFn
that windows elements into periods measured by months.For example,
CalendarWindows.months(8).withStartingMonth(2014, 1).beginningOnDay(10)
will window elements into 8 month windows where that start on the 10th day of month, and the first window begins in January 2014.
-
years
public static CalendarWindows.YearsWindows years(int number)
Returns aWindowFn
that windows elements into periods measured by years.For example,
CalendarWindows.years(1).withTimeZone(DateTimeZone.forId("America/Los_Angeles"))
will window elements into year-long windows that start at midnight on Jan 1, in the America/Los_Angeles time zone.
-
-