code: def __init__(self, uri: str, database: str, collection: str) -> None:
      _check_import(self, module="pymongo", package="pymongo")
      _check_import(self, module="pymongoarrow", package="pymongoarrow")
  
      self.uri = uri
      self.database = database
      self.collection = collection
  
file_path: ray/python/ray/data/datasource/mongo_datasink.py
imports: import logging
  from typing import Any, Iterable
  from ray.data._internal.delegating_block_builder import DelegatingBlockBuilder
  from ray.data._internal.execution.interfaces import TaskContext
  from ray.data._internal.util import _check_import
  from ray.data.block import Block, BlockAccessor
  from ray.data.datasource.datasink import Datasink
  from ray.data.datasource.mongo_datasource import _validate_database_collection_exist
label_desc: Use image node_id 1 to create a new _MongoDatasink object from inherited base classes: Datasink with example: obj = _MongoDatasink(uri, database, collection)