This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch remove-sync-entry in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ab8827e2648866aed0d83f24701749b5944857ca Author: Steve Yurong Su <[email protected]> AuthorDate: Sat Jun 17 03:37:56 2023 +0800 rename package --- .../main/java/org/apache/iotdb/db/audit/AuditLogger.java | 2 +- .../{lagacy => legacy}/IoTDBSyncConnectorV1_1.java | 4 ++-- .../{lagacy => legacy}/IoTDBSyncReceiverV1_1.java | 14 +++++++------- .../exception/SyncDataLoadException.java | 2 +- .../{lagacy => legacy}/pipedata/DeletionPipeData.java | 6 +++--- .../connector/{lagacy => legacy}/pipedata/PipeData.java | 4 ++-- .../{lagacy => legacy}/pipedata/TsFilePipeData.java | 8 ++++---- .../{lagacy => legacy}/pipedata/load/DeletionLoader.java | 4 ++-- .../{lagacy => legacy}/pipedata/load/ILoader.java | 4 ++-- .../{lagacy => legacy}/pipedata/load/TsFileLoader.java | 4 ++-- .../pipedata/queue/BufferedPipeDataQueue.java | 10 +++++----- .../{lagacy => legacy}/pipedata/queue/PipeDataQueue.java | 4 ++-- .../{lagacy => legacy}/transport/SyncIdentityInfo.java | 2 +- .../connector/{lagacy => legacy}/utils/SyncConstant.java | 2 +- .../connector/{lagacy => legacy}/utils/SyncPathUtil.java | 4 ++-- .../db/pipe/task/subtask/PipeConnectorSubtaskManager.java | 2 +- .../iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java | 2 +- 17 files changed, 39 insertions(+), 39 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/audit/AuditLogger.java b/server/src/main/java/org/apache/iotdb/db/audit/AuditLogger.java index a6d3a83a3ae..ab7df92e591 100644 --- a/server/src/main/java/org/apache/iotdb/db/audit/AuditLogger.java +++ b/server/src/main/java/org/apache/iotdb/db/audit/AuditLogger.java @@ -43,7 +43,7 @@ import org.slf4j.LoggerFactory; import java.util.List; -import static org.apache.iotdb.db.pipe.connector.lagacy.pipedata.load.ILoader.SCHEMA_FETCHER; +import static org.apache.iotdb.db.pipe.connector.legacy.pipedata.load.ILoader.SCHEMA_FETCHER; public class AuditLogger { private static final Logger logger = LoggerFactory.getLogger(AuditLogger.class); diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/IoTDBSyncConnectorV1_1.java b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/IoTDBSyncConnectorV1_1.java similarity index 98% rename from server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/IoTDBSyncConnectorV1_1.java rename to server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/IoTDBSyncConnectorV1_1.java index 2ee8b3e1730..5f6b6f84906 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/IoTDBSyncConnectorV1_1.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/IoTDBSyncConnectorV1_1.java @@ -17,7 +17,7 @@ * under the License. */ -package org.apache.iotdb.db.pipe.connector.lagacy; +package org.apache.iotdb.db.pipe.connector.legacy; import org.apache.iotdb.common.rpc.thrift.TSStatus; import org.apache.iotdb.commons.client.property.ThriftClientProperty; @@ -26,7 +26,7 @@ import org.apache.iotdb.commons.conf.CommonDescriptor; import org.apache.iotdb.commons.conf.IoTDBConstant; import org.apache.iotdb.commons.exception.pipe.PipeRuntimeCriticalException; import org.apache.iotdb.commons.pipe.config.PipeConfig; -import org.apache.iotdb.db.pipe.connector.lagacy.pipedata.TsFilePipeData; +import org.apache.iotdb.db.pipe.connector.legacy.pipedata.TsFilePipeData; import org.apache.iotdb.db.pipe.connector.v1.IoTDBThriftConnectorClient; import org.apache.iotdb.db.pipe.event.common.tablet.PipeInsertNodeTabletInsertionEvent; import org.apache.iotdb.db.pipe.event.common.tablet.PipeRawTabletInsertionEvent; diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/IoTDBSyncReceiverV1_1.java b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/IoTDBSyncReceiverV1_1.java similarity index 97% rename from server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/IoTDBSyncReceiverV1_1.java rename to server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/IoTDBSyncReceiverV1_1.java index 97990579caf..2a1c34bbd9c 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/IoTDBSyncReceiverV1_1.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/IoTDBSyncReceiverV1_1.java @@ -17,7 +17,7 @@ * under the License. * */ -package org.apache.iotdb.db.pipe.connector.lagacy; +package org.apache.iotdb.db.pipe.connector.legacy; import org.apache.iotdb.common.rpc.thrift.TSStatus; import org.apache.iotdb.commons.exception.IllegalPathException; @@ -29,12 +29,12 @@ import org.apache.iotdb.db.mpp.plan.analyze.IPartitionFetcher; import org.apache.iotdb.db.mpp.plan.analyze.schema.ISchemaFetcher; import org.apache.iotdb.db.mpp.plan.execution.ExecutionResult; import org.apache.iotdb.db.mpp.plan.statement.metadata.DatabaseSchemaStatement; -import org.apache.iotdb.db.pipe.connector.lagacy.exception.SyncDataLoadException; -import org.apache.iotdb.db.pipe.connector.lagacy.pipedata.PipeData; -import org.apache.iotdb.db.pipe.connector.lagacy.pipedata.TsFilePipeData; -import org.apache.iotdb.db.pipe.connector.lagacy.transport.SyncIdentityInfo; -import org.apache.iotdb.db.pipe.connector.lagacy.utils.SyncConstant; -import org.apache.iotdb.db.pipe.connector.lagacy.utils.SyncPathUtil; +import org.apache.iotdb.db.pipe.connector.legacy.exception.SyncDataLoadException; +import org.apache.iotdb.db.pipe.connector.legacy.pipedata.PipeData; +import org.apache.iotdb.db.pipe.connector.legacy.pipedata.TsFilePipeData; +import org.apache.iotdb.db.pipe.connector.legacy.transport.SyncIdentityInfo; +import org.apache.iotdb.db.pipe.connector.legacy.utils.SyncConstant; +import org.apache.iotdb.db.pipe.connector.legacy.utils.SyncPathUtil; import org.apache.iotdb.db.query.control.SessionManager; import org.apache.iotdb.rpc.RpcUtils; import org.apache.iotdb.rpc.TSStatusCode; diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/exception/SyncDataLoadException.java b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/exception/SyncDataLoadException.java similarity index 94% rename from server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/exception/SyncDataLoadException.java rename to server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/exception/SyncDataLoadException.java index 399c1373d92..0fffb488a4f 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/exception/SyncDataLoadException.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/exception/SyncDataLoadException.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * under the License. */ -package org.apache.iotdb.db.pipe.connector.lagacy.exception; +package org.apache.iotdb.db.pipe.connector.legacy.exception; import org.apache.iotdb.pipe.api.exception.PipeException; diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/DeletionPipeData.java b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/DeletionPipeData.java similarity index 94% rename from server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/DeletionPipeData.java rename to server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/DeletionPipeData.java index bf3f513f67c..b7162c5e00f 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/DeletionPipeData.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/DeletionPipeData.java @@ -17,12 +17,12 @@ * under the License. * */ -package org.apache.iotdb.db.pipe.connector.lagacy.pipedata; +package org.apache.iotdb.db.pipe.connector.legacy.pipedata; import org.apache.iotdb.commons.exception.IllegalPathException; import org.apache.iotdb.db.engine.modification.Deletion; -import org.apache.iotdb.db.pipe.connector.lagacy.pipedata.load.DeletionLoader; -import org.apache.iotdb.db.pipe.connector.lagacy.pipedata.load.ILoader; +import org.apache.iotdb.db.pipe.connector.legacy.pipedata.load.DeletionLoader; +import org.apache.iotdb.db.pipe.connector.legacy.pipedata.load.ILoader; import org.apache.iotdb.tsfile.utils.ReadWriteIOUtils; import org.slf4j.Logger; diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/PipeData.java b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/PipeData.java similarity index 96% rename from server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/PipeData.java rename to server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/PipeData.java index 5b0d924c5b7..dae6141019d 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/PipeData.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/PipeData.java @@ -17,10 +17,10 @@ * under the License. * */ -package org.apache.iotdb.db.pipe.connector.lagacy.pipedata; +package org.apache.iotdb.db.pipe.connector.legacy.pipedata; import org.apache.iotdb.commons.exception.IllegalPathException; -import org.apache.iotdb.db.pipe.connector.lagacy.pipedata.load.ILoader; +import org.apache.iotdb.db.pipe.connector.legacy.pipedata.load.ILoader; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/TsFilePipeData.java b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/TsFilePipeData.java similarity index 96% rename from server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/TsFilePipeData.java rename to server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/TsFilePipeData.java index 979d9fbfd56..60882c74dd7 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/TsFilePipeData.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/TsFilePipeData.java @@ -17,14 +17,14 @@ * under the License. * */ -package org.apache.iotdb.db.pipe.connector.lagacy.pipedata; +package org.apache.iotdb.db.pipe.connector.legacy.pipedata; import org.apache.iotdb.commons.exception.IllegalPathException; import org.apache.iotdb.db.engine.modification.ModificationFile; import org.apache.iotdb.db.engine.storagegroup.TsFileResource; -import org.apache.iotdb.db.pipe.connector.lagacy.pipedata.load.ILoader; -import org.apache.iotdb.db.pipe.connector.lagacy.pipedata.load.TsFileLoader; -import org.apache.iotdb.db.pipe.connector.lagacy.utils.SyncConstant; +import org.apache.iotdb.db.pipe.connector.legacy.pipedata.load.ILoader; +import org.apache.iotdb.db.pipe.connector.legacy.pipedata.load.TsFileLoader; +import org.apache.iotdb.db.pipe.connector.legacy.utils.SyncConstant; import org.apache.iotdb.tsfile.utils.ReadWriteIOUtils; import org.slf4j.Logger; diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/load/DeletionLoader.java b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/load/DeletionLoader.java similarity index 96% rename from server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/load/DeletionLoader.java rename to server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/load/DeletionLoader.java index 0e0c2f7b7a8..e60a77dee5b 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/load/DeletionLoader.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/load/DeletionLoader.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * under the License. */ -package org.apache.iotdb.db.pipe.connector.lagacy.pipedata.load; +package org.apache.iotdb.db.pipe.connector.legacy.pipedata.load; import org.apache.iotdb.commons.conf.CommonDescriptor; import org.apache.iotdb.db.conf.IoTDBDescriptor; @@ -27,7 +27,7 @@ import org.apache.iotdb.db.mpp.plan.execution.ExecutionResult; import org.apache.iotdb.db.mpp.plan.statement.Statement; import org.apache.iotdb.db.mpp.plan.statement.crud.DeleteDataStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.DeleteTimeSeriesStatement; -import org.apache.iotdb.db.pipe.connector.lagacy.exception.SyncDataLoadException; +import org.apache.iotdb.db.pipe.connector.legacy.exception.SyncDataLoadException; import org.apache.iotdb.db.query.control.SessionManager; import org.apache.iotdb.rpc.TSStatusCode; diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/load/ILoader.java b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/load/ILoader.java similarity index 91% rename from server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/load/ILoader.java rename to server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/load/ILoader.java index de07aec08fa..fe2518beb04 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/load/ILoader.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/load/ILoader.java @@ -16,13 +16,13 @@ * specific language governing permissions and limitations * under the License. */ -package org.apache.iotdb.db.pipe.connector.lagacy.pipedata.load; +package org.apache.iotdb.db.pipe.connector.legacy.pipedata.load; import org.apache.iotdb.db.mpp.plan.analyze.ClusterPartitionFetcher; import org.apache.iotdb.db.mpp.plan.analyze.IPartitionFetcher; import org.apache.iotdb.db.mpp.plan.analyze.schema.ClusterSchemaFetcher; import org.apache.iotdb.db.mpp.plan.analyze.schema.ISchemaFetcher; -import org.apache.iotdb.db.pipe.connector.lagacy.exception.SyncDataLoadException; +import org.apache.iotdb.db.pipe.connector.legacy.exception.SyncDataLoadException; /** * This interface is used to load files, including tsFile, syncTask, schema, modsFile and diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/load/TsFileLoader.java b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/load/TsFileLoader.java similarity index 96% rename from server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/load/TsFileLoader.java rename to server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/load/TsFileLoader.java index 5cfd59e6661..0609dc3056d 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/load/TsFileLoader.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/load/TsFileLoader.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * under the License. */ -package org.apache.iotdb.db.pipe.connector.lagacy.pipedata.load; +package org.apache.iotdb.db.pipe.connector.legacy.pipedata.load; import org.apache.iotdb.commons.exception.IllegalPathException; import org.apache.iotdb.commons.path.PartialPath; @@ -25,7 +25,7 @@ import org.apache.iotdb.db.exception.LoadFileException; import org.apache.iotdb.db.mpp.plan.Coordinator; import org.apache.iotdb.db.mpp.plan.execution.ExecutionResult; import org.apache.iotdb.db.mpp.plan.statement.crud.LoadTsFileStatement; -import org.apache.iotdb.db.pipe.connector.lagacy.exception.SyncDataLoadException; +import org.apache.iotdb.db.pipe.connector.legacy.exception.SyncDataLoadException; import org.apache.iotdb.db.query.control.SessionManager; import org.apache.iotdb.rpc.TSStatusCode; diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/queue/BufferedPipeDataQueue.java b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/queue/BufferedPipeDataQueue.java similarity index 97% rename from server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/queue/BufferedPipeDataQueue.java rename to server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/queue/BufferedPipeDataQueue.java index d6c28f4c4da..495a6118c02 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/queue/BufferedPipeDataQueue.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/queue/BufferedPipeDataQueue.java @@ -16,14 +16,14 @@ * specific language governing permissions and limitations * under the License. */ -package org.apache.iotdb.db.pipe.connector.lagacy.pipedata.queue; +package org.apache.iotdb.db.pipe.connector.legacy.pipedata.queue; import org.apache.iotdb.commons.exception.IllegalPathException; import org.apache.iotdb.commons.utils.FileUtils; -import org.apache.iotdb.db.pipe.connector.lagacy.pipedata.PipeData; -import org.apache.iotdb.db.pipe.connector.lagacy.pipedata.TsFilePipeData; -import org.apache.iotdb.db.pipe.connector.lagacy.utils.SyncConstant; -import org.apache.iotdb.db.pipe.connector.lagacy.utils.SyncPathUtil; +import org.apache.iotdb.db.pipe.connector.legacy.pipedata.PipeData; +import org.apache.iotdb.db.pipe.connector.legacy.pipedata.TsFilePipeData; +import org.apache.iotdb.db.pipe.connector.legacy.utils.SyncConstant; +import org.apache.iotdb.db.pipe.connector.legacy.utils.SyncPathUtil; import org.apache.iotdb.tsfile.exception.NotImplementedException; import org.slf4j.Logger; diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/queue/PipeDataQueue.java b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/queue/PipeDataQueue.java similarity index 89% rename from server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/queue/PipeDataQueue.java rename to server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/queue/PipeDataQueue.java index 837707d7658..08ecfe0f3ce 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/pipedata/queue/PipeDataQueue.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/pipedata/queue/PipeDataQueue.java @@ -16,9 +16,9 @@ * specific language governing permissions and limitations * under the License. */ -package org.apache.iotdb.db.pipe.connector.lagacy.pipedata.queue; +package org.apache.iotdb.db.pipe.connector.legacy.pipedata.queue; -import org.apache.iotdb.db.pipe.connector.lagacy.pipedata.PipeData; +import org.apache.iotdb.db.pipe.connector.legacy.pipedata.PipeData; import java.util.List; diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/transport/SyncIdentityInfo.java b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/transport/SyncIdentityInfo.java similarity index 96% rename from server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/transport/SyncIdentityInfo.java rename to server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/transport/SyncIdentityInfo.java index 7691cfaa6ca..c1f62c0695c 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/transport/SyncIdentityInfo.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/transport/SyncIdentityInfo.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * under the License. */ -package org.apache.iotdb.db.pipe.connector.lagacy.transport; +package org.apache.iotdb.db.pipe.connector.legacy.transport; import org.apache.iotdb.service.rpc.thrift.TSyncIdentityInfo; diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/utils/SyncConstant.java b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/utils/SyncConstant.java similarity index 97% rename from server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/utils/SyncConstant.java rename to server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/utils/SyncConstant.java index 10489a329b1..cfac1eec568 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/utils/SyncConstant.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/utils/SyncConstant.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * under the License. */ -package org.apache.iotdb.db.pipe.connector.lagacy.utils; +package org.apache.iotdb.db.pipe.connector.legacy.utils; public class SyncConstant { /** common */ diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/utils/SyncPathUtil.java b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/utils/SyncPathUtil.java similarity index 96% rename from server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/utils/SyncPathUtil.java rename to server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/utils/SyncPathUtil.java index ae82ddf1d22..057ca641930 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/utils/SyncPathUtil.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/utils/SyncPathUtil.java @@ -17,10 +17,10 @@ * under the License. */ -package org.apache.iotdb.db.pipe.connector.lagacy.utils; +package org.apache.iotdb.db.pipe.connector.legacy.utils; import org.apache.iotdb.commons.conf.CommonDescriptor; -import org.apache.iotdb.db.pipe.connector.lagacy.transport.SyncIdentityInfo; +import org.apache.iotdb.db.pipe.connector.legacy.transport.SyncIdentityInfo; import java.io.File; import java.io.IOException; diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeConnectorSubtaskManager.java b/server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeConnectorSubtaskManager.java index 829e0bb993b..149808e1cb8 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeConnectorSubtaskManager.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeConnectorSubtaskManager.java @@ -24,7 +24,7 @@ import org.apache.iotdb.commons.pipe.plugin.builtin.BuiltinPipePlugin; import org.apache.iotdb.db.pipe.agent.PipeAgent; import org.apache.iotdb.db.pipe.config.constant.PipeConnectorConstant; import org.apache.iotdb.db.pipe.config.plugin.configuraion.PipeTaskRuntimeConfiguration; -import org.apache.iotdb.db.pipe.connector.lagacy.IoTDBSyncConnectorV1_1; +import org.apache.iotdb.db.pipe.connector.legacy.IoTDBSyncConnectorV1_1; import org.apache.iotdb.db.pipe.connector.v1.IoTDBThriftConnectorV1; import org.apache.iotdb.db.pipe.connector.v2.IoTDBThriftConnectorV2; import org.apache.iotdb.db.pipe.execution.executor.PipeConnectorSubtaskExecutor; diff --git a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java index 509f1c7d298..c29da22ab37 100644 --- a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java +++ b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java @@ -63,7 +63,7 @@ import org.apache.iotdb.db.mpp.plan.statement.metadata.template.DropSchemaTempla import org.apache.iotdb.db.mpp.plan.statement.metadata.template.SetSchemaTemplateStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.template.UnsetSchemaTemplateStatement; import org.apache.iotdb.db.pipe.agent.PipeAgent; -import org.apache.iotdb.db.pipe.connector.lagacy.IoTDBSyncReceiverV1_1; +import org.apache.iotdb.db.pipe.connector.legacy.IoTDBSyncReceiverV1_1; import org.apache.iotdb.db.query.control.SessionManager; import org.apache.iotdb.db.query.control.clientsession.IClientSession; import org.apache.iotdb.db.quotas.DataNodeThrottleQuotaManager;
