Create a Table object to interact with a Cloud Bigtable table.
Package
@google-cloud/bigtableExample
const
{
Bigtable
}
=
require
(
' @google-cloud/bigtable
'
);
const
bigtable
=
new
Bigtable
();
const
instance
=
bigtable
.
instance
(
'my-instance'
);
const
table
=
instance
.
table
(
'prezzy'
);
Constructors
(constructor)(instance, id)
constructor
(
instance
:
Instance
,
id
:
string
);
Constructs a new instance of the Table
class
Properties
bigtable
bigtable
:
Bigtable
;
id
id
:
string
;
instance
instance
:
Instance
;
maxRetries
maxRetries
?:
number
;
metadata
metadata
?:
google
.
bigtable
.
admin
.
v2
.
ITable
;
name
name
:
string
;
VIEWS
static
VIEWS
:
{
[
index
:
string
]
:
number
;
};
The view to be applied to the returned table's fields. Defaults to schema if unspecified.
Methods
checkConsistency(token)
checkConsistency
(
token
:
string
)
:
Promise<CheckConsistencyResponse>
;
token
string
checkConsistency(token, callback)
checkConsistency
(
token
:
string
,
callback
:
CheckConsistencyCallback
)
:
void
;
void
create(options)
create
(
options
?:
CreateTableOptions
)
:
Promise<CreateTableResponse>
;
create(options, callback)
create
(
options
:
CreateTableOptions
,
callback
:
CreateTableCallback
)
:
void
;
void
create(callback)
create
(
callback
:
CreateTableCallback
)
:
void
;
void
createBackup(id, config)
createBackup
(
id
:
string
,
config
:
CreateBackupConfig
)
:
Promise<CreateBackupResponse>
;
id
string
config
CreateBackupConfig
createBackup(id, config, callback)
createBackup
(
id
:
string
,
config
:
CreateBackupConfig
,
callback
:
CreateBackupCallback
)
:
void
;
void
createBackup(id, config, callback)
createBackup
(
id
:
string
,
config
:
CreateBackupConfig
,
callback
:
CreateBackupCallback
)
:
void
;
void
createFamily(id, options)
createFamily
(
id
:
string
,
options
?:
CreateFamilyOptions
)
:
Promise<CreateFamilyResponse>
;
createFamily(id, options, callback)
createFamily
(
id
:
string
,
options
:
CreateFamilyOptions
,
callback
:
CreateFamilyCallback
)
:
void
;
void
createFamily(id, callback)
createFamily
(
id
:
string
,
callback
:
CreateFamilyCallback
)
:
void
;
void
createPrefixRange(start)
static
createPrefixRange
(
start
:
string
)
:
PrefixRange
;
Creates a range based off of a key prefix.
start
string
The key prefix/starting bound.
const
{
Bigtable
}
=
require
(
' @google-cloud/bigtable
'
);
const
bigtable
=
new
Bigtable
();
const
instance
=
bigtable
.
instance
(
'my-instance'
);
const
table
=
instance
.
table
(
'prezzy'
);
table
.
createPrefixRange
(
'start'
);
// => {
// start: 'start',
// end: {
// value: 'staru',
// inclusive: false
// }
// }
createReadStream(opts)
createReadStream
(
opts
?:
GetRowsOptions
)
:
PassThrough
;
Get Row objects for the rows currently in your table as a readable object stream.
PassThrough
{stream}
table
.
createReadStream
()
.
on
(
'error'
,
err
=
>
{
// Handle the error.
})
.
on
(
'data'
,
row
=
>
{
// `row` is a Row object.
})
.
on
(
'end'
,
()
=
>
{
// All rows retrieved.
});
//-
// If you anticipate many results, you can end a stream early to prevent
// unnecessary processing.
//-
// table
// .createReadStream()
// .on('data', function (row) {
// this.end();
// });
//-
// Specify arbitrary keys for a non-contiguous set of rows.
// The total size of the keys must remain under 1MB, after encoding.
//-
// table.createReadStream({
// keys: [
// 'alincoln',
// 'gwashington'
// ]
// });
//-
// Scan for row keys that contain a specific prefix.
//-
// table.createReadStream({
// prefix: 'gwash'
// });
//-
// Specify a contiguous range of rows to read by supplying `start` and `end`
// keys.
//
// If the `start` key is omitted, it is interpreted as an empty string.
// If the `end` key is omitted, it is interpreted as infinity.
//-
// table.createReadStream({
// start: 'alincoln',
// end: 'gwashington'
// });
//-
// Specify multiple ranges.
//-
// table.createReadStream({
// ranges: [{
// start: 'alincoln',
// end: 'gwashington'
// }, {
// start: 'tjefferson',
// end: 'jadams'
// }]
// });
//-
// Apply a {@link Filter} to the contents of the specified rows.
//-
// table.createReadStream({
// filter: [
// {
// column: 'gwashington'
// }, {
// value: 1
// }
// ]
// });
//
decodePolicyEtag(policy)
static
decodePolicyEtag
(
policy
:
Policy
)
:
Policy
;
Formats the decodes policy etag value to string.
delete(gaxOptions)
delete
(
gaxOptions
?:
CallOptions
)
:
Promise<DeleteTableResponse>
;
gaxOptions
CallOptions
delete(gaxOptions, callback)
delete
(
gaxOptions
:
CallOptions
,
callback
:
DeleteTableCallback
)
:
void
;
void
delete(callback)
delete
(
callback
:
DeleteTableCallback
)
:
void
;
void
deleteRows(prefix, gaxOptions)
deleteRows
(
prefix
:
string
,
gaxOptions
?:
CallOptions
)
:
Promise<DeleteRowsResponse>
;
prefix
string
gaxOptions
CallOptions
deleteRows(prefix, gaxOptions, callback)
deleteRows
(
prefix
:
string
,
gaxOptions
:
CallOptions
,
callback
:
DeleteRowsCallback
)
:
void
;
void
deleteRows(prefix, callback)
deleteRows
(
prefix
:
string
,
callback
:
DeleteRowsCallback
)
:
void
;
void
exists(gaxOptions)
exists
(
gaxOptions
?:
CallOptions
)
:
Promise<TableExistsResponse>
;
gaxOptions
CallOptions
exists(gaxOptions, callback)
exists
(
gaxOptions
:
CallOptions
,
callback
:
TableExistsCallback
)
:
void
;
void
exists(callback)
exists
(
callback
:
TableExistsCallback
)
:
void
;
void
family(id)
family
(
id
:
string
)
:
Family
;
Get a reference to a Table Family.
id
string
The family unique identifier.
const
family
=
table
.
family
(
'my-family'
);
formatName_(instanceName, id)
static
formatName_
(
instanceName
:
string
,
id
:
string
)
:
string
;
Formats the table name to include the Bigtable cluster.
instanceName
string
The formatted instance name.
id
string
string
Table
.
formatName_
(
'projects/my-project/zones/my-zone/instances/my-instance'
,
'my-table'
);
//
'projects/my-project/zones/my-zone/instances/my-instance/tables/my-table'
generateConsistencyToken()
generateConsistencyToken
()
:
Promise<GenerateConsistencyTokenResponse>
;
generateConsistencyToken(callback)
generateConsistencyToken
(
callback
:
GenerateConsistencyTokenCallback
)
:
void
;
void
get(options)
get
(
options
?:
GetTableOptions
)
:
Promise<GetTableResponse>
;
get(options, callback)
get
(
options
:
GetTableOptions
,
callback
:
GetTableCallback
)
:
void
;
void
get(callback)
get
(
callback
:
GetTableCallback
)
:
void
;
void
getFamilies(gaxOptions)
getFamilies
(
gaxOptions
?:
CallOptions
)
:
Promise<GetFamiliesResponse>
;
gaxOptions
CallOptions
getFamilies(gaxOptions, callback)
getFamilies
(
gaxOptions
:
CallOptions
,
callback
:
GetFamiliesCallback
)
:
void
;
void
getFamilies(callback)
getFamilies
(
callback
:
GetFamiliesCallback
)
:
void
;
void
getIamPolicy(options)
getIamPolicy
(
options
?:
GetIamPolicyOptions
)
:
Promise
< [
Policy
]>;
getIamPolicy(options, callback)
getIamPolicy
(
options
:
GetIamPolicyOptions
,
callback
:
GetIamPolicyCallback
)
:
void
;
void
getMetadata(options)
getMetadata
(
options
?:
GetMetadataOptions
)
:
Promise<GetMetadataResponse>
;
getMetadata(options, callback)
getMetadata
(
options
:
GetMetadataOptions
,
callback
:
GetMetadataCallback
)
:
void
;
void
getMetadata(callback)
getMetadata
(
callback
:
GetMetadataCallback
)
:
void
;
void
getReplicationStates(gaxOptions)
getReplicationStates
(
gaxOptions
?:
CallOptions
)
:
Promise<GetReplicationStatesResponse>
;
gaxOptions
CallOptions
getReplicationStates(gaxOptions, callback)
getReplicationStates
(
gaxOptions
:
CallOptions
,
callback
:
GetReplicationStatesCallback
)
:
void
;
void
getReplicationStates(callback)
getReplicationStates
(
callback
:
GetReplicationStatesCallback
)
:
void
;
void
getRows(options)
getRows
(
options
?:
GetRowsOptions
)
:
Promise<GetRowsResponse>
;
getRows(options, callback)
getRows
(
options
:
GetRowsOptions
,
callback
:
GetRowsCallback
)
:
void
;
void
getRows(callback)
getRows
(
callback
:
GetRowsCallback
)
:
void
;
void
insert(entries, gaxOptions)
insert
(
entries
:
Entry
|
Entry
[],
gaxOptions
?:
CallOptions
)
:
Promise<InsertRowsResponse>
;
insert(entries, gaxOptions, callback)
insert
(
entries
:
Entry
|
Entry
[],
gaxOptions
:
CallOptions
,
callback
:
InsertRowsCallback
)
:
void
;
gaxOptions
CallOptions
callback
void
insert(entries, callback)
insert
(
entries
:
Entry
|
Entry
[],
callback
:
InsertRowsCallback
)
:
void
;
void
mutate(entries, options)
mutate
(
entries
:
Entry
|
Entry
[],
options
?:
MutateOptions
)
:
Promise<MutateResponse>
;
mutate(entries, options, callback)
mutate
(
entries
:
Entry
|
Entry
[],
options
:
MutateOptions
,
callback
:
MutateCallback
)
:
void
;
void
mutate(entries, callback)
mutate
(
entries
:
Entry
|
Entry
[],
callback
:
MutateCallback
)
:
void
;
void
row(key)
row
(
key
:
string
)
:
Row
;
Get a reference to a table row.
key
string
The row key.
const
row
=
table
.
row
(
'lincoln'
);
sampleRowKeys(gaxOptions)
sampleRowKeys
(
gaxOptions
?:
CallOptions
)
:
Promise<SampleRowsKeysResponse>
;
gaxOptions
CallOptions
sampleRowKeys(gaxOptions, callback)
sampleRowKeys
(
gaxOptions
:
CallOptions
,
callback
:
SampleRowKeysCallback
)
:
void
;
void
sampleRowKeys(callback)
sampleRowKeys
(
callback
?:
SampleRowKeysCallback
)
:
void
;
void
sampleRowKeysStream(gaxOptions)
sampleRowKeysStream
(
gaxOptions
?:
CallOptions
)
:
any
;
Returns a sample of row keys in the table as a readable object stream.
See for more details.
gaxOptions
CallOptions
Request configuration options, outlined here: https://googleapis.github.io/gax-nodejs/CallSettings.html .
any
{stream}
table
.
sampleRowKeysStream
()
.
on
(
'error'
,
console
.
error
)
.
on
(
'data'
,
function
(
key
)
{
// Do something with the `key` object.
});
//-
// If you anticipate many results, you can end a stream early to prevent
// unnecessary processing.
//-
table
.
sampleRowKeysStream
()
.
on
(
'data'
,
function
(
key
)
{
this
.
end
();
});
setIamPolicy(policy, gaxOptions)
setIamPolicy
(
policy
:
Policy
,
gaxOptions
?:
CallOptions
)
:
Promise<SetIamPolicyResponse>
;
setIamPolicy(policy, callback)
setIamPolicy
(
policy
:
Policy
,
callback
:
SetIamPolicyCallback
)
:
void
;
void
setIamPolicy(policy, gaxOptions, callback)
setIamPolicy
(
policy
:
Policy
,
gaxOptions
:
CallOptions
,
callback
:
SetIamPolicyCallback
)
:
void
;
void
testIamPermissions(permissions, gaxOptions)
testIamPermissions
(
permissions
:
string
|
string
[],
gaxOptions
?:
CallOptions
)
:
Promise<TestIamPermissionsResponse>
;
permissions
string | string[]
gaxOptions
CallOptions
testIamPermissions(permissions, callback)
testIamPermissions
(
permissions
:
string
|
string
[],
callback
:
TestIamPermissionsCallback
)
:
void
;
void
testIamPermissions(permissions, gaxOptions, callback)
testIamPermissions
(
permissions
:
string
|
string
[],
gaxOptions
:
CallOptions
,
callback
:
TestIamPermissionsCallback
)
:
void
;
permissions
string | string[]
gaxOptions
CallOptions
callback
void
truncate(gaxOptions)
truncate
(
gaxOptions
?:
CallOptions
)
:
Promise<TruncateResponse>
;
gaxOptions
CallOptions
truncate(gaxOptions, callback)
truncate
(
gaxOptions
:
CallOptions
,
callback
:
TruncateCallback
)
:
void
;
void
truncate(callback)
truncate
(
callback
:
TruncateCallback
)
:
void
;
void
waitForReplication()
waitForReplication
()
:
Promise<WaitForReplicationResponse>
;
waitForReplication(callback)
waitForReplication
(
callback
:
WaitForReplicationCallback
)
:
void
;
void