(
self, dataset_name: str, table_name: str, credentials: ServiceCredentials
)
| 18 | MAX_BUFFER_SIZE = 1024 |
| 19 | |
| 20 | def __init__( |
| 21 | self, dataset_name: str, table_name: str, credentials: ServiceCredentials |
| 22 | ) -> None: |
| 23 | from google.cloud import bigquery |
| 24 | |
| 25 | self._client = bigquery.Client(credentials=credentials) |
| 26 | self._table_ref = self._client.dataset(dataset_name).table(table_name) |
| 27 | self._buffer: list[dict] = [] |
| 28 | |
| 29 | def on_change( |
| 30 | self, key: Pointer, row: dict[str, Any], time: int, is_addition: bool |