in app/src/main/kotlin/beam/starter/App.kt [38:43]
fun main(args: Array<String>) {
val options = PipelineOptionsFactory.fromArgs(*args).withValidation().`as`(Options::class.java)
val pipeline = Pipeline.create(options)
buildPipeline(pipeline, options.inputText)
pipeline.run().waitUntilFinish()
}