keyedStreamTable

语法

keyedStreamTable(keyColumn, X, [X1], [X2], .....)

keyedStreamTable(keyColumn, capacity:size, colNames, colTypes)

参数

keyColumn 是一个字符串或向量,表示主键。

第一种用法中: X, X1....是向量。

第二种用法中:

capacity 是正整数,表示建表时系统为该表分配的内存(以记录数为单位)。当记录数超过 capacity 时,系统会首先会分配 capacity 1.2~2 倍的新的内存空间,然后复制数据到新的内存空间,最后释放原来的内存。对于规模较大的表,此类操作的内存占用会很高。因此,建议建表时预先分配一个合理的 capacity

size 只能是0或1。若 size=0,则建立一个空表;若 size=1,则建立一个只包含1条记录的表,记录初始值如下:

  • BOOL 类型默认值为 false;

  • 数值类型、时间类型、IPADDR、COMPLEX、POINT 的默认值为 0;

  • Literal, INT128 类型的默认值为 NULL。

colNames 是字符串向量,表示列名。

colTypes 是向量,表示各列的数据类型。自 2.00.11.2 版本起,允许主键外的其它列指定为数组向量类型。

详情

创建键值流数据表。该表的主键不允许包含重复值。主键支持一个或多个字段。

向表中添加新记录时,系统会自动检查新记录的主键值:

  • 如果新记录的主键值与已有记录的主键值重复时,已有的记录不会被更新。

  • 一次性批量插入新记录时,若有多条记录具有相同的主键值,且该主键值与已有记录的主键值不同,只有第一条记录能成功插入。

例子

第一种用法:

id=`A`B`C`D`E
x=1 2 3 4 5
t1=keyedStreamTable(`id, id, x)
t1;
id x
A 1
B 2
C 3
D 4
E 5

第二种用法:

t2=keyedStreamTable(`id,100:0,`id`x, [INT,INT])
insert into t2 values(1 2 3,10 20 30);
t2;
id x
1 10
2 20
3 30

往表 t2 中插入重复主键值的数据:

insert into t2 values(3 4 5,35 45 55)
t2;
id x
1 10
2 20
3 30
4 45
5 55

可以看到,id=3 的记录并没有被覆盖。

主键为多个字段:

t=keyedStreamTable(`sym`id,1:0,`sym`id`val,[SYMBOL,INT,DOUBLE])
insert into t values(`A`B`C`D`E,5 4 3 2 1,52.1 64.2 25.5 48.8 71.9);
insert into t values(`A`B`R`T`Y,5 8 3 2 1,152.3 164.6 125.5 148.8 171.6);
t;
sym id val
A 5 52.1
B 4 64.2
C 3 25.5
D 2 48.8
E 1 71.9
B 8 164.6
R 3 125.5
T 2 148.8
Y 1 171.6