Dataflow read all

Use SQL queries with the Dataflow connector to read data from all available tables in a database.

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.

PCollection<Struct> allRecords = p.apply(
    .withQuery("SELECT t.table_name FROM information_schema.tables AS t WHERE t"
        + ".table_catalog = '' AND t.table_schema = ''")).apply(
        .via((SerializableFunction<Struct, ReadOperation>) input -> {
          String tableName = input.getString(0);
          return ReadOperation.create().withQuery("SELECT * FROM " + tableName);

What's next

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