【问题标题】:Can I import a stream table into a partitioned table in dolphindb database?我可以将流表导入 dolphindb 数据库中的分区表吗?
【发布时间】:2021-05-18 08:11:37
【问题描述】:

我可以将流表导入 dolphindb 数据库中的分区表吗?

我创建一个分区表如下:

login("admin", "123456")
dbPath="dfs://thermalDB"
stream = streamTable(10000:0,`id`ts`tem,[SYMBOL,TIMESTAMP,DOUBLE])
dbDate = database(, VALUE, 2021.03.17..2031.03.17)
dbID = database(,  HASH,  [SYMBOL,  50])
db=database(dbPath, COMPO,  [dbDate,  dbID])
db.createPartitionedTable(stream, "pt", `ts`id)

但它返回一个错误:

A stream table does not support direct access. Please use sql query to retrieve data

错误是如何发生的?

【问题讨论】:

    标签: database-partitioning dolphindb


    【解决方案1】:

    传入函数 createPartitionedTable 的表不能是流表。可以这样写代码:

    login("admin", "123456")
    dbPath="dfs://thermalDB"
    dbDate = database(, VALUE, 2021.03.17..2031.03.17)
    dbID = database(,  HASH,  [SYMBOL,  50])
    db=database(dbPath, COMPO,  [dbDate,  dbID])
    t = table(1:0,`id`ts`tem,[SYMBOL,TIMESTAMP,DOUBLE])
    db.createPartitionedTable(t, "pt", `ts`id)
    

    【讨论】:

      猜你喜欢
      • 2023-03-11
      • 1970-01-01
      • 1970-01-01
      • 2013-01-05
      • 2019-11-09
      • 2021-03-22
      • 2011-01-12
      • 2013-07-02
      • 1970-01-01
      相关资源
      最近更新 更多