code: def to_simple_rdd(
      sc: SparkContext, features: np.array, labels: np.array
  ):
      """Convert numpy arrays of features and labels into
      an RDD of pairs.
  
      :param sc: Spark context
      :param features: numpy array with features
      :param labels: numpy array with labels
      :return: Spark RDD with feature-label pairs
      """
      pairs = [(x, y) for x, y in zip(features, labels)]
      return sc.parallelize(pairs)
  
file_path: elephas/elephas/utils/rdd_utils.py
imports: from pyspark import RDD, SparkContext
  from pyspark.mllib.regression import LabeledPoint
  import numpy
  from ..mllib.adapter import to_vector, from_vector
label_desc: Use image node_id 1 for calling a global function with example usage: to_simple_rdd(sc, features, labels) and returns: sc