Elgato_dark/zeppelin
1
0
Fork 0
mirror of https://github.com/apache/zeppelin synced 2026-05-24 09:38:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

fix code style

Browse source
This commit is contained in:
Jeff Zhang 2021-08-07 13:18:19 +08:00
parent c9e63fa4e0
commit 7a3e54e539
2 changed files with 16 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
python/src/main/java/org/apache/zeppelin/python/PythonInterpreterPandasSql.java
View file

@ -46,7 +46,8 @@ public class PythonInterpreterPandasSql extends Interpreter {
public void open() throws InterpreterException {
LOGGER.info("Open Python SQL interpreter instance: PythonInterpreterPandasSql");
try {
LOGGER.info("Bootstrap PythonInterpreterPandasSql interpreter with {}", SQL_BOOTSTRAP_FILE_PY);
LOGGER.info("Bootstrap PythonInterpreterPandasSql interpreter with {}",
SQL_BOOTSTRAP_FILE_PY);
this.pythonInterpreter = getInterpreterInTheSameSessionByClassName(PythonInterpreter.class);
this.pythonInterpreter.bootstrapInterpreter(SQL_BOOTSTRAP_FILE_PY);
} catch (IOException e) {

26
python/src/test/java/org/apache/zeppelin/python/PythonInterpreterPandasSqlTest.java
View file

@ -35,7 +35,6 @@ import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.util.Arrays;
import java.util.LinkedList;
import java.util.List;
import java.util.Properties;
@ -122,7 +121,7 @@ public class PythonInterpreterPandasSqlTest {
}
@After
public void afterTest() throws IOException, InterpreterException {
public void afterTest() throws InterpreterException {
pandasSqlInterpreter.close();
}
@ -165,8 +164,9 @@ public class PythonInterpreterPandasSqlTest {
assertTrue(new String(out.getOutputAt(1).toByteArray()).indexOf("park\t34") > 0);
assertEquals(InterpreterResult.Code.SUCCESS,
pandasSqlInterpreter.interpret("select case when name==\"aa\" then name else name end from df2",
context).code());
pandasSqlInterpreter.interpret(
"select case when name==\"aa\" then name else name end from df2",
context).code());
}
@Test
@ -191,12 +191,13 @@ public class PythonInterpreterPandasSqlTest {
assertTrue(new String(out.getOutputAt(1).toByteArray()).indexOf("park\t34") > 0);
assertEquals(InterpreterResult.Code.SUCCESS,
pandasSqlInterpreter.interpret("select case when name==\"aa\" then name else name end from df2",
pandasSqlInterpreter.interpret(
"select case when name==\"aa\" then name else name end from df2",
context).code());
}
@Test
public void badSqlSyntaxFails() throws IOException, InterpreterException {
public void badSqlSyntaxFails() throws InterpreterException {
//when
InterpreterResult ret = pandasSqlInterpreter.interpret("select wrong syntax", context);
@ -207,14 +208,15 @@ public class PythonInterpreterPandasSqlTest {
@Test
public void showDataFrame() throws IOException, InterpreterException {
InterpreterResult ret;
ret = pythonInterpreter.interpret("import pandas as pd", context);
ret = pythonInterpreter.interpret("import numpy as np", context);
pythonInterpreter.interpret("import pandas as pd", context);
pythonInterpreter.interpret("import numpy as np", context);
// given a Pandas DataFrame with an index and non-text data
ret = pythonInterpreter.interpret("index = pd.Index([10, 11, 12, 13], name='index_name')", context);
ret = pythonInterpreter.interpret("d1 = {1 : [np.nan, 1, 2, 3], 'two' : [3., 4., 5., 6.7]}", context);
ret = pythonInterpreter.interpret("df1 = pd.DataFrame(d1, index=index)", context);
pythonInterpreter.interpret(
"index = pd.Index([10, 11, 12, 13], name='index_name')", context);
pythonInterpreter.interpret(
"d1 = {1 : [np.nan, 1, 2, 3], 'two' : [3., 4., 5., 6.7]}", context);
InterpreterResult ret = pythonInterpreter.interpret("df1 = pd.DataFrame(d1, index=index)", context);
assertEquals(ret.message().toString(), InterpreterResult.Code.SUCCESS, ret.code());
// when