THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
| Table of Contents |
|---|
时间序列
一元时间序列
多元时间序列
可以aligned
多元时间序列不支持序列嵌套、不支持多时间戳（目前IoTDB均不支持）
3、“设备”
...
1、物理量（Measurement，也称工况、字段 field）
物理量，是在实际场景中检测装置所记录的测量信息，且可以按一定规律变换成为电信号或其他所需形式的信息输出并发送给 IoTDB。在 IoTDB 当中，存储的所有数据及路径，都是以物理量为单位进行组织。
2、实体（Entity，也称设备，device）
一个物理实体，是在实际场景中拥有物理量的设备或装置。在 IoTDB 当中，所有的物理量都有其对应的归属实体。
3、存储组（Storage group）
一组物理实体，用户可以将任意前缀路径设置成存储组。
4、数据点（Data point）
一个“时间-值”对。
5、时间序列（一个实体的某个物理量对应一个时间序列，Timeseries，也称测点 meter、时间线 timeline，实时数据库中常被称作标签 tag、参数 parameter）
一个物理实体的某个物理量在时间轴上的记录，是数据点的序列。
6、对齐的时间序列（Aligned timeseries）
对齐的多个时间序列需要同时创建，aligned。
不可以在对齐序列所属的设备下创建非对齐的序列，不可以在非对齐序列所属的设备下创建对齐序列。
7、物理量模板（Schema template）
实际应用中有许多实体所采集的物理量相同，即具有相同的工况名称和类型，可以声明一个物理量模板来定义可采集的物理量集合。在实践中，物理量模板的使用可帮助减少元数据的资源占用。
| Code Block | ||||
|---|---|---|---|---|
| ||||
// 创建时间序列 // 1. 完整语法（v0.12及之前） create timeseries root. |
...
sg1.d1. |
...
s1 with datatype=FLOAT, encoding=RLE, compression=SNAPPY, tags(tag1=v1, tag2=v2), attributes(attr1=v1, attr2=v2) create timeseries root.sg1.d1.s2 with datatype=FLOAT, encoding=RLE, |
...
compression=SNAPPY, |
...
|
...
tags(tag1=v1, tag2=v2), |
...
|
...
attributes(attr1=v1, attr2=v2)
|
...
// |
...
2. 简化语法（v0.13开始支持，与之前语法兼容） create timeseries root. |
...
sg1. |
...
d1.s1 FLOAT |
...
encoding=RLE |
...
|
...
compression=SNAPPY |
...
|
...
tags(tag1=v1, tag2=v2) |
...
|
...
attributes(attr1=v1, attr2=v2) |
...
create timeseries root. |
...
sg1. |
...
d1.s2 FLOAT |
...
encoding=RLE |
...
|
...
compression=SNAPPY |
...
|
...
tags(tag1=v1, tag2=v2) |
...
|
...
attributes(attr1=v1, attr2=v2) |
...
// 插入语句 insert into root. |
...
sg1. |
...
d1(time, s1) values(1,1) |
...
insert into root. |
...
sg1. |
...
d1(time, s1, s2) values(1,1,2) |
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
// |
...
在实体 root.sg1. |
...
d2 下创建一组对齐的时间序列 create aligned timeseries root.sg1. |
...
d2(s1 FLOAT encoding=RLE |
...
, |
...
s2 INT32 |
...
encoding=Grollia |
...
compression=SNAPPY) / |
...
/ 注：可以指定每条时间序列的编码(encoding)和压缩方式(compression)，但是暂不支持指定 props, attributes, tags 等。 // 插入语句，必须使用 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) |
| Code Block | ||||
|---|---|---|---|---|
|
...
不能
...
// 创建语句
create |
...
aligned |
...
timeseries root. |
...
sg1.d3. |
...
v1(s1 FLOAT, s2 INT32) create |
...
aligned |
...
timeseries root. |
...
sg1.d3. |
...
v2( |
...
s1 FLOAT, |
...
s2 INT32) |
...
// |
...
插入语句，不能同时向多组对齐的时间序列中插入值 insert into root. |
...
sg1.d3.v1(time, |
...
s1, s2) |
...
|
...
aligned values(1, |
...
1, 2) insert into root.sg1.d3.v1(time, s1) aligned values(2, 3 |
...
)
insert into root. |
...
sg1.d3.v2(time, |
...
s1, s2) |
...
aligned values(1, |
...
1, 2 |
...
)
|
...
可以扩充
create timeseries root.sg.d3.s3 FLOAT...
insert into root.sg1.d3.v2(time, s2) aligned values(3, 4) |
| Code Block | ||||
|---|---|---|---|---|
| ||||
// 创建语句 create timeseries root.sg1.d4.t1.s1 FLOAT create aligned timeseries root.sg1.d4.v1(s1 FLOAT, s2 INT32) create aligned timeseries root.sg1.d4.v2(s1 FLOAT, s2 INT32) // 插入语句，不能同时向非对齐和对齐的时间序列中插入值 insert into root.sg1.d4.t1(time, s1) values(1, 1) insert into root.sg1.d4.v1(time, s1, s2) aligned values(1, 1, 2) insert into root. |
...
sg1.d4. |
...
v1(time, |
...
s1) aligned values(2, |
...
3) insert into root.sg1.d4.v2(time, s1, s2) aligned values(1, |
...
1, 2) insert into root.sg1.d4.v2(time, s2) aligned values(3, 4) |
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
void createAlignedTimeseries(
|
...
String prefixPath, // "root.sg.d1.陀螺仪" |
...
List<String> measurements, |
...
List<TSDataType> dataTypes, |
...
List<TSEncoding> encodings, |
...
CompressionType compressor, |
...
List<String> measurementAliasList ); |
insert into root.sg1.sgd1.d3v1(time, 陀螺仪(s1, s2)) aligned values(1,(1,2))
| Code Block | ||||
|---|---|---|---|---|
| ||||
// 服务器需要做类型推断，可能会有额外耗时
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") ) |
...
...
// 只插入到部分序列，其他序列值自动置为 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) ) |
| Code Block | ||||
|---|---|---|---|---|
| ||||
// 插入一个 Tablet
void insertTablet(Tablet tablet) |
...
// 插入多个 Tablet void insertTablets(Map<String, Tablet> 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); |
...