Re: @pabloem the [pipeline](https://github.com/apache/beam/blob/master/examples/java/src/main/java/org/apache/beam/examples/complete/TrafficRoutes.java#L323) reads from a [input file](https://github.com/apache/beam/blob/master/examples/java/src/main/java/org/apache/beam/examples/complete/TrafficRoutes.java#L323) and uses [ExampleUtils](https://github.com/apache/beam/blob/master/examples/java/src/main/java/org/apache/beam/examples/complete/TrafficRoutes.java#L378) to stop the injector.
[ Full content available at: https://github.com/apache/beam/pull/6366 ] This message was relayed via gitbox.apache.org for [email protected]
