code: def spark_output_receiver(feature_store_manager_factory):
      return SparkOutputReceiver(feature_store_manager_factory)
  
file_path: sagemaker-python-sdk/tests/unit/sagemaker/feature_store/feature_processor/test_udf_output_receiver.py
imports: from __future__ import absolute_import
  import pytest
  import test_data_helpers
  from feature_store_pyspark.FeatureStoreManager import FeatureStoreManager
  from mock import Mock
  from py4j.protocol import Py4JJavaError
  from pyspark.sql import DataFrame
  from sagemaker.feature_store.feature_processor import IngestionError
  from sagemaker.feature_store.feature_processor._spark_factory import FeatureStoreManagerFactory
  from sagemaker.feature_store.feature_processor._udf_output_receiver import SparkOutputReceiver
label_desc: Use image node_id 4 for calling a global function with example usage: spark_output_receiver(feature_store_manager_factory) and returns: SparkOutputReceiver