This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch pipe-package-refactor in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 2bc49f220593dbe550a6db52b7d8eb765f9e23b8 Author: Steve Yurong Su <[email protected]> AuthorDate: Wed Jun 7 02:48:05 2023 +0800 Pipe: refactor package structure (db-test) --- .../db/pipe/execution/executor/PipeConnectorSubtaskExecutor.java | 2 +- .../db/pipe/execution/executor/PipeProcessorSubtaskExecutor.java | 2 +- .../pipe/{core => }/collector/CachedSchemaPatternMatcherTest.java | 2 +- .../iotdb/db/pipe/{core => }/collector/PipeRealtimeCollectTest.java | 2 +- .../iotdb/db/pipe/{core => }/connector/PipeThriftRequestTest.java | 2 +- .../db/pipe/{core => }/event/PipeTabletInsertionEventTest.java | 6 +++--- .../db/pipe/{core => }/event/TsFileInsertionDataContainerTest.java | 2 +- .../execution/{executor => }/PipeConnectorSubtaskExecutorTest.java | 3 ++- .../execution/{executor => }/PipeProcessorSubtaskExecutorTest.java | 3 ++- .../db/pipe/execution/{executor => }/PipeSubtaskExecutorTest.java | 3 ++- 10 files changed, 15 insertions(+), 12 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/execution/executor/PipeConnectorSubtaskExecutor.java b/server/src/main/java/org/apache/iotdb/db/pipe/execution/executor/PipeConnectorSubtaskExecutor.java index b6a26508ddc..83ce8c8febd 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/execution/executor/PipeConnectorSubtaskExecutor.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/execution/executor/PipeConnectorSubtaskExecutor.java @@ -24,7 +24,7 @@ import org.apache.iotdb.commons.pipe.config.PipeConfig; public class PipeConnectorSubtaskExecutor extends PipeSubtaskExecutor { - PipeConnectorSubtaskExecutor() { + public PipeConnectorSubtaskExecutor() { super( PipeConfig.getInstance().getPipeSubtaskExecutorMaxThreadNum(), ThreadName.PIPE_CONNECTOR_EXECUTOR_POOL); diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/execution/executor/PipeProcessorSubtaskExecutor.java b/server/src/main/java/org/apache/iotdb/db/pipe/execution/executor/PipeProcessorSubtaskExecutor.java index f806e287fc4..3d3d5598699 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/execution/executor/PipeProcessorSubtaskExecutor.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/execution/executor/PipeProcessorSubtaskExecutor.java @@ -24,7 +24,7 @@ import org.apache.iotdb.commons.pipe.config.PipeConfig; public class PipeProcessorSubtaskExecutor extends PipeSubtaskExecutor { - PipeProcessorSubtaskExecutor() { + public PipeProcessorSubtaskExecutor() { super( PipeConfig.getInstance().getPipeSubtaskExecutorMaxThreadNum(), ThreadName.PIPE_PROCESSOR_EXECUTOR_POOL); diff --git a/server/src/test/java/org/apache/iotdb/db/pipe/core/collector/CachedSchemaPatternMatcherTest.java b/server/src/test/java/org/apache/iotdb/db/pipe/collector/CachedSchemaPatternMatcherTest.java similarity index 99% rename from server/src/test/java/org/apache/iotdb/db/pipe/core/collector/CachedSchemaPatternMatcherTest.java rename to server/src/test/java/org/apache/iotdb/db/pipe/collector/CachedSchemaPatternMatcherTest.java index 7db76191a87..ef8e2e67e3a 100644 --- a/server/src/test/java/org/apache/iotdb/db/pipe/core/collector/CachedSchemaPatternMatcherTest.java +++ b/server/src/test/java/org/apache/iotdb/db/pipe/collector/CachedSchemaPatternMatcherTest.java @@ -17,7 +17,7 @@ * under the License. */ -package org.apache.iotdb.db.pipe.core.collector; +package org.apache.iotdb.db.pipe.collector; import org.apache.iotdb.commons.pipe.task.meta.PipeTaskMeta; import org.apache.iotdb.db.pipe.collector.realtime.PipeRealtimeDataRegionCollector; diff --git a/server/src/test/java/org/apache/iotdb/db/pipe/core/collector/PipeRealtimeCollectTest.java b/server/src/test/java/org/apache/iotdb/db/pipe/collector/PipeRealtimeCollectTest.java similarity index 99% rename from server/src/test/java/org/apache/iotdb/db/pipe/core/collector/PipeRealtimeCollectTest.java rename to server/src/test/java/org/apache/iotdb/db/pipe/collector/PipeRealtimeCollectTest.java index 2c074fd790d..202c1527bd2 100644 --- a/server/src/test/java/org/apache/iotdb/db/pipe/core/collector/PipeRealtimeCollectTest.java +++ b/server/src/test/java/org/apache/iotdb/db/pipe/collector/PipeRealtimeCollectTest.java @@ -17,7 +17,7 @@ * under the License. */ -package org.apache.iotdb.db.pipe.core.collector; +package org.apache.iotdb.db.pipe.collector; import org.apache.iotdb.commons.conf.IoTDBConstant; import org.apache.iotdb.commons.path.PartialPath; diff --git a/server/src/test/java/org/apache/iotdb/db/pipe/core/connector/PipeThriftRequestTest.java b/server/src/test/java/org/apache/iotdb/db/pipe/connector/PipeThriftRequestTest.java similarity index 99% rename from server/src/test/java/org/apache/iotdb/db/pipe/core/connector/PipeThriftRequestTest.java rename to server/src/test/java/org/apache/iotdb/db/pipe/connector/PipeThriftRequestTest.java index 2c7eae3a424..72e5075cb43 100644 --- a/server/src/test/java/org/apache/iotdb/db/pipe/core/connector/PipeThriftRequestTest.java +++ b/server/src/test/java/org/apache/iotdb/db/pipe/connector/PipeThriftRequestTest.java @@ -17,7 +17,7 @@ * under the License. */ -package org.apache.iotdb.db.pipe.core.connector; +package org.apache.iotdb.db.pipe.connector; import org.apache.iotdb.commons.path.PartialPath; import org.apache.iotdb.db.mpp.plan.planner.plan.node.PlanNodeId; diff --git a/server/src/test/java/org/apache/iotdb/db/pipe/core/event/PipeTabletInsertionEventTest.java b/server/src/test/java/org/apache/iotdb/db/pipe/event/PipeTabletInsertionEventTest.java similarity index 98% rename from server/src/test/java/org/apache/iotdb/db/pipe/core/event/PipeTabletInsertionEventTest.java rename to server/src/test/java/org/apache/iotdb/db/pipe/event/PipeTabletInsertionEventTest.java index 80f46ff1530..abd0cf9b056 100644 --- a/server/src/test/java/org/apache/iotdb/db/pipe/core/event/PipeTabletInsertionEventTest.java +++ b/server/src/test/java/org/apache/iotdb/db/pipe/event/PipeTabletInsertionEventTest.java @@ -17,7 +17,7 @@ * under the License. */ -package org.apache.iotdb.db.pipe.core.event; +package org.apache.iotdb.db.pipe.event; import org.apache.iotdb.commons.exception.IllegalPathException; import org.apache.iotdb.commons.path.PartialPath; @@ -40,8 +40,8 @@ import java.util.Arrays; public class PipeTabletInsertionEventTest { - InsertRowNode insertRowNode; - InsertTabletNode insertTabletNode; + private InsertRowNode insertRowNode; + private InsertTabletNode insertTabletNode; final String deviceId = "root.sg.d1"; final long[] times = new long[] {110L, 111L, 112L, 113L, 114L}; diff --git a/server/src/test/java/org/apache/iotdb/db/pipe/core/event/TsFileInsertionDataContainerTest.java b/server/src/test/java/org/apache/iotdb/db/pipe/event/TsFileInsertionDataContainerTest.java similarity index 99% rename from server/src/test/java/org/apache/iotdb/db/pipe/core/event/TsFileInsertionDataContainerTest.java rename to server/src/test/java/org/apache/iotdb/db/pipe/event/TsFileInsertionDataContainerTest.java index 7556182505e..aa0b7506cbf 100644 --- a/server/src/test/java/org/apache/iotdb/db/pipe/core/event/TsFileInsertionDataContainerTest.java +++ b/server/src/test/java/org/apache/iotdb/db/pipe/event/TsFileInsertionDataContainerTest.java @@ -17,7 +17,7 @@ * under the License. */ -package org.apache.iotdb.db.pipe.core.event; +package org.apache.iotdb.db.pipe.event; import org.apache.iotdb.db.pipe.event.common.tablet.PipeRawTabletInsertionEvent; import org.apache.iotdb.db.pipe.event.common.tsfile.TsFileInsertionDataContainer; diff --git a/server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeConnectorSubtaskExecutorTest.java b/server/src/test/java/org/apache/iotdb/db/pipe/execution/PipeConnectorSubtaskExecutorTest.java similarity index 92% rename from server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeConnectorSubtaskExecutorTest.java rename to server/src/test/java/org/apache/iotdb/db/pipe/execution/PipeConnectorSubtaskExecutorTest.java index bf48f14758e..08ec913c32a 100644 --- a/server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeConnectorSubtaskExecutorTest.java +++ b/server/src/test/java/org/apache/iotdb/db/pipe/execution/PipeConnectorSubtaskExecutorTest.java @@ -17,8 +17,9 @@ * under the License. */ -package org.apache.iotdb.db.pipe.execution.executor; +package org.apache.iotdb.db.pipe.execution; +import org.apache.iotdb.db.pipe.execution.executor.PipeConnectorSubtaskExecutor; import org.apache.iotdb.db.pipe.task.connection.BoundedBlockingPendingQueue; import org.apache.iotdb.db.pipe.task.subtask.PipeConnectorSubtask; import org.apache.iotdb.pipe.api.PipeConnector; diff --git a/server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeProcessorSubtaskExecutorTest.java b/server/src/test/java/org/apache/iotdb/db/pipe/execution/PipeProcessorSubtaskExecutorTest.java similarity index 92% rename from server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeProcessorSubtaskExecutorTest.java rename to server/src/test/java/org/apache/iotdb/db/pipe/execution/PipeProcessorSubtaskExecutorTest.java index 7e57ecf40f6..b1a454c732c 100644 --- a/server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeProcessorSubtaskExecutorTest.java +++ b/server/src/test/java/org/apache/iotdb/db/pipe/execution/PipeProcessorSubtaskExecutorTest.java @@ -17,8 +17,9 @@ * under the License. */ -package org.apache.iotdb.db.pipe.execution.executor; +package org.apache.iotdb.db.pipe.execution; +import org.apache.iotdb.db.pipe.execution.executor.PipeProcessorSubtaskExecutor; import org.apache.iotdb.db.pipe.task.connection.EventSupplier; import org.apache.iotdb.db.pipe.task.subtask.PipeProcessorSubtask; import org.apache.iotdb.pipe.api.PipeProcessor; diff --git a/server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeSubtaskExecutorTest.java b/server/src/test/java/org/apache/iotdb/db/pipe/execution/PipeSubtaskExecutorTest.java similarity index 97% rename from server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeSubtaskExecutorTest.java rename to server/src/test/java/org/apache/iotdb/db/pipe/execution/PipeSubtaskExecutorTest.java index d24efc3fb7f..883804cf69d 100644 --- a/server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeSubtaskExecutorTest.java +++ b/server/src/test/java/org/apache/iotdb/db/pipe/execution/PipeSubtaskExecutorTest.java @@ -17,8 +17,9 @@ * under the License. */ -package org.apache.iotdb.db.pipe.execution.executor; +package org.apache.iotdb.db.pipe.execution; +import org.apache.iotdb.db.pipe.execution.executor.PipeSubtaskExecutor; import org.apache.iotdb.db.pipe.task.subtask.PipeSubtask; import org.junit.After;
