'Feeds Spark data partitions into the TensorFlow worker nodes and returns an RDD of results.'

def inference(self, dataRDD, qname='input'):

    logging.info('Feeding    inference    data')
    assert (self.input_mode == InputMode.SPARK)
    assert (qname in self.queues)
    return dataRDD.mapPartitions(TFSparkNode.inference(self.cluster_info, qname))
