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:

Code sample

Java

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

To authenticate to Spanner, set up Application Default Credentials. For more information, see Set up authentication for a local development environment .

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

Create a Mobile Website
View Site in Mobile | Classic
Share by: