This is an automated email from the ASF dual-hosted git repository.
hxd pushed a change to branch cluster-
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 9fdbbad [cluster-refactor] update start class name in shell/bat
script and apply (#3993)
add adb1cbc [IOTDB-1562] Fix incorrect exception processing in
insertXXX() API (#3758)
add 3333f3b [IOTDB-1450] Deletion should only delete related time
partitions (#3439)
add 1ad4b3d [IOTDB-1564] Make hearbeat and election timeout parameters be
configurable (#3797)
add 2400c36 [ISSUE-3856] refine exception handling logic in commitTo in
Raft… (#3848)
add ba988ee [IOTDB-1600] Support InsertRowsOfOneDevicePlan in cluster
(#3877)
add 3877d00 [IOTDB-1630] Compile cpp client on ARM Linux (#3912)
add aaa96b9 Modify user manual about datatime-input (#3901)
add 2f279dd [IOTDB-1619] There is an error msg when I restart
iotdb-cluster (#3930)
add d5ebc3c [IOTDB-1275] Fix backgroup exec for cli -e function causes an
infinite loop in writing output file (#3932)
add 601df56 [IOTDB-1659] Fix Windows CLI cannot set maxPRC less than or
equal to 0 (#3936)
add a885ec9 [IOTDB-1670] Fix cli -e mode didn't fetch timestamp_precision
from server (#3942)
add 3cb08e0 [IOTDB-1543] LastCache for Template and Vector (#3796)
add b76a799 [IOTDB-1632] fill only if the value is missing (#3914)
add 922cc09 [IOTDB-1674] Fix command interpret error causing somaxconn
warning failed (#3951)
add 0163f03 [IoTDB-1671] modify dockerfile and Download file for
releasing v0.12.2 (#3946)
add 177913d [IOTDB-1629] fix the NPE when using value fill in cluster
mode (#3913)
add 511cb00 [IOTDB-1666] Implement vector support align by device (#3916)
add 184fd6f [ISSUE-3945] Fuzzy query support multiDevices and
alignByDevice Dataset (#3958)
add 0e1edde [IOTDB-1289] fix CPP mem-leak in SessionExample.cpp
insertRecords() (#3960)
add 28ce04e [IOTDB-1677] not generate file
apache-iotdb-0.x.x-client-cpp-linux-x86_64-bin.zip.sha512 (#3961)
add 255bc61 [IOTDB-1484]Auto create schema functionality with e2e testing
in cluster (#3879)
add d97128f [IOTDB-1287] Fix C++ class Session has 2 useless sort()
(#3966)
add 5f0dcd9 [IOTDB-1679] client-cpp: Session descontruction need release
server resource. (#3964)
add 45b3d6f [IOTDB-1678] Fix client-cpp session bug: can cause connection
leak. (#3962)
add d5e59d2 Change the way of calculating vector avg points (#3970)
add e5d86c9 [IOTDB-1690] Fix align by device type cast error (#3971)
add f1c342a [IOTDB-1338] The content of DDL viewing sub-nodes in the user
guide module is wrong (#3991)
add 8a039eb [IOTDB-1703] Fix MManager slow recover with tag (#3997)
add 4e778b5 [IOTDB-1691] Wrong way of calculating the vector's memory
footprint (#3979)
add 00a2484 [IOTDB-1650] Rename the sql command `move` to `unload` (#4002)
add 64f7179 [IOTDB-1713] Run IoTDB CI with JDK17 (#3998)
add ed99733 [ISSUE-3927] Inefficient Usage of JCF (#3926)
add d13523b [IOTDB-1716] Remove `TEMPORARY` keyword from `CREATE
FUNCTION` statement (#4004)
add c75a71f [IOTDB-842] Better Export/Import-CSV Tool (#3820)
add 6dc45c6 [IOTDB-1721] client-cpp-example pom.xml copy useless
client-cpp-xxx.zip (#4011)
new 06cbe01 merge with master
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/main-unix.yml | 2 +-
.github/workflows/main-win.yml | 2 +-
README.md | 2 +-
README_ZH.md | 2 +-
RELEASE_NOTES.md | 2 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 20 +-
checkstyle.xml | 2 +-
cli/pom.xml | 5 +
.../java/org/apache/iotdb/cli/AbstractCli.java | 17 +-
cli/src/main/java/org/apache/iotdb/cli/Cli.java | 3 +-
cli/src/main/java/org/apache/iotdb/cli/WinCli.java | 13 +-
.../org/apache/iotdb/tool/AbstractCsvTool.java | 96 ++-
.../main/java/org/apache/iotdb/tool/ExportCsv.java | 240 +++----
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 789 +++++++++++++--------
.../java/org/apache/iotdb/cli/AbstractScript.java | 10 +-
.../org/apache/iotdb/cli/StartClientScriptIT.java | 27 +
.../org/apache/iotdb/tool/CsvLineSplitTest.java | 33 -
.../tool/{ => integration}/ExportCsvTestIT.java | 2 +-
.../tool/{ => integration}/ImportCsvTestIT.java | 2 +-
.../apache/iotdb/tool/unit/WriteCsvFileTestUT.java | 36 +-
client-cpp/pom.xml | 18 +
client-cpp/src/main/Session.cpp | 12 +-
client-cpp/src/main/Session.h | 4 +-
.../resources/conf/iotdb-cluster.properties | 13 +-
.../client/sync/SyncDataHeartbeatClient.java | 2 +-
.../client/sync/SyncMetaHeartbeatClient.java | 3 +-
.../apache/iotdb/cluster/config/ClusterConfig.java | 20 +
.../iotdb/cluster/config/ClusterConstant.java | 61 +-
.../iotdb/cluster/config/ClusterDescriptor.java | 10 +
.../iotdb/cluster/log/applier/BaseApplier.java | 94 ++-
.../iotdb/cluster/log/applier/DataLogApplier.java | 66 +-
.../manage/FilePartitionedSnapshotLogManager.java | 12 +-
.../log/manage/PartitionedSnapshotLogManager.java | 5 +-
.../iotdb/cluster/log/manage/RaftLogManager.java | 115 +--
.../serializable/SyncLogDequeSerializer.java | 9 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 79 +--
.../slot/SlotTimePartitionFilter.java} | 38 +-
.../cluster/query/ClusterDataQueryExecutor.java | 2 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 23 +-
.../iotdb/cluster/query/ClusterPlanRouter.java | 36 +
.../iotdb/cluster/query/ClusterQueryRouter.java | 14 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 6 +-
.../query/dataset/ClusterAlignByDeviceDataSet.java | 61 --
.../cluster/query/fill/ClusterFillExecutor.java | 53 +-
.../cluster/query/reader/ClusterReaderFactory.java | 12 +-
.../query/reader/mult/RemoteMultSeriesReader.java | 3 +-
.../cluster/server/heartbeat/HeartbeatThread.java | 50 +-
.../cluster/server/member/DataGroupMember.java | 113 ++-
.../cluster/server/member/MetaGroupMember.java | 2 +-
.../iotdb/cluster/server/member/RaftMember.java | 2 +-
.../cluster/log/applier/DataLogApplierTest.java | 39 +-
.../query/{ => fill}/ClusterFillExecutorTest.java | 69 +-
.../server/heartbeat/HeartbeatThreadTest.java | 5 +-
.../iotdb/cluster/server/member/BaseMember.java | 14 +-
.../cluster/server/member/MetaGroupMemberTest.java | 6 +-
compile-tools/pom.xml | 24 +
cross-tests/pom.xml | 9 +
.../tests/tools/importCsv/AbstractScript.java | 54 +-
.../tests/tools/importCsv/ExportCsvTestIT.java | 209 ++----
.../tests/tools/importCsv/ImportCsvTestIT.java | 383 ++++++----
distribution/pom.xml | 2 +-
...le-0.12.1-cluster => Dockerfile-0.12.2-cluster} | 10 +-
...ckerfile-0.12.1-node => Dockerfile-0.12.2-node} | 10 +-
docs/Download/README.md | 34 +-
docs/UserGuide/Cluster/Cluster-Setup-Example.md | 2 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 21 +-
docs/UserGuide/Data-Concept/Data-Type.md | 14 +-
docs/UserGuide/Data-Concept/Encoding.md | 2 +-
.../DDL-Data-Definition-Language.md | 2 +-
docs/UserGuide/System-Tools/CSV-Tool.md | 204 ++++--
.../UserGuide/System-Tools/Load-External-Tsfile.md | 10 +-
docs/zh/Download/README.md | 34 +-
docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md | 2 +-
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 22 +-
docs/zh/UserGuide/Data-Concept/Data-Type.md | 14 +-
docs/zh/UserGuide/Data-Concept/Encoding.md | 4 +-
.../DDL-Data-Definition-Language.md | 2 +-
docs/zh/UserGuide/System-Tools/CSV-Tool.md | 205 ++++--
.../UserGuide/System-Tools/Load-External-Tsfile.md | 10 +-
example/client-cpp-example/pom.xml | 19 +-
example/client-cpp-example/src/SessionExample.cpp | 15 +-
.../iotdb/AlignedTimeseriesSessionExample.java | 6 +-
.../iotdb/HybridTimeseriesSessionExample.java | 5 +-
.../iotdb/tsfile/TsFileWriteVectorWithTablet.java | 2 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 4 +-
pom.xml | 4 +-
server/src/assembly/resources/conf/iotdb-env.sh | 4 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../org/apache/iotdb/db/conf/OperationType.java | 65 ++
.../org/apache/iotdb/db/engine/StorageEngine.java | 23 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 121 ++--
.../iotdb/db/engine/memtable/AbstractMemTable.java | 21 +-
.../db/engine/memtable/PrimitiveMemTable.java | 3 +-
.../db/engine/merge/manage/MergeResource.java | 4 +-
.../db/engine/querycontext/ReadOnlyMemChunk.java | 19 +-
.../engine/storagegroup/StorageGroupProcessor.java | 187 ++---
.../db/engine/storagegroup/TsFileProcessor.java | 21 +-
.../virtualSg/VirtualStorageGroupManager.java | 9 +-
.../org/apache/iotdb/db/metadata/MManager.java | 356 ++++++----
.../java/org/apache/iotdb/db/metadata/MTree.java | 110 +--
.../org/apache/iotdb/db/metadata/PartialPath.java | 21 +-
.../iotdb/db/metadata/VectorPartialPath.java | 68 +-
.../db/metadata/lastCache/LastCacheManager.java | 331 +++++++++
.../container/ILastCacheContainer.java} | 56 +-
.../lastCache/container/LastCacheContainer.java | 118 +++
.../lastCache/container/value/ILastCacheValue.java | 27 +-
.../container/value/UnaryLastCacheValue.java | 106 +++
.../container/value/VectorLastCacheValue.java | 86 +++
.../iotdb/db/metadata/mnode/EntityMNode.java | 25 +
.../iotdb/db/metadata/mnode/IEntityMNode.java | 6 +
.../iotdb/db/metadata/mnode/IMeasurementMNode.java | 9 +-
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 2 +-
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 51 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 8 +-
.../iotdb/db/metadata/template/Template.java | 2 +-
.../apache/iotdb/db/qp/constant/SQLConstant.java | 4 +-
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 9 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 50 +-
.../org/apache/iotdb/db/qp/logical/Operator.java | 2 +-
.../iotdb/db/qp/logical/crud/LikeOperator.java | 4 +
.../iotdb/db/qp/logical/crud/QueryOperator.java | 16 +-
.../iotdb/db/qp/logical/crud/RegexpOperator.java | 4 +
.../db/qp/logical/sys/CreateFunctionOperator.java | 11 +-
.../db/qp/logical/sys/ShowFunctionsOperator.java | 12 +-
...veFileOperator.java => UnloadFileOperator.java} | 10 +-
.../org/apache/iotdb/db/qp/physical/BatchPlan.java | 9 +
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 4 +
.../iotdb/db/qp/physical/crud/DeletePlan.java | 15 +
.../db/qp/physical/crud/InsertMultiTabletPlan.java | 19 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 11 +-
.../physical/crud/InsertRowsOfOneDevicePlan.java | 89 ++-
.../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 15 +-
.../iotdb/db/qp/physical/crud/LastQueryPlan.java | 2 -
.../iotdb/db/qp/physical/crud/QueryPlan.java | 2 +-
.../db/qp/physical/crud/RawDataQueryPlan.java | 30 +-
.../db/qp/physical/sys/CreateFunctionPlan.java | 18 +-
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 12 +-
.../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 15 +
.../db/qp/physical/sys/ShowFunctionsPlan.java | 9 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 14 +-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 14 +
.../iotdb/db/query/control/QueryTimeManager.java | 25 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 54 +-
.../dataset/RawQueryDataSetWithoutValueFilter.java | 6 +-
.../iotdb/db/query/executor/FillQueryExecutor.java | 94 ++-
.../iotdb/db/query/executor/LastQueryExecutor.java | 34 +-
.../iotdb/db/query/executor/QueryRouter.java | 28 +-
.../db/query/executor/fill/LastPointReader.java | 13 +-
.../query/expression/unary/TimeSeriesOperand.java | 2 +-
.../query/timegenerator/ServerTimeGenerator.java | 7 -
.../udf/service/UDFRegistrationInformation.java | 13 +-
.../query/udf/service/UDFRegistrationService.java | 58 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 146 +++-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 34 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 36 +-
.../iotdb/db/writelog/recover/LogReplayer.java | 4 +-
.../engine/modification/DeletionFileNodeTest.java | 109 ++-
.../db/engine/modification/DeletionQueryTest.java | 77 +-
.../storagegroup/StorageGroupProcessorTest.java | 2 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 4 +-
.../apache/iotdb/db/integration/IoTDBFillIT.java | 34 +-
.../{IoTDBLikeIT.java => IoTDBFuzzyQueryIT.java} | 125 +++-
.../apache/iotdb/db/integration/IoTDBLastIT.java | 28 +-
.../db/integration/IoTDBLoadExternalTsfileIT.java | 26 +-
.../iotdb/db/integration/IoTDBUDFManagementIT.java | 104 +--
.../aggregation/IoTDBAggregationSmallDataIT.java | 17 +-
.../iotdb/db/metadata/MManagerAdvancedTest.java | 16 +-
.../qp/physical/InsertRowsOfOneDevicePlanTest.java | 75 ++
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 44 +-
.../java/org/apache/iotdb/session/Session.java | 21 +-
.../org/apache/iotdb/session/SessionUtils.java | 4 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 286 +++++++-
.../apache/iotdb/session/IoTDBSessionVectorIT.java | 5 +-
.../.vuepress/public/img/contributor-avatar/cw.jpg | Bin 163226 -> 163225 bytes
.../test/java/org/apache/iotdb/db/sql/Cases.java | 304 +++++++-
.../java/org/apache/iotdb/db/sql/ClusterIT.java | 9 +-
.../tsfile/write/chunk/ChunkGroupWriterImpl.java | 2 +-
.../tsfile/write/chunk/VectorChunkWriterImpl.java | 8 +-
.../apache/iotdb/tsfile/write/record/Tablet.java | 16 +-
.../tsfile/write/schema/IMeasurementSchema.java | 14 +-
.../tsfile/write/schema/MeasurementSchema.java | 14 +-
.../write/schema/VectorMeasurementSchema.java | 96 +--
.../write/writer/VectorMeasurementSchemaStub.java | 14 +-
183 files changed, 5308 insertions(+), 2675 deletions(-)
delete mode 100644
cli/src/test/java/org/apache/iotdb/tool/CsvLineSplitTest.java
rename cli/src/test/java/org/apache/iotdb/tool/{ =>
integration}/ExportCsvTestIT.java (98%)
rename cli/src/test/java/org/apache/iotdb/tool/{ =>
integration}/ImportCsvTestIT.java (98%)
copy
server/src/test/java/org/apache/iotdb/db/engine/version/SysTimeVersionControllerTest.java
=> cli/src/test/java/org/apache/iotdb/tool/unit/WriteCsvFileTestUT.java (51%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/{query/filter/SlotSgFilter.java
=> partition/slot/SlotTimePartitionFilter.java} (52%)
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/dataset/ClusterAlignByDeviceDataSet.java
rename cluster/src/test/java/org/apache/iotdb/cluster/query/{ =>
fill}/ClusterFillExecutorTest.java (69%)
copy docker/src/main/{Dockerfile-0.12.1-cluster => Dockerfile-0.12.2-cluster}
(85%)
copy docker/src/main/{Dockerfile-0.12.1-node => Dockerfile-0.12.2-node} (83%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/conf/OperationType.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/lastCache/LastCacheManager.java
copy
server/src/main/java/org/apache/iotdb/db/metadata/{mnode/IMeasurementMNode.java
=> lastCache/container/ILastCacheContainer.java} (51%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/lastCache/container/LastCacheContainer.java
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/IPointReader.java =>
server/src/main/java/org/apache/iotdb/db/metadata/lastCache/container/value/ILastCacheValue.java
(59%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/lastCache/container/value/UnaryLastCacheValue.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/lastCache/container/value/VectorLastCacheValue.java
rename
server/src/main/java/org/apache/iotdb/db/qp/logical/sys/{MoveFileOperator.java
=> UnloadFileOperator.java} (85%)
rename server/src/test/java/org/apache/iotdb/db/integration/{IoTDBLikeIT.java
=> IoTDBFuzzyQueryIT.java} (57%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/qp/physical/InsertRowsOfOneDevicePlanTest.java
