in pipelines/etl_integration_java/src/main/java/com/google/cloud/dataflow/solutions/load/Spanner.java [61:71]
public SpannerWriteResult expand(PCollection<TaxiObjects.TaxiEvent> events) {
PCollection<Mutation> mutations =
events.apply("To mutations", ParDo.of(new EventToMutationDoFn(tableName())));
return mutations.apply(
"Write to Spanner",
SpannerIO.write()
.withProjectId(projectId())
.withInstanceId(instanceId())
.withDatabaseId(databaseId()));
}