This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
################################################################################ | |
## PySpark Invocation | |
## submit code using /usr/lib/spark/bin/spark-submit review.py | |
################################################################################ | |
import os,sys | |
os.environ['PYSPARK_PYTHON'] = sys.executable | |
print([os.environ.get('PYSPARK_PYTHON','missing'),os.environ.get('PYSPARK_DRIVER_PYTHON','missing')]) | |
import pyspark | |
import py4j | |
from pyspark import SparkContext |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
################################################################################ | |
## PySpark Invocation | |
## submit code using /usr/lib/spark/bin/spark-submit review.py | |
################################################################################ | |
import os,sys | |
os.environ['PYSPARK_PYTHON'] = sys.executable | |
print([os.environ.get('PYSPARK_PYTHON','missing'),os.environ.get('PYSPARK_DRIVER_PYTHON','missing')]) | |
import pyspark | |
import py4j | |
from pyspark import SparkContext |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
################################################################################ | |
## PySpark Invocation | |
## submit code using /usr/lib/spark/bin/spark-submit review.py | |
################################################################################ | |
import os,sys | |
os.environ['PYSPARK_PYTHON'] = sys.executable | |
print([os.environ['PYSPARK_PYTHON'],os.environ['PYSPARK_DRIVER_PYTHON']]) | |
import pyspark | |
import py4j | |
from pyspark import SparkContext |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
################################################################################ | |
## PySpark Invocation | |
## submit code using /usr/lib/spark/bin/spark-submit review.py | |
################################################################################ | |
import os,sys | |
os.environ['PYSPARK_PYTHON'] = sys.executable | |
import pyspark | |
import py4j | |
from pyspark import SparkContext |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
################################################################################ | |
## PySpark Invocation | |
## submit code using /usr/lib/spark/bin/spark-submit review.py | |
################################################################################ | |
import os | |
os.environ['PYSPARK_PYTHON'] = sys.executable | |
import pyspark | |
import py4j | |
from pyspark import SparkContext |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
1 pound red kidney beans 1 link of Hillshire Farms smoked sausage (like polish | |
style) 1 celery stalk 1 yellow onion 1-2 bay leaves Ground cayenne pepper Brown | |
rice or long-grain white rice Crystal brand hot sauce | |
This is my pressure cooker adaptation of my mother-in-law's recipe. | |
Rinse 1 pound of red kidney beans, then cover with 3-4" of water and soak | |
overnight. The next morning, dump the water and rinse them thoroughly. | |
Chop one medium-sized yellow onion and one celery stalk. |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
################################################################################ | |
## PySpark Invocation | |
## submit code using /usr/lib/spark/bin/spark-submit review.py | |
################################################################################ | |
import pyspark | |
import py4j | |
from pyspark import SparkContext | |
from pyspark.sql import SQLContext | |
sc = pyspark.SparkContext() | |
sqlContext = SQLContext(sc) |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
################################################################################ | |
## PySpark Invocation | |
## submit code using /usr/lib/spark/bin/spark-submit review.py | |
################################################################################ | |
import pyspark | |
import py4j | |
from pyspark import SparkContext | |
from pyspark.sql import SQLContext | |
sc = pyspark.SparkContext() | |
sqlContext = SQLContext(sc) |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
################################################################################ | |
## PySpark Invocation | |
## submit code using /usr/lib/spark/bin/spark-submit review.py | |
################################################################################ | |
import pyspark | |
import py4j | |
from pyspark import SparkContext | |
from pyspark.sql import SQLContext | |
sc = pyspark.SparkContext() | |
sqlContext = SQLContext(sc) |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
################################################################################ | |
## PySpark Invocation | |
## submit code using /usr/lib/spark/bin/spark-submit review.py | |
################################################################################ | |
import pyspark | |
import py4j | |
from pyspark import SparkContext | |
from pyspark.sql import SQLContext | |
sc = pyspark.SparkContext() | |
sqlContext = SQLContext(sc) |