public static void main(final String[] args) throws Exception {
    prepareData();
    // dataQuery();
    // dataSubscription1();
    // dataSubscription2();
    // dataSubscription3();
    dataSubscription4();
  }
multi pull consumer subscribe topic with tsfile format and snapshot mode
example/session/src/main/java/org/apache/iotdb/SubscriptionSessionExample.java