Hi, I'm looking at the portable pipeline translation for streaming. I understand that for batch pipelines, it is sufficient to translate Impulse.
What is the intended path to support unbounded sources? The goal here is to get a minimum translation working that will allow streaming wordcount execution. Thanks, Thomas
