in pipelines/etl_integration_java/src/main/java/com/google/cloud/dataflow/solutions/ETLIntegration.java [31:41]
public static void main(String[] args) {
String jobName = "pubsub-to-spanner";
SpannerPublisherOptions spannerPublisherOptions =
PipelineOptionsFactory.fromArgs(args)
.withoutStrictParsing()
.as(SpannerPublisherOptions.class);
Pipeline p = createPipeline(spannerPublisherOptions);
p.getOptions().setJobName(jobName);
p.run();
}