public SpannerWriteResult expand()

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()));
        }