You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2021/08/23 03:19:14 UTC
[iotdb] branch fix_tsm_cache updated (327ffe8 -> 2f20c37)
This is an automated email from the ASF dual-hosted git repository.
xiangweiwei pushed a change to branch fix_tsm_cache
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 327ffe8 add log
add 884ad96 [maven-release-plugin] prepare for next development iteration
add a06b91c Fix compaction lock with query (#3366)
add 1ad3223 upgrade code-coverage to 0.12.2-SNAPSHOT
add 92c064c change concurrent_writing_time_partition to 100
add 33ee473 [To rel/0.12][ISSUE-3378] Fix NPE when clear upgrade folder; Fix some upgraded pageHeader missing statistics (#3376)
add 969fc0d [To Rel/0.12]Remove the broken cached leader connection & optimize the insertRecords method in session (#3373)
add 995cfc5 Merge branch 'rel/0.12' of github.com:apache/incubator-iotdb into rel/0.12
add 7111d5a [IOTDB-1419][To rel/0.12] remove redundant clearCompactionStatus (#3370)
add a8186d6 add compaction_interval=1000ms (#3387)
add 4bb1748 [IOTDB-1433] [To rel/0.12] Fix bug in getMetadataAndEndOffset when querying non-exist device (#3392)
add f2e1dc9 fix level compaction loss data (#3395)
add 0e1f630 Change the default primitive array size to 32 (#3399)
add bf3ac9f [To Rel/0.12][IOTDB-1437]Fix the tsfile sketch tool NPE (#3403)
add f42aa84 change default tsfile_size_threshold=1
add 2488ebb [To rel/0.12]TTL can be set to any path (#3389)
add f089d84 cleanup generated files in client-py after post-integration-test
add 26bfb7b update the release note for v0.12.1
add 4968354 [To rel/0.12] fix ci bug (#3412)
add 8ad6e9a [To rel/0.12]try to fix the AsyncMetaClientTest (#3411)
add ada66cd revert clean generated codes in client-py module
add e99c7f4 fix cpp query last example not close dataset
add 4c7bb10 [maven-release-plugin] prepare release v0.12.1
add 9f14da8 [maven-release-plugin] prepare for next development iteration
add 784ac10 [To rel/0.12] [IOTDB-1442] Time filter & TTL is not used during the construction of ClusterTimeGenerator (#3421)
add ae9c3cc [maven-release-plugin] prepare release v0.12.1
add 4bad902 [maven-release-plugin] prepare for next development iteration
add 9b0ee65 Sync 0.12 with master (#3427)
add e5b4f22 avoiding compaction to fix ci bug (#3428)
add 4fa072a [ISSUE-3436] [To rel/0.12] Fix Bug: delete timeseries with multiple time interval
add 47b864f [To rel/0.12][IOTDB-1447] ClientPool is blocking other nodes when one node fails (#3429)
add df14c65 [ISSUE-3316] Fix constructing firstChunkMetaDatahasNextChunk logic in hasNextChunk() (#3444) (#3451)
add 535400f [To rel/0.12] Fix DataMigrationExample OOM if migrate too many timeseries (#3463)
add 651a12a [To rel/0.12][Cluster][Cherry-Pick] write perfromance optimization when replicaNum == 1 && fix a query concurrent bug when query multi timeseries && remove no-merge info log (#3460)
add f976985 [IOTDB-1452] [To rel/0.12] remove compaction log/ change logger to daily (#3466)
add 3f23dde handle false positive cases of tsfile bloom filter (#3471)
add fa7af01 cherry pick to 0.12 cluster exe batch bug (#3476)
add f8c47a2 [To rel/0.12] Cherry pick Windows start-up script fixes (#3492)
add 5c03e61 Fix Load configuration command shows null error message #3458 (#3491)
add 747c7ba fix cross space compaction recover bug (#3488)
add 0d2872e [To rel/0.12] Primitive Array Manager v2 (#3484)
add 68e8801 fix take byte array null pointer (#3497)
add f0344f6 [To rel/0.12] Bug fix: time interval is parsed incorrectly (#3504)
add 82da977 [IOTDB-1461][To rel/0.12] Fix compaction conflicts with ttl (#3509)
add 8eee30e Primitive Array Manager v3 (#3508)
add 5787d13 fix monitor bug (#3512)
add 8f567e9 add audit log when execute delete and set sg for tracing (#3511)
add e80ffa8 PrimitiveArrayManager: improve accuracy when updating limits (#3521)
add c2fc008 [IOTDB-1469][To rel/0.12]fix cross space compaction loss data bug (#3515)
add 36ae1e5 [To rel/0.12] Use StringCachedPool in TsFileResource to reduce the memory size (#3514)
add f23af15 [IOTDB-1466] Support device template in rel/0.12 (#3510)
add c2493d1 [Cluster][To rel/0.12] enable cacheLeader by default (#3469)
add 03897b0 fix sg may not ready log (#3522)
add de7a87a cherry picked from commit f1bc4e32ec11bc36dbae153e8b6a36e3a5505413 (#3528)
add 0cb1e4f [IOTDB-1407][To rel/0.12] Filtering time series based on tags query fails Occasion… (#3529)
add eaf27f5 [To rel/0.12] Improve group by month performance (#3518)
add b741f0a Fix cluster auto create schema bug when retry locally (#3532)
add 4c57a9e [IOTDB-1481] Modify the format problem in the IoTDB v0.12 UserGuide (#3535)
add 05d95ec [To rel/0.12][IOTDB-1486] Add the createTemplate Session example in 0.12 (#3536)
add 48c77f2 [To rel/0.12][IOTDB-1482] Fix Count Timeseries and Count Devices with Template Bug (#3540)
add fbd0c6a [To rel/0.12][IOTDB-1488] Fix metaMember's forwarding clientPool timeout in cluster module (#3538)
add 3f88740 improve compatibility from 0.12.1 to 0.12.2 (#3547)
add 8d48298 [To rel/0.12] Using cached pool to reduce the String memory size in TsFileResourse (#3550)
add bf6d83c [To rel/0.12] fix compaction block flush bug (#3534)
add c6b8113 make parameter definition clearer (#3551)
add 4e78faf [IOTDB-1485] Replace tsfile_size_threshold by unseq_tsfile_size/seq_tsfile_size (#3558)
add ec526ea [IOTDB-1417] [To rel/0.12]UDF meta plans for cluster (#3571)
add c257e4a [To rel/0.12][IOTDB-1492] Fix mLogParser.sh cannot parse the device template (#3557)
add eb8220e [To rel/0.12] [ISSUE-3545] Bug: Time interval value is disorder in group by month (#3566)
add cac70a5 [IoTDB-1501][To rel/0.12] Fix compaction recover delete tsfile bug (#3568)
add b7e39fd [To rel/0.12][IoTDB-1499] Remove series registeration using IoTDBSink -> 0.12 (#3575)
add a0fe4e9 [IOTDB-1491] UDTF query supported in cluster mode (#3565) (#3603)
add 845ad2f [IOTDB-1456] Fix Error occurred while executing delete timeseries statement (#3474) (#3600)
add 153a4a3 modify NodeTool user to root (#3593)
add c56f71f remove EXCEPTION in IoTDBSink(#3619)
add 822a735 [To rel/0.12][IOTDB-959]Add createStorageGroup Grammar (#3616)
add 2f7c945 [To rel/0.12] [IOTDB-1500] Remove current dynamic query memory control (#3564)
add 8a1aba5 Fix compile error in assignQueryId(#3628)
add 30e3dad [To rel/0.12] Revert commit bf6d83cd (#3534) and commit cac70a50 (#3568) (#3634)
add 18f0144 [To rel/0.12] Cherry pick from autoai (#3637)
add 87fb3d9 fix bug in compaction (#3626)
add 9be4d2f replace synchronized with write lock in cross compaction selection (#3633)
add 2489b6e [IOTDB-1529]Fix mlog recover idx bug and synchronize setStorageGroup (#3636)
add 430cfcd [To rel/0.12]Fix thrift out of sequence in cluster module (#3580)
add 88bc428 shutdown FLUSH_BUFFER_THREAD_POOL (#3643)
add a356a4a [IOTDB-1282] fix C++ class SessionDataSet mem-leak (#3648)
add 56df02a Fix 0.12 order by time desc bug (#3654)
add 85d43e8 modified the description of tlog (#3651)
add 97e75df skip non exist measurement in where clause (#3590) (#3664)
add 473e075 [To rel/0.12][IOTDB-1542] Cpp client segment fault: char[] buffer overflow caused by long exception message (#3672)
add e0bc394 [ISSUE-3674] Disable thrift code gen for Javascript (#3676)
add f26bc84 add Template Constraint (#3669)
add aa5c839 make zh doc same to english doc (#3683)
add 773fe94 [To rel/0.12] Stop NO_COMPACTION strategy from submitting compaction task (#3685)
add d663e46 [To rel/0.12][IOTDB-1545] Query dataset momory leak on server caused by cpp client (#3681)
add 33ba044 correct an error of iotdb-engine configuration (#3687)
add 3a6a861 [IOTDB-1537]fix insertTablet premission
add bfcc8db [ISSUE-3690] Memory leaks on the server when cpp client invokes checkTimeseriesExists (#3691)
add ef10239 (cherrypick #3602) Function Improvement: add overlapped page rate in Tracing (#3662)
add 75077fb [IOTDB-1546] [To rel/0.12] Optimize the Upgrade Tool rewrite logic to reduce the temp memory cost (#3670)
add 2ddd003 [IOTDB-1475][To rel/0.12] MeasurementId check while create timeseries or template/ disable time or timestamp in path (#3699)
add e9aea37 [To rel/0.12] Avoid Compaction blocking Flush (Fix CI not stop problem) (#3695)
add c8a2204 [IOTDB-1556] Abort auto create device while setStorageGroup exception (#3707)
add be003c2 [IOTDB-1541][To rel/0.12] Change sequence of wal and memtable in insert (#3705)
add 7cf9d76 [IOTDB-1540] [To rel/0.12] Bug Fix: 500 when using IN operator (#3658)
add 4e21af5 [To rel/0.12] fix dead lock in compaction file selection (#3666)
add 50e83bb [To rel/0.12] Release note of 0.12.2 (#3716)
add b8c2c95 Fix boostrap 1.72.0 download failed in CI because of the redirection by jfrog.io (#3720)
add fdf8534 [To rel/0.12] add JMX monitor to all ThreadPools in the server module (#3717)
add 75dbdb0 Some basic operators should not be applied to text time series (#3723)
add 5e876f3 [To rel/0.12] Fix CreateTimeseriesIT runs slow (#3724)
add 03a744b [To rel/0.12] support fill by specific value (#3621)
add 1e39525 add IOTDB-1552 in release note
add bc0f512 Add IOTDB-1561 in release note (#3727)
add b3f94a5 [To rel/0.12] Fix CI runs slow caused by connection not closing (#3728)
add 62377da [To rel/0.12] Fix compaction recover loses data (#3733)
add ea8546e [To rel/0.12][IOTDB-1536]Support fuzzy query (#3734)
add 2fac702 [To rel/0.12] Fix compaction lost ChunkGroupMetadata (#3737)
add 48629b7 [To rel/0.12] Set line endings to Unix style (#3743)
add 6f77c15 [IOTDB-1539] [To rel/0.12] Fix delete operation with value filter is abnormal (#3747)
add ea97b8a [IOTDB-1567] fix some WAL and SG processor threadpools having the same JMX name (#3748)
add 1a787f8 Modify the comparsion way of enum type (#3750)
add 349656c [IOTDB-1566] [To rel/0.12] Delete the configuration:concurrent_writing_time_partition (#3749)
add c8455e5 Fix issues of blocking heartbeat broadcast and vote requesting caused by client reconnection (#3751) (#3757)
add 04a51b8 [IOTDB-1561][To rel/0.12]Fix problems caused by keywords (#3756)
add 7430fdc [IOTDB-1519][To rel/0.12] add metadata checking option and change grammar for loading tsfile (#3754)
add df4e110 edit deletion log (#3762)
add 0d64916 [IOTDB-1565] [To rel/0.12] Add sql: set system to readonly/writable (#3764)
add 4324d18 PrimitiveArrayManager: reduce log of array deque size update & add limitUpdateThreshold update log (#3779)
add d07b73c [IOTDB-1575] [To rel/0.12] Tsfile valueFilter cannot handle multiple pages (#3780)
add a322674 [IOTDB-1574][To rel/0.12] [ISSUE-3786] Data file is deleted while file handle is not released (#3788)
add 290600e [To rel/0.12]Fix gitattribute covert pictures (#3799)
add b8e3d84 [IOTDB-1496][IOTDB-1569][To rel/0.12] Timed flush memtable & Timed close TsFileProcessor (#3777)
add fb40695 [To rel/0.12]claim current JDBC is not suitable for high throughput operations in document (#3782)
add 43f5e26 Merge branch 'rel/0.12' into fix_tsm_cache
add 2f20c37 update release note
No new revisions were added by this update.
Summary of changes:
.gitattributes | 1 +
.github/workflows/client.yml | 11 +-
RELEASE_NOTES.md | 103 +
antlr/pom.xml | 2 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 48 +-
cli/pom.xml | 2 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 2 +-
client-cpp/pom.xml | 2 +-
client-cpp/src/main/Session.cpp | 2263 ++++++++++----------
client-cpp/src/main/Session.h | 1406 ++++++------
client-cpp/src/test/main.cpp | 6 +-
client-py/pom.xml | 2 +-
cluster/pom.xml | 2 +-
cluster/src/assembly/resources/sbin/stop-node.sh | 6 +-
.../iotdb/cluster/client/DataClientProvider.java | 48 +-
.../cluster/client/async/AsyncClientPool.java | 57 +-
.../iotdb/cluster/client/sync/SyncClientPool.java | 29 +-
.../iotdb/cluster/coordinator/Coordinator.java | 131 +-
.../iotdb/cluster/log/applier/BaseApplier.java | 21 +-
.../cluster/log/manage/CommittedEntryManager.java | 4 +
.../apache/iotdb/cluster/metadata/CMManager.java | 182 +-
.../apache/iotdb/cluster/metadata/MetaPuller.java | 18 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 39 +-
.../apache/iotdb/cluster/query/ClusterPlanner.java | 13 +-
.../iotdb/cluster/query/ClusterQueryRouter.java | 40 +
.../cluster/query/ClusterUDTFQueryExecutor.java | 12 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 48 +-
.../cluster/query/aggregate/ClusterAggregator.java | 9 +-
.../cluster/query/fill/ClusterPreviousFill.java | 25 +-
.../query/groupby/RemoteGroupByExecutor.java | 21 +-
.../query/last/ClusterLastQueryExecutor.java | 11 +-
.../cluster/query/manage/ClusterQueryManager.java | 8 +-
.../cluster/query/reader/ClusterReaderFactory.java | 27 +-
.../cluster/query/reader/ClusterTimeGenerator.java | 45 +-
.../iotdb/cluster/query/reader/DataSourceInfo.java | 36 +-
.../reader/RemoteSeriesReaderByTimestamp.java | 2 +
.../query/reader/RemoteSimpleSeriesReader.java | 2 +
.../query/reader/mult/MultDataSourceInfo.java | 15 +-
.../query/reader/mult/RemoteMultSeriesReader.java | 21 +-
.../apache/iotdb/cluster/server/ClientServer.java | 8 +-
.../iotdb/cluster/server/DataClusterServer.java | 9 +
.../iotdb/cluster/server/MetaClusterServer.java | 10 +
.../cluster/server/heartbeat/HeartbeatThread.java | 41 +-
.../cluster/server/member/DataGroupMember.java | 45 +-
.../cluster/server/member/MetaGroupMember.java | 89 +-
.../iotdb/cluster/server/member/RaftMember.java | 32 +-
.../cluster/server/service/BaseAsyncService.java | 4 +
.../cluster/server/service/BaseSyncService.java | 4 +
.../apache/iotdb/cluster/utils/PartitionUtils.java | 12 +-
.../apache/iotdb/cluster/utils/PlanSerializer.java | 8 +-
.../apache/iotdb/cluster/utils/StatusUtils.java | 3 +-
.../utils/nodetool/function/NodeToolCmd.java | 2 +-
.../cluster/client/DataClientProviderTest.java | 5 +-
.../cluster/client/async/AsyncMetaClientTest.java | 28 +-
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 3 +-
.../iotdb/cluster/common/TestAsyncDataClient.java | 11 +
.../iotdb/cluster/integration/SingleNodeTest.java | 35 +
.../cluster/log/snapshot/FileSnapshotTest.java | 20 +
.../apache/iotdb/cluster/query/BaseQueryTest.java | 4 +-
.../query/ClusterAggregateExecutorTest.java | 4 +-
.../query/ClusterDataQueryExecutorTest.java | 16 +-
.../cluster/query/ClusterFillExecutorTest.java | 4 +-
.../cluster/query/ClusterPlanExecutorTest.java | 23 +-
.../cluster/query/ClusterQueryRouterTest.java | 45 +-
.../query/ClusterUDTFQueryExecutorTest.java | 116 +
.../ClusterGroupByNoVFilterDataSetTest.java | 2 +-
.../groupby/ClusterGroupByVFilterDataSetTest.java | 2 +-
.../query/groupby/MergeGroupByExecutorTest.java | 4 +-
.../query/groupby/RemoteGroupByExecutorTest.java | 4 +-
.../query/manage/ClusterQueryManagerTest.java | 12 +-
.../query/reader/ClusterReaderFactoryTest.java | 82 +
.../query/reader/ClusterTimeGeneratorTest.java | 60 +-
.../iotdb/cluster/server/member/BaseMember.java | 2 +-
.../cluster/server/member/DataGroupMemberTest.java | 2 +-
.../cluster/server/member/MetaGroupMemberTest.java | 4 +-
code-coverage/pom.xml | 2 +-
compile-tools/pom.xml | 2 +-
compile-tools/thrift/pom.xml | 5 +-
cross-tests/pom.xml | 2 +-
distribution/pom.xml | 2 +-
docs/SystemDesign/SchemaManager/SchemaManager.md | 39 +-
docs/UserGuide/API/Programming-JDBC.md | 4 +
docs/UserGuide/Appendix/SQL-Reference.md | 26 +
.../UserGuide/Ecosystem Integration/Flink IoTDB.md | 3 +-
.../Ecosystem Integration/Zeppelin-IoTDB.md | 2 +-
.../DDL-Data-Definition-Language.md | 6 +-
.../DML-Data-Manipulation-Language.md | 52 +-
.../IoTDB-SQL-Language/Maintenance-Command.md | 27 +-
.../UserGuide/System-Tools/Load-External-Tsfile.md | 32 +-
.../zh/SystemDesign/SchemaManager/SchemaManager.md | 55 +-
docs/zh/UserGuide/API/Programming-JDBC.md | 3 +
docs/zh/UserGuide/Appendix/SQL-Reference.md | 24 +
.../Ecosystem Integration/Zeppelin-IoTDB.md | 2 +-
.../DDL-Data-Definition-Language.md | 12 +-
.../DML-Data-Manipulation-Language.md | 66 +-
.../IoTDB-SQL-Language/Maintenance-Command.md | 28 +-
.../UserGuide/System-Tools/Load-External-Tsfile.md | 56 +-
example/client-cpp-example/pom.xml | 2 +-
example/client-cpp-example/src/SessionExample.cpp | 1 +
example/flink/pom.xml | 2 +-
.../org/apache/iotdb/flink/FlinkIoTDBSink.java | 1 -
example/hadoop/pom.xml | 2 +-
example/jdbc/pom.xml | 2 +-
example/kafka/pom.xml | 2 +-
example/mqtt/pom.xml | 2 +-
example/pom.xml | 2 +-
example/pulsar/pom.xml | 2 +-
example/rocketmq/pom.xml | 2 +-
example/session/pom.xml | 2 +-
.../org/apache/iotdb/DataMigrationExample.java | 8 +-
.../org/apache/iotdb/SessionConcurrentExample.java | 198 ++
.../main/java/org/apache/iotdb/SessionExample.java | 44 +
example/tsfile/pom.xml | 2 +-
example/udf/pom.xml | 2 +-
flink-iotdb-connector/pom.xml | 2 +-
.../java/org/apache/iotdb/flink/IoTDBSink.java | 19 +-
.../iotdb/flink/options/IoTDBSinkOptions.java | 11 -
flink-tsfile-connector/pom.xml | 2 +-
grafana/pom.xml | 2 +-
hadoop/pom.xml | 2 +-
hive-connector/pom.xml | 2 +-
jdbc/pom.xml | 2 +-
pom.xml | 6 +-
server/pom.xml | 2 +-
.../resources/conf/iotdb-engine.properties | 69 +-
server/src/assembly/resources/conf/iotdb-env.bat | 39 +-
server/src/assembly/resources/conf/logback.xml | 24 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 1 +
.../db/concurrent/IoTDBThreadPoolFactory.java | 89 +-
.../threadpool/IThreadPoolMBean.java} | 26 +-
.../WrappedScheduledExecutorService.java | 192 ++
.../WrappedScheduledExecutorServiceMBean.java | 4 +-
.../WrappedSingleThreadExecutorService.java | 118 +
.../WrappedSingleThreadExecutorServiceMBean.java} | 7 +-
.../WrappedSingleThreadScheduledExecutor.java | 123 ++
...WrappedSingleThreadScheduledExecutorMBean.java} | 7 +-
.../threadpool/WrappedThreadPoolExecutor.java | 88 +
.../threadpool/WrappedThreadPoolExecutorMBean.java | 4 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 162 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 1 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 169 +-
.../iotdb/db/cost/statistic/Measurement.java | 4 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 175 +-
.../compaction/CompactionMergeTaskPoolManager.java | 54 +-
.../db/engine/compaction/TsFileManagement.java | 166 +-
.../level/LevelCompactionTsFileManagement.java | 198 +-
.../no/NoCompactionTsFileManagement.java | 20 +-
.../compaction/utils/CompactionLogAnalyzer.java | 20 +-
.../engine/compaction/utils/CompactionUtils.java | 13 +-
.../apache/iotdb/db/engine/flush/FlushManager.java | 4 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 21 +-
.../apache/iotdb/db/engine/memtable/IMemTable.java | 8 +
.../iotdb/db/engine/merge/manage/MergeManager.java | 20 +-
.../db/engine/merge/manage/MergeResource.java | 3 +-
.../merge/selector/MaxFileMergeFileSelector.java | 15 +-
.../merge/task/CompactionMergeRecoverTask.java | 81 +
.../iotdb/db/engine/merge/task/MergeFileTask.java | 8 +-
.../db/engine/merge/task/MergeMultiChunkTask.java | 11 +-
.../db/engine/merge/task/RecoverMergeTask.java | 4 +-
.../db/engine/querycontext/QueryDataSource.java | 12 +-
.../engine/storagegroup/StorageGroupProcessor.java | 463 ++--
.../db/engine/storagegroup/TsFileProcessor.java | 75 +-
.../db/engine/storagegroup/TsFileResource.java | 2 +-
.../storagegroup/timeindex/DeviceTimeIndex.java | 5 +
.../storagegroup/timeindex/FileTimeIndex.java | 5 +
.../virtualSg/VirtualStorageGroupManager.java | 31 +-
.../iotdb/db/engine/upgrade/UpgradeTask.java | 7 +-
.../version/SimpleFileVersionController.java | 2 +-
...ption.java => DuplicatedTemplateException.java} | 13 +-
.../metadata/StorageGroupAlreadySetException.java | 7 +
...eption.java => UndefinedTemplateException.java} | 13 +-
.../exception/query/PathNumOverLimitException.java | 9 +-
.../org/apache/iotdb/db/metadata/MManager.java | 329 ++-
.../java/org/apache/iotdb/db/metadata/MTree.java | 301 ++-
.../iotdb/db/metadata/MetadataOperationType.java | 4 +
.../db/metadata/{ => logfile}/MLogTxtWriter.java | 71 +-
.../iotdb/db/metadata/logfile/MLogWriter.java | 21 +
.../db/metadata/{ => logfile}/TagLogFile.java | 2 +-
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 69 +
.../iotdb/db/metadata/template/Template.java | 147 ++
.../org/apache/iotdb/db/monitor/StatMonitor.java | 6 +-
.../main/java/org/apache/iotdb/db/qp/Planner.java | 32 +-
.../apache/iotdb/db/qp/constant/SQLConstant.java | 2 +
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 100 +-
.../org/apache/iotdb/db/qp/logical/Operator.java | 8 +-
.../db/qp/logical/crud/BasicFunctionOperator.java | 21 +-
.../iotdb/db/qp/logical/crud/InOperator.java | 4 +
.../iotdb/db/qp/logical/crud/LikeOperator.java | 131 ++
.../iotdb/db/qp/logical/sys/LoadFilesOperator.java | 21 +-
...ingOperator.java => SetSystemModeOperator.java} | 16 +-
.../org/apache/iotdb/db/qp/physical/BatchPlan.java | 11 +
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 69 +-
.../db/qp/physical/crud/CreateTemplatePlan.java | 270 +++
.../physical/crud/InsertRowsOfOneDevicePlan.java | 7 +
.../SetDeviceTemplatePlan.java} | 82 +-
...oupPlan.java => AutoCreateDeviceMNodePlan.java} | 69 +-
.../db/qp/physical/sys/CreateFunctionPlan.java | 45 +-
.../iotdb/db/qp/physical/sys/DropFunctionPlan.java | 25 +-
.../iotdb/db/qp/physical/sys/OperateFilePlan.java | 23 +-
.../{TracingPlan.java => SetSystemModePlan.java} | 14 +-
...upPlan.java => SetUsingDeviceTemplatePlan.java} | 65 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 247 ++-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 43 +-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 38 +-
.../qp/strategy/optimizer/ILogicalOptimizer.java | 3 +-
.../apache/iotdb/db/qp/utils/DatetimeUtils.java | 48 +-
.../iotdb/db/query/control/QueryFileManager.java | 2 +-
.../db/query/control/QueryResourceManager.java | 100 +-
.../iotdb/db/query/control/SessionManager.java | 202 ++
.../apache/iotdb/db/query/control/TracingInfo.java | 84 +
.../iotdb/db/query/control/TracingManager.java | 139 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 14 +-
.../dataset/groupby/GroupByEngineDataSet.java | 2 +
.../iotdb/db/query/executor/QueryRouter.java | 4 +-
.../iotdb/db/query/executor/fill/ValueFill.java | 110 +
.../reader/series/SeriesRawDataBatchReader.java | 5 +
.../iotdb/db/query/reader/series/SeriesReader.java | 113 +-
.../reader/universal/DescPriorityMergeReader.java | 5 +-
.../reader/universal/PriorityMergeReader.java | 14 +-
.../query/timegenerator/ServerTimeGenerator.java | 2 +-
.../apache/iotdb/db/rescon/MemTableManager.java | 4 +
.../iotdb/db/rescon/PrimitiveArrayManager.java | 349 ++-
.../java/org/apache/iotdb/db/service/IoTDB.java | 14 +-
.../apache/iotdb/db/service/MetricsService.java | 4 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 330 ++-
.../org/apache/iotdb/db/service/UpgradeSevice.java | 7 +-
.../apache/iotdb/db/tools/TsFileRewriteTool.java | 149 +-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 15 +-
.../org/apache/iotdb/db/tools/mlog/MLogParser.java | 19 +-
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 150 +-
.../java/org/apache/iotdb/db/utils/QueryUtils.java | 5 +-
.../iotdb/db/utils/datastructure/TVList.java | 2 +-
.../writelog/manager/MultiFileLogNodeManager.java | 12 +-
.../db/writelog/node/ExclusiveWriteLogNode.java | 86 +-
.../writelog/recover/TsFileRecoverPerformer.java | 29 +-
.../compaction/LevelCompactionMergeTest.java | 68 +
.../compaction/LevelCompactionRecoverTest.java | 28 +-
.../db/engine/compaction/LevelCompactionTest.java | 59 +
.../iotdb/db/engine/merge/MergeTaskTest.java | 151 ++
.../storagegroup/StorageGroupProcessorTest.java | 196 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 6 +-
.../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 54 +
.../db/integration/IoTDBAutoCreateSchemaIT.java | 8 +-
.../db/integration/IoTDBCreateStorageGroupIT.java | 130 ++
.../db/integration/IoTDBCreateTimeseriesIT.java | 8 +-
.../db/integration/IoTDBDeleteTimeseriesIT.java | 55 +-
.../iotdb/db/integration/IoTDBDeletionIT.java | 81 +
.../apache/iotdb/db/integration/IoTDBFillIT.java | 32 +
.../iotdb/db/integration/IoTDBGroupByMonthIT.java | 9 +-
.../org/apache/iotdb/db/integration/IoTDBInIT.java | 255 +++
.../{IoTDBTracingIT.java => IoTDBJMXTest.java} | 36 +-
.../db/integration/IoTDBLoadExternalTsfileIT.java | 121 +-
.../db/integration/IoTDBNewTsFileCompactionIT.java | 1057 ---------
.../iotdb/db/integration/IoTDBQueryDemoIT.java | 220 ++
.../db/integration/IoTDBQueryMemoryControlIT.java | 7 +-
.../iotdb/db/integration/IoTDBRestartIT.java | 48 +
.../db/integration/IoTDBSequenceDataQueryIT.java | 9 +-
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 11 +-
....java => IoTDBSetSystemReadOnlyWritableIT.java} | 150 +-
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 17 +
.../db/integration/IoTDBUDFWindowQueryIT.java | 35 +-
.../integration/IoTDBUDTFAlignByTimeQueryIT.java | 147 +-
.../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 35 +-
.../db/integration/IoTDBUDTFHybridQueryIT.java | 28 +-
.../db/integration/IoTDBUDTFNonAlignQueryIT.java | 42 +-
.../aggregation/IoTDBAggregationSmallDataIT.java | 5 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 511 +++++
.../iotdb/db/metadata/MManagerImproveTest.java | 17 +-
.../iotdb/db/qp/logical/LogicalPlanSmallTest.java | 2 +-
.../iotdb/db/qp/physical/InsertRowPlanTest.java | 200 ++
.../iotdb/db/qp/physical/InsertTabletPlanTest.java | 156 ++
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 77 +-
.../db/qp/utils/DatetimeQueryDataSetUtilsTest.java | 28 +
.../iotdb/db/query/control/TracingManagerTest.java | 7 +-
.../dataset/groupby/GroupByFillDataSetTest.java | 2 +-
.../reader/series/SeriesAggregateReaderTest.java | 6 +-
.../reader/series/SeriesReaderByTimestampTest.java | 6 +-
.../db/sync/receiver/load/FileLoaderTest.java | 7 +
.../org/apache/iotdb/db/tools/MLogParserTest.java | 71 +-
.../iotdb/db/tools/TsFileSketchToolTest.java | 49 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 12 +-
.../iotdb/db/utils/TsFileRewriteToolTest.java | 4 +-
.../apache/iotdb/db/writelog/PerformanceTest.java | 2 +-
service-rpc/pom.xml | 2 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 9 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +
session/pom.xml | 2 +-
.../main/java/org/apache/iotdb/session/Config.java | 2 +-
.../java/org/apache/iotdb/session/Session.java | 234 +-
.../apache/iotdb/session/SessionConnection.java | 122 +-
.../org/apache/iotdb/session/SessionUtils.java | 35 +
.../iotdb/session/IoTDBSessionComplexIT.java | 35 +
.../apache/iotdb/session/SessionCacheLeaderUT.java | 434 +++-
site/pom.xml | 2 +-
site/src/main/.vuepress/config.js | 16 +-
.../theme/global-components/Contributor.vue | 2 +-
spark-iotdb-connector/pom.xml | 2 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 117 +-
spark-tsfile/pom.xml | 2 +-
thrift-cluster/pom.xml | 2 +-
thrift-cluster/src/main/thrift/cluster.thrift | 6 +-
thrift-sync/pom.xml | 2 +-
thrift/pom.xml | 2 +-
thrift/src/main/thrift/rpc.thrift | 20 +
tsfile/pom.xml | 2 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 6 +-
.../read/expression/util/ExpressionOptimizer.java | 34 +-
.../tsfile/read/filter/GroupByMonthFilter.java | 114 +-
.../iotdb/tsfile/read/filter/ValueFilter.java | 43 +
.../read/filter/factory/FilterSerializeId.java | 3 +-
.../read/filter/operator/{In.java => Like.java} | 65 +-
.../read/query/timegenerator/node/LeafNode.java | 2 +-
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 31 +-
.../write/writer/RestorableTsFileIOWriter.java | 41 +
.../iotdb/tsfile/write/writer/TsFileOutput.java | 4 +-
...easurementChunkMetadataListMapIteratorTest.java | 4 +
.../iotdb/tsfile/read/ReadOnlyTsFileTest.java | 69 +
.../tsfile/read/filter/GroupByMonthFilterTest.java | 46 +-
zeppelin-interpreter/pom.xml | 2 +-
319 files changed, 13023 insertions(+), 5917 deletions(-)
create mode 100644 .gitattributes
copy server/src/main/java/org/apache/iotdb/db/query/executor/UDTFQueryExecutor.java => cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterUDTFQueryExecutor.java (91%)
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterUDTFQueryExecutorTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/reader/ClusterReaderFactoryTest.java
create mode 100644 example/session/src/main/java/org/apache/iotdb/SessionConcurrentExample.java
mode change 100644 => 100755 server/src/assembly/resources/conf/iotdb-env.bat
copy server/src/main/java/org/apache/iotdb/db/{query/dataset/UDFInputDataSet.java => concurrent/threadpool/IThreadPoolMBean.java} (68%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/threadpool/WrappedScheduledExecutorService.java
copy cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/package-info.java => server/src/main/java/org/apache/iotdb/db/concurrent/threadpool/WrappedScheduledExecutorServiceMBean.java (85%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/threadpool/WrappedSingleThreadExecutorService.java
copy server/src/main/java/org/apache/iotdb/db/{rescon/TVListAllocatorMBean.java => concurrent/threadpool/WrappedSingleThreadExecutorServiceMBean.java} (87%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/threadpool/WrappedSingleThreadScheduledExecutor.java
copy server/src/main/java/org/apache/iotdb/db/{rescon/TVListAllocatorMBean.java => concurrent/threadpool/WrappedSingleThreadScheduledExecutorMBean.java} (87%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/threadpool/WrappedThreadPoolExecutor.java
copy cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/package-info.java => server/src/main/java/org/apache/iotdb/db/concurrent/threadpool/WrappedThreadPoolExecutorMBean.java (86%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/merge/task/CompactionMergeRecoverTask.java
copy server/src/main/java/org/apache/iotdb/db/exception/metadata/{IllegalParameterOfPathException.java => DuplicatedTemplateException.java} (73%)
copy server/src/main/java/org/apache/iotdb/db/exception/metadata/{IllegalParameterOfPathException.java => UndefinedTemplateException.java} (73%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ => logfile}/MLogTxtWriter.java (77%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ => logfile}/TagLogFile.java (99%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/template/Template.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/LikeOperator.java
copy server/src/main/java/org/apache/iotdb/db/qp/logical/sys/{TracingOperator.java => SetSystemModeOperator.java} (76%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/CreateTemplatePlan.java
copy server/src/main/java/org/apache/iotdb/db/qp/physical/{sys/SetTTLPlan.java => crud/SetDeviceTemplatePlan.java} (50%)
copy server/src/main/java/org/apache/iotdb/db/qp/physical/sys/{SetStorageGroupPlan.java => AutoCreateDeviceMNodePlan.java} (58%)
copy server/src/main/java/org/apache/iotdb/db/qp/physical/sys/{TracingPlan.java => SetSystemModePlan.java} (81%)
copy server/src/main/java/org/apache/iotdb/db/qp/physical/sys/{DeleteStorageGroupPlan.java => SetUsingDeviceTemplatePlan.java} (53%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/control/SessionManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/control/TracingInfo.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/fill/ValueFill.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/integration/IoTDBCreateStorageGroupIT.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/integration/IoTDBInIT.java
copy server/src/test/java/org/apache/iotdb/db/integration/{IoTDBTracingIT.java => IoTDBJMXTest.java} (64%)
delete mode 100644 server/src/test/java/org/apache/iotdb/db/integration/IoTDBNewTsFileCompactionIT.java
copy server/src/test/java/org/apache/iotdb/db/integration/{IoTDBClearCacheIT.java => IoTDBSetSystemReadOnlyWritableIT.java} (64%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/InsertRowPlanTest.java
copy example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteWithTablet.java => server/src/test/java/org/apache/iotdb/db/tools/TsFileSketchToolTest.java (77%)
copy tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/{In.java => Like.java} (62%)