datafu.spark
this class let's the user invoke PySpark code from scala example usage:
val runner = ScalaPythonBridgeRunner() runner.runPythonFile("my_package/my_pyspark_logic.py")
this class let's the user invoke PySpark code from scala example usage:
val runner = ScalaPythonBridgeRunner() runner.runPythonFile("my_package/my_pyspark_logic.py")