Expose ZeppelinContext
Project: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/commit/fe75baf5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/tree/fe75baf5 Diff: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/diff/fe75baf5 Branch: refs/heads/master Commit: fe75baf5858232e8a9beb90e18e6abef69e95e87 Parents: f79ff2f Author: Lee moon soo <[email protected]> Authored: Thu Mar 12 10:08:06 2015 +0900 Committer: Lee moon soo <[email protected]> Committed: Thu Mar 12 10:08:06 2015 +0900 ---------------------------------------------------------------------- .../main/java/com/nflabs/zeppelin/spark/PySparkInterpreter.java | 4 +++- spark/src/main/resources/python/zeppelin_pyspark.py | 2 ++ 2 files changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/blob/fe75baf5/spark/src/main/java/com/nflabs/zeppelin/spark/PySparkInterpreter.java ---------------------------------------------------------------------- diff --git a/spark/src/main/java/com/nflabs/zeppelin/spark/PySparkInterpreter.java b/spark/src/main/java/com/nflabs/zeppelin/spark/PySparkInterpreter.java index 51c7496..cfd66a9 100644 --- a/spark/src/main/java/com/nflabs/zeppelin/spark/PySparkInterpreter.java +++ b/spark/src/main/java/com/nflabs/zeppelin/spark/PySparkInterpreter.java @@ -247,7 +247,9 @@ public class PySparkInterpreter extends Interpreter implements ExecuteResultHand SparkInterpreter sparkInterpreter = getSparkInterpreter(); String jobGroup = sparkInterpreter.getJobGroup(context); - + ZeppelinContext z = sparkInterpreter.getZeppelinContext(); + z.setInterpreterContext(context); + z.setGui(context.getGui()); pythonInterpretRequest = new PythonInterpretRequest(st, jobGroup); statementOutput = null; http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/blob/fe75baf5/spark/src/main/resources/python/zeppelin_pyspark.py ---------------------------------------------------------------------- diff --git a/spark/src/main/resources/python/zeppelin_pyspark.py b/spark/src/main/resources/python/zeppelin_pyspark.py index 4362406..5c4529d 100644 --- a/spark/src/main/resources/python/zeppelin_pyspark.py +++ b/spark/src/main/resources/python/zeppelin_pyspark.py @@ -36,6 +36,8 @@ conf = SparkConf(_jvm = gateway.jvm, _jconf = jconf) sc = SparkContext(jsc=jsc, gateway=gateway, conf=conf) sqlc = SQLContext(sc, intp.getSQLContext()) +z = intp.getZeppelinContext() + class Logger(object): def __init__(self): self.out = ""
