Constructor
new Table(database, name)
Parameters:
Name | Type | Description |
---|---|---|
database | Database | Database instance. |
name | string | Name of the table. |
Members
database
name
The name of this table.
Methods
createReadStream(query, optionsopt) → {PartialResultStream}
Create a readable object stream to receive rows from the database using key lookups and scans.
Parameters:
Name | Type | Attributes | Description |
---|---|---|---|
query | ReadRequest | Configuration object, describing what to read from the table.. | |
options | TimestampBounds | <optional> |
Returns:
Type | Description |
---|---|
PartialResultStream | A readable stream that emits rows. |
Example
``` const {Spanner} = require('@google-cloud/spanner'); const spanner = new Spanner(); const instance = spanner.instance('my-instance'); const database = instance.database('my-database'); const table = database.table('Singers'); table.createReadStream({ keys: ['1'], columns: ['SingerId', 'name'] }) .on('error', function(err) {}) .on('data', function(row) { // row = { // SingerId: '1', // Name: 'Eddie Wilson' // } }) .on('end', function() { // All results retrieved. }); //- // Provide an array for `query.keys` to read with a composite key. //- const query = { keys: [ [ 'Id1', 'Name1' ], [ 'Id2', 'Name2' ] ], // ... }; //- // If you anticipate many results, you can end a stream early to prevent // unnecessary processing and API requests. //- table.createReadStream({ keys: ['1'], columns: ['SingerId', 'name'] }) .on('data', function(row) { this.end(); }); ```