|

楼主 |
发表于 2018-1-10 17:09:02
|
显示全部楼层
我是用ksqlQueryProcedure这种方式的,哪里看java。我看代码那里 也是标准的
public static Table query(String ksql, Map<String, Object> variables, String dataModel, String fnModel) {
Utils.check(Utils.isNotEmptyString(ksql) && Utils.isNotEmptyString(dataModel),
CommonMessages.class, CommonMessages.PARAM_NULL1, "ksql, dataModel");
return KSQL.select(ksql, variables, dataModel, Utils.isEmptyString(fnModel) ? null : ModelUtils.getModel(fnModel));
}
|
|