Class Table (1.2.1)

Table(table_id, instance, mutation_timeout=None, app_profile_id=None)

Representation of a Google Cloud Bigtable Table.

Note: We don't define any properties on a table other than the name. The only other fields are column_families and granularity, The column_families are not stored locally and granularity is an enum with only one value.

create the table
delete the table
list_column_families in the table

Parameters

Name	Description
`table_id`	`str` The ID of the table.
`instance`	`Instance` The instance that owns the table.
`app_profile_id`	`str` (Optional) The unique name of the AppProfile.

Properties

name

Table name used in requests.

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_table_name] :end-before: [END bigtable_table_name]

Note: This property will not change if table_id does not, but the return value is not cached.

"projects/../instances/../tables/{table_id}"

Returns

Type	Description
`str`	The table name.

Methods

append_row

append_row(row_key)

Create a xref_AppendRow associated with this table.

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_table_append_row] :end-before: [END bigtable_table_append_row]

Parameter

Name	Description
`row_key`	`bytes` The key for the row being created.

column_family

column_family(column_family_id, gc_rule=None)

Factory to create a column family associated with this table.

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_table_column_family] :end-before: [END bigtable_table_column_family]

Parameters

Name	Description
`column_family_id`	`str` The ID of the column family. Must be of the form `<code>_a-zA-Z0-9][-_.a-zA-Z0-9]</code>*`.
`gc_rule`	`.GarbageCollectionRule` (Optional) The garbage collection settings for this column family.

Returns

Type	Description
`.ColumnFamily`	A column family owned by this table.

conditional_row

conditional_row(row_key, filter_)

Create a xref_ConditionalRow associated with this table.

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_table_conditional_row] :end-before: [END bigtable_table_conditional_row]

Parameters

Name	Description
`row_key`	`bytes` The key for the row being created.
`filter_`	`.RowFilter` (Optional) Filter to be used for conditional mutations. See `.ConditionalRow` for more details.

create

create(initial_split_keys=[], column_families={})

Creates this table.

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_create_table] :end-before: [END bigtable_create_table]

Note: A create request returns a ._generated.table_pb2.Table but we don't use this response.

Parameter

Name	Description
`initial_split_keys`	`list` (Optional) list of row keys in bytes that will be used to initially split the table into several tablets.

delete

delete()

Delete this table.

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_delete_table] :end-before: [END bigtable_delete_table]

direct_row

direct_row(row_key)

Create a xref_DirectRow associated with this table.

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_table_direct_row] :end-before: [END bigtable_table_direct_row]

Parameter

Name	Description
`row_key`	`bytes` The key for the row being created.

drop_by_prefix

drop_by_prefix(row_key_prefix, timeout=None)

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_drop_by_prefix] :end-before: [END bigtable_drop_by_prefix]

Parameters

Name	Description
`row_prefix`	`bytes` Delete all rows that start with this row key prefix. Prefix cannot be zero length.
`timeout`	`float` (Optional) The amount of time, in seconds, to wait for the request to complete. :raise: google.api_core.exceptions.GoogleAPICallError: If the request failed for any reason. google.api_core.exceptions.RetryError: If the request failed due to a retryable error and retry attempts failed. ValueError: If the parameters are invalid.

exists

exists()

Check whether the table exists.

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_check_table_exists] :end-before: [END bigtable_check_table_exists]

Returns

Type	Description
`bool`	True if the table exists, else False.

get_cluster_states

get_cluster_states()

List the cluster states owned by this table.

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_get_cluster_states] :end-before: [END bigtable_get_cluster_states]

Returns

Type	Description
`dict`	Dictionary of cluster states for this table. Keys are cluster ids and values are :class: 'ClusterState' instances.

get_iam_policy

get_iam_policy()

Gets the IAM access control policy for this table.

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_table_get_iam_policy] :end-before: [END bigtable_table_get_iam_policy]

Returns

Type	Description
`Policy`	The current IAM policy of this table.

list_column_families

list_column_families()

