2022-12-16 13:56 回答问题
需要分三步 1 先将 列转化为 BasicArrayVector 2 然后调用 getVectorValue 3 . 再转换 Entity[] 才能转换为 MultithreadedTableWriter::insert 能识别的格式 for (int rowIdx = 0; rowIdx < data.rows(); rowIdx++) { List<Object> row = new ArrayList<>(); for (int k
2022-12-02 13:22 回答问题
def wideModelSinglePartitionUpdate(dbname,tbname,start_time,end_time,update_factor,symbol_name){ num_row = exec count(*) from loadTable(dbname,tbname) where tradetime>=start_time and tradetime<=end_time and symbol = symbol_name script =
2022-10-27 13:33 发起提问
2022-10-26 10:13 发起提问
2022-10-10 13:34 发起提问
2022-04-13 11:02 回答问题
如果机器编码增加不多的话,可以把机器编码按 HASH 分区
2022-03-30 17:45 回答问题
hello, have you tried gema function? https://www.dolphindb.cn/cn/help/FunctionsandCommands/FunctionReferences/g/gema.html?highlight=gema
2022-03-14 15:36 回答问题
1 是的,对于文档中支持的函数,可以自动处理成级联的引擎 2 对不支持的 metrics ,无法正确处理 3 是的,主要是简化了代码 3 可以在运行 streamEngineParser 后,运行 getStreamEngineStat() 查看 parser 生成的引擎 (比如手册https://www.dolphindb.cn/cn/help/FunctionsandCommands/FunctionReferences/s/streamEngineParser.html?highlight=st
2022-03-14 10:29 发起提问
2022-03-14 09:31 发起提问