code: def _start_internal(
      self,
      path: Optional[str] = None,
      tableName: Optional[str] = None,
      format: Optional[str] = None,
      outputMode: Optional[str] = None,
      partitionBy: Optional[Union[str, List[str]]] = None,
      queryName: Optional[str] = None,
      **options: "OptionalPrimitiveType",
  ) -> StreamingQuery:
      self.options(**options)
      if outputMode is not None:
          self.outputMode(outputMode)
      if partitionBy is not None:
          self.partitionBy(partitionBy)
      if format is not None:
          self.format(format)
      if queryName is not None:
          self.queryName(queryName)
      if path:
          self._write_proto.path = path
      if tableName:
          self._write_proto.table_name = tableName
  
      cmd = self._write_stream.command(self._session.client)
      (_, properties) = self._session.client.execute_command(cmd)
  
      start_result = cast(
          pb2.WriteStreamOperationStartResult,
          properties["write_stream_operation_start_result"],
      )
      return StreamingQuery(
          session=self._session,
          queryId=start_result.query_id.id,
          runId=start_result.query_id.run_id,
          name=start_result.name,
      )
  
imports: from pyspark.sql.connect.utils import check_dependencies
  import sys
  import pickle
  from typing import cast, overload, Callable, Dict, List, Optional, TYPE_CHECKING, Union
  from pyspark.serializers import CloudPickleSerializer
  from pyspark.sql.connect.plan import DataSource, LogicalPlan, Read, WriteStreamOperation
  import pyspark.sql.connect.proto
  from pyspark.sql.connect.readwriter import OptionUtils, to_str
  from pyspark.sql.connect.streaming.query import StreamingQuery
  from pyspark.sql.streaming.readwriter import DataStreamReader, DataStreamWriter
  from pyspark.sql.connect.utils import get_python_ver
  from pyspark.sql.types import Row, StructType
  from pyspark.errors import PySparkTypeError, PySparkValueError, PySparkPicklingError
label_desc: Use image node_id 19 for calling the DataStreamWriter obj's underlying member method code with example usage: obj._start_internal(path, tableName, format, outputMode, partitionBy, queryName) and returns: StreamingQuery