Capable of regularly outputting current results during the test process.
Use Logger to print test result, instead of System.out
In the code, the downward passing of the Mesaurement objects seems unnecessary (BaseMode->SchemaClient->DBWrapper, DataClient->DBWrapper) , so it has been removed. Now the DBWrapper creates the Measurement object itself.
10:12:32.838 [DataClient-thread-9] DEBUG cn.edu.tsinghua.iot.benchmark.client.generate.GenerateBaseClient - [Client-8] sleep 996 ms.
10:12:32.863 [DataClient-thread-12] DEBUG cn.edu.tsinghua.iot.benchmark.client.generate.GenerateBaseClient - [Client-11] sleep 975 ms.
10:12:32.863 [ShowResultPeriodically] INFO cn.edu.tsinghua.iot.benchmark.mode.BaseMode - The test is in progress. The current test result is:
Create schema cost 0.24 second
Test elapsed time (not include schema creation): 1.00 second
----------------------------------------------------------Result Matrix----------------------------------------------------------
Operation okOperation okPoint failOperation failPoint throughput(point/s)
INGESTION 60 1200000 0 0 1196976.59
PRECISE_POINT 0 0 0 0 0.00
TIME_RANGE 0 0 0 0 0.00
VALUE_RANGE 0 0 0 0 0.00
AGG_RANGE 0 0 0 0 0.00
AGG_VALUE 0 0 0 0 0.00
AGG_RANGE_VALUE 0 0 0 0 0.00
GROUP_BY 0 0 0 0 0.00
LATEST_POINT 0 0 0 0 0.00
RANGE_QUERY_DESC 0 0 0 0 0.00
VALUE_RANGE_QUERY_DESC 0 0 0 0 0.00
GROUP_BY_DESC 0 0 0 0 0.00
---------------------------------------------------------------------------------------------------------------------------------
--------------------------------------------------------------------------Latency (ms) Matrix-------------------------------------------------------------------------- Operation AVG MIN P10 P25 MEDIAN P75 P90 P95 P99 P999 MAX SLOWEST_THREAD INGESTION 75.72 4.75 7.17 18.02 39.92 161.34 176.28 177.07 188.06 186.56 186.40 262.79
PRECISE_POINT 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00
TIME_RANGE 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00
VALUE_RANGE 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00
AGG_RANGE 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00
AGG_VALUE 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00
AGG_RANGE_VALUE 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00
GROUP_BY 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00
LATEST_POINT 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00
RANGE_QUERY_DESC 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00
VALUE_RANGE_QUERY_DESC 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00
GROUP_BY_DESC 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00 0.00
10:12:32.864 [DataClient-thread-1] DEBUG cn.edu.tsinghua.iot.benchmark.client.generate.GenerateBaseClient - [Client-0] sleep 974 ms. 10:12:32.864 [DataClient-thread-15] DEBUG cn.edu.tsinghua.iot.benchmark.client.generate.GenerateBaseClient - [Client-14] sleep 974 ms. 10:12:32.864 [DataClient-thread-16] DEBUG cn.edu.tsinghua.iot.benchmark.client.generate.GenerateBaseClient - [Client-15] sleep 975 ms.