Dataflow read api

Use the Dataflow connector to read from a database without using a query by specifying a table name and a list of columns.

Documentation pages that include this code sample

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

Code sample

Java

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

// Query for all the columns and rows in the specified Spanner table
PCollection<Struct> records = p.apply(
    SpannerIO.read()
        .withInstanceId(instanceId)
        .withDatabaseId(databaseId)
        .withTable("Singers")
        .withColumns("singerId", "firstName", "lastName"));

What's next

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