docs: high-volume.md

docs/examples/java/src/main/java/com/taos/example/highvolume/DataBaseMonitor.java

+package com.taos.example.highvolume;
+
+import java.sql.*;
+
+/**
+ * Prepare target database.
+ * Count total records in database periodically so that we can estimate the writing speed.
+ */
+public class DataBaseMonitor {
+    private Connection conn;
+    private Statement stmt;
+
+    public DataBaseMonitor init() throws SQLException {
+        if (conn == null) {
+            String jdbcURL = System.getenv("TDENGINE_JDBC_URL");
+            conn = DriverManager.getConnection(jdbcURL);
+            stmt = conn.createStatement();
+        }
+        return this;
+    }
+
+    public void close() {
+        try {
+            stmt.close();
+        } catch (SQLException e) {
+        }
+        try {
+            conn.close();
+        } catch (SQLException e) {
+        }
+    }
+
+    public void prepareDatabase() throws SQLException {
+        stmt.execute("DROP DATABASE IF EXISTS test");
+        stmt.execute("CREATE DATABASE test");
+        stmt.execute("CREATE STABLE test.meters (ts TIMESTAMP, current FLOAT, voltage INT, phase FLOAT) TAGS (location BINARY(64), groupId INT)");
+    }
+
+    public Long count() throws SQLException {
+        if (!stmt.isClosed()) {
+            ResultSet result = stmt.executeQuery("SELECT count(*) from test.meters");
+            result.next();
+            return result.getLong(1);
+        }
+        return null;
+    }
+}
\ No newline at end of file

docs/examples/java/src/main/java/com/taos/example/highvolume/FastWriteExample.java

@@ -9,51 +9,7 @@ import java.util.List;
 import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.BlockingQueue;
 
-/**
- * Prepare target database.
- * Count total records in database periodically so that we can estimate the writing speed.
- */
-class DataBaseMonitor {
-    private Connection conn;
-    private Statement stmt;
 
-    public DataBaseMonitor init() throws SQLException {
-        if (conn == null) {
-            String jdbcURL = System.getenv("TDENGINE_JDBC_URL");
-            conn = DriverManager.getConnection(jdbcURL);
-            stmt = conn.createStatement();
-        }
-        return this;
-    }
-
-    public void close() {
-        try {
-            stmt.close();
-        } catch (SQLException e) {
-        }
-        try {
-            conn.close();
-        } catch (SQLException e) {
-        }
-    }
-
-    public void prepareDatabase() throws SQLException {
-        stmt.execute("DROP DATABASE IF EXISTS test");
-        stmt.execute("CREATE DATABASE test");
-        stmt.execute("CREATE STABLE test.meters (ts TIMESTAMP, current FLOAT, voltage INT, phase FLOAT) TAGS (location BINARY(64), groupId INT)");
-    }
-
-    public Long count() throws SQLException {
-        if (!stmt.isClosed()) {
-            ResultSet result = stmt.executeQuery("SELECT count(*) from test.meters");
-            result.next();
-            return result.getLong(1);
-        }
-        return null;
-    }
-}
-
-// ANCHOR: main
 public class FastWriteExample {
     final static Logger logger = LoggerFactory.getLogger(FastWriteExample.class);
 
@@ -111,4 +67,3 @@ public class FastWriteExample {
         }
     }
 }
\ No newline at end of file
-// ANCHOR_END: main
\ No newline at end of file

docs/examples/java/src/main/java/com/taos/example/highvolume/MockDataSource.java

