def transacCreate(dbName, tbName)
{
    if(existsDatabase(dbName))
    {
	    dropDatabase(dbName)
    }

    db1 = database(, VALUE, 2021.12.01..2021.12.31)
    db2 = database(, HASH, [SYMBOL, 25])
    db = database(dbName, COMPO, [db1, db2], , 'TSDB')

    schemaTable = table(
        array(SYMBOL, 0) as SecurityID,
        array(DATE, 0) as MDDate,
        array(TIME, 0) as MDTime,
        array(TIMESTAMP, 0) as DataTimestamp,
        array(SYMBOL, 0) as SecurityIDSource,
        array(SYMBOL, 0) as SecurityType,
        array(LONG, 0) as TradeIndex,
        array(LONG, 0) as TradeBuyNo,
        array(LONG, 0) as TradeSellNo,
        array(INT, 0) as TradeType,
        array(INT, 0) as TradeBSFlag,
        array(LONG, 0) as TradePrice,
        array(LONG, 0) as TradeQty,
        array(LONG, 0) as TradeMoney,
        array(LONG, 0) as ApplSeqNum,
        array(INT, 0) as ChannelNo,
        array(DATE, 0) as ExchangeDate,
        array(TIME, 0) as Exchanime
    )

    db.createPartitionedTable(table=schemaTable, tableName=tbName, partitionColumns=`MDDate`SecurityID, sortColumns=`SecurityID`MDTime, keepDuplicates=ALL,compressMethods={MDDate:"delta", MDTime:"delta",DataTimestamp:"delta",ExchangeDate:"delta",Exchanime:"delta"})
}

dbName = "dfs://Test_transaction"
tbName = "transaction"
transacCreate(dbName, tbName)