This is an automated email from the ASF dual-hosted git repository.
marklau99 pushed a change to branch IOTDB-3455
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from d851cc93da remove some useless code
add 695b901bfa check and create log file in the init function of
SnapshotLogger (#7151)
add 2a5efd828e [IOTDB-2760][IOTDB-2769][IOTDB-3302] Fix some auth problems
and add Auth IT test. (#7134)
add dda8ac4ff7 [IOTDB-4241] Support set system mode in new cluster (#7148)
add f218f0bdb9 [IOTDB-3164] Manage the memory of cross space compaction in
write memory controller (#6914)
add 210a0b532e [IOTDB-4246] Fix last query without data only return time
column (#7146)
add 470d992b48 [IOTDB-4178] Stop StandaloneScheduler keep running while
dispatching failed (#7159)
add 88c3a3e4b2 Fix datanode cannot restart (#7165)
add aba398d559 [IOTDB-4262] Fix missing setSessionId when
showAllTemplates(#7164)
add 03106229f2 [IOTDB-4141] Add semantic checks for aggregate query in old
standalone (#7160)
add 883acb3e47 [IOTDB-4241] Fix set system mode (#7161)
add fc4cda7592 [IOTDB-4253] Modify the jdbc query time column to be empty
(#7156)
add 42865df4ee [IOTDB-4271] Fix heartbeat error after setting a DataNode's
status to Read-Only (#7166)
add 42fcbfcdbb [IOTDB-4254] Update metric grafana dashboard (#7157)
add 3770dd0751 [IOTDB-4128]Add more description about align by device in
documents (#7169)
add 1c1b0596e0 [IOTDB-4094] Perfect the process of remove-confignode
(#7135)
add bbab64fe9a [IOTDB-4267]Add the logic to process other PlanNode besides
InsertNode in MultiLeaderConsensus (#7170)
add bc1a59e6a6 Guarantee Atomicity in Ratis InstallSnapshot RPC (#7131)
add 743c5fd1e9 [IOTDB-4272]Fix count timeseries with template (#7174)
add 7de6b21798 fix between bug in select
add 93444b53bc [IOTDB-4244] Optimize csv tool, add Options '-typeInfer' ,
'-linesPer… (#7145)
add 6462d20f4f [IOTDB-4280]no privilege when using benchmark create
timeseries (#7177)
add ff3b4a64e1 [IOTDB-4190] update documents about nifi-iotdb-bundle
(#7140)
add 2427167706 [IOTDB-2782] When users are not granted READ_TIMESERIES or
INSERT_TIMESERIES, the verification prompt needs to be unified (#7173)
add 013a533bec [IOTDB-2769] Add Auth IT Test when grant user role. (#7168)
add edc81cc361 [IOTDB-4242] Fix inconsistency of auth check between old
standalone and new standalone (#7158)
add 0d47aab530 [IOTDB-4027] Ratis snapshot atomicity: Reorder (#7178)
add 391b2c1e00 [IOTDB-4202] fix delete from sql IT and user-guide (#7081)
add 2d106516ad [IOTDB-4295] add confignode leader for show confignodes
(#7186)
add 4808d89e9e [IOTDB-4258]Replace StorageGroupNode inside cache member if
setToEntity (#7184)
add 3458541da6 add system.exit(0) for the stop method of datanode (#7183)
add fda695a95a Add flushing state timeout detection in
FragmentInstanceManager (#7185)
add bac112870c [Doc] Fix unavailable references (#7188)
add cc11e38bf0 [IOTDB-4247] Antlr and Statement for create trigger (#7175)
add ecf7673ba2 UpdateUserGuide And Update storageGroupCount (#7182)
add 83a4641738 [IOTDB-4298] Fix schema memory allocate for cluster (#7199)
add b612688b3c add release note of 0.14.0-preview2 (#7204)
add e2b790e34f Fix transport open bug (#7181)
add 1d514a7783 [IOTDB-4275]Handle measurement when traversing for paths
using template (#7201)
add 3a9fec2986 [IOTDB-4299] Move ReadOnly State from IoTDBConfig to
CommonConfig
add 6d2a1cff9b [IOTDB-4282] Supply deserialization for DeleteDataPlan in
MultiLeaderConsensus (#7205)
add a3559e5e0e Call start() method before FI really executing (#7206)
add 436d36a6ce [IOTDB-4278] null value processing to the Session API
(#7176)
add eef201614c [IOTDB-4306] Make max number of clients for InternalService
configurable (#7210)
add 41f74a578f [IOTDB-4304]Add TriggerTable and TriggerInformation (#7208)
add 6365fcddce [IOTDB-4137] Reject write when Peer in ReadOnly state in
RatisConsensus (#7216)
add 2db66c686d update release note of preview2 (#7227)
add 79e4a73d1f [IOTDB-4321] Migrate Trigger-API into a seperate module
(#7218)
add 0cf20ae58c [IOTFB-4279] Migrate Trigger related class to node-commons
(#7215)
add 518dcfbfa4 [IOTDB-4301] [IOTDB-4303] fix bug in create regions group
procedure (#7228)
add f53029b133 Add doc for last query order by timeseries (#7232)
add 35dd0cc002 [IOTDB-4305] fix website building (#7233)
add 85fa188ed1 [IOTDB-4325] NaN and Infinity will be regard as positive
Infinity in where clause in 0.14.0 (#7226)
add 8a179d7868 [IOTDB-4243] Antlr and Statement for Drop Trigger (#7220)
add 94500581f6 [IOTDB-3224][IOTDB-3949] Sync pipe execution and data
collection process in standalone version (#7154)
add 0095eb3cee update website about release-0.13.2 (#7235)
add d81192ddca delete origin data before loading snapshot without log
(#7236)
add 0e6c1e0e6c Merge remote-tracking branch 'upstream/master' into
IOTDB-3455
No new revisions were added by this update.
Summary of changes:
RELEASE_NOTES.md | 25 +
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 7 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 16 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 24 +
.../org/apache/iotdb/tool/AbstractCsvTool.java | 72 +-
.../main/java/org/apache/iotdb/tool/ExportCsv.java | 124 ++-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 191 +++-
.../confignode/client/DataNodeRequestType.java | 1 +
.../async/datanode/AsyncDataNodeClientPool.java | 19 +-
...ionHandler.java => SetSystemStatusHandler.java} | 12 +-
.../sync/confignode/SyncConfigNodeClientPool.java | 12 +-
.../sync/datanode/SyncDataNodeClientPool.java | 2 +-
.../confignode/conf/ConfigNodeRemoveCheck.java | 10 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 38 +-
.../request/write/CreateRegionGroupsPlan.java | 10 +
.../statemachine/PartitionRegionStateMachine.java | 4 +-
.../iotdb/confignode/manager/ConfigManager.java | 8 +
.../apache/iotdb/confignode/manager/IManager.java | 3 +
.../iotdb/confignode/manager/NodeManager.java | 19 +
.../load/heartbeat/ConfigNodeHeartbeatCache.java | 2 +-
.../load/heartbeat/DataNodeHeartbeatCache.java | 4 +-
.../load/heartbeat/NodeHeartbeatSample.java | 2 +-
.../iotdb/confignode/persistence/UDFInfo.java | 4 +-
.../persistence/partition/PartitionInfo.java | 6 +-
.../impl/CreateRegionGroupsProcedure.java | 85 +-
.../procedure/state/RemoveConfigNodeState.java | 3 +-
.../procedure/store/ProcedureFactory.java | 10 +
.../iotdb/confignode/service/ConfigNode.java | 51 +-
.../confignode/service/ConfigNodeCommandLine.java | 6 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 19 +
.../impl/CreateRegionGroupsProcedureTest.java | 110 ++
...upException.java => NodeReadOnlyException.java} | 11 +-
.../ratis/ApplicationStateMachineProxy.java | 29 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 34 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 16 +-
.../apache/iotdb/consensus/ratis/SnapshotTest.java | 6 +-
.../tests/tools/importCsv/ExportCsvTestIT.java | 6 +-
.../tests/tools/importCsv/ImportCsvTestIT.java | 2 +-
docs/Development/HowtoContributeCode.md | 2 +-
docs/Download/README.md | 28 +-
docs/UserGuide/API/Status-Codes.md | 2 +-
.../Administration-Management/Administration.md | 4 +-
docs/UserGuide/Data-Concept/Data-Type.md | 2 +-
docs/UserGuide/Data-Concept/Time-Partition.md | 2 +-
docs/UserGuide/Data-Modeling/DataRegion.md | 2 +-
.../DBeaver.md | 0
.../Flink-IoTDB.md} | 0
.../Flink-TsFile.md} | 0
.../Grafana-Connector.md} | 0
.../Grafana-Plugin.md} | 0
.../Hive-TsFile.md} | 0
.../MapReduce-TsFile.md} | 0
docs/UserGuide/Ecosystem-Integration/NiFi-IoTDB.md | 115 ++
.../Spark-IoTDB.md} | 0
.../Spark-TsFile.md} | 0
.../Writing-Data-on-HDFS.md} | 0
.../Zeppelin-IoTDB.md | 0
.../Maintenance-Tools/Maintenance-Command.md | 37 +-
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 22 +-
docs/UserGuide/Process-Data/Triggers.md | 2 +-
docs/UserGuide/Query-Data/Fill-Null-Value.md | 6 +-
docs/UserGuide/Query-Data/Last-Query.md | 18 +-
docs/UserGuide/Query-Data/Result-Format.md | 6 +
docs/UserGuide/QuickStart/Files.md | 8 +-
docs/UserGuide/QuickStart/QuickStart.md | 2 +-
docs/UserGuide/Write-And-Delete-Data/CSV-Tool.md | 41 +-
.../UserGuide/Write-And-Delete-Data/Delete-Data.md | 2 +-
docs/zh/Development/HowtoContributeCode.md | 2 +-
docs/zh/Download/README.md | 28 +-
.../Administration-Management/Administration.md | 4 +-
docs/zh/UserGuide/Data-Concept/Data-Type.md | 2 +-
docs/zh/UserGuide/Data-Concept/Time-Partition.md | 2 +-
docs/zh/UserGuide/Data-Modeling/DataRegion.md | 2 +-
.../DBeaver.md | 0
.../Flink-IoTDB.md} | 0
.../Flink-TsFile.md} | 0
.../Grafana-Connector.md} | 0
.../Grafana-Plugin.md} | 0
.../Hive-TsFile.md} | 0
.../MapReduce-TsFile.md} | 0
.../UserGuide/Ecosystem-Integration/NiFi-IoTDB.md | 115 ++
.../Spark-IoTDB.md} | 0
.../Spark-TsFile.md} | 0
.../Writing-Data-on-HDFS.md} | 0
.../Zeppelin-IoTDB.md | 0
.../Maintenance-Tools/Maintenance-Command.md | 38 +-
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 22 +-
docs/zh/UserGuide/Process-Data/Triggers.md | 2 +-
docs/zh/UserGuide/Query-Data/Fill-Null-Value.md | 6 +-
docs/zh/UserGuide/Query-Data/Last-Query.md | 18 +-
docs/zh/UserGuide/Query-Data/Result-Format.md | 6 +
docs/zh/UserGuide/QuickStart/Files.md | 8 +-
.../zh/UserGuide/Write-And-Delete-Data/CSV-Tool.md | 34 +-
.../UserGuide/Write-And-Delete-Data/Delete-Data.md | 2 +-
.../org/apache/iotdb/trigger/AlertingExample.java | 2 +-
.../org/apache/iotdb/trigger/TriggerExample.java | 2 +-
.../Apache IoTDB ConfigNode Dashboard v0.14.0.json | 215 +---
.../Apache IoTDB DataNode Dashboard v0.14.0.json | 6 +-
.../iotdb/influxdb/session/InfluxDBSession.java | 4 +-
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 28 +-
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 11 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 13 +-
.../java/org/apache/iotdb/db/it/IoTDBAuthIT.java | 830 ++++++++++++++-
.../org/apache/iotdb/db/it/IoTDBConfigNodeIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBDeletionIT.java | 2 +-
.../apache/iotdb/db/it/IoTDBFilterBetweenIT.java | 32 +
...CacheWithDeletionIT.java => IoTDBFilterIT.java} | 79 +-
.../org/apache/iotdb/db/it/IoTDBNestedQueryIT.java | 2 +-
.../db/it/aggregation/IoTDBAggregationIT.java | 26 -
.../db/it/aligned/IoTDBAlignedDataDeletionIT.java | 2 +-
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 12 +-
.../apache/iotdb/db/it/query/IoTDBResultSetIT.java | 53 +
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 62 +-
.../{IoTDBPipeSinkIT.java => IoTDBPipeIT.java} | 82 +-
.../apache/iotdb/db/it/sync/IoTDBPipeSinkIT.java | 4 +-
.../db/engine/trigger/example/Accumulator.java | 2 +-
.../iotdb/db/engine/trigger/example/Counter.java | 2 +-
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 724 ++++---------
.../IoTDBSetSystemReadOnlyWritableIT.java | 2 +-
.../db/integration/sync/IoTDBSyncSenderIT.java | 1 +
.../IoTDBDeletionVersionAdaptionIT.java | 2 +-
.../iotdb/session/IoTDBSessionInsertNullT.java | 298 ++++++
jdbc/README.md | 2 +-
.../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java | 1 +
node-commons/pom.xml | 5 +
.../apache/iotdb/commons/cluster/NodeStatus.java | 11 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 44 +
.../iotdb/commons/conf/CommonDescriptor.java | 7 +
.../commons/enums/HandleSystemErrorStrategy.java | 55 +
.../commons/executable/ExecutableManager.java | 115 ++
.../ExecutableResource.java} | 6 +-
.../iotdb/commons/file/SystemFileFactory.java | 11 +
.../apache/iotdb/commons/service/ServiceType.java | 4 +-
.../apache/iotdb/commons/sync/SyncConstant.java | 4 +-
.../iotdb/commons/trigger/TriggerInformation.java | 157 +++
.../apache/iotdb/commons/trigger/TriggerTable.java | 64 ++
.../iotdb/commons/trigger/enums}/TriggerEvent.java | 6 +-
.../iotdb/commons/trigger/enums/TriggerType.java | 24 +-
.../exception/TriggerExecutionException.java | 12 +-
.../exception/TriggerRegistrationException.java | 9 +-
.../trigger/service/TriggerClassLoader.java | 4 +-
.../service/TriggerClassLoaderManager.java} | 74 +-
.../service/TriggerRegistrationService.java | 89 ++
.../commons/udf/service/UDFClassLoaderManager.java | 12 +-
.../commons/udf/service/UDFExecutableManager.java | 108 +-
.../udf/service/UDFRegistrationService.java | 3 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 2 +-
pom.xml | 1 +
.../schemaregion/rocksdb/RSchemaRegion.java | 7 +
.../resources/conf/iotdb-datanode.properties | 30 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 9 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 74 +-
.../iotdb/db/client/DataNodeClientPoolFactory.java | 12 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 129 +--
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 84 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 4 -
.../db/conf/directories/DirectoryManager.java | 5 +-
.../iotdb/db/conf/directories/FolderManager.java | 6 +-
.../directories/strategy/DirectoryStrategy.java | 4 +-
.../consensus/statemachine/BaseStateMachine.java | 2 +-
.../statemachine/DataRegionStateMachine.java | 32 +-
.../statemachine/SchemaRegionStateMachine.java | 4 +-
.../statemachine/visitor/DataExecutionVisitor.java | 2 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 5 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 9 +-
.../db/engine/compaction/CompactionScheduler.java | 8 +-
.../db/engine/compaction/CompactionUtils.java | 16 -
.../compaction/cross/CrossSpaceCompactionTask.java | 11 +
.../RewriteCrossSpaceCompactionSelector.java | 256 ++++-
.../selector/RewriteCompactionFileSelector.java | 285 -----
.../cross/utils/InplaceCompactionEstimator.java | 3 +-
.../compaction/task/CompactionRecoverTask.java | 3 +-
.../compaction/task/ICompactionSelector.java | 5 +
.../iotdb/db/engine/snapshot/SnapshotLoader.java | 8 +
.../iotdb/db/engine/snapshot/SnapshotLogger.java | 9 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 70 +-
.../db/engine/storagegroup/TsFileManager.java | 14 +-
.../db/engine/storagegroup/TsFileProcessor.java | 34 +-
.../dataregion/StorageGroupManager.java | 10 -
.../iotdb/db/engine/trigger/api/Trigger.java | 1 +
.../db/engine/trigger/builtin/ForwardTrigger.java | 2 +-
.../engine/trigger/executor/TriggerExecutor.java | 4 +-
.../trigger/service/TriggerClassLoaderManager.java | 1 +
.../service/TriggerRegistrationService.java | 3 +-
.../trigger/sink/local/LocalIoTDBHandler.java | 4 +-
.../mpp/FragmentInstanceDispatchException.java | 1 +
.../iotdb/db/localconfignode/LocalConfigNode.java | 80 +-
.../iotdb/db/metadata/logfile/MLogWriter.java | 3 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 34 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 4 +
.../schemaregion/SchemaRegionMemoryImpl.java | 18 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 18 +-
.../db/mpp/common/header/ColumnHeaderConstant.java | 23 +-
.../db/mpp/common/header/DatasetHeaderFactory.java | 4 +
.../execution/exchange/MPPDataExchangeManager.java | 2 +-
.../fragment/FragmentInstanceContext.java | 17 +
.../fragment/FragmentInstanceExecution.java | 8 -
.../fragment/FragmentInstanceManager.java | 66 +-
.../operator/schema/TimeSeriesCountOperator.java | 9 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 17 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 96 +-
.../iotdb/db/mpp/plan/constant/StatementType.java | 2 +-
.../plan/execution/config/ConfigTaskVisitor.java | 34 +-
.../config/executor/ClusterConfigTaskExecutor.java | 137 ++-
.../config/executor/IConfigTaskExecutor.java | 46 +-
.../executor/StandaloneConfigTaskExecutor.java | 178 +++-
...ateFunctionTask.java => CreateTriggerTask.java} | 40 +-
...{DropFunctionTask.java => DropTriggerTask.java} | 13 +-
.../config/metadata/ShowConfigNodesTask.java | 1 +
.../plan/execution/config/sys/ClearCacheTask.java | 4 +-
.../mpp/plan/execution/config/sys/FlushTask.java | 4 +-
.../config/sys/LoadConfigurationTask.java | 4 +-
.../mpp/plan/execution/config/sys/MergeTask.java | 4 +-
...learCacheTask.java => SetSystemStatusTask.java} | 15 +-
.../execution/config/sys/sync/CreatePipeTask.java | 4 +-
.../execution/config/sys/sync/DropPipeTask.java | 4 +-
.../execution/config/sys/sync/ShowPipeTask.java | 41 +-
.../execution/config/sys/sync/StartPipeTask.java | 4 +-
.../execution/config/sys/sync/StopPipeTask.java | 4 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 111 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 15 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 11 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 3 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 4 +
.../node/metedata/read/TimeSeriesCountNode.java | 37 +-
.../planner/plan/node/write/DeleteDataNode.java | 86 +-
.../db/mpp/plan/scheduler/StandaloneScheduler.java | 23 +-
.../db/mpp/plan/statement/StatementVisitor.java | 16 +
.../db/mpp/plan/statement/crud/QueryStatement.java | 12 +-
.../plan/statement/metadata/CountStatement.java | 16 +-
...nStatement.java => CreateTriggerStatement.java} | 74 +-
...ionStatement.java => DropTriggerStatement.java} | 17 +-
.../db/mpp/plan/statement/sys/AuthorStatement.java | 10 +-
.../plan/statement/sys/ClearCacheStatement.java | 15 +-
.../db/mpp/plan/statement/sys/FlushStatement.java | 14 +-
.../statement/sys/LoadConfigurationStatement.java | 10 +-
.../db/mpp/plan/statement/sys/MergeStatement.java | 10 +-
...tatement.java => SetSystemStatusStatement.java} | 32 +-
.../statement/sys/sync/CreatePipeStatement.java | 38 +
.../binary/CompareBinaryColumnTransformer.java | 12 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 11 +-
.../qp/logical/crud/AggregationQueryOperator.java | 38 +-
.../qp/logical/crud/GroupByFillQueryOperator.java | 19 +-
.../db/qp/logical/crud/GroupByQueryOperator.java | 17 +-
.../iotdb/db/qp/logical/sys/AuthorOperator.java | 12 +-
.../db/qp/logical/sys/SetSystemModeOperator.java | 15 +-
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 32 +
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 12 +-
.../db/qp/physical/sys/SetSystemModePlan.java | 21 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 23 +-
.../iotdb/db/query/control/SessionManager.java | 5 +-
.../iotdb/db/rescon/PrimitiveArrayManager.java | 2 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 29 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 19 +-
.../db/service/DataNodeServerCommandLine.java | 2 +-
.../service/basic/StandaloneServiceProvider.java | 4 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 3 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 28 +-
.../db/service/thrift/impl/TSServiceImpl.java | 12 +-
.../java/org/apache/iotdb/db/sync/SyncService.java | 95 ++
.../iotdb/db/sync/common/ISyncInfoFetcher.java | 5 +-
.../iotdb/db/sync/common/LocalSyncInfoFetcher.java | 19 +-
.../org/apache/iotdb/db/sync/common/SyncInfo.java | 35 +-
.../db/sync/common/persistence/SyncLogReader.java | 8 +-
.../db/sync/common/persistence/SyncLogWriter.java | 17 +-
.../db/sync/receiver/load/DeletionLoader.java | 4 +-
.../iotdb/db/sync/receiver/load/TsFileLoader.java | 54 +-
.../sender/manager/ISyncManager.java} | 26 +-
.../db/sync/sender/manager/LocalSyncManager.java | 90 ++
.../db/sync/sender/manager/SchemaSyncManager.java | 149 ---
.../db/sync/sender/manager/TsFileSyncManager.java | 106 --
.../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 12 +
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 144 +--
.../db/sync/transport/client/SenderManager.java | 1 -
.../apache/iotdb/db/utils/sync/SyncPipeUtil.java | 47 +
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 26 +-
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 11 +-
.../apache/iotdb/db/wal/buffer/WALEntryType.java | 9 +-
.../apache/iotdb/db/wal/buffer/WALInfoEntry.java | 1 +
.../iotdb/db/wal/checkpoint/CheckpointManager.java | 5 +-
.../org/apache/iotdb/db/wal/node/IWALNode.java | 4 +
.../org/apache/iotdb/db/wal/node/WALFakeNode.java | 6 +
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 17 +-
.../db/wal/recover/file/TsFilePlanRedoer.java | 21 +
.../file/UnsealedTsFileRecoverPerformer.java | 4 +
.../engine/compaction/CompactionSchedulerTest.java | 194 ++--
.../compaction/CompactionTaskComparatorTest.java | 1 +
.../compaction/CompactionTaskManagerTest.java | 1 +
.../compaction/cross/CrossSpaceCompactionTest.java | 33 +-
.../cross/CrossSpaceCompactionValidationTest.java | 1111 +++++++++++---------
.../engine/compaction/cross/MergeUpgradeTest.java | 19 +-
.../cross/RewriteCompactionFileSelectorTest.java | 296 ++++--
.../cross/RewriteCrossSpaceCompactionTest.java | 4 +
.../db/engine/storagegroup/DataRegionTest.java | 3 +-
.../storagegroup/StorageGroupProcessorTest.java | 3 +-
.../engine/storagegroup/TsFileProcessorTest.java | 6 +-
.../metadata/idtable/trigger_example/Counter.java | 2 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 3 +-
.../operator/schema/CountMergeOperatorTest.java | 7 +-
.../operator/schema/SchemaCountOperatorTest.java | 7 +-
.../db/sync/receiver/manager/SyncInfoTest.java | 8 +-
.../db/sync/receiver/recovery/SyncLogTest.java | 8 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 2 +-
.../org/apache/iotdb/db/wal/io/WALFileTest.java | 14 +
.../iotdb/db/wal/node/ConsensusReqReaderTest.java | 99 +-
.../db/wal/recover/file/TsFilePlanRedoerTest.java | 33 +
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 1 +
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 2 +-
...leTransport.java => NoValidValueException.java} | 13 +-
.../java/org/apache/iotdb/session/Session.java | 685 +++++++++++-
.../apache/iotdb/session/SessionConnection.java | 5 +-
site/src/main/.vuepress/config.js | 50 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 3 +-
thrift-commons/src/main/thrift/common.thrift | 11 +
.../src/main/thrift/confignode.thrift | 64 +-
thrift/src/main/thrift/datanode.thrift | 26 +
{udf-api => trigger-api}/pom.xml | 15 +-
.../java/org/apache/iotdb/trigger/api/Trigger.java | 68 ++
.../iotdb}/trigger/api/TriggerAttributes.java | 2 +-
319 files changed, 7893 insertions(+), 3723 deletions(-)
copy
confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/{LoadConfigurationHandler.java
=> SetSystemStatusHandler.java} (87%)
create mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/CreateRegionGroupsProcedureTest.java
copy
consensus/src/main/java/org/apache/iotdb/consensus/exception/{PeerNotInConsensusGroupException.java
=> NodeReadOnlyException.java} (74%)
rename docs/UserGuide/{Ecosystem Integration =>
Ecosystem-Integration}/DBeaver.md (100%)
rename docs/UserGuide/{Ecosystem Integration/Flink IoTDB.md =>
Ecosystem-Integration/Flink-IoTDB.md} (100%)
rename docs/UserGuide/{Ecosystem Integration/Flink TsFile.md =>
Ecosystem-Integration/Flink-TsFile.md} (100%)
rename docs/UserGuide/{Ecosystem Integration/Grafana Connector.md =>
Ecosystem-Integration/Grafana-Connector.md} (100%)
rename docs/UserGuide/{Ecosystem Integration/Grafana Plugin.md =>
Ecosystem-Integration/Grafana-Plugin.md} (100%)
rename docs/UserGuide/{Ecosystem Integration/Hive TsFile.md =>
Ecosystem-Integration/Hive-TsFile.md} (100%)
rename docs/UserGuide/{Ecosystem Integration/MapReduce TsFile.md =>
Ecosystem-Integration/MapReduce-TsFile.md} (100%)
create mode 100644 docs/UserGuide/Ecosystem-Integration/NiFi-IoTDB.md
rename docs/UserGuide/{Ecosystem Integration/Spark IoTDB.md =>
Ecosystem-Integration/Spark-IoTDB.md} (100%)
rename docs/UserGuide/{Ecosystem Integration/Spark TsFile.md =>
Ecosystem-Integration/Spark-TsFile.md} (100%)
rename docs/UserGuide/{Ecosystem Integration/Writing Data on HDFS.md =>
Ecosystem-Integration/Writing-Data-on-HDFS.md} (100%)
rename docs/UserGuide/{Ecosystem Integration =>
Ecosystem-Integration}/Zeppelin-IoTDB.md (100%)
rename docs/zh/UserGuide/{Ecosystem Integration =>
Ecosystem-Integration}/DBeaver.md (100%)
rename docs/zh/UserGuide/{Ecosystem Integration/Flink IoTDB.md =>
Ecosystem-Integration/Flink-IoTDB.md} (100%)
rename docs/zh/UserGuide/{Ecosystem Integration/Flink TsFile.md =>
Ecosystem-Integration/Flink-TsFile.md} (100%)
rename docs/zh/UserGuide/{Ecosystem Integration/Grafana Connector.md =>
Ecosystem-Integration/Grafana-Connector.md} (100%)
rename docs/zh/UserGuide/{Ecosystem Integration/Grafana Plugin.md =>
Ecosystem-Integration/Grafana-Plugin.md} (100%)
rename docs/zh/UserGuide/{Ecosystem Integration/Hive TsFile.md =>
Ecosystem-Integration/Hive-TsFile.md} (100%)
rename docs/zh/UserGuide/{Ecosystem Integration/MapReduce TsFile.md =>
Ecosystem-Integration/MapReduce-TsFile.md} (100%)
create mode 100644 docs/zh/UserGuide/Ecosystem-Integration/NiFi-IoTDB.md
rename docs/zh/UserGuide/{Ecosystem Integration/Spark IoTDB.md =>
Ecosystem-Integration/Spark-IoTDB.md} (100%)
rename docs/zh/UserGuide/{Ecosystem Integration/Spark TsFile.md =>
Ecosystem-Integration/Spark-TsFile.md} (100%)
rename docs/zh/UserGuide/{Ecosystem Integration/Writing Data on HDFS.md =>
Ecosystem-Integration/Writing-Data-on-HDFS.md} (100%)
rename docs/zh/UserGuide/{Ecosystem Integration =>
Ecosystem-Integration}/Zeppelin-IoTDB.md (100%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{aligned/IoTDBLastQueryWithoutLastCacheWithDeletionIT.java
=> IoTDBFilterIT.java} (57%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/sync/{IoTDBPipeSinkIT.java
=> IoTDBPipeIT.java} (56%)
create mode 100644
integration/src/test/java/org/apache/iotdb/session/IoTDBSessionInsertNullT.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/enums/HandleSystemErrorStrategy.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/executable/ExecutableManager.java
rename
node-commons/src/main/java/org/apache/iotdb/commons/{udf/service/UDFExecutableResource.java
=> executable/ExecutableResource.java} (87%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/trigger/TriggerInformation.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/trigger/TriggerTable.java
copy {server/src/main/java/org/apache/iotdb/db/engine/trigger/executor =>
node-commons/src/main/java/org/apache/iotdb/commons/trigger/enums}/TriggerEvent.java
(90%)
copy
server/src/main/java/org/apache/iotdb/db/engine/trigger/executor/TriggerEvent.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/trigger/enums/TriggerType.java
(72%)
copy {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons/trigger}/exception/TriggerExecutionException.java
(85%)
copy
server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/exception/SinkException.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/trigger/exception/TriggerRegistrationException.java
(77%)
rename {server/src/main/java/org/apache/iotdb/db/engine =>
node-commons/src/main/java/org/apache/iotdb/commons}/trigger/service/TriggerClassLoader.java
(93%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/{udf/service/UDFClassLoaderManager.java
=> trigger/service/TriggerClassLoaderManager.java} (51%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/trigger/service/TriggerRegistrationService.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/selector/RewriteCompactionFileSelector.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/{CreateFunctionTask.java
=> CreateTriggerTask.java} (53%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/{DropFunctionTask.java
=> DropTriggerTask.java} (78%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/sys/{ClearCacheTask.java
=> SetSystemStatusTask.java} (75%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{CreateFunctionStatement.java
=> CreateTriggerStatement.java} (51%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{DropFunctionStatement.java
=> DropTriggerStatement.java} (81%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/{ClearCacheStatement.java
=> SetSystemStatusStatement.java} (71%)
copy
server/src/main/java/org/apache/iotdb/db/{mpp/plan/planner/plan/node/write/BatchInsertNode.java
=> sync/sender/manager/ISyncManager.java} (55%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/sender/manager/LocalSyncManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/sender/manager/SchemaSyncManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/sender/manager/TsFileSyncManager.java
copy
service-rpc/src/main/java/org/apache/iotdb/rpc/{TimeoutChangeableTransport.java
=> NoValidValueException.java} (81%)
copy {udf-api => trigger-api}/pom.xml (84%)
create mode 100644
trigger-api/src/main/java/org/apache/iotdb/trigger/api/Trigger.java
rename {server/src/main/java/org/apache/iotdb/db/engine =>
trigger-api/src/main/java/org/apache/iotdb}/trigger/api/TriggerAttributes.java
(98%)
