Repository: incubator-toree Updated Branches: refs/heads/master e06da57a8 -> 70b804bd7
Add Flush Method to Logger so it can be compliant to stream interface Project: http://git-wip-us.apache.org/repos/asf/incubator-toree/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-toree/commit/e1dc4e54 Tree: http://git-wip-us.apache.org/repos/asf/incubator-toree/tree/e1dc4e54 Diff: http://git-wip-us.apache.org/repos/asf/incubator-toree/diff/e1dc4e54 Branch: refs/heads/master Commit: e1dc4e5414599ea2d298540a4805d0f87a83d5eb Parents: 9b577f1 Author: David Taieb <[email protected]> Authored: Wed Jan 4 08:36:49 2017 -0500 Committer: David Taieb <[email protected]> Committed: Wed Jan 4 08:36:49 2017 -0500 ---------------------------------------------------------------------- pyspark-interpreter/src/main/resources/PySpark/pyspark_runner.py | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-toree/blob/e1dc4e54/pyspark-interpreter/src/main/resources/PySpark/pyspark_runner.py ---------------------------------------------------------------------- diff --git a/pyspark-interpreter/src/main/resources/PySpark/pyspark_runner.py b/pyspark-interpreter/src/main/resources/PySpark/pyspark_runner.py index e3864f8..fcb1a06 100644 --- a/pyspark-interpreter/src/main/resources/PySpark/pyspark_runner.py +++ b/pyspark-interpreter/src/main/resources/PySpark/pyspark_runner.py @@ -93,6 +93,9 @@ class Logger(object): def reset(self): self.out = "" + + def flush(self): + pass output = Logger() sys.stdout = output
