查询数据的时候如何按分区字段规划的分区提取数据

创建库表的语句如下:

dbName = "dfs://trade"
tbName = "trade"
if(existsDatabase(dbName)){
	dropDatabase(dbName)
}
db1 = database(, VALUE, 2020.01.01..2022.01.01)
db2 = database(, HASH, [SYMBOL, 5])
db = database(dbName, COMPO, [db1, db2], , "TSDB")
schemaTable = table(
	array(SYMBOL, 0) as SecurityID,
	array(SYMBOL, 0) as Market,
	array(TIMESTAMP, 0) as TradeTime,
	array(DOUBLE, 0) as TradePrice,
	array(INT, 0) as TradeQty,
	array(DOUBLE, 0) as TradeAmount,
	array(INT, 0) as BuyNum,
	array(INT, 0) as SellNum
)
db.createPartitionedTable(schemaTable, tbName, `TradeTime`SecurityID, {TradeTim:"delta"}, sortColumns=`SecurityID`TradeTime, keepDuplicates=ALL)

`TradeTime`SecurityID为分区字段,我想提取某天某一个分区的所有股票的数据,请问应该怎么操作?

请先 登录 后评论

1 个回答

Jason Tang - 时序数据库技术支持

以提取2020.01.02这天,SecurityID分区内HASH为1的分区的数据为例:

select count(*) from loadTable("dfs://trade", "trade") where date(TradeTime)=2020.01.02, partition(SecurityID, 1)

请先 登录 后评论