Hi I am reading large files and emit to a windowing function ( window duration for a minute ) Then using grouping ParDo transform I am grouping by key and collection.
Because of the file size is large it is stuck at the group by key pipeline step. As per the documentation looks like I need to set a trigger to emit the results from the group by key step because of windowing. Looks like go sdk does not support trigger. Could you please tell me alternate way for this or when do you plan to release a code for trigger concept like in java Thanks laks
