code: def _do_pipeline_transform(
      df: DataFrame, transformer: Union[Transformer, PipelineModel]
  ):
      """
      A util method that runs transform on a pipeline model/transformer
  
      :param df:a spark dataframe
      :return: output transformed dataframe using pipeline model/transformer
      """
      return transformer.transform(df)
  
file_path: mlflow/mlflow/pyspark/ml/_autolog.py
imports: import re
  from functools import reduce
  from typing import Set, Union
  from pyspark.ml.base import Transformer
  from pyspark.ml.functions import vector_to_array
  from pyspark.ml.linalg import VectorUDT
  from pyspark.ml.pipeline import PipelineModel
  from pyspark.sql import DataFrame
  from pyspark.sql import types
label_desc: Use image node_id 2 for calling a global function with example usage: _do_pipeline_transform(df, transformer) and returns: transformer