分区类型是hash,怎么得到某个分区的全部数据

发布于 2022-09-12 04:02:08 字数 880 浏览 27 评论 0

DolphindDB分布式表建库建表的代码如下,其中分区字段是nActionDay和szWindCode,分区类型分别是按月值分区和HASH分区:

def createDfsDB(dbPath,tbName,userName,userPass){
        login(userName, userPass)
        if(existsDatabase(dbPath)){
            dropDatabase(dbPath)
        }
        
        db1 = database(, VALUE, 2017.01M..2025.12M)
        db2 = database("", HASH,[SYMBOL,20])
        db = database(dbPath,COMPO, [db1,db2])
        columns = `szWindCode`nActionDay`nTime`nOpen`nHigh`nLow`nMatch`iVolume`iTurnover`bar_close`S_DQ_PRECLOSE`S_DQ_ADJFACTOR`HighLimit`LowLimit
        types = [SYMBOL,DATE,INT,INT,INT,INT,INT,INT,INT,BOOL,INT,DOUBLE,INT,INT]
        db.createPartitionedTable(table(100:0, columns,types),tbName, `nActionDay`szWindCode)
}

createDfsDB("dfs://marketdata","symbol_data",`admin,`123456)

在导入2020年1月的股市分钟k线数据后,我想得到路径为/202001M/key0
的这个分区的所有数据,请问该怎么写查询语句?

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

心凉 2022-09-19 04:02:08

可以用hashBucket得到hash值,代码如下:

symbol_data=loadTable("dfs://marketdata","symbol_data")
select * from symbol_data where nActionDay between 2020.01.01:2020.01.31 and   hashBucket(szWindCode,20)=0
~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文