Hi,
I am little confused about how the runner should handle SideInput if it
comes from a sliding-windowed PCollection.
Say we have two PCollections A and B. Apply
Window.into(SlidingWindows.of...) on B, and create a View from it (call it
VB).
Then, a Pardo takes the PCollection A as the main input and VB as side
input: A.apply(ParDo.withSideInputs(VB).of(new DoFun() {...})).
In the DoFun.processElement(), when the user code calls
ProcessContext.sideInput(VB), the view of which window in VB should be
returned if the event time of the current element in A corresponds to
multiple sliding windows in B?
Thanks,
Shen
