getTSDBSortKeyEntry

Syntax

getTSDBSortKeyEntry(chunkId, [tableName])

Arguments

chunkId is a STRING scalar or vector indicating the chunk ID. Note: When chunkId is a vector, its length cannot exceed 1024.

tableName (optional) is a STRING scalar indicating the DFS table name. If not specified, all tables under the specified chunk are checked.

Details

Note that the function cannot check data in the cache engine. You can call flushTSDBCache to forcibly flush the completed transactions cached in the TSDB cache engine to disk.

Examples

n = 10000
SecurityID = rand(`st0001`st0002`st0003`st0004`st0005, n)
sym = rand(`A`B`C`D`E, n)
TradeDate = 2022.01.01 + rand(100,n)
TotalVolumeTrade = rand(1000..3000, n)
TotalValueTrade = rand(100.0, n)
schemaTable_snap = table(SecurityID, sym, TradeDate, TotalVolumeTrade, TotalValueTrade).sortBy!(`SecurityID`sym`TradeDate)

dbPath = "dfs://TSDB_STOCK"
if(existsDatabase(dbPath)){dropDatabase(dbPath)}
db_snap = database(dbPath, VALUE, 2022.01.01..2022.01.05, engine='TSDB')

snap=createPartitionedTable(dbHandle=db_snap, table=schemaTable_snap, tableName="snap", partitionColumns=`TradeDate, sortColumns=`SecurityID`sym`TradeDate, keepDuplicates=ALL, sortKeyMappingFunction=[hashBucket{,3}, hashBucket{,2}])
snap.append!(schemaTable_snap)

snap1=createPartitionedTable(dbHandle=db_snap, table=schemaTable_snap, tableName="snap1", partitionColumns=`TradeDate, sortColumns=`SecurityID`sym`TradeDate, keepDuplicates=ALL)
snap1.append!(schemaTable_snap)

flushTSDBCache()

getChunksMeta()

getTSDBSortKeyEntry("fe93077a-5a05-34a8-554c-67467415bf68")