savePartition
语法
savePartition(dbHandle, table, tableName,
[compression=true])
参数
dbHandle 是一个 DolphinDB 数据库句柄。
table 是将要保存的内存中的表。
tableName 是表示保存的分区表名称的字符串。
compression 是否压缩数据。默认的设置是 true。
详情
把一张表保存为分布式数据库中的分区表。该命令必须要用户登录后才能执行。
在用 savePartition 保存之前,要用 createPartitionedTable 先创建空的分区表。
例子
n=1000000
ID=rand(10, n)
value=rand(1.0, n)
t=table(ID, value);
db=database("dfs://rangedb_Trades", RANGE, 0 5 10)
Trades = db.createPartitionedTable(t, "Trades", "ID");
savePartition(db, t, `Trades)
Trades=loadTable(db, `Trades)
select count(value) from Trades;
// output
1,000,000
在上述例子中,数据库 db 有两个分区:[0,5)和[5,10)。表t被保存为一个分区表 Trades,它包含数据库 db 中的分区列。
我们可以在表 Trades 中追加另一个表:
n=500000
ID=rand(10, n)
value=rand(1.0, n)
t1=table(ID, value);
savePartition(db, t1, `Trades)
Trades=loadTable(db, `Trades)
select count(value) from Trades;
// output
1,500,000