List the column families owned by this table.

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_list_column_families] :end-before: [END bigtable_list_column_families]

Exceptions

Type	Description
`ValueErro

Returns

Type	Description
`dict`	Dictionary of column families attached to this table. Keys are strings (column family names) and values are `.ColumnFamily` instances.

mutate_rows

mutate_rows(rows, retry=<google.api_core.retry.Retry object>)

Mutates multiple rows in bulk.

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_mutate_rows] :end-before: [END bigtable_mutate_rows]

The method tries to update all specified rows. If some of the rows weren't updated, it would not remove mutations. They can be applied to the row separately. If row mutations finished successfully, they would be cleaned up.

Optionally, a retry strategy can be specified to re-attempt mutations on rows that return transient errors. This method will retry until all rows succeed or until the request deadline is reached. To specify a retry strategy of "do-nothing", a deadline of 0.0 can be specified.

Parameters

Name	Description
`rows`	`list` List or other iterable of `.DirectRow` instances.
`retry`	`google.api_core.retry.Retry` (Optional) Retry delay and deadline arguments. To override, the default value `DEFAULT_RETRY` can be used and modified with the `google.api_core.retry.Retry.with_delay` method or the `google.api_core.retry.Retry.with_deadline` method.

Returns

Type	Description
`list`	A list of response statuses (`google.rpc.status_pb2.Status`) corresponding to success or failure of each row mutation sent. These will be in the same order as the `rows`.

mutations_batcher

mutations_batcher(flush_count=1000, max_row_bytes=5242880)

Factory to create a mutation batcher associated with this instance.

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_mutations_batcher] :end-before: [END bigtable_mutations_batcher]

Parameters

Name	Description
`table`	`class` class:`Table`.
`flush_count`	`int` (Optional) Maximum number of rows per batch. If it reaches the max number of rows it calls finish_batch() to mutate the current row batch. Default is FLUSH_COUNT (1000 rows).
`max_row_bytes`	`int` (Optional) Max number of row mutations size to flush. If it reaches the max number of row mutations size it calls finish_batch() to mutate the current row batch. Default is MAX_ROW_BYTES (5 MB).

read_row

read_row(row_key, filter_=None)

Read a single row from this table.

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_read_row] :end-before: [END bigtable_read_row]

Parameters

Name	Description
`row_key`	`bytes` The key of the row to read from.
`filter_`	`.RowFilter` (Optional) The filter to apply to the contents of the row. If unset, returns the entire row.

Exceptions

Type	Description
`ValueErro

Returns

Type	Description
`.PartialRowData, :data:NoneType`	The contents of the row if any chunks were returned in the response, otherwise :data:`None`.

read_rows

read_rows(start_key=None, end_key=None, limit=None, filter_=None, end_inclusive=False, row_set=None, retry=<google.api_core.retry.Retry object>)

Read rows from this table.

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_read_rows] :end-before: [END bigtable_read_rows]

Parameters

Name	Description
`start_key`	`bytes` (Optional) The beginning of a range of row keys to read from. The range will include `start_key`. If left empty, will be interpreted as the empty string.
`end_key`	`bytes` (Optional) The end of a range of row keys to read from. The range will not include `end_key`. If left empty, will be interpreted as an infinite string.
`limit`	`int` (Optional) The read will terminate after committing to N rows' worth of results. The default (zero) is to return all results.
`filter_`	`.RowFilter` (Optional) The filter to apply to the contents of the specified row(s). If unset, reads every column in each row.
`end_inclusive`	`bool` (Optional) Whether the `end_key` should be considered inclusive. The default is False (exclusive).
`row_set`	`row_set.RowSet` (Optional) The row set containing multiple row keys and row_ranges.
`retry`	`google.api_core.retry.Retry` (Optional) Retry delay and deadline arguments. To override, the default value `DEFAULT_RETRY_READ_ROWS` can be used and modified with the `google.api_core.retry.Retry.with_delay` method or the `google.api_core.retry.Retry.with_deadline` method.

