code: def streamToAzureSearch(df, **options):
      jvm = SparkContext.getOrCreate()._jvm
      writer = (
          jvm.com.microsoft.azure.synapse.ml.services.search.AzureSearchWriter
      )
      return writer.stream(df._jdf, options)
  
file_path: SynapseML/cognitive/src/main/python/synapse/ml/services/search/AzureSearchWriter.py
imports: import sys
  import pyspark
  from pyspark import SparkContext
  from pyspark import sql
  from pyspark.ml.param.shared import *
  from pyspark.sql import DataFrame
label_desc: Use image node_id 1 for calling a global function with example usage: streamToAzureSearch(df) and returns: writer