Skip to content

Instantly share code, notes, and snippets.

View saptarshiguha's full-sized avatar

Saptarshi Guha saptarshiguha

View GitHub Profile
################################################################################
## 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
################################################################################
## 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
################################################################################
## 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
################################################################################
## 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
################################################################################
## 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
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.
################################################################################
## 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)
################################################################################
## 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)
################################################################################
## 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)
################################################################################
## 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)