This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch rc/1.2.0
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6686f8a780d Pipe: avoid overriding wal entries when loading entries
from different wal nodes (#10134)
add f77272a6af1 fix a a coding pattern that could possibly have security
impact (#10136) (#10138)
add e6a8fc115a4 [To rel/1.2] Avoid useless query in SchemaRegion when
executing show child nodes (#10139)
add 9fc107e763a [To rel/1.2] Support not checking `isAligned` in insertion
(#10142)
add 067c3a7a514 [To rel/1.2] Support not checking `isAligned` in select
into (#10156)
add 9754a36ccc2 [To rel/1.1] Support show timeseries of system db in tail
(#10157)
add 821277b10de [To rel/1.2] Fix show latest alias series (#10167)
add af5c45e3258 [To rel/1.2] Refactor Alter View (#10165)
add 9c8fc4df984 [To rel/1.2][IOTDB-5996] Fix time display of show queries
add 27cc8a5dab8 Only SequenceStrategy and MaxDiskUsableSpaceFirstStrategy
are allowed in cluster mode (#10164) (#10177)
add 75f638cf37a Add size threshold to control wal disk usage (#10160)
(#10178)
add 31a927d8665 change log level from info to debug when degrade tsfile
resource (#10184) (#10189)
add ee28dd63b52 optimize configuration (#10176) (#10181)
add 23137a8dd07 fix concurrent modification (#10182)
add 26aa7009463 [To rel/1.2] Rename Schema_File to PB_Tree (#10187)
add 86c4f1c26ba [To rel/1.2] Remove water mark related configurarions in
iotdb-common.properties
add f2e3e7ae082 Update configuration and remove FREQ encoding (#10169)
(#10185)
add 0266249fbb8 [To rel/1.2] Rename ViewType values to VIEW/BASE (#10191)
add e4bdd13c2fd [To rel/1.2][Metric] Fix missing IoTConsensus metric items
add d62da665248 [IOTDB-6001] Pipe: a non-blocking iotdb connector
(iotdb_thrift_connector_v2) (#10174) (#10199)
add abf8bdfc0dd [IOTDB-6006] Pipe: remove the legacy code of sync (#10192)
(#10200)
add 545dadf8176 [IOTDB-5990][IOTDB-5991] Pipe: support transferring
aligned tablets (#10137) (#10202)
add d84a6eecf11 [To rel/1.2] use Boolean for isAligned (#10198)
add 2c40c9f33a5 [IOTDB-5971] Fix potential QUOTE problem in iotdb reporter
(#10125) (#10205)
add a07ba5c7229 [To rel/1.2][IOTDB-5931] Pipe: async execute
pipeHandleLeaderChange and pipeHandleMetaChange to avoid causing heartbeats to
timeout (#10204)
add 9a07aee90d7 [To rel/1.2][IOTDB-5983] Refactor error info in GROUP
BY/ORDER BY in align by device
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 139 +--
.../resources/conf/iotdb-confignode.properties | 34 +-
.../confignode/client/DataNodeRequestType.java | 2 +
.../client/async/AsyncDataNodeClientPool.java | 29 +-
.../client/async/handlers/AsyncClientHandler.java | 5 +-
...RPCHandler.java => SchemaUpdateRPCHandler.java} | 6 +-
.../request/write/sync/PreCreatePipePlanV1.java | 2 +-
.../request/write/sync/RecordPipeMessagePlan.java | 2 +-
.../request/write/sync/SetPipeStatusPlanV1.java | 2 +-
.../iotdb/confignode/manager/ConfigManager.java | 11 +
.../apache/iotdb/confignode/manager/IManager.java | 3 +
.../iotdb/confignode/manager/ProcedureManager.java | 100 +-
.../pipe/runtime/PipeHeartbeatParser.java} | 248 ++--
...ordinator.java => PipeLeaderChangeHandler.java} | 58 +-
.../manager/pipe/runtime/PipeMetaSyncer.java | 4 +-
.../pipe/runtime/PipeRuntimeCoordinator.java | 91 +-
.../persistence/executor/ConfigPlanExecutor.java | 15 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 2 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 174 +--
...ocedure.java => AlterLogicalViewProcedure.java} | 288 +++--
.../impl/schema/DeleteLogicalViewProcedure.java | 3 +-
.../procedure/impl/sync/CreatePipeProcedure.java | 3 +-
.../procedure/impl/sync/DropPipeProcedure.java | 1 +
.../procedure/impl/sync/StartPipeProcedure.java | 3 +-
.../procedure/impl/sync/StopPipeProcedure.java | 3 +-
.../state/schema/AlterLogicalViewState.java | 14 +-
.../procedure/store/ProcedureFactory.java | 6 +
.../confignode/procedure/store/ProcedureType.java | 5 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
.../request/ConfigPhysicalPlanSerDeTest.java | 8 +-
.../runtime/PipeHandleMetaChangeProcedureTest.java | 7 +-
.../logdispatcher/LogDispatcherThreadMetrics.java | 38 +-
docs/UserGuide/API/InfluxDB-Protocol.md | 344 ------
docs/UserGuide/Data-Concept/Encoding.md | 22 +-
.../Data-Modeling/SchemaRegion-rocksdb.md | 2 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 375 ------
.../Maintenance-Tools/SchemaFileSketch-Tool.md | 10 +-
docs/UserGuide/Maintenance-Tools/Watermark-Tool.md | 196 ----
docs/UserGuide/Reference/Common-Config-Manual.md | 105 +-
docs/UserGuide/Reference/DataNode-Config-Manual.md | 4 +-
docs/UserGuide/Reference/Status-Codes.md | 260 ++---
docs/zh/UserGuide/API/InfluxDB-Protocol.md | 347 ------
docs/zh/UserGuide/Data-Concept/Encoding.md | 22 +-
.../Data-Modeling/SchemaRegion-rocksdb.md | 2 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 362 ------
.../Maintenance-Tools/SchemaFileSketch-Tool.md | 10 +-
.../UserGuide/Maintenance-Tools/Watermark-Tool.md | 196 ----
.../zh/UserGuide/Reference/Common-Config-Manual.md | 87 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 14 +-
docs/zh/UserGuide/Reference/Status-Codes.md | 260 ++---
example/ext-pipe-plugin-example/README.md | 60 -
example/ext-pipe-plugin-example/pom.xml | 65 --
.../iotdb/extpipe/ExtPipeSinkWriterFactory.java | 139 ---
.../iotdb/extpipe/ExtPipeSinkWriterImpl.java | 164 ---
...ipe.external.api.IExternalPipeSinkWriterFactory | 1 -
example/pom.xml | 1 -
integration-test/import-control.xml | 1 -
.../iotdb/it/env/cluster/MppCommonConfig.java | 24 -
.../it/env/cluster/MppSharedCommonConfig.java | 28 -
.../iotdb/it/env/remote/RemoteCommonConfig.java | 20 -
.../org/apache/iotdb/itbase/env/CommonConfig.java | 8 -
.../it/partition/IoTDBPartitionGetterIT.java | 2 +-
.../org/apache/iotdb/db/it/IoTDBEncodingIT.java | 59 -
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 60 +-
.../db/it/groupby/IoTDBGroupByConditionIT.java | 44 +
.../iotdb/db/it/groupby/IoTDBGroupByCountIT.java | 44 +
.../db/it/groupby/IoTDBGroupByVariationIT.java | 23 +-
.../apache/iotdb/db/it/orderBy/IoTDBOrderByIT.java | 74 +-
.../iotdb/db/it/schema/IoTDBExtendTemplateIT.java | 32 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 56 +-
.../db/it/schema/IoTDBSortedShowTimeseriesIT.java | 2 +-
.../org/apache/iotdb/db/it/schema/IoTDBTagIT.java | 2 +-
.../db/it/schema/view/IoTDBAliasSeriesIT.java | 13 +-
.../iotdb/db/it/schema/view/IoTDBAlterViewIT.java | 117 ++
.../it/schema/view/IoTDBCreateAndShowViewIT.java | 72 +-
.../view/IoTDBShowDevicesContainedViewIT.java | 226 ++++
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 38 +-
.../iotdb/db/it/watermark/IoTDBWatermarkIT.java | 229 ----
.../org/apache/iotdb/util/AbstractSchemaIT.java | 14 +-
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 12 +-
iotdb-api/external-pipe-api/pom.xml | 35 -
.../apache/iotdb/pipe/external/api/DataType.java | 51 -
.../external/api/ExternalPipeSinkWriterStatus.java | 77 --
.../pipe/external/api/IExternalPipeSinkWriter.java | 175 ---
.../api/IExternalPipeSinkWriterFactory.java | 63 -
.../apache/iotdb/pipe/api/access/RowIterator.java | 75 --
iotdb-client/client-cpp/src/main/Session.h | 5 +-
.../client-py/iotdb/utils/IoTDBConstants.py | 1 -
iotdb-client/client-py/tests/test_dataframe.py | 2 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 14 -
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 4 -
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 4 +-
.../iotdb/flink/tsfile/util/TSFileConfigUtil.java | 1 -
.../util/TSFileConfigUtilCompletenessTest.java | 2 -
.../src/main/thrift/confignode.thrift | 7 +
.../thrift/src/main/thrift/client.thrift | 12 +-
.../thrift/src/main/thrift/datanode.thrift | 7 +
.../iotdb/metrics/utils/IoTDBMetricsUtils.java | 13 +-
.../resources/conf/iotdb-common.properties | 58 +-
.../iotdb/commons/client/ClientPoolFactory.java | 24 +
.../async/AsyncPipeDataTransferServiceClient.java | 167 +++
.../iotdb/commons/concurrent/ThreadName.java | 18 +-
.../iotdb/commons/conf/CommonDescriptor.java | 4 -
.../exception/sync/PipeAlreadyExistException.java | 31 -
.../commons/exception/sync/PipeException.java | 36 -
.../exception/sync/PipeNotExistException.java | 25 -
.../exception/sync/PipeServerException.java | 34 -
.../sync/PipeSinkAlreadyExistException.java | 25 -
.../exception/sync/PipeSinkBeingUsedException.java | 27 -
.../commons/exception/sync/PipeSinkException.java | 42 -
.../exception/sync/PipeSinkNotExistException.java | 25 -
.../exception/sync/SyncConnectionException.java | 39 -
.../exception/sync/SyncHandshakeException.java | 26 -
.../apache/iotdb/commons/path/MeasurementPath.java | 11 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 10 +
.../apache/iotdb/commons/path/PathPatternUtil.java | 4 +
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 8 +-
...cConnectorV1_1.java => IoTDBSyncConnector.java} | 2 +-
.../builtin/connector/IoTDBThriftConnector.java | 16 +-
.../builtin/connector/IoTDBThriftConnectorV1.java | 5 +-
.../builtin/connector/IoTDBThriftConnectorV2.java} | 9 +-
.../iotdb/commons/schema/filter/SchemaFilter.java | 12 +-
...FilterVisitor.java => SchemaFilterFactory.java} | 45 +-
.../commons/schema/filter/SchemaFilterType.java | 9 +-
.../commons/schema/filter/SchemaFilterVisitor.java | 28 +-
.../impl/{DataTypeFilter.java => AndFilter.java} | 41 +-
.../commons/schema/filter/impl/DataTypeFilter.java | 6 +-
.../schema/filter/impl/PathContainsFilter.java | 8 +-
.../commons/schema/filter/impl/TagFilter.java | 6 +-
.../{DataTypeFilter.java => ViewTypeFilter.java} | 32 +-
.../node/common/AbstractDatabaseDeviceMNode.java | 11 +-
.../schema/node/common/AbstractDeviceMNode.java | 11 +-
.../node/common/AbstractMeasurementMNode.java | 2 +-
.../commons/schema/node/info/IDeviceInfo.java | 4 +-
.../commons/schema/node/role/IDeviceMNode.java | 4 +-
.../PipeStatus.java => schema/view/ViewType.java} | 51 +-
.../iotdb/commons/sync/{pipe => }/PipeInfo.java | 46 +-
.../iotdb/commons/sync/{pipe => }/PipeMessage.java | 5 +-
.../iotdb/commons/sync/{pipe => }/PipeStatus.java | 3 +-
.../commons/sync/{pipe => }/TsFilePipeInfo.java | 36 +-
.../iotdb/commons/sync/metadata/SyncMetadata.java | 241 ----
.../commons/sync/persistence/SyncLogReader.java | 111 --
.../commons/sync/persistence/SyncLogWriter.java | 94 --
.../iotdb/commons/sync/pipesink/IoTDBPipeSink.java | 166 ---
.../iotdb/commons/sync/pipesink/PipeSink.java | 88 --
.../commons/sync/transport/SyncIdentityInfo.java | 57 -
.../iotdb/commons/sync/utils/SyncConstant.java | 87 --
.../iotdb/commons/sync/utils/SyncPathUtil.java | 156 ---
.../commons/sync/metedata/SyncMetadataTest.java | 189 ---
pom.xml | 1 -
server/pom.xml | 5 -
.../resources/conf/iotdb-datanode.properties | 40 +-
...rint-schema-file.bat => print-pb-tree-file.bat} | 2 +-
...{print-schema-file.sh => print-pb-tree-file.sh} | 0
.../org/apache/iotdb/db/audit/AuditLogger.java | 2 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 22 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 188 +--
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 74 +-
.../iotdb/db/conf/directories/TierManager.java | 7 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 2 -
.../iotdb/db/engine/storagegroup/DataRegion.java | 86 +-
.../db/engine/storagegroup/TsFileManager.java | 74 --
.../db/engine/storagegroup/TsFileProcessor.java | 17 -
.../SchemaFileLogCorruptedException.java | 4 +-
.../metadata/schemafile/SchemaFileNotExists.java | 4 +-
.../schemafile/SchemaPageOverflowException.java | 3 +-
.../metadata/view/ViewNotExistException.java | 25 -
.../apache/iotdb/db/metadata/MetadataConstant.java | 8 +-
.../db/metadata/cache/TimeSeriesSchemaCache.java | 8 +-
.../idtable/AppendOnlyDiskSchemaManager.java | 2 +-
.../metadata/metric/SchemaEngineCachedMetric.java | 1 +
.../db/metadata/mnode/mem/info/DeviceInfo.java | 6 +-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 6 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 36 +-
.../mtree/snapshot/MemMTreeSnapshotUtil.java | 4 +-
.../db/metadata/mtree/store/CachedMTreeStore.java | 12 +-
.../mtree/store/disk/cache/CacheMemoryManager.java | 2 +-
.../ReleaseFlushStrategyNumBasedImpl.java | 2 +-
.../mtree/store/disk/schemafile/ISchemaFile.java | 4 +-
.../store/disk/schemafile/MockSchemaFile.java | 4 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 34 +-
.../store/disk/schemafile/SchemaFileConfig.java | 14 +-
.../disk/schemafile/pagemgr/BTreePageManager.java | 2 +-
.../store/disk/schemafile/pagemgr/PageManager.java | 2 +-
.../traverser/collector/MeasurementCollector.java | 2 +-
.../plan/schemaregion/SchemaRegionPlanType.java | 1 +
.../plan/schemaregion/SchemaRegionPlanVisitor.java | 5 +
.../impl/SchemaRegionPlanDeserializer.java | 9 +
.../impl/SchemaRegionPlanSerializer.java | 13 +
.../impl/SchemaRegionPlanTxtSerializer.java | 11 +
.../impl/read/SchemaRegionReadPlanFactory.java | 9 +-
.../impl/write/AlterLogicalViewPlanImpl.java | 56 +
.../impl/write/SchemaRegionWritePlanFactory.java | 8 +
.../schemaregion/result/ShowDevicesResult.java | 6 +-
.../write/view/IAlterLogicalViewPlan.java | 46 +
.../db/metadata/query/info/IDeviceSchemaInfo.java | 2 +-
.../rescon/CachedSchemaEngineStatistics.java | 2 +-
.../rescon/CachedSchemaRegionStatistics.java | 2 +-
.../db/metadata/rescon/SchemaResourceManager.java | 4 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 3 +
.../db/metadata/schemaregion/SchemaEngine.java | 2 +-
.../db/metadata/schemaregion/SchemaEngineMode.java | 2 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 23 +
...maFileImpl.java => SchemaRegionPBTreeImpl.java} | 53 +-
.../db/metadata/visitor/DeviceFilterVisitor.java | 6 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 20 +
.../metadata/visitor/TimeseriesFilterVisitor.java | 15 +-
.../mpp/common/schematree/ClusterSchemaTree.java | 10 +-
.../schema/source/LogicalViewSchemaSource.java | 77 +-
.../schema/source/TimeSeriesSchemaSource.java | 7 +-
.../operator/source/ShowQueriesOperator.java | 6 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 35 +-
.../iotdb/db/mpp/plan/analyze/SelectIntoUtils.java | 9 +-
.../mpp/plan/analyze/schema/ISchemaValidation.java | 6 +
.../plan/analyze/schema/NormalSchemaFetcher.java | 66 +-
.../plan/execution/config/ConfigTaskVisitor.java | 30 +-
.../config/executor/ClusterConfigTaskExecutor.java | 161 +--
.../config/executor/IConfigTaskExecutor.java | 13 +-
.../execution/config/sys/pipe/ShowPipeTask.java | 10 +-
.../config/sys/sync/CreatePipeSinkTask.java | 42 -
.../config/sys/sync/DropPipeSinkTask.java | 42 -
.../config/sys/sync/ShowPipeSinkTask.java | 96 --
.../memory/StatementMemorySourceVisitor.java | 22 -
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 139 +--
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 6 +-
.../plan/planner/distribution/SourceRewriter.java | 122 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 6 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 5 +
.../metedata/write/view/AlterLogicalViewNode.java | 186 +++
.../db/mpp/plan/statement/StatementVisitor.java | 26 +-
.../plan/statement/crud/InsertRowStatement.java | 11 +-
.../plan/statement/crud/InsertTabletStatement.java | 11 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 24 +-
.../metadata/view/AlterLogicalViewStatement.java | 11 -
.../metadata/view/CreateLogicalViewStatement.java | 4 +
...wPipeStatement.java => ShowPipesStatement.java} | 6 +-
.../sys/sync/CreatePipeSinkStatement.java | 120 --
.../statement/sys/sync/DropPipeSinkStatement.java | 62 -
.../statement/sys/sync/ShowPipeSinkStatement.java | 48 -
.../sys/sync/ShowPipeSinkTypeStatement.java | 31 -
.../pipe/agent/receiver/IoTDBThriftReceiver.java | 6 +-
.../db/pipe/agent/receiver/PipeReceiverAgent.java | 10 +-
.../config/constant/PipeConnectorConstant.java | 5 +
...ava => IoTDBThriftConnectorRequestVersion.java} | 7 +-
.../IoTDBSyncConnector.java} | 57 +-
.../connector/legacy/IoTDBSyncReceiver.java} | 491 ++++----
.../connector/legacy/loader}/DeletionLoader.java | 19 +-
.../connector/legacy/loader}/ILoader.java | 5 +-
.../connector/legacy/loader}/TsFileLoader.java | 16 +-
.../legacy}/pipedata/DeletionPipeData.java | 20 +-
.../connector/legacy}/pipedata/PipeData.java | 13 +-
.../connector/legacy}/pipedata/TsFilePipeData.java | 89 +-
.../{ => v1}/IoTDBThriftConnectorClient.java | 2 +-
.../pipe/connector/v1/IoTDBThriftConnectorV1.java | 8 +-
.../pipe/connector/v1/IoTDBThriftReceiverV1.java | 8 +-
.../v1/request/PipeTransferFilePieceReq.java | 4 +-
.../v1/request/PipeTransferFileSealReq.java | 4 +-
.../v1/request/PipeTransferHandshakeReq.java | 4 +-
.../v1/request/PipeTransferInsertNodeReq.java | 4 +-
.../v1/request/PipeTransferTabletReq.java | 52 +-
.../pipe/connector/v2/IoTDBThriftConnectorV2.java | 314 +++++
...nsferInsertNodeTabletInsertionEventHandler.java | 51 +
...ipeTransferRawTabletInsertionEventHandler.java} | 29 +-
.../PipeTransferTabletInsertionEventHandler.java | 131 +++
.../PipeTransferTsFileInsertionEventHandler.java | 222 ++++
.../apache/iotdb/db/pipe/event/EnrichedEvent.java | 8 +-
.../iotdb/db/pipe/event/common/row/PipeRow.java | 7 +
.../db/pipe/event/common/row/PipeRowCollector.java | 4 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 23 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 20 +-
.../tablet/TabletInsertionDataContainer.java | 17 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 4 +-
.../tsfile/TsFileInsertionDataContainer.java | 21 +-
.../event/realtime/PipeRealtimeCollectEvent.java | 8 +-
.../realtime/PipeRealtimeCollectEventFactory.java | 3 +-
.../pipe/resource/wal/PipeWALResourceManager.java | 2 +-
.../task/subtask/PipeConnectorSubtaskManager.java | 21 +-
.../protocol/influxdb/util/QueryResultUtils.java | 2 +-
.../iotdb/db/rescon/TsFileResourceManager.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 5 -
.../iotdb/db/service/InfluxDBRPCService.java | 109 --
.../service/thrift/impl/ClientRPCServiceImpl.java | 21 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 35 +
.../java/org/apache/iotdb/db/sync/SyncService.java | 561 ---------
.../db/sync/common/ClusterSyncInfoFetcher.java | 133 ---
.../iotdb/db/sync/common/ISyncInfoFetcher.java | 58 -
.../apache/iotdb/db/sync/common/LocalSyncInfo.java | 142 ---
.../iotdb/db/sync/common/LocalSyncInfoFetcher.java | 168 ---
.../iotdb/db/sync/datasource/AbstractOpBlock.java | 119 --
.../iotdb/db/sync/datasource/DeletionGroup.java | 242 ----
.../iotdb/db/sync/datasource/DeletionOpBlock.java | 106 --
.../iotdb/db/sync/datasource/PipeOpManager.java | 345 ------
.../iotdb/db/sync/datasource/PipeOpSgManager.java | 197 ----
.../db/sync/datasource/PipeStorageGroupInfo.java | 50 -
.../iotdb/db/sync/datasource/TsFileOpBlock.java | 1208 --------------------
.../iotdb/db/sync/externalpipe/ExtPipePlugin.java | 676 -----------
.../externalpipe/ExtPipePluginConfiguration.java | 140 ---
.../db/sync/externalpipe/ExtPipePluginManager.java | 338 ------
.../sync/externalpipe/ExtPipePluginRegister.java | 139 ---
.../db/sync/externalpipe/ExternalPipeStatus.java | 58 -
.../externalpipe/operation/DeleteOperation.java | 78 --
.../externalpipe/operation/InsertOperation.java | 61 -
.../db/sync/externalpipe/operation/Operation.java | 80 --
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 426 -------
.../db/sync/pipedata/queue/PipeDataQueue.java | 41 -
.../iotdb/db/sync/sender/manager/ISyncManager.java | 44 -
.../db/sync/sender/manager/LocalSyncManager.java | 91 --
.../db/sync/sender/pipe/ExternalPipeSink.java | 130 ---
.../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 141 ---
.../iotdb/db/sync/sender/pipe/PipeSinkFactory.java | 41 -
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 464 --------
.../db/sync/sender/recovery/TsFilePipeLogger.java | 155 ---
.../db/sync/transport/client/ISyncClient.java | 44 -
.../db/sync/transport/client/IoTDBSyncClient.java | 278 -----
.../db/sync/transport/client/SenderManager.java | 283 -----
.../sync/transport/client/SyncClientFactory.java | 59 -
...leSketchTool.java => PBTreeFileSketchTool.java} | 10 +-
.../watermark/GroupedLSBWatermarkEncoder.java | 150 ---
.../db/tools/watermark/WatermarkDetector.java | 220 ----
.../iotdb/db/tools/watermark/WatermarkEncoder.java | 36 -
.../org/apache/iotdb/db/utils/SchemaUtils.java | 2 -
.../iotdb/db/utils/TimestampPrecisionUtils.java | 57 +
.../apache/iotdb/db/utils/sync/SyncPipeUtil.java | 84 --
.../java/org/apache/iotdb/db/wal/WALManager.java | 15 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 71 +-
.../mtree/schemafile/AliasIndexPageTest.java | 2 +-
.../mtree/schemafile/InternalPageTest.java | 2 +-
.../mtree/schemafile/SchemaFileLogTest.java | 15 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 2 +-
.../mtree/schemafile/WrappedSegmentTest.java | 2 +-
.../schemaRegion/AbstractSchemaRegionTest.java | 12 +-
.../schemaRegion/SchemaRegionBasicTest.java | 29 +-
.../schemaRegion/SchemaStatisticsTest.java | 2 +-
.../pipe/event/PipeTabletInsertionEventTest.java | 76 +-
.../event/TsFileInsertionDataContainerTest.java | 16 +-
.../org/apache/iotdb/db/sync/SyncTestUtils.java | 41 -
.../db/sync/datasource/DeletionGroupTest.java | 231 ----
.../db/sync/datasource/DeletionOpBlockTest.java | 62 -
.../db/sync/datasource/PipeOpManagerTest.java | 595 ----------
.../db/sync/datasource/TsFileOpBlockTest.java | 1123 ------------------
.../db/sync/persistence/LocalSyncInfoTest.java | 104 --
.../iotdb/db/sync/persistence/SyncLogTest.java | 121 --
.../iotdb/db/sync/pipedata/PipeDataTest.java | 65 --
...leSketchTest.java => PBTreeFileSketchTest.java} | 10 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 4 -
.../src/test/resources/iotdb-datanode.properties | 4 +-
site/src/main/.vuepress/sidebar/en.ts | 10 -
site/src/main/.vuepress/sidebar/zh.ts | 10 -
tsfile/pom.xml | 4 -
.../iotdb/tsfile/common/conf/TSFileConfig.java | 20 -
.../iotdb/tsfile/common/conf/TSFileDescriptor.java | 3 -
.../iotdb/tsfile/encoding/decoder/Decoder.java | 2 -
.../iotdb/tsfile/encoding/decoder/FreqDecoder.java | 144 ---
.../iotdb/tsfile/encoding/encoder/FreqEncoder.java | 317 -----
.../tsfile/encoding/encoder/TSEncodingBuilder.java | 64 --
.../tsfile/file/metadata/TimeseriesMetadata.java | 2 -
.../tsfile/file/metadata/enums/TSEncoding.java | 3 +-
.../apache/iotdb/tsfile/utils/BitConstructor.java | 94 --
.../org/apache/iotdb/tsfile/utils/BitReader.java | 70 --
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 19 +-
.../tsfile/encoding/decoder/FreqDecoderTest.java | 161 ---
361 files changed, 4402 insertions(+), 19419 deletions(-)
rename
confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/{DeleteSchemaRPCHandler.java
=> SchemaUpdateRPCHandler.java} (93%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/{procedure/impl/pipe/runtime/PipeHandleMetaChangeProcedure.java
=> manager/pipe/runtime/PipeHeartbeatParser.java} (51%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/runtime/{PipeRuntimeCoordinator.java
=> PipeLeaderChangeHandler.java} (63%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/{DeleteLogicalViewProcedure.java
=> AlterLogicalViewProcedure.java} (51%)
rename
node-commons/src/main/java/org/apache/iotdb/commons/sync/pipe/SyncOperation.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/AlterLogicalViewState.java
(82%)
delete mode 100644 docs/UserGuide/API/InfluxDB-Protocol.md
delete mode 100644 docs/UserGuide/Edge-Cloud-Collaboration/Sync-Tool.md
delete mode 100644 docs/UserGuide/Maintenance-Tools/Watermark-Tool.md
delete mode 100644 docs/zh/UserGuide/API/InfluxDB-Protocol.md
delete mode 100644 docs/zh/UserGuide/Edge-Cloud-Collaboration/Sync-Tool.md
delete mode 100644 docs/zh/UserGuide/Maintenance-Tools/Watermark-Tool.md
delete mode 100644 example/ext-pipe-plugin-example/README.md
delete mode 100644 example/ext-pipe-plugin-example/pom.xml
delete mode 100644
example/ext-pipe-plugin-example/src/main/java/org/apache/iotdb/extpipe/ExtPipeSinkWriterFactory.java
delete mode 100644
example/ext-pipe-plugin-example/src/main/java/org/apache/iotdb/extpipe/ExtPipeSinkWriterImpl.java
delete mode 100644
example/ext-pipe-plugin-example/src/main/resources/META-INF/services/org.apache.iotdb.pipe.external.api.IExternalPipeSinkWriterFactory
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/view/IoTDBAlterViewIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/view/IoTDBShowDevicesContainedViewIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/watermark/IoTDBWatermarkIT.java
delete mode 100644 iotdb-api/external-pipe-api/pom.xml
delete mode 100644
iotdb-api/external-pipe-api/src/main/java/org/apache/iotdb/pipe/external/api/DataType.java
delete mode 100644
iotdb-api/external-pipe-api/src/main/java/org/apache/iotdb/pipe/external/api/ExternalPipeSinkWriterStatus.java
delete mode 100644
iotdb-api/external-pipe-api/src/main/java/org/apache/iotdb/pipe/external/api/IExternalPipeSinkWriter.java
delete mode 100644
iotdb-api/external-pipe-api/src/main/java/org/apache/iotdb/pipe/external/api/IExternalPipeSinkWriterFactory.java
delete mode 100644
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/access/RowIterator.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/async/AsyncPipeDataTransferServiceClient.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/PipeAlreadyExistException.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/PipeException.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/PipeNotExistException.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/PipeServerException.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/PipeSinkAlreadyExistException.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/PipeSinkBeingUsedException.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/PipeSinkException.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/PipeSinkNotExistException.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/SyncConnectionException.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/SyncHandshakeException.java
rename
node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{IoTDBSyncConnectorV1_1.java
=> IoTDBSyncConnector.java} (97%)
rename
server/src/main/java/org/apache/iotdb/db/service/InfluxDBRPCServiceMBean.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/IoTDBThriftConnectorV1.java
(86%)
rename
node-commons/src/main/java/org/apache/iotdb/commons/{exception/sync/PipeDataLoadException.java
=> pipe/plugin/builtin/connector/IoTDBThriftConnectorV2.java} (81%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/{SchemaFilterVisitor.java
=> SchemaFilterFactory.java} (52%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/{DataTypeFilter.java
=> AndFilter.java} (58%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/{DataTypeFilter.java
=> ViewTypeFilter.java} (63%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/{sync/pipe/PipeStatus.java
=> schema/view/ViewType.java} (58%)
rename node-commons/src/main/java/org/apache/iotdb/commons/sync/{pipe =>
}/PipeInfo.java (79%)
rename node-commons/src/main/java/org/apache/iotdb/commons/sync/{pipe =>
}/PipeMessage.java (97%)
rename node-commons/src/main/java/org/apache/iotdb/commons/sync/{pipe =>
}/PipeStatus.java (97%)
rename node-commons/src/main/java/org/apache/iotdb/commons/sync/{pipe =>
}/TsFilePipeInfo.java (79%)
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/sync/metadata/SyncMetadata.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/sync/persistence/SyncLogReader.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/sync/persistence/SyncLogWriter.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/sync/pipesink/IoTDBPipeSink.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/sync/pipesink/PipeSink.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/sync/transport/SyncIdentityInfo.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/sync/utils/SyncConstant.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/sync/utils/SyncPathUtil.java
delete mode 100644
node-commons/src/test/java/org/apache/iotdb/commons/sync/metedata/SyncMetadataTest.java
rename server/src/assembly/resources/tools/schema/{print-schema-file.bat =>
print-pb-tree-file.bat} (97%)
rename server/src/assembly/resources/tools/schema/{print-schema-file.sh =>
print-pb-tree-file.sh} (100%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/write/AlterLogicalViewPlanImpl.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/view/IAlterLogicalViewPlan.java
rename
server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/{SchemaRegionSchemaFileImpl.java
=> SchemaRegionPBTreeImpl.java} (97%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/sys/sync/CreatePipeSinkTask.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/sys/sync/DropPipeSinkTask.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/sys/sync/ShowPipeSinkTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/view/AlterLogicalViewNode.java
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/pipe/{ShowPipeStatement.java
=> ShowPipesStatement.java} (91%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/sync/CreatePipeSinkStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/sync/DropPipeSinkStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/sync/ShowPipeSinkStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/sync/ShowPipeSinkTypeStatement.java
rename
server/src/main/java/org/apache/iotdb/db/pipe/connector/{IoTDBThriftConnectorVersion.java
=> IoTDBThriftConnectorRequestVersion.java} (87%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/connector/{lagacy/IoTDBSyncConnectorImplV1_1.java
=> legacy/IoTDBSyncConnector.java} (84%)
rename
server/src/main/java/org/apache/iotdb/db/{sync/transport/server/ReceiverManager.java
=> pipe/connector/legacy/IoTDBSyncReceiver.java} (65%)
rename server/src/main/java/org/apache/iotdb/db/{sync/pipedata/load =>
pipe/connector/legacy/loader}/DeletionLoader.java (85%)
rename server/src/main/java/org/apache/iotdb/db/{sync/pipedata/load =>
pipe/connector/legacy/loader}/ILoader.java (89%)
rename server/src/main/java/org/apache/iotdb/db/{sync/pipedata/load =>
pipe/connector/legacy/loader}/TsFileLoader.java (87%)
rename server/src/main/java/org/apache/iotdb/db/{sync =>
pipe/connector/legacy}/pipedata/DeletionPipeData.java (81%)
rename server/src/main/java/org/apache/iotdb/db/{sync =>
pipe/connector/legacy}/pipedata/PipeData.java (91%)
rename server/src/main/java/org/apache/iotdb/db/{sync =>
pipe/connector/legacy}/pipedata/TsFilePipeData.java (55%)
rename server/src/main/java/org/apache/iotdb/db/pipe/connector/{ =>
v1}/IoTDBThriftConnectorClient.java (97%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/connector/v2/IoTDBThriftConnectorV2.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/connector/v2/handler/PipeTransferInsertNodeTabletInsertionEventHandler.java
copy
server/src/main/java/org/apache/iotdb/db/pipe/{agent/receiver/IoTDBThriftReceiver.java
=> connector/v2/handler/PipeTransferRawTabletInsertionEventHandler.java} (51%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/connector/v2/handler/PipeTransferTabletInsertionEventHandler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/connector/v2/handler/PipeTransferTsFileInsertionEventHandler.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/service/InfluxDBRPCService.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/SyncService.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/common/ClusterSyncInfoFetcher.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/common/ISyncInfoFetcher.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/common/LocalSyncInfo.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/common/LocalSyncInfoFetcher.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/datasource/AbstractOpBlock.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/datasource/DeletionGroup.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/datasource/DeletionOpBlock.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/datasource/PipeOpManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/datasource/PipeOpSgManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/datasource/PipeStorageGroupInfo.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/datasource/TsFileOpBlock.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/externalpipe/ExtPipePlugin.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/externalpipe/ExtPipePluginConfiguration.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/externalpipe/ExtPipePluginManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/externalpipe/ExtPipePluginRegister.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/externalpipe/ExternalPipeStatus.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/externalpipe/operation/DeleteOperation.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/externalpipe/operation/InsertOperation.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/externalpipe/operation/Operation.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/pipedata/queue/BufferedPipeDataQueue.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/pipedata/queue/PipeDataQueue.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/sender/manager/ISyncManager.java
delete 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/pipe/ExternalPipeSink.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/sender/pipe/Pipe.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/sender/pipe/PipeSinkFactory.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/sender/pipe/TsFilePipe.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/sender/recovery/TsFilePipeLogger.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/transport/client/ISyncClient.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/transport/client/IoTDBSyncClient.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/transport/client/SenderManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/transport/client/SyncClientFactory.java
rename
server/src/main/java/org/apache/iotdb/db/tools/schema/{SchemaFileSketchTool.java
=> PBTreeFileSketchTool.java} (93%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/tools/watermark/GroupedLSBWatermarkEncoder.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/tools/watermark/WatermarkDetector.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/tools/watermark/WatermarkEncoder.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/TimestampPrecisionUtils.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/utils/sync/SyncPipeUtil.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/sync/SyncTestUtils.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/sync/datasource/DeletionGroupTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/sync/datasource/DeletionOpBlockTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/sync/datasource/PipeOpManagerTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/sync/datasource/TsFileOpBlockTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/sync/persistence/LocalSyncInfoTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/sync/persistence/SyncLogTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/sync/pipedata/PipeDataTest.java
rename
server/src/test/java/org/apache/iotdb/db/tools/{SchemaFileSketchTest.java =>
PBTreeFileSketchTest.java} (94%)
delete mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/FreqDecoder.java
delete mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/FreqEncoder.java
delete mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/utils/BitConstructor.java
delete mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/utils/BitReader.java
delete mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/FreqDecoderTest.java
