Arun Pandian

Wrong First Occurrence for MONTHLY rrule when BYDAY & BYSETPOS are present

1

```js recur = ICAL.Recur.fromData({ freq:"MONTHLY", byday: ['SU'], bysetpos: [-1] }); // last sunday in every month start = ICAL.Time.fromDateString("2017-07-01") //saturday it = recur.iterator(start) console.log('Expected 2017-07-30, Actual ' + it.next()); //...

Recurrence Missing instances if bymonthday is not sorted

2

```js recur = ICAL.Recur.fromData({ freq:"MONTHLY", bymonthday: [3, 2, 1], until: "2017-07-02" }); // 1st, 2nd, 3rd of every month till 2017-07-02 start = ICAL.Time.fromDateString("2017-07-01") it = recur.iterator(start) console.log('Expected 2017-07-01, Actual...

[Do not Merge] [WIP] Combine.perKeyWithBucketing: Combiner for reducing key cardinality

1

`Combine.perKeyWithBucketing(childCombiner, numBuckets)` applies the child combiner to the PCollection using numberOfBuckets number of intermediate keys. This is a POC, sending it now to share and get early feedback. TODO: Add...

[Dataflow Streaming] Micro Optimizations

2

### What needs to happen? Issue to tie together changes to micro optimize dataflow streaming code path ### Issue Priority Priority: 2 (default / most normal work should be filed...

[Dataflow Streaming] Move timer tag logic to WindmillStateTagUtil

3

This is a preparation to introduce a new version of WindmillStateTagUtil. No logic changes, just moving code around.