mirror of
https://github.com/apache/zeppelin
synced 2026-05-24 09:38:26 +00:00
remove unnecessary test
This commit is contained in:
parent
bde2316c71
commit
fd56855522
1 changed files with 0 additions and 26 deletions
|
|
@ -142,32 +142,6 @@ public class PythonInterpreterPandasSqlTest implements InterpreterOutputListener
|
|||
context).code());
|
||||
}
|
||||
|
||||
@Test
|
||||
public void sqlCountOverTestDataFrame() throws IOException, InterpreterException {
|
||||
InterpreterResult ret;
|
||||
// given
|
||||
// DataFrame df3 \w generated 200 test rows
|
||||
ret = python.interpret("import pandas as pd\n"
|
||||
+ "import numpy as np\n"
|
||||
+ "df3 = pd.DataFrame(\n"
|
||||
+ " np.array([\n"
|
||||
+ " np.arange(0, 200),\n"
|
||||
+ " np.random.randn(200).cumsum(),\n"
|
||||
+ " np.random.randn(200).cumsum(),\n"
|
||||
+ " np.random.randint(1, 3, 200)\n"
|
||||
+ " ]).transpose(),\n"
|
||||
+ " columns=[\"X\", \"Y\", \"Z\", \"Group\"])", context);
|
||||
assertEquals(ret.message().toString(), InterpreterResult.Code.SUCCESS, ret.code());
|
||||
|
||||
//when
|
||||
ret = sql.interpret("select count(*) from df3", context);
|
||||
|
||||
//then
|
||||
assertEquals(InterpreterResult.Code.SUCCESS, ret.code());
|
||||
assertEquals(Type.TABLE, out.getOutputAt(1).getType());
|
||||
assertTrue(new String(out.getOutputAt(1).toByteArray()).contains("200"));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void badSqlSyntaxFails() throws IOException, InterpreterException {
|
||||
//when
|
||||
|
|
|
|||
Loading…
Reference in a new issue