Dataflow read api

Stay organized with collections Save and categorize content based on your preferences.

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:

Code sample

Java

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

// Query for all the columns and rows in the specified Spanner table
PCollection<Struct> records = pipeline.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.