Returns

Type	Description
`.PartialRowsData`	A `.PartialRowsData` a generator for consuming the streamed results.

row

row(row_key, filter_=None, append=False)

Factory to create a row associated with this table.

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_table_row] :end-before: [END bigtable_table_row]

Warning: At most one of filter_ and append can be used in a xref_Row.

Parameters

Name	Description
`row_key`	`bytes` The key for the row being created.
`filter_`	`.RowFilter` (Optional) Filter to be used for conditional mutations. See `.ConditionalRow` for more details.
`append`	`bool` (Optional) Flag to determine if the row should be used for append mutations.

Exceptions

Type	Description
`ValueErro

Returns

Type	Description
`Row`	A row owned by this table.

sample_row_keys

sample_row_keys()

Read a sample of row keys in the table.

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_sample_row_keys] :end-before: [END bigtable_sample_row_keys]

The returned row keys will delimit contiguous sections of the table of approximately equal size, which can be used to break up the data for distributed tasks like mapreduces.

The elements in the iterator are a SampleRowKeys response and they have the properties offset_bytes and row_key. They occur in sorted order. The table might have contents before the first row key in the list and after the last one, but a key containing the empty string indicates "end of table" and will be the last response given, if present.

Returns

Type	Description
`GrpcRendezvous`	A cancel-able iterator. Can be consumed by calling `next()` or by casting to a `list` and can be cancelled by calling `cancel()`.

set_iam_policy

set_iam_policy(policy)

Sets the IAM access control policy for this table. Replaces any existing policy.

For more information about policy, please see documentation of class google.cloud.bigtable.policy.Policy

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_table_set_iam_policy] :end-before: [END bigtable_table_set_iam_policy]

Parameter

Name	Description
`policy`	`Policy` A new IAM policy to replace the current IAM policy of this table.

Returns

Type	Description
`Policy`	The current IAM policy of this table.

test_iam_permissions

test_iam_permissions(permissions)

Tests whether the caller has the given permissions for this table. Returns the permissions that the caller has.

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_table_test_iam_permissions] :end-before: [END bigtable_table_test_iam_permissions]

Parameter

Name	Description
`permissions`	`list` The set of permissions to check for the `resource`. Permissions with wildcards (such as '' or 'storage.') are not allowed. For more information see `IAM Overview https://cloud.google.com/iam/docs/overview#permissions`. `Bigtable Permissions https://cloud.google.com/bigtable/docs/access-control`.

Returns

Type	Description
`list`	A List(string) of permissions allowed on the table.

truncate

truncate(timeout=None)

Truncate the table

For example:

.. literalinclude:: snippets_table.py :start-after: [START bigtable_truncate_table] :end-before: [END bigtable_truncate_table]

Parameter

Name	Description
`timeout`	`float` (Optional) The amount of time, in seconds, to wait for the request to complete. :raise: google.api_core.exceptions.GoogleAPICallError: If the request failed for any reason. google.api_core.exceptions.RetryError: If the request failed due to a retryable error and retry attempts failed. ValueError: If the parameters are invalid.

yield_rows

yield_rows(**kwargs)

Read rows from this table.

Warning: This method will be removed in future releases. Please use read_rows instead.

Parameters

Name	Description
`start_key`	`bytes` (Optional) The beginning of a range of row keys to read from. The range will include `start_key`. If left empty, will be interpreted as the empty string.
`end_key`	`bytes` (Optional) The end of a range of row keys to read from. The range will not include `end_key`. If left empty, will be interpreted as an infinite string.
`limit`	`int` (Optional) The read will terminate after committing to N rows' worth of results. The default (zero) is to return all results.
`filter_`	`.RowFilter` (Optional) The filter to apply to the contents of the specified row(s). If unset, reads every column in each row.
`row_set`	`row_set.RowSet` (Optional) The row set containing multiple row keys and row_ranges.

Returns

Type	Description
`.PartialRowData`	A `.PartialRowData` for each row returned