diff options
| author | Aaron Davidson <aaron@databricks.com> | 2013-09-07 14:41:31 -0700 |
|---|---|---|
| committer | Aaron Davidson <aaron@databricks.com> | 2013-09-07 14:41:31 -0700 |
| commit | c1cc8c4da239965e8ad478089b27e9c694088978 (patch) | |
| tree | 4fb6bd7a08f28121e1d899cf47558e6957bbed9c /python/pyspark/shell.py | |
| parent | 8001687af597056f630fb81f1edbcaf354c5388a (diff) | |
| download | spark-c1cc8c4da239965e8ad478089b27e9c694088978.tar.gz spark-c1cc8c4da239965e8ad478089b27e9c694088978.tar.bz2 spark-c1cc8c4da239965e8ad478089b27e9c694088978.zip | |
Export StorageLevel and refactor
Diffstat (limited to 'python/pyspark/shell.py')
| -rw-r--r-- | python/pyspark/shell.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pyspark/shell.py b/python/pyspark/shell.py index e374ca4ee4..dc205b306f 100644 --- a/python/pyspark/shell.py +++ b/python/pyspark/shell.py @@ -24,12 +24,12 @@ import os import platform import pyspark from pyspark.context import SparkContext +from pyspark.storagelevel import StorageLevel # this is the equivalent of ADD_JARS add_files = os.environ.get("ADD_FILES").split(',') if os.environ.get("ADD_FILES") != None else None sc = SparkContext(os.environ.get("MASTER", "local"), "PySparkShell", pyFiles=add_files) -StorageLevel = sc.StorageLevel # alias StorageLevel to global scope print """Welcome to ____ __ |