Also, note that I observed similar behaviour with DataflowRunner.
On Thu, 28 May 2020 at 21:24, Jay wrote:
> I was trying to simulate the PaneInfo in Python to check for parity with
> the Java SDK. I was able to get PaneInfo after introduction a CombinePerKey.
> I am not sure why GBK
it seems that PaneInfo is not well supported yet on the
>> local runners: https://issues.apache.org/jira/browse/BEAM-3759
>>
>> Can you share more about your use case, and what you'd like to do with
>> the PaneInfo?
>>
>> On Sat, May 23, 2020 at 10:03 AM J
Hi All -
Below is a sample code written in Python which reads data from Pub/Sub and
tries to determine the PaneInfo for different elements
There are 3 rows of data as shown below
{"country":"USA","user_id": 1,"ts": 0},
> {"country":"USA","user_id": 2,"ts": 0},
> {"country":"USA","user_id": 3,"ts
