mirror of
https://github.com/apache/zeppelin
synced 2026-05-24 09:38:26 +00:00
Added interpreter-setting.json
Fixed test environments
This commit is contained in:
parent
5d5d758ce6
commit
5e2304382e
3 changed files with 67 additions and 28 deletions
|
|
@ -56,24 +56,6 @@ public class KylinInterpreter extends Interpreter {
|
|||
static final Pattern KYLIN_TABLE_FORMAT_REGEX_LABEL = Pattern.compile("\"label\":\"(.*?)\"");
|
||||
static final Pattern KYLIN_TABLE_FORMAT_REGEX = Pattern.compile("\"results\":\\[\\[\"(.*?)\"]]");
|
||||
|
||||
static {
|
||||
Interpreter.register(
|
||||
"kylin",
|
||||
"kylin",
|
||||
KylinInterpreter.class.getName(),
|
||||
new InterpreterPropertyBuilder()
|
||||
.add(KYLIN_USERNAME, "ADMIN", "username for kylin user")
|
||||
.add(KYLIN_PASSWORD, "KYLIN", "password for kylin user")
|
||||
.add(KYLIN_QUERY_API_URL, "http://<host>:<port>/kylin/api/query", "Kylin API.")
|
||||
.add(KYLIN_QUERY_PROJECT, "default", "kylin project name")
|
||||
.add(KYLIN_QUERY_OFFSET, "0", "kylin query offset")
|
||||
.add(KYLIN_QUERY_LIMIT, "5000", "kylin query limit")
|
||||
.add(KYLIN_QUERY_ACCEPT_PARTIAL, "true", "The kylin query partial flag").build());
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
public KylinInterpreter(Properties property) {
|
||||
super(property);
|
||||
}
|
||||
|
|
|
|||
54
kylin/src/main/resources/interpreter-setting.json
Normal file
54
kylin/src/main/resources/interpreter-setting.json
Normal file
|
|
@ -0,0 +1,54 @@
|
|||
[
|
||||
{
|
||||
"group": "kylin",
|
||||
"name": "kylin",
|
||||
"className": "org.apache.zeppelin.kylin.KylinInterpreter",
|
||||
"properties": {
|
||||
"kylin.api.url": {
|
||||
"envName": null,
|
||||
"propertyName": "kylin.api.url",
|
||||
"defaultValue": "http://localhost:7070/kylin/api/query",
|
||||
"description": "Kylin API"
|
||||
},
|
||||
"kylin.api.user": {
|
||||
"envName": null,
|
||||
"propertyName": "kylin.api.user",
|
||||
"defaultValue": "ADMIN",
|
||||
"description": "username for kylin user"
|
||||
},
|
||||
"kylin.api.password": {
|
||||
"envName": null,
|
||||
"propertyName": "kylin.api.password",
|
||||
"defaultValue": "KYLIN",
|
||||
"description": "password for kylin user"
|
||||
},
|
||||
"kylin.query.project": {
|
||||
"envName": null,
|
||||
"propertyName": "kylin.query.project",
|
||||
"defaultValue": "default",
|
||||
"description": "kylin project name"
|
||||
},
|
||||
"kylin.query.offset": {
|
||||
"envName": null,
|
||||
"propertyName": "kylin.query.offset",
|
||||
"defaultValue": "0",
|
||||
"description": "kylin query offset"
|
||||
},
|
||||
"kylin.query.limit": {
|
||||
"envName": null,
|
||||
"propertyName": "kylin.query.limit",
|
||||
"defaultValue": "5000",
|
||||
"description": "kylin query limit"
|
||||
},
|
||||
"kylin.query.ispartial": {
|
||||
"envName": null,
|
||||
"propertyName": "kylin.query.ispartial",
|
||||
"defaultValue": "true",
|
||||
"description": "The kylin query partial flag"
|
||||
}
|
||||
},
|
||||
"editor": {
|
||||
"language": "sql"
|
||||
}
|
||||
}
|
||||
]
|
||||
|
|
@ -20,8 +20,7 @@ import org.apache.http.client.methods.HttpPost;
|
|||
import org.apache.http.message.AbstractHttpMessage;
|
||||
import org.apache.zeppelin.interpreter.InterpreterResult;
|
||||
import org.apache.zeppelin.kylin.KylinInterpreter;
|
||||
import org.junit.After;
|
||||
import org.junit.Before;
|
||||
import org.junit.BeforeClass;
|
||||
import org.junit.Test;
|
||||
|
||||
import java.io.ByteArrayInputStream;
|
||||
|
|
@ -33,19 +32,23 @@ import java.util.Properties;
|
|||
|
||||
import static org.junit.Assert.assertEquals;
|
||||
|
||||
|
||||
public class KylinInterpreterTest {
|
||||
@Before
|
||||
public void setUp() throws Exception {
|
||||
}
|
||||
static final Properties kylinProperties = new Properties();
|
||||
|
||||
@After
|
||||
public void tearDown() throws Exception {
|
||||
@BeforeClass
|
||||
public static void setUpClass() {
|
||||
kylinProperties.put("kylin.api.url", "http://localhost:7070/kylin/api/query");
|
||||
kylinProperties.put("kylin.api.user", "ADMIN");
|
||||
kylinProperties.put("kylin.api.password", "KYLIN");
|
||||
kylinProperties.put("kylin.query.project", "default");
|
||||
kylinProperties.put("kylin.query.offset", "0");
|
||||
kylinProperties.put("kylin.query.limit", "5000");
|
||||
kylinProperties.put("kylin.query.ispartial", "true");
|
||||
}
|
||||
|
||||
@Test
|
||||
public void test(){
|
||||
KylinInterpreter t = new MockKylinInterpreter(new Properties());
|
||||
KylinInterpreter t = new MockKylinInterpreter(kylinProperties);
|
||||
InterpreterResult result = t.interpret(
|
||||
"select a.date,sum(b.measure) as measure from kylin_fact_table a " +
|
||||
"inner join kylin_lookup_table b on a.date=b.date group by a.date", null);
|
||||
|
|
@ -198,4 +201,4 @@ class MockEntity implements HttpEntity{
|
|||
public void consumeContent() throws IOException {
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in a new issue