private void insert_data(long timestamp)
      throws IoTDBConnectionException, StatementExecutionException {
    Tablet tablet = new Tablet(device, schemaList, 10);
    int rowIndex = 0;
    for (int row = 0; row < 5; row++) {
      rowIndex = tablet.getRowSize();
      tablet.addTimestamp(rowIndex, timestamp);
      tablet.addValue("`ABH#01`", rowIndex, row * 20 + row);
      tablet.addValue("`BJ-ABH#01`", rowIndex, true);
      timestamp += row * 2000;
    }
    session_src.insertTablet(tablet);
  }
Sequence-level topic, with start, end, tsfile
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/treemodel/regression/topic/IoTDBDataSet1TopicConsumerSpecialIT.java