Dataflow write with mutations

Use the Dataflow connector to write data by using mutations.

Explore further

For detailed documentation that includes this code sample, see the following:

Code sample


To learn how to install and use the client library for Cloud Spanner, see Cloud Spanner client libraries.

    // 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()

What's next

To search and filter code samples for other Google Cloud products, see the Google Cloud sample browser.