示例代码如下:
n=1000 ID=rand(`A`B`C, n) dates=2017.08.07..2017.08.11 date=rand(dates, n) x=take(0..49, n) + 0.1 t=table(ID, date, x) db1 = database(, VALUE, ID) db2 = database(, RANGE, date(datetimeAdd(2000.01M,0..40*12,'M'))) db = database("dfs://test1", COMPO, [db1, db2]) pt = db.createPartitionedTable(t, `pt, `ID`date) pt.append!(t) pt=loadTable(db,`pt)
数据写入后的分区规则如下:
VALUE会自动增加分区,有新的code来,会自动创建这个code分区,写入的话,只要每一个线程写1个code,这样并发写入也不会有问题。