### What is this PR for? Add new interpreter to Python group: `%python.sql` for SQL over DataFrame support ### What type of PR is it? Improvement ### TODOs * [x] add new interpreter `%python.sql` * [x] add test * [x] make Python-dependant tests, excluded from CI * PythonInterpreterWithPythonInstalledTest * PythonPandasSqlInterpreterTest * run manually by `mvn -Dpython.test.exclude='' test -pl python -am` * [x] add docs `%python.sql` * [x] make `%python.sql` fail gracefully in case there is no Pandas or PandaSQL installed * [x] after #747 is merged - rebase and remove `-Dpython.test.exclude=''` from both profiles ### What is the Jira issue? [ZEPPELIN-1115](https://issues.apache.org/jira/browse/ZEPPELIN-1115) ### How should this be tested? `mvn -Dpython.test.exclude='' test -pl python -am` should pass or manually run - Given the DataFrame i.e ``` %python import pandas as pd rates = pd.read_csv("bank.csv", sep=";") ``` - SQL query it like ``` %python.sql SELECT * FROM rates LIMIT 10 ``` ### Screenshots (if appropriate)  ### Questions: * Does the licenses files need update? No, no dependencies were included in source or binary release * Is there breaking changes for older versions? No * Does this needs documentation? Yes Author: Alexander Bezzubov <bzz@apache.org> Closes #1164 from bzz/ZEPPELIN-1115/python/add-sql-for-dataframes and squashes the following commits:0f2f852[Alexander Bezzubov] Fail SQL gracefully if no python dependencies installedaca2bdf[Alexander Bezzubov] Fix typos in docs ⚡158ba6a[Alexander Bezzubov] Remove third-party dependant test from CI5fe46fc[Alexander Bezzubov] Update Python Matplotlib notebook example72884c8[Alexander Bezzubov] Add docs for %python.sql featuree931dc4[Alexander Bezzubov] Make test for PythonPandasSqlInterpreter usable76bbb44[Alexander Bezzubov] Complete implementation of the PythonPandasSqlInterpreterf6ca1eb[Alexander Bezzubov] Add %python.sql to interpreter menue11ba490[Alexander Bezzubov] Add draft implementation of %python.sql for DataFrames
4.3 KiB
| layout | title | description | group |
|---|---|---|---|
| page | Python Interpreter | Python Interpreter | interpreter |
{% include JB/setup %}
Python 2 & 3 Interpreter for Apache Zeppelin
Configuration
| Property | Default | Description |
|---|---|---|
| zeppelin.python | python | Path of the already installed Python binary (could be python2 or python3). If python is not in your $PATH you can set the absolute directory (example : /usr/bin/python) |
| zeppelin.python.maxResult | 1000 | Max number of dataframe rows to display. |
Enabling Python Interpreter
In a notebook, to enable the Python interpreter, click on the Gear icon and select Python
Using the Python Interpreter
In a paragraph, use %python to select the Python interpreter and then input all commands.
The interpreter can only work if you already have python installed (the interpreter doesn't bring it own python binaries).
To access the help, type help()
Python modules
The interpreter can use all modules already installed (with pip, easy_install...)
Using Zeppelin Dynamic Forms
You can leverage Zeppelin Dynamic Form inside your Python code.
Zeppelin Dynamic Form can only be used if py4j Python library is installed in your system. If not, you can install it with pip install py4j.
Example :
%python
### Input form
print (z.input("f1","defaultValue"))
### Select form
print (z.select("f1",[("o1","1"),("o2","2")],"2"))
### Checkbox form
print("".join(z.checkbox("f3", [("o1","1"), ("o2","2")],["1"])))
Zeppelin features not fully supported by the Python Interpreter
- Interrupt a paragraph execution (
cancel()method) is currently only supported in Linux and MacOs. If interpreter runs in another operating system (for instance MS Windows) , interrupt a paragraph will close the whole interpreter. A JIRA ticket (ZEPPELIN-893) is opened to implement this feature in a next release of the interpreter. - Progression bar in webUI (
getProgress()method) is currently not implemented. - Code-completion is currently not implemented.
Matplotlib integration
The python interpreter can display matplotlib graph with the function z.show().
You need to have matplotlib module installed and a XServer running to use this functionality !
%python
import matplotlib.pyplot as plt
plt.figure()
(.. ..)
z.show(plt)
plt.close()
z.show function can take optional parameters to adapt graph width and height
%python
z.show(plt, width='50px')
z.show(plt, height='150px')
Pandas integration
Apache Zeppelin Table Display System provides built-in data visualization capabilities. Python interpreter leverages it to visualize Pandas DataFrames though similar z.show() API, same as with Matplotlib integration.
Example:
import pandas as pd
rates = pd.read_csv("bank.csv", sep=";")
z.show(rates)
SQL over Pandas DataFrames
There is a convenience %python.sql interpreter that matches Apache Spark experience in Zeppelin and enables usage of SQL language to query Pandas DataFrames and visualization of results though built-in Table Display System.
Pre-requests
- Pandas
pip install pandas - PandaSQL
pip install -U pandasql
In case default binded interpreter is Python (first in the interpreter list, under the Gear Icon), you can just use it as %sql i.e
- first paragraph
import pandas as pd
rates = pd.read_csv("bank.csv", sep=";")
- next paragraph
%sql
SELECT * FROM rates WHERE age < 40
Otherwise it can be referred to as %python.sql
Technical description
For in-depth technical details on current implementation please refer to python/README.md.