You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2022/01/17 03:04:15 UTC
[iotdb] branch client_manager_add_close updated (d64b6d2 -> b7a86a2)
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch client_manager_add_close
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from d64b6d2 fix count timeseries
add c31903b [IOTDB-2353] CQ: support specifying first execution time (BOUNDARY) when creating CQ (#4831)
add 53f48d2 [IOTDB-2400] Fix series reader bug (#4819)
add 46ee27b [IOTDB-1892] Add TsfileSelfCheckTool in server (#4674)
add 186c12f [IOTDB-2363] LEVEL can be specified at non-last level in metadata queries (#4838)
add 6c24a24 [IOTDB-2392] Memory control of raft log in cluster (#4825)
add 23c35f3 [IOTDB-2379]Fix code of pulsar example (#4840)
add de01258 [IOTDB-2328] Missing system config in user manual (#4841)
add b959fb3 [IOTDB-2403] The parameter "ascending" is not set correctly when getting QueryDataSource (#4830)
add 3c94818 [IOTDB-2383] Make simplified SQL of creating timeseries and schema template more flexible (#4832)
add cca356e Fix timed flush memtable and timed close tsfile test (#4839)
add 76fe523 [IOTDB-2321] Add schema template APIs for C++ client (#4796)
add 81154e6 [IOTDB-2394] Fixed temporary network unavailability caused by frequent closed connections (#4815)
add ff60ebc [IOTDB-2375][IOTDB-2376] CQ: Get a wrong result data set (#4842)
add d84856e [IOTDB-2407] When there is an xxx.tsfile.mods, using load tsfile will lose all data (#4843)
add aebe6f1 [IOTDB-2310][IOTDB-2311][IOTDB-2372] Add query type check for REST query API (#4844)
add fdf79b8 Close the tsfile once the memtable is flushed into (#4821)
add 138d14c [IOTDB-2313] REST: GC overhead limit when select * from root.** (#4845)
add 2bf83a5 [IOTDB-2287] Separate CLI history by different hosts, ports and usernames (#4826)
add 707c2b4 [IOTDB-2181] Fix cluster throw exception when queried tag does not exist (#4613)
add 3115b09 [IOTDB-2326] add doc for compaction param (#4822)
add 478b9bd [IOTDB-2191] Use IoTDB itself to collect runtime metrics (#4634)
add b0282e1 [IOTDB-2406] Incorrect docs; Incorrect error-log (#4847)
add b7a86a2 Merge branch 'master' into client_manager_add_close
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlLexer.g4 | 4 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 4 +-
cli/src/main/java/org/apache/iotdb/cli/Cli.java | 18 +-
.../org/apache/iotdb/cli/utils/JlineUtils.java | 15 +-
.../main/java/org/apache/iotdb/tool/ExportCsv.java | 2 +-
client-cpp/src/main/Session.cpp | 410 +++++++++++++++--
client-cpp/src/main/Session.h | 512 +++++++++++++++------
client-cpp/src/test/cpp/sessionIT.cpp | 469 +++++++++----------
.../resources/conf/iotdb-cluster.properties | 21 +-
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 26 +-
.../iotdb/cluster/client/ClientPoolFactory.java | 3 +
.../apache/iotdb/cluster/config/ClusterConfig.java | 51 ++
.../iotdb/cluster/config/ClusterDescriptor.java | 26 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 3 +-
.../cluster/query/reader/ClusterReaderFactory.java | 2 +-
.../org/apache/iotdb/cluster/server/Response.java | 3 +-
.../server/handlers/caller/LogCatchUpHandler.java | 11 +-
.../iotdb/cluster/server/member/RaftMember.java | 154 +++++--
.../cluster/client/ClientPoolFactoryTest.java | 31 ++
docs/SystemDesign/SchemaManager/SchemaManager.md | 8 +-
docs/UserGuide/API/Programming-Cpp-Native-API.md | 422 +++++++++++------
.../Advanced-Features/Continuous-Query.md | 97 +++-
docs/UserGuide/Appendix/Config-Manual.md | 391 +++++++++++++---
docs/UserGuide/Appendix/SQL-Reference.md | 2 +-
docs/UserGuide/Data-Concept/Schema-Template.md | 36 +-
.../UserGuide/System-Tools/Load-External-Tsfile.md | 10 +-
docs/UserGuide/System-Tools/Metric-Tool.md | 2 +-
.../UserGuide/System-Tools/TsFileSelfCheck-Tool.md | 42 ++
.../zh/SystemDesign/SchemaManager/SchemaManager.md | 2 +-
.../zh/UserGuide/API/Programming-Cpp-Native-API.md | 417 +++++++++++------
.../Advanced-Features/Continuous-Query.md | 114 ++++-
docs/zh/UserGuide/Appendix/Config-Manual.md | 310 +++++++++----
docs/zh/UserGuide/Appendix/SQL-Reference.md | 2 +-
.../UserGuide/System-Tools/Load-External-Tsfile.md | 12 +-
docs/zh/UserGuide/System-Tools/Metric-Tool.md | 2 +-
.../UserGuide/System-Tools/TsFileSelfCheck-Tool.md | 42 ++
.../src/AlignedTimeseriesSessionExample.cpp | 52 ++-
example/client-cpp-example/src/SessionExample.cpp | 47 +-
.../apache/iotdb/pulsar/PulsarConsumerThread.java | 1 +
.../db/integration/IoTDBContinuousQueryIT.java | 191 +++++++-
.../db/integration/IoTDBLoadExternalTsfileIT.java | 204 ++++++++
.../db/integration/IoTDBNewTsFileCompactionIT.java | 4 +
.../iotdb/db/integration/IoTDBTagAlterIT.java | 7 +-
.../apache/iotdb/db/integration/IoTDBTagIT.java | 15 +-
.../aligned/IOTDBInsertAlignedValuesIT.java | 3 +
.../aligned/IoTDBLoadExternalAlignedTsFileIT.java | 211 ++++++++-
...ava => IoTDBRawQueryWithoutValueFilter3IT.java} | 8 +-
metrics/ReadMe.md | 1 +
.../reporter/prometheus/PrometheusReporter.java | 4 +-
.../main/assembly/resources/conf/iotdb-metric.yml | 3 +-
.../apache/iotdb/metrics/utils/ReporterType.java | 2 +-
.../iotdb/metrics/config/MetricConfigTest.java | 9 +-
.../src/{main => }/test/resources/iotdb-metric.yml | 3 +-
.../org.apache.iotdb.metrics.MetricManager | 2 +-
server/pom.xml | 5 +
.../resources/conf/iotdb-engine.properties | 13 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 24 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 1 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 10 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 30 +-
.../cross/inplace/manage/MergeManager.java | 3 +-
.../engine/cq/ContinuousQuerySchemaCheckTask.java | 99 ++++
.../db/{ => engine}/cq/ContinuousQueryService.java | 50 +-
.../db/{ => engine}/cq/ContinuousQueryTask.java | 177 ++-----
.../cq/ContinuousQueryTaskPoolManager.java | 2 +-
.../selectinto/InsertTabletPlansIterator.java | 51 +-
.../storagegroup/VirtualStorageGroupProcessor.java | 10 +-
...java => TsFileTimeseriesMetadataException.java} | 11 +-
.../org/apache/iotdb/db/metadata/MManager.java | 2 +-
.../db/metadata/lastCache/LastCacheManager.java | 4 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 13 +-
.../reporter/DropwizardIoTDBReporter.java | 47 +-
.../metrics/dropwizard/reporter/IoTDBReporter.java | 233 ++++++++++
.../org/apache/iotdb/db/metrics/metricsUtils.java | 61 +++
.../micrometer/registry/IoTDBMeterRegistry.java | 150 ++++++
.../micrometer/registry/IoTDBRegistryConfig.java | 12 +-
.../reporter/MicrometerIoTDBReporter.java | 29 +-
.../handler/PhysicalPlanValidationHandler.java | 78 ++++
.../rest/handler/RequestValidationHandler.java | 5 +
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 5 +-
.../db/protocol/rest/impl/RestApiServiceImpl.java | 21 +-
.../main/java/org/apache/iotdb/db/qp/Planner.java | 38 ++
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 23 +-
.../logical/sys/CreateContinuousQueryOperator.java | 8 +-
.../qp/physical/sys/CreateContinuousQueryPlan.java | 24 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 6 +-
.../iotdb/db/query/context/QueryContext.java | 9 -
.../db/query/control/QueryResourceManager.java | 4 +-
.../query/dataset/ShowContinuousQueriesResult.java | 21 +-
.../groupby/GroupByWithValueFilterDataSet.java | 3 +-
.../groupby/LocalAlignedGroupByExecutor.java | 2 +-
.../dataset/groupby/LocalGroupByExecutor.java | 2 +-
.../db/query/executor/AggregationExecutor.java | 20 +-
.../iotdb/db/query/executor/FillQueryExecutor.java | 3 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 4 +-
.../db/query/executor/RawDataQueryExecutor.java | 6 +-
.../iotdb/db/query/executor/fill/LinearFill.java | 8 +-
.../iotdb/db/query/executor/fill/PreviousFill.java | 5 +-
.../iotdb/db/query/expression/ResultColumn.java | 5 +
.../iotdb/db/query/reader/series/SeriesReader.java | 19 +-
.../query/timegenerator/ServerTimeGenerator.java | 3 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 6 +-
.../db/service/thrift/impl/TSServiceImpl.java | 11 +-
.../apache/iotdb/db/tools/TsFileSelfCheckTool.java | 190 ++++++++
.../apache/iotdb/db/tools/TsFileSketchTool.java | 1 +
.../apache/iotdb/db/utils/EnvironmentUtils.java | 2 +-
.../services/org.apache.iotdb.metrics.Reporter | 4 +-
.../engine/modification/DeletionFileNodeTest.java | 4 +-
.../storagegroup/StorageGroupProcessorTest.java | 19 +-
.../iotdb/db/tools/TsFileSelfCheckToolTest.java | 239 ++++++++++
.../TsFileStatisticsMistakesException.java | 7 +-
.../file/metadata/statistics/BinaryStatistics.java | 15 +
.../metadata/statistics/BooleanStatistics.java | 17 +
.../file/metadata/statistics/DoubleStatistics.java | 20 +
.../file/metadata/statistics/FloatStatistics.java | 20 +
.../metadata/statistics/IntegerStatistics.java | 19 +
.../file/metadata/statistics/LongStatistics.java | 19 +
.../iotdb/tsfile/read/TsFileCheckStatus.java | 7 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 135 ++++++
119 files changed, 5110 insertions(+), 1427 deletions(-)
create mode 100644 docs/UserGuide/System-Tools/TsFileSelfCheck-Tool.md
create mode 100644 docs/zh/UserGuide/System-Tools/TsFileSelfCheck-Tool.md
copy integration/src/test/java/org/apache/iotdb/db/integration/aligned/{IoTDBLastQuery2IT.java => IoTDBRawQueryWithoutValueFilter3IT.java} (92%)
rename metrics/interface/src/{main/test => test/java}/org/apache/iotdb/metrics/config/MetricConfigTest.java (86%)
rename metrics/interface/src/{main => }/test/resources/iotdb-metric.yml (92%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/cq/ContinuousQuerySchemaCheckTask.java
rename server/src/main/java/org/apache/iotdb/db/{ => engine}/cq/ContinuousQueryService.java (83%)
rename server/src/main/java/org/apache/iotdb/db/{ => engine}/cq/ContinuousQueryTask.java (52%)
rename server/src/main/java/org/apache/iotdb/db/{ => engine}/cq/ContinuousQueryTaskPoolManager.java (98%)
copy server/src/main/java/org/apache/iotdb/db/exception/{WriteLockFailedException.java => TsFileTimeseriesMetadataException.java} (81%)
copy metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/DropwizardJmxReporter.java => server/src/main/java/org/apache/iotdb/db/metrics/dropwizard/reporter/DropwizardIoTDBReporter.java (58%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metrics/dropwizard/reporter/IoTDBReporter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metrics/metricsUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metrics/micrometer/registry/IoTDBMeterRegistry.java
copy metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter/IoTDBJmxConfig.java => server/src/main/java/org/apache/iotdb/db/metrics/micrometer/registry/IoTDBRegistryConfig.java (75%)
copy metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter/MicrometerJmxReporter.java => server/src/main/java/org/apache/iotdb/db/metrics/micrometer/reporter/MicrometerIoTDBReporter.java (67%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/rest/handler/PhysicalPlanValidationHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/tools/TsFileSelfCheckTool.java
copy {metrics/dropwizard-metrics => server}/src/main/resources/META-INF/services/org.apache.iotdb.metrics.Reporter (84%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/tools/TsFileSelfCheckToolTest.java
copy server/src/main/java/org/apache/iotdb/db/exception/WriteLockFailedException.java => tsfile/src/main/java/org/apache/iotdb/tsfile/exception/TsFileStatisticsMistakesException.java (81%)