# Path: tensorflowonspark/TFParallel.py
# def run(sc, map_fn, tf_args, num_executors, use_barrier=True):
#   def _run(it):


import unittest
import test
      import tensorflow as tf
      import tensorflow as tf
      import tensorflow as tf
from tensorflowonspark import TFParallel


class TFParallelTest(test.SparkTest):

  @classmethod
  def setUpClass(cls):
    super(TFParallelTest, cls).setUpClass()

  @classmethod
  def tearDownClass(cls):

# Path: tensorflowonspark/TFParallel.py
# def run(sc, map_fn, tf_args, num_executors, use_barrier=True):
#   def _run(it):


# Path: tests/test_TFParallel.py
import unittest
import test
      import tensorflow as tf
      import tensorflow as tf
      import tensorflow as tf
from tensorflowonspark import TFParallel



class TFParallelTest(test.SparkTest):

  @classmethod
  def setUpClass(cls):
    super(TFParallelTest, cls).setUpClass()

  @classmethod
  def tearDownClass(cls):

    super(TFParallelTest, cls).tearDownClass()