TheNeuralBit commented on pull request #14977: URL: https://github.com/apache/beam/pull/14977#issuecomment-915656232
Sorry for the looong delay here. Lost track of this then I was out for a couple of months. > Sure, but doesn't TestPipeline use that? TestPipeline is the supported option for unit testing, and this is intended to be a utility for that. This is just an abstraction copying the pattern I've used for unit testing in the past. TestPipeline doesn't always use the DirectRunner, it can be configured to use any runner, e.g.: https://github.com/apache/beam/blob/a89b12a414357bb4cc03d3ca59b63e99f71f5c37/runners/spark/spark_runner.gradle#L120-L124 > I've been trying to find a better abstraction for unit testing streaming transforms You might look at some usages of [TestStream](https://github.com/apache/beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestStream.java) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
