Page History

...

6、对齐的时间序列（Aligned timeseries）

在实际应用中，存在某些实体的多个物理量同时采样（如 GPS 的经度和维度），形成在时间列上对齐的多条时间序列。

在实际应用中，存在某些实体的多个物理量同时采样（如 GPS 的经度和维度），形成具有相同时间戳的多条时间序列，称这些时间序列是对齐的。对齐时间序列的时间戳列在内存和磁盘中仅需存储一次，可以减少存储资源的占用。

对齐的多个时间序列需要同时创建，使用关键字 aligned 显式声明，后续可以删除其中某列，但不能新增列。 显式声明。

不可以在对齐序列所属的设备下创建非对齐的序列，不可以在非对齐序列所属的设备下创建对齐序列。

查询数据时，可以对于每一条时间序列单独查询。

插入数据时，对齐的时间序列中某列的某些行允许有空值。

...

// 在实体 root.sg1.d2 下创建一组对齐的时间序列
create aligned timeseries root.sg1.d2.(s1 FLOAT encoding=RLE, s2 INT32 encoding=Grollia compression=SNAPPY) compression=SNAPPY

// 注：
// 1.可以指定每条时间序列的编码注：可以指定每条时间序列的编码(encoding)和压缩方式(compression)，但是暂不支持指定别名(alias)，props，但是暂不支持指定 props, attributes, tags 等。
// 2.未指定 compression 的时间序列，则采用系统默认配置；小括号外的 compression 定义时间列压缩方式和未显式声明的列的压缩方式。

// 插入语句，必须使用 aligned 关键词
insert into root.sg.d2(time, s1, s2) aligned values(1, 1, 2)
insert into root.sg.d2(time, s1) aligned values(2, 1)  //允许单独写某条时间序列，其他时间序列在该时间点上为空值

// 场景2所创建的对齐时间序列所属物理实体可以扩充时间序列，但需要在该物理实体下嵌套新实体。
// 例如，可以向d2下继续添加时间序列： 
create timeseries root.sg1.d2.t1.s1 FLOAT
create timeseries root.sg1.d2.v1.(s1 FLOAT, s2 FLOAT)

...

一个 Record 是一个设备一个时间戳下多个测点的数据，例如：

insert into root.sg1.sgd1.d3v1(time, 陀螺仪(s1, s2)) aligned values(1,(1,2))

API 如下：

// 服务器需要做类型推断，可能会有额外耗时
void insertAlignedRecord(String prefixPath, long time, List<String> measurements, List<String> values)

...

// 提供数据类型后，服务器不需要做类型推断，可以提高性能
void insertAlignedRecord(String prefixPath, long time, List<String> measurements, List<TSDataType> types, List<Object> values

...

应用到上面的例子即：

)

// 应用到上面的例子即：
void insertAlignedRecord(
    "root.

...

sg1.

...

d1.

...

v1",
    1,
    Arrays.asList("s1", "s2"),
    Arrays.asList("1", "2")
)

...

注意：当前仅支持 record 插入一个多元时间序列。后期将适配如下 SQL（即在同一个 record 中涉及多个多元时间序列、或涉及混合的一元和多元时间序列）

...

// 只插入到部分序列，其他序列值自动置为 null
void insertAlignedRecord(
    "root.sg1.d1.v1",
    1,
    Arrays.asList("s1"),
    Arrays.asList("1")
)

// 也可以通过null显式声明
void insertAlignedRecord(
    "root.sg1.d1.v1",
    1,
    Arrays.asList("s1","s2"),
    Arrays.asList("1",null)
)

3、插入Tablet

Tablet 是一个设备若干行非空数据块，每一行的列都相同

// 插入一个 Tablet
void insertTablet(Tablet tablet)

...

 

// 插入多个 Tablet
void insertTablets(Map<String, Tablet> tablet)

...

多元时间序列通过 VectorMeasurementSchema 构建 Tablet

...

// 对齐的时间序列通过 measurementSchema 构建 Tablet
List<IMeasurementSchema> schemaList = new ArrayList<>();
schemaList.add(new

...

 measurementSchema(new String[] {"s1", "s2"}, new TSDataType[] {TSDataType.INT64, TSDataType.INT32}));
Tablet tablet = new Tablet("root.sg1.d1.

...

v1", schemaList);

...

TODO：更新下面的API描述

//多元序列允许某列的某些行有空值，如时间戳2下只有s1有值，s2无值，则只需：

insert into root.sg.d1(time, b(s1)) values(2,(1))

//上述例子也可以通过null显式声明：

insert into root.sg.d1(time, b(s1, s2)) values(2,(1, null))

//多元序列允许各列独自写入：

insert into root.sg.d1(time, b(s1)) values(3,(1))

...