Dataflow write with mutations

Use the Dataflow connector to write data by using mutations.

Documentation pages that include this code sample

To view the code sample used in context, see the following documentation:

Code Sample


    // Spanner expects a Mutation object, so create it using the Album's data
    .apply("CreateAlbumMutation", ParDo.of(new DoFn<Album, Mutation>() {
      public void processElement(ProcessContext c) {
        Album album = c.element();
    // Write mutations to Spanner
    .apply("WriteAlbums", SpannerIO.write()