Hi,
I have a streaming pipeline which reads from pubsub, enriches data using
redis and finally writes to pubsub. The code has some stateful DoFns with
timers. I wanted to write unit tests for the whole pipeline, that reads
from TestStream<> , enriches data using a mocked redis client, and writes
data to a PCollection on which I can do PAsserts. The trouble I am having
here is how to set up the mocked redis client. Are there any examples that
I can take a look at? I am using java with junit4 as a testing framework.
More details about my code are here -
https://stackoverflow.com/questions/67963189/unit-tests-apache-beam-stateful-pipeline-with-external-dependencies
