338 个回答
流计算示例的疑问
enableTableShareAndPersistence将表tradeOriginalStreamTemp 共享到当前节点的所有会话中，共享名为tradeOriginalStream。共享后，在其他会话中可访问tradeOriginalStream，但不能访问tradeOriginalStreamTemp ，所以这里就可以把tradeOriginalStreamTemp 释放了。
回答于 2024-02-21 13:45
如何把csv中的datetime和毫秒数2列合并成timestamp并导入到分布...
我写了一个简单的 demo供参考： db = database("dfs://testdb", VALUE, 2022.01.01..2022.01.03)t = table(1:0, [`time], [TIMESTAMP])createPartitionedTable(dbHandle=db, table=t, tableName=`pt1, partitionColumns=`time)s = extractTextSchema("D:/data/data1.csv")update s set type="TIMESTAMP" where name = `alo...
回答于 2024-02-21 13:38
怎样才能指定分区查询
用where条件指定分区，类似下面： select count(*) from loadTable('dfs://db1','table1') where month(date)=2023.11M
回答于 2024-02-21 11:35
python_api中，我使用完ddb.DBConnectionPool后，是否可以不调用...
调用 shutDown() 后线程任务执行结束会立即释放连接，若不调用，连接也会释放，但存在延时。
回答于 2024-02-19 22:13
请求：能否开发grafana的alert部分，在大多数场景中需要对于信号...
请参阅https://gitee.com/dolphindb/Tutorials_CN/blob/master/cluster_monitor.md#4-%E9%82%AE%E4%BB%B6%E5%91%8A%E8%AD%A6%E4%B8%8E%E9%A2%84%E8%AD%A6 第4节邮件告警与预警，看一下是否还有什么需求不能实现。
回答于 2024-02-17 11:01
where条件中like怎么用
举例如下供参考： tbIndex=table(["充电桩1","桩2"] as index_name) keyWords = ['充电桩','充电'] select * from tbIndex where index_name like ("%"+keyWords[0]+"%") or index_name like ("%"+keyWords[1]+ "%")
回答于 2024-02-03 16:47
表中有很多形如event_i_j的列名，要求查询出i>j的列
可以用元编程的方式： t = table(1 2 3 4 as event_1_5, 1 3 4 5 as event_2_5, 1 2 3 4 as event_5_1, 1 2 3 4 as event_5_8, 1 2 3 4 as event_6_3) colNames=t.columnNames() s=split(colNames,"_") cols=colNames[each(x->int(x[1])>int(x[2]), s)] sql(select=sqlCol(cols), from=t).eval()
回答于 2024-02-03 16:34
用loadTextEx 导入分区表时增加2列报错
把quotes表的最后一个字段Time的类型STRING改成TIME，建议第一个字段代码的类型从STRING改成SYMBOL。然后把mytransform改成如下即可： def mytransform(mutable t){ t[`DateMy]=date(t[`col1]) t[`Time]=time(t[`col1]) return t }
回答于 2024-02-03 09:25