getTSDBSortKeyEntry

Syntax

getTSDBSortKeyEntry(chunkId, [tableName])

Details

This function obtains information on the sort key entries of each chunk (See the parameter sortColumns).

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.

Parameters

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.

Returns

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")