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 发起提问