code: def __init__(
      self, sql: str, connection_factory: Callable[[], Connection]
  ):
      self.sql = sql
      self.connection_factory = connection_factory
  
file_path: ray/python/ray/data/datasource/sql_datasink.py
imports: from typing import Any, Callable, Iterable
  from ray.data._internal.execution.interfaces import TaskContext
  from ray.data.block import Block, BlockAccessor
  from ray.data.datasource.datasink import Datasink
  from ray.data.datasource.sql_datasource import Connection, _connect
label_desc: Use image node_id 1 to create a new _SQLDatasink object from inherited base classes: Datasink with example: obj = _SQLDatasink(sql, connection_factory)