code: def __init__(
      self,
      project_id: str,
      dataset: str,
      max_retry_cnt: int = DEFAULT_MAX_RETRY_CNT,
  ) -> None:
      _check_import(self, module="google.cloud", package="bigquery")
      _check_import(
          self, module="google.cloud", package="bigquery_storage"
      )
      _check_import(
          self, module="google.api_core", package="exceptions"
      )
  
      self.project_id = project_id
      self.dataset = dataset
      self.max_retry_cnt = max_retry_cnt
  
file_path: ray/python/ray/data/datasource/bigquery_datasink.py
imports: import logging
  import os
  import tempfile
  import time
  import uuid
  from typing import Any, Iterable
  import pyarrow.parquet
  from ray.data._internal.execution.interfaces import TaskContext
  from ray.data._internal.remote_fn import cached_remote_fn
  from ray.data._internal.util import _check_import
  from ray.data.block import Block, BlockAccessor
  from ray.data.datasource.datasink import Datasink
label_desc: Use image node_id 1 to create a new _BigQueryDatasink object from inherited base classes: Datasink with example: obj = _BigQueryDatasink(project_id, dataset, max_retry_cnt)