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.

Explore further

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

• Import, export, and modify data using Dataflow

Code sample

Java

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

View on GitHub Feedback

// 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.