code: def readPointBatch(iterator: Iterable[str]) -> List[np.ndarray]:
      strs = list(iterator)
      matrix = np.zeros((len(strs), D + 1))
      for i, s in enumerate(strs):
          matrix[i] = np.fromstring(
              s.replace(",", " "), dtype=np.float32, sep=" "
          )
      return [matrix]
  
imports: import sys
  from typing import Iterable, List
  import numpy
  from pyspark.sql import SparkSession
label_desc: Use image node_id 1 for calling a global function with example usage: readPointBatch(iterator) and returns: list