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;
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;
1,500,000