Hi,

We have a stream processing pipeline which process the customer UI interactions 
data .
As part of the pipeline we read the information from AWS redis cache and store 
it in a PCollectionView. The PCollectionView is accessed as side input in the 
next CombineFnWithContext accumulators and transform functions in the pipeline.
Could you please suggest an alternative approach where we can avoid using side 
input for accessing redis cache information in next functions in the pipeline.

Thanks,
Madhavi

Reply via email to