Orca采用了惰性求值策略,某些操作不会立刻在服务端计算,而是转化成一个中间表达式,直到真正需要时才发生计算。需要触发计算时,用户应调用compute函数。df['Volume'].rolling(1000).mean()实际没有计算,要触发计算,须修改如下: df['Volume'].rolling(1000).mean().compute()
回答于 2021-05-19 14:29
这是因为设置了过滤条件。在发布端,下列代码指定了流数据表的过滤列sym: setStreamTableFilterColumn(trades, `sym) 在订阅端,你设置了过滤值为filter=np.array(['ab'])如下: 流数据表过滤列在filter中的数据才会发布到订阅端,不在filter中的数据不会发布。
回答于 2021-05-19 14:28
DolphinDB中有个update!可以就地更新表中的列,它的语法是 update!(table, colNames, newValues, [filter]) 其中的参数table是DolphinDB中Table类型的表。上面代码的问题是给table赋值了一个字符串,可以用objByName转换一下,代码如下: update!(objByName(tableName), `v, 666); 更多有关动态更新内存表的内容请参阅...
回答于 2021-05-19 14:25
当前系统中可以通过如下脚本实现 re = '{"errcode":0,"errmsg":"ok","access_token":"T_DiOftjAVWXEagpulGB3pURcvQxRxsC6ic1o8nwj9HWzZGfqmCcf4gNrPnWkDM0CSvi9KWR6PyEt912n5LHoQPOw8-FCwZzxnec5Io0s6r-cNccZkuqd8TFPLbhJeF0xRK5DKYReLAbLAxzC4uG4ApZZwWG26XkZtnyYexV760ZeHHfh3JkYCJCVnIPbRBpwPBCx9VT1-iwLx-_XkFRyA","ex...
回答于 2021-05-19 14:24