•总体内存分配：【存储引擎：查询：元数据：空闲内存】 write_read_schema_free_memory_proportion=4:3:1:2

•存储引擎内存分配：【Write ：Compaction】

    storage_engine_memory_proportion=8:2

•查询引擎内存分配：【BloomFilterCache : ChunkCache : TimeSeriesMetadataCache : Coordinator : Operators : DataExchange : timeIndex in TsFileResourceList : others.】chunk_timeseriesmeta_free_memory_proportion=1:100:200:50:200:200:200:50

•元数据内存分配：【分区表缓存：元数据缓存：SchemaRegion：LastCache】schema_memory_allocate_proportion=5:3:1:1

•客户端 C 连接集群任意 DataNode A 发送写入请求

•如果 A 本地没有当前写入数据的分区表缓存，向 ConfigNode 共识组发送写入的设备全路径和时间

•ConfigNode共识组的执行流程

    找到此数据对应的数据分区，找到此数据分区对应的 List<DataRegion 共识组>，选择最后一个作为写入的 DataRegion，找到此 DataRegion 共识组对应的一组 DataNode 并返回

•DataNodeA 缓存分区信息，并根据该信息将写入请求转发给 DataNodeB，并携带 DataRegion 共识组信息

•如果DataNode B 本地没有写入序列的元数据，则检查此次写入的序列是否已经在集群注册

    如果DataNodeB 本地没有当前存储组的元数据分区表缓存，则向 ConfigNode 共识组发请求，查找写入点的元数据所在的 SchemaRegion 及所在的 DataNode D，B 缓存分区信息，并根据该信息将写入的序列及推断类型发送至 SchemaRegion ，DataNodeB 以 SchemaRegion 返回的信息决定抛错或者在本地注册不存在序列的元数据。

•DataNodeB 将数据添加到共识模块中，写入成功后返回

•客户端C连接集群内任意DataNode A发送写入请求

•如果A的ClientRequestHandler接收到写入请求，使用planner转为物理计划InsertRowPlan，传递给Coordinator处理

•A在Coordinator中使用ClusterPlanRouter对写入请求进行路由

•根据路由结果，将写入的物理计划转发给B，并携带DataRegion共识组信息

•B的ClusterRequestHandler接收来自A的物理计划，转给Coordinator处理

•B在Coordinator传递给本地DataRegion执行

•DataRegion若发现本地没有写入序列的元数据，则检查此次写入的序列是否已经在集群注册

•B将请求发送给共识模块，调用consensusLayer中的write方法，写入成功后返回

•客户端C连接集群内任意DataNode A发送写入请求

•如果A的ClientRequestHandler接收到写入请求，使用planner转为物理计划InsertRowsPlan，传递给Coordinator处理

•A在Coordinator中使用ClusterPlanRouter对写入请求进行路由

•根据路由结果，分发属于对应DataRegion的子请求，以节点B为例

•B的ClusterRequestHandler接收来自A的物理计划，转给Coordinator处理

•B在Coordinator传递给本地DataRegion执行

•DataRegion若发现本地没有写入序列的元数据，则检查此次写入的序列是否已经在集群注册

•B将请求发送给共识模块，调用consensusLayer中的write方法，写入成功后返回

public static void main(String[] args) throws ClassNotFoundException, SQLException {
    Class.forName("org.apache.iotdb.jdbc.IoTDBDriver");
    try (Connection connection = DriverManager
        .getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
        Statement statement = connection.createStatement()) {
      // 创建存储组
      statement.execute("SET STORAGE GROUP TO root.statistic");
      // 创建时间序列
      statement.execute("CREATE TIMESERIES root.statistic.device1.s1 WITH DATATYPE=INT64, ENCODING=RLE, COMPRESSOR=SNAPPY");
      statement.execute("CREATE TIMESERIES root.statistic.device1.s2 WITH DATATYPE=INT64, ENCODING=RLE, COMPRESSOR=SNAPPY");
      statement.execute("CREATE TIMESERIES root.statistic.device1.s3 WITH DATATYPE=INT64, ENCODING=RLE, COMPRESSOR=SNAPPY");
      // 在客户端积累一批更新语句
      for (int i = 0; i <= 100; i++) {
        statement.addBatch("insert into root.statistic.device1(timestamp, s1, s2, s3) values("+ i + "," + 1 + "," + 1 + "," + 1 + ")"); 
      }
      // 执行
      statement.executeBatch();
      statement.clearBatch();
      // 查询
      ResultSet resultSet = statement.executeQuery("select * from root where time <= 10");
      // 打印结果集
      ResultSetMetaData metaData = resultSet.getMetaData();
      int columnCount = metaData.getColumnCount();
      while (resultSet.next()) {
        for (int i = 1; i < columnCount; i++) {
          System.out.print(resultSet.getString(i));
          System.out.print(" ");
        }
        System.out.println();
      }
    }
  }

 insertRecordsOfOneDevice(String deviceId,
    List<Long> times,
    List<List<String>> measurementsList,
    List<List<TSDataType>> typesList,
    List<List<Object>> valuesList )

insertTablet(Tablet tablet, boolean sorted)

    String deviceId = "root.statistic.`1.2.156.156.11.20.156474992001050684`";
    List<MeasurementSchema> schemaList = new ArrayList<>();
    schemaList.add(new MeasurementSchema("s1", TSDataType.INT64));
    schemaList.add(new MeasurementSchema("s2", TSDataType.INT64));
    schemaList.add(new MeasurementSchema("s3", TSDataType.INT64));

    Tablet tablet = new Tablet(deviceId, schemaList, 100);

    tablet.initBitMaps();

    long timestamp = System.currentTimeMillis();
    for (long row = 0; row < 100; row++) {
      int rowIndex = tablet.rowSize++;
      tablet.addTimestamp(rowIndex, timestamp);
      for (int s = 0; s < 3; s++) {
        long value = new Random().nextLong();
        // mark null value
        if (row % 3 == s) {
          tablet.bitMaps[s].mark((int) row);
        }
        tablet.addValue(schemaList.get(s).getMeasurementId(), rowIndex, value);
      }
      if (tablet.rowSize == tablet.getMaxRowNumber()) {
        session.insertTablet(tablet, true);
        tablet.reset();
      }
      timestamp++;
    }

    if (tablet.rowSize != 0) {
      session.insertTablet(tablet);
      tablet.reset();
    }