Dataflow read all

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

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 Spanner, see Spanner client libraries.

PCollection<Struct> allRecords =
                    "SELECT t.table_name FROM information_schema.tables AS t WHERE t"
                        + ".table_catalog = '' AND t.table_schema = ''"))
                    (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.