+package com.taos.example.highvolume;
+
+import java.util.Iterator;
+
+/**
+ * Generate test data
+ */
+class MockDataSource implements Iterator {
+    private String tbNamePrefix;
+    private int tableCount;
+    private long maxRowsPerTable = 1000000000L;
+
+    // 100 milliseconds between two neighbouring rows.
+    long startMs = System.currentTimeMillis() - maxRowsPerTable * 100;
+    private int currentRow = 0;
+    private int currentTbId = -1;
+
+    // mock values
+    String[] location = {"LosAngeles", "SanDiego", "Hollywood", "Compton", "San Francisco"};
+    float[] current = {8.8f, 10.7f, 9.9f, 8.9f, 9.4f};
+    int[] voltage = {119, 116, 111, 113, 118};
+    float[] phase = {0.32f, 0.34f, 0.33f, 0.329f, 0.141f};
+
+    public MockDataSource(String tbNamePrefix, int tableCount) {
+        this.tbNamePrefix = tbNamePrefix;
+        this.tableCount = tableCount;
+    }
+
+    @Override
+    public boolean hasNext() {
+        currentTbId += 1;
+        if (currentTbId == tableCount) {
+            currentTbId = 0;
+            currentRow += 1;
+        }
+        return currentRow < maxRowsPerTable;
+    }
+
+    @Override
+    public String next() {
+        long ts = startMs + 100 * currentRow;
+        int groupId = currentTbId % 5 == 0 ? currentTbId / 5 : currentTbId / 5 + 1;
+        StringBuilder sb = new StringBuilder(tbNamePrefix + "_" + currentTbId + ","); // tbName
+        sb.append(ts).append(','); // ts
+        sb.append(current[currentRow % 5]).append(','); // current
+        sb.append(voltage[currentRow % 5]).append(','); // voltage
+        sb.append(phase[currentRow % 5]).append(','); // phase
+        sb.append(location[currentRow % 5]).append(','); // location
+        sb.append(groupId); // groupID
+
+        return sb.toString();
+    }
+}
\ No newline at end of file

docs/examples/java/src/main/java/com/taos/example/highvolume/ReadTask.java

@@ -7,57 +7,6 @@ import java.util.Iterator;
 import java.util.List;
 import java.util.concurrent.BlockingQueue;
 
-/**
- * Generate test data
- */
-class MockDataSource implements Iterator {
-    private String tbNamePrefix;
-    private int tableCount;
-    private long maxRowsPerTable = 1000000000L;
-
-    // 100 milliseconds between two neighbouring rows.
-    long startMs = System.currentTimeMillis() - maxRowsPerTable * 100;
-    private int currentRow = 0;
-    private int currentTbId = -1;
-
-    // mock values
-    String[] location = {"LosAngeles", "SanDiego", "Hollywood", "Compton", "San Francisco"};
-    float[] current = {8.8f, 10.7f, 9.9f, 8.9f, 9.4f};
-    int[] voltage = {119, 116, 111, 113, 118};
-    float[] phase = {0.32f, 0.34f, 0.33f, 0.329f, 0.141f};
-
-    public MockDataSource(String tbNamePrefix, int tableCount) {
-        this.tbNamePrefix = tbNamePrefix;
-        this.tableCount = tableCount;
-    }
-
-    @Override
-    public boolean hasNext() {
-        currentTbId += 1;
-        if (currentTbId == tableCount) {
-            currentTbId = 0;
-            currentRow += 1;
-        }
-        return currentRow < maxRowsPerTable;
-    }
-
-    @Override
-    public String next() {
-        long ts = startMs + 100 * currentRow;
-        int groupId = currentTbId % 5 == 0 ? currentTbId / 5 : currentTbId / 5 + 1;
-        StringBuilder sb = new StringBuilder(tbNamePrefix + "_" + currentTbId + ","); // tbName
-        sb.append(ts).append(','); // ts
-        sb.append(current[currentRow % 5]).append(','); // current
-        sb.append(voltage[currentRow % 5]).append(','); // voltage
-        sb.append(phase[currentRow % 5]).append(','); // phase
-        sb.append(location[currentRow % 5]).append(','); // location
-        sb.append(groupId); // groupID
-
-        return sb.toString();
-    }
-}
-
-// ANCHOR: ReadTask
 class ReadTask implements Runnable {
     private final static Logger logger = LoggerFactory.getLogger(ReadTask.class);
     private final int taskId;
@@ -107,5 +56,3 @@ class ReadTask implements Runnable {
         this.active = false;
     }
 }
\ No newline at end of file
-
-// ANCHOR_END: ReadTask
\ No newline at end of file

docs/examples/java/src/main/java/com/taos/example/highvolume/SQLWriter.java

@@ -7,8 +7,6 @@ import java.sql.*;
 import java.util.HashMap;
 import java.util.Map;
 
-// ANCHOR: SQLWriter
-
 /**
  * A helper class encapsulate the logic of writing using SQL.
  * <p>
@@ -205,4 +203,3 @@ public class SQLWriter {
         }
     }
 }
\ No newline at end of file
-// ANCHOR_END: SQLWriter

docs/examples/java/src/main/java/com/taos/example/highvolume/StmtWriter.java

+package com.taos.example.highvolume;
+
+public class StmtWriter {
+}

docs/examples/java/src/main/java/com/taos/example/highvolume/WriteTask.java

@@ -5,7 +5,6 @@ import org.slf4j.LoggerFactory;
 
 import java.util.concurrent.BlockingQueue;
 
-// ANCHOR: WriteTask
 class WriteTask implements Runnable {
     private final static Logger logger = LoggerFactory.getLogger(WriteTask.class);
     private final int maxBatchSize;
@@ -57,4 +56,3 @@ class WriteTask implements Runnable {
         this.active = false;
     }
 }
\ No newline at end of file
-// ANCHOR_END: WriteTask
\ No newline at end of file

docs/examples/java/src/main/resources/highvolume2.drawio

 <mxfile host="65bd71144e">
     <diagram id="_BjMg4p5x31hL4Gv-87s" name="第 1 页">
-        <mxGraphModel dx="728" dy="412" grid="0" gridSize="10" guides="1" tooltips="1" connect="1" arrows="1" fold="1" page="1" pageScale="1" pageWidth="900" pageHeight="900" background="none" math="0" shadow="0">
+        <mxGraphModel dx="1259" dy="615" grid="0" gridSize="10" guides="1" tooltips="1" connect="1" arrows="1" fold="1" page="1" pageScale="1" pageWidth="900" pageHeight="900" background="none" math="0" shadow="0">
             <root>
                 <mxCell id="0"/>
                 <mxCell id="1" parent="0"/>
@@ -52,22 +52,22 @@
                         <mxPoint x="275" y="162.5" as="targetPoint"/>
                     </mxGeometry>
                 </mxCell>
-                <mxCell id="20" value="&lt;font style=&quot;font-size: 14px&quot;&gt;&lt;font style=&quot;font-size: 14px&quot;&gt;Write Tas&lt;/font&gt;&lt;font style=&quot;font-size: 14px&quot;&gt;k 2&lt;/font&gt;&lt;/font&gt;" style="rounded=1;whiteSpace=wrap;html=1;fillColor=#dae8fc;strokeColor=#6c8ebf;fontStyle=1" parent="1" vertex="1">
+                <mxCell id="20" value="&lt;font style=&quot;font-size: 14px&quot;&gt;&lt;font style=&quot;font-size: 14px&quot;&gt;Write Tas&lt;/font&gt;&lt;font style=&quot;font-size: 14px&quot;&gt;k 1&lt;/font&gt;&lt;/font&gt;" style="rounded=1;whiteSpace=wrap;html=1;fillColor=#dae8fc;strokeColor=#6c8ebf;fontStyle=1" parent="1" vertex="1">
                     <mxGeometry x="588" y="129" width="100" height="31" as="geometry"/>
                 </mxCell>
                 <mxCell id="21" value="&lt;font style=&quot;font-size: 14px&quot;&gt;&lt;font style=&quot;font-size: 14px&quot;&gt;Write Tas&lt;/font&gt;&lt;font style=&quot;font-size: 14px&quot;&gt;k 2&lt;/font&gt;&lt;/font&gt;" style="rounded=1;whiteSpace=wrap;html=1;fillColor=#dae8fc;strokeColor=#6c8ebf;fontStyle=1" parent="1" vertex="1">
                     <mxGeometry x="588" y="175" width="100" height="33" as="geometry"/>
                 </mxCell>
-                <mxCell id="30" style="edgeStyle=none;html=1;exitX=1;exitY=0.5;exitDx=0;exitDy=0;entryX=0;entryY=0.5;entryDx=0;entryDy=0;" edge="1" parent="1" source="26" target="29">
+                <mxCell id="30" style="edgeStyle=none;html=1;exitX=1;exitY=0.5;exitDx=0;exitDy=0;entryX=0;entryY=0.5;entryDx=0;entryDy=0;" parent="1" source="26" target="29" edge="1">
                     <mxGeometry relative="1" as="geometry"/>
                 </mxCell>
-                <mxCell id="26" value="Queue 3" style="rounded=0;whiteSpace=wrap;html=1;fontSize=17;fillColor=#f8cecc;strokeColor=#b85450;" vertex="1" parent="1">
+                <mxCell id="26" value="Queue 4" style="rounded=0;whiteSpace=wrap;html=1;fontSize=17;fillColor=#f8cecc;strokeColor=#b85450;" parent="1" vertex="1">
                     <mxGeometry x="265" y="271" width="245" height="29" as="geometry"/>
                 </mxCell>
-                <mxCell id="28" value="&lt;font style=&quot;font-size: 14px&quot;&gt;&lt;font style=&quot;font-size: 14px&quot;&gt;Write Tas&lt;/font&gt;&lt;font style=&quot;font-size: 14px&quot;&gt;k 4&lt;/font&gt;&lt;/font&gt;" style="rounded=1;whiteSpace=wrap;html=1;fillColor=#dae8fc;strokeColor=#6c8ebf;fontStyle=1" vertex="1" parent="1">
+                <mxCell id="28" value="&lt;font style=&quot;font-size: 14px&quot;&gt;&lt;font style=&quot;font-size: 14px&quot;&gt;Write Tas&lt;/font&gt;&lt;font style=&quot;font-size: 14px&quot;&gt;k 3&lt;/font&gt;&lt;/font&gt;" style="rounded=1;whiteSpace=wrap;html=1;fillColor=#dae8fc;strokeColor=#6c8ebf;fontStyle=1" parent="1" vertex="1">
                     <mxGeometry x="588" y="221.5" width="100" height="33" as="geometry"/>
                 </mxCell>
-                <mxCell id="29" value="&lt;font style=&quot;font-size: 14px&quot;&gt;&lt;font style=&quot;font-size: 14px&quot;&gt;Write Tas&lt;/font&gt;&lt;font style=&quot;font-size: 14px&quot;&gt;k 4&lt;/font&gt;&lt;/font&gt;" style="rounded=1;whiteSpace=wrap;html=1;fillColor=#dae8fc;strokeColor=#6c8ebf;fontStyle=1" vertex="1" parent="1">
+                <mxCell id="29" value="&lt;font style=&quot;font-size: 14px&quot;&gt;&lt;font style=&quot;font-size: 14px&quot;&gt;Write Tas&lt;/font&gt;&lt;font style=&quot;font-size: 14px&quot;&gt;k 4&lt;/font&gt;&lt;/font&gt;" style="rounded=1;whiteSpace=wrap;html=1;fillColor=#dae8fc;strokeColor=#6c8ebf;fontStyle=1" parent="1" vertex="1">
                     <mxGeometry x="588" y="271" width="100" height="33" as="geometry"/>
                 </mxCell>
             </root>

docs/examples/python/highvolume_faster_queue.py

@@ -10,7 +10,7 @@ import time
 import os
 from multiprocessing import Process
 from faster_fifo import Queue
-from mockdatasoruce import MockDataSource
+from mockdatasource import MockDataSource
 from queue import Empty
 from typing import List