This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new e013c1a87 [INLONG-4701][Manager] Change the operating classes name
from Operation to Operator (#4784)
e013c1a87 is described below
commit e013c1a873e393fca8994aa05a58e823649d1148
Author: wilburjiang0 <[email protected]>
AuthorDate: Mon Jun 27 09:52:41 2022 +0800
[INLONG-4701][Manager] Change the operating classes name from Operation to
Operator (#4784)
---
.../inlong/manager/service/core/impl/AgentServiceImpl.java | 6 +++---
.../manager/service/group/InlongGroupServiceImpl.java | 8 ++++----
.../service/resource/SinkResourceOperatorFactory.java | 2 +-
.../inlong/manager/service/sink/AbstractSinkOperator.java | 2 +-
...{SinkOperationFactory.java => SinkOperatorFactory.java} | 12 ++++++------
.../{StreamSinkOperation.java => StreamSinkOperator.java} | 4 ++--
.../inlong/manager/service/sink/StreamSinkServiceImpl.java | 10 +++++-----
...HouseSinkOperation.java => ClickHouseSinkOperator.java} | 6 +++---
...ebergSinkOperation.java => DLCIcebergSinkOperator.java} | 6 +++---
...chSinkOperation.java => ElasticsearchSinkOperator.java} | 6 +++---
...enplumSinkOperation.java => GreenplumSinkOperator.java} | 6 +++---
.../{HBaseSinkOperation.java => HBaseSinkOperator.java} | 6 +++---
.../hdfs/{HdfsSinkOperation.java => HdfsSinkOperator.java} | 6 +++---
.../hive/{HiveSinkOperation.java => HiveSinkOperator.java} | 6 +++---
...{IcebergSinkOperation.java => IcebergSinkOperator.java} | 6 +++---
.../{KafkaSinkOperation.java => KafkaSinkOperator.java} | 6 +++---
.../{MySQLSinkOperation.java => MySQLSinkOperator.java} | 6 +++---
.../{OracleSinkOperation.java => OracleSinkOperator.java} | 6 +++---
...ostgresSinkOperation.java => PostgresSinkOperator.java} | 6 +++---
...ServerSinkOperation.java => SqlServerSinkOperator.java} | 6 +++---
...SinkOperation.java => TDSQLPostgreSQLSinkOperator.java} | 6 +++---
...actSourceOperation.java => AbstractSourceOperator.java} | 6 +++---
...rceOperationFactory.java => SourceOperatorFactory.java} | 12 ++++++------
...eSnapshotOperation.java => SourceSnapshotOperator.java} | 4 ++--
...treamSourceOperation.java => StreamSourceOperator.java} | 4 ++--
.../manager/service/source/StreamSourceServiceImpl.java | 14 +++++++-------
...ushSourceOperation.java => AutoPushSourceOperator.java} | 6 +++---
...inlogSourceOperation.java => BinlogSourceOperator.java} | 6 +++---
.../{FileSourceOperation.java => FileSourceOperator.java} | 6 +++---
...{KafkaSourceOperation.java => KafkaSourceOperator.java} | 6 +++---
...goDBSourceOperation.java => MongoDBSourceOperator.java} | 6 +++---
...racleSourceOperation.java => OracleSourceOperator.java} | 6 +++---
...resSourceOperation.java => PostgresSourceOperator.java} | 6 +++---
...ulsarSourceOperation.java => PulsarSourceOperator.java} | 6 +++---
...erSourceOperation.java => SqlServerSourceOperator.java} | 6 +++---
35 files changed, 111 insertions(+), 111 deletions(-)
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java
index 39718b17a..96436e8af 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java
@@ -41,7 +41,7 @@ import
org.apache.inlong.manager.dao.mapper.InlongStreamEntityMapper;
import org.apache.inlong.manager.dao.mapper.StreamSourceEntityMapper;
import org.apache.inlong.manager.service.core.AgentService;
import org.apache.inlong.manager.service.core.StreamConfigLogService;
-import org.apache.inlong.manager.service.source.SourceSnapshotOperation;
+import org.apache.inlong.manager.service.source.SourceSnapshotOperator;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -72,7 +72,7 @@ public class AgentServiceImpl implements AgentService {
@Autowired
private StreamSourceEntityMapper sourceMapper;
@Autowired
- private SourceSnapshotOperation snapshotOperation;
+ private SourceSnapshotOperator snapshotOperator;
@Autowired
private DataSourceCmdConfigEntityMapper sourceCmdConfigMapper;
@Autowired
@@ -82,7 +82,7 @@ public class AgentServiceImpl implements AgentService {
@Override
public Boolean reportSnapshot(TaskSnapshotRequest request) {
- return snapshotOperation.snapshot(request);
+ return snapshotOperator.snapshot(request);
}
@Override
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupServiceImpl.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupServiceImpl.java
index 7e8f7ac4a..69f48ff18 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupServiceImpl.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupServiceImpl.java
@@ -46,8 +46,8 @@ import
org.apache.inlong.manager.dao.mapper.InlongGroupEntityMapper;
import org.apache.inlong.manager.dao.mapper.InlongGroupExtEntityMapper;
import org.apache.inlong.manager.dao.mapper.StreamSourceEntityMapper;
import org.apache.inlong.manager.service.core.InlongStreamService;
-import org.apache.inlong.manager.service.source.SourceOperationFactory;
-import org.apache.inlong.manager.service.source.StreamSourceOperation;
+import org.apache.inlong.manager.service.source.SourceOperatorFactory;
+import org.apache.inlong.manager.service.source.StreamSourceOperator;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -81,7 +81,7 @@ public class InlongGroupServiceImpl implements
InlongGroupService {
@Autowired
private StreamSourceEntityMapper streamSourceMapper;
@Autowired
- private SourceOperationFactory sourceOperationFactory;
+ private SourceOperatorFactory sourceOperatorFactory;
@Autowired
private InlongStreamService streamService;
@@ -185,7 +185,7 @@ public class InlongGroupServiceImpl implements
InlongGroupService {
Map<String, List<SourceListResponse>> sourceMap =
Maps.newHashMap();
sourceEntities.forEach(sourceEntity -> {
SourceType sourceType =
SourceType.forType(sourceEntity.getSourceType());
- StreamSourceOperation operation =
sourceOperationFactory.getInstance(sourceType);
+ StreamSourceOperator operation =
sourceOperatorFactory.getInstance(sourceType);
SourceListResponse sourceListResponse =
operation.getFromEntity(sourceEntity, SourceListResponse::new);
sourceMap.computeIfAbsent(sourceEntity.getInlongGroupId(), k
-> Lists.newArrayList())
.add(sourceListResponse);
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/SinkResourceOperatorFactory.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/SinkResourceOperatorFactory.java
index 1ae343fcd..b0f55acc1 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/SinkResourceOperatorFactory.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/SinkResourceOperatorFactory.java
@@ -36,7 +36,7 @@ public class SinkResourceOperatorFactory {
private List<SinkResourceOperator> operationList;
/**
- * Get a sink resource operation instance via the given sinkType
+ * Get a sink resource operator instance via the given sinkType
*/
public SinkResourceOperator getInstance(SinkType sinkType) {
Optional<SinkResourceOperator> instance = operationList.stream()
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/AbstractSinkOperator.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/AbstractSinkOperator.java
index 6ae8f616f..3cc13ff45 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/AbstractSinkOperator.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/AbstractSinkOperator.java
@@ -44,7 +44,7 @@ import java.util.List;
/**
* Default operation of stream sink.
*/
-public abstract class AbstractSinkOperator implements StreamSinkOperation {
+public abstract class AbstractSinkOperator implements StreamSinkOperator {
private static final Logger LOGGER =
LoggerFactory.getLogger(AbstractSinkOperator.class);
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/SinkOperationFactory.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/SinkOperatorFactory.java
similarity index 82%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/SinkOperationFactory.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/SinkOperatorFactory.java
index 695513e4a..1d1f7c32c 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/SinkOperationFactory.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/SinkOperatorFactory.java
@@ -27,19 +27,19 @@ import java.util.List;
import java.util.Optional;
/**
- * Factory for {@link StreamSinkOperation}.
+ * Factory for {@link StreamSinkOperator}.
*/
@Service
-public class SinkOperationFactory {
+public class SinkOperatorFactory {
@Autowired
- private List<StreamSinkOperation> sinkOperationList;
+ private List<StreamSinkOperator> sinkOperatorList;
/**
- * Get a sink operation instance via the given sinkType
+ * Get a sink operator instance via the given sinkType
*/
- public StreamSinkOperation getInstance(SinkType sinkType) {
- Optional<StreamSinkOperation> instance = sinkOperationList.stream()
+ public StreamSinkOperator getInstance(SinkType sinkType) {
+ Optional<StreamSinkOperator> instance = sinkOperatorList.stream()
.filter(inst -> inst.accept(sinkType))
.findFirst();
if (!instance.isPresent()) {
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkOperator.java
index fb6607f41..50f9cf625 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkOperator.java
@@ -28,9 +28,9 @@ import org.apache.inlong.manager.dao.entity.StreamSinkEntity;
import java.util.function.Supplier;
/**
- * Interface of the sink operation
+ * Interface of the sink operator
*/
-public interface StreamSinkOperation {
+public interface StreamSinkOperator {
/**
* Determines whether the current instance matches the specified type.
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkServiceImpl.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkServiceImpl.java
index 335435653..13091daf3 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkServiceImpl.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkServiceImpl.java
@@ -66,7 +66,7 @@ public class StreamSinkServiceImpl implements
StreamSinkService {
private static final Logger LOGGER =
LoggerFactory.getLogger(StreamSinkServiceImpl.class);
@Autowired
- private SinkOperationFactory operationFactory;
+ private SinkOperatorFactory operatorFactory;
@Autowired
private GroupCheckService groupCheckService;
@Autowired
@@ -100,7 +100,7 @@ public class StreamSinkServiceImpl implements
StreamSinkService {
}
// According to the sink type, save sink information
- StreamSinkOperation operation =
operationFactory.getInstance(SinkType.forType(sinkType));
+ StreamSinkOperator operation =
operatorFactory.getInstance(SinkType.forType(sinkType));
List<SinkField> fields = request.getSinkFieldList();
// Remove id in sinkField when save
if (CollectionUtils.isNotEmpty(fields)) {
@@ -121,7 +121,7 @@ public class StreamSinkServiceImpl implements
StreamSinkService {
throw new BusinessException(ErrorCodeEnum.SINK_INFO_NOT_FOUND);
}
String sinkType = entity.getSinkType();
- StreamSinkOperation operation =
operationFactory.getInstance(SinkType.forType(sinkType));
+ StreamSinkOperator operation =
operatorFactory.getInstance(SinkType.forType(sinkType));
StreamSink streamSink = operation.getByEntity(entity);
LOGGER.debug("success to get sink info by id={}", id);
return streamSink;
@@ -174,7 +174,7 @@ public class StreamSinkServiceImpl implements
StreamSinkService {
List<SinkListResponse> sinkListResponses = Lists.newArrayList();
for (Map.Entry<SinkType, Page<StreamSinkEntity>> entry :
sinkMap.entrySet()) {
SinkType sinkType = entry.getKey();
- StreamSinkOperation operation =
operationFactory.getInstance(sinkType);
+ StreamSinkOperator operation =
operatorFactory.getInstance(sinkType);
PageInfo<? extends SinkListResponse> pageInfo =
operation.getPageInfo(entry.getValue());
sinkListResponses.addAll(pageInfo.getList());
}
@@ -214,7 +214,7 @@ public class StreamSinkServiceImpl implements
StreamSinkService {
fields.stream().forEach(sinkField -> sinkField.setId(null));
}
- StreamSinkOperation operation =
operationFactory.getInstance(SinkType.forType(sinkType));
+ StreamSinkOperator operation =
operatorFactory.getInstance(SinkType.forType(sinkType));
operation.updateOpt(request, operator);
// The inlong group status is [Configuration successful], then
asynchronously initiate
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/ck/ClickHouseSinkOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/ck/ClickHouseSinkOperator.java
similarity index 96%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/ck/ClickHouseSinkOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/ck/ClickHouseSinkOperator.java
index 509a30747..f32bbf579 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/ck/ClickHouseSinkOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/ck/ClickHouseSinkOperator.java
@@ -48,12 +48,12 @@ import java.util.List;
import java.util.function.Supplier;
/**
- * Click house sink operation, such as save or update click house field, etc.
+ * Click house sink operator, such as save or update click house field, etc.
*/
@Service
-public class ClickHouseSinkOperation extends AbstractSinkOperator {
+public class ClickHouseSinkOperator extends AbstractSinkOperator {
- private static final Logger LOGGER =
LoggerFactory.getLogger(ClickHouseSinkOperation.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(ClickHouseSinkOperator.class);
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/dlc/DLCIcebergSinkOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/dlc/DLCIcebergSinkOperator.java
similarity index 96%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/dlc/DLCIcebergSinkOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/dlc/DLCIcebergSinkOperator.java
index df2eddb07..7a844b475 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/dlc/DLCIcebergSinkOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/dlc/DLCIcebergSinkOperator.java
@@ -47,12 +47,12 @@ import java.util.List;
import java.util.function.Supplier;
/**
- * DLCIceberg sink operation, such as save or update DLCIceberg field, etc.
+ * DLCIceberg sink operator, such as save or update DLCIceberg field, etc.
*/
@Service
-public class DLCIcebergSinkOperation extends AbstractSinkOperator {
+public class DLCIcebergSinkOperator extends AbstractSinkOperator {
- private static final Logger LOGGER =
LoggerFactory.getLogger(DLCIcebergSinkOperation.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(DLCIcebergSinkOperator.class);
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/es/ElasticsearchSinkOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/es/ElasticsearchSinkOperator.java
similarity index 96%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/es/ElasticsearchSinkOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/es/ElasticsearchSinkOperator.java
index 208834cb3..5c6ae3474 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/es/ElasticsearchSinkOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/es/ElasticsearchSinkOperator.java
@@ -48,12 +48,12 @@ import java.util.List;
import java.util.function.Supplier;
/**
- * Elasticsearch sink operation, such as save or update Elasticsearch field,
etc.
+ * Elasticsearch sink operator, such as save or update Elasticsearch field,
etc.
*/
@Service
-public class ElasticsearchSinkOperation extends AbstractSinkOperator {
+public class ElasticsearchSinkOperator extends AbstractSinkOperator {
- private static final Logger LOGGER =
LoggerFactory.getLogger(ElasticsearchSinkOperation.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(ElasticsearchSinkOperator.class);
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/greenplum/GreenplumSinkOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/greenplum/GreenplumSinkOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/greenplum/GreenplumSinkOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/greenplum/GreenplumSinkOperator.java
index b93575c98..ee6ade83d 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/greenplum/GreenplumSinkOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/greenplum/GreenplumSinkOperator.java
@@ -48,12 +48,12 @@ import java.util.List;
import java.util.function.Supplier;
/**
- * Greenplum sink operation
+ * Greenplum sink operator
*/
@Service
-public class GreenplumSinkOperation extends AbstractSinkOperator {
+public class GreenplumSinkOperator extends AbstractSinkOperator {
- private static final Logger LOGGER =
LoggerFactory.getLogger(GreenplumSinkOperation.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(GreenplumSinkOperator.class);
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hbase/HBaseSinkOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hbase/HBaseSinkOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hbase/HBaseSinkOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hbase/HBaseSinkOperator.java
index d9ae15c28..ab7dd8f12 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hbase/HBaseSinkOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hbase/HBaseSinkOperator.java
@@ -47,12 +47,12 @@ import java.util.List;
import java.util.function.Supplier;
/**
- * HBase sink operation
+ * HBase sink operator
*/
@Service
-public class HBaseSinkOperation extends AbstractSinkOperator {
+public class HBaseSinkOperator extends AbstractSinkOperator {
- private static final Logger LOGGER =
LoggerFactory.getLogger(HBaseSinkOperation.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(HBaseSinkOperator.class);
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hdfs/HdfsSinkOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hdfs/HdfsSinkOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hdfs/HdfsSinkOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hdfs/HdfsSinkOperator.java
index fd0095085..a30edb8e0 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hdfs/HdfsSinkOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hdfs/HdfsSinkOperator.java
@@ -48,12 +48,12 @@ import java.util.List;
import java.util.function.Supplier;
/**
- * Hdfs sink operation
+ * Hdfs sink operator
*/
@Service
-public class HdfsSinkOperation extends AbstractSinkOperator {
+public class HdfsSinkOperator extends AbstractSinkOperator {
- private static final Logger LOGGER =
LoggerFactory.getLogger(HdfsSinkOperation.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(HdfsSinkOperator.class);
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hive/HiveSinkOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hive/HiveSinkOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hive/HiveSinkOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hive/HiveSinkOperator.java
index 11510cf5e..1bd76cee2 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hive/HiveSinkOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hive/HiveSinkOperator.java
@@ -48,12 +48,12 @@ import java.util.List;
import java.util.function.Supplier;
/**
- * Hive sink operation
+ * Hive sink operator
*/
@Service
-public class HiveSinkOperation extends AbstractSinkOperator {
+public class HiveSinkOperator extends AbstractSinkOperator {
- private static final Logger LOGGER =
LoggerFactory.getLogger(HiveSinkOperation.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(HiveSinkOperator.class);
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/iceberg/IcebergSinkOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/iceberg/IcebergSinkOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/iceberg/IcebergSinkOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/iceberg/IcebergSinkOperator.java
index d9d3ec8d6..1f5c204d4 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/iceberg/IcebergSinkOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/iceberg/IcebergSinkOperator.java
@@ -52,12 +52,12 @@ import java.util.List;
import java.util.function.Supplier;
/**
- * Iceberg sink operation, such as save or update iceberg field, etc.
+ * Iceberg sink operator, such as save or update iceberg field, etc.
*/
@Service
-public class IcebergSinkOperation extends AbstractSinkOperator {
+public class IcebergSinkOperator extends AbstractSinkOperator {
- private static final Logger LOGGER =
LoggerFactory.getLogger(IcebergSinkOperation.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(IcebergSinkOperator.class);
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/kafka/KafkaSinkOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/kafka/KafkaSinkOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/kafka/KafkaSinkOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/kafka/KafkaSinkOperator.java
index 760c7d855..65d0648b2 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/kafka/KafkaSinkOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/kafka/KafkaSinkOperator.java
@@ -48,12 +48,12 @@ import java.util.List;
import java.util.function.Supplier;
/**
- * Kafka sink operation
+ * Kafka sink operator
*/
@Service
-public class KafkaSinkOperation extends AbstractSinkOperator {
+public class KafkaSinkOperator extends AbstractSinkOperator {
- private static final Logger LOGGER =
LoggerFactory.getLogger(KafkaSinkOperation.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(KafkaSinkOperator.class);
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/mysql/MySQLSinkOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/mysql/MySQLSinkOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/mysql/MySQLSinkOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/mysql/MySQLSinkOperator.java
index 406df8e77..33e83ad5f 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/mysql/MySQLSinkOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/mysql/MySQLSinkOperator.java
@@ -48,12 +48,12 @@ import java.util.List;
import java.util.function.Supplier;
/**
- * MySQL sink operation
+ * MySQL sink operator
*/
@Service
-public class MySQLSinkOperation extends AbstractSinkOperator {
+public class MySQLSinkOperator extends AbstractSinkOperator {
- private static final Logger LOGGER =
LoggerFactory.getLogger(MySQLSinkOperation.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(MySQLSinkOperator.class);
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/oracle/OracleSinkOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/oracle/OracleSinkOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/oracle/OracleSinkOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/oracle/OracleSinkOperator.java
index 2167a122b..cd82e63ca 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/oracle/OracleSinkOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/oracle/OracleSinkOperator.java
@@ -47,12 +47,12 @@ import java.util.List;
import java.util.function.Supplier;
/**
- * Oracle sink operation
+ * Oracle sink operator
*/
@Service
-public class OracleSinkOperation extends AbstractSinkOperator {
+public class OracleSinkOperator extends AbstractSinkOperator {
- private static final Logger LOGGER =
LoggerFactory.getLogger(OracleSinkOperation.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(OracleSinkOperator.class);
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/postgres/PostgresSinkOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/postgres/PostgresSinkOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/postgres/PostgresSinkOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/postgres/PostgresSinkOperator.java
index 418a200d9..6de68837b 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/postgres/PostgresSinkOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/postgres/PostgresSinkOperator.java
@@ -48,12 +48,12 @@ import java.util.List;
import java.util.function.Supplier;
/**
- * Postgres sink operation
+ * Postgres sink operator
*/
@Service
-public class PostgresSinkOperation extends AbstractSinkOperator {
+public class PostgresSinkOperator extends AbstractSinkOperator {
- private static final Logger LOGGER =
LoggerFactory.getLogger(PostgresSinkOperation.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(PostgresSinkOperator.class);
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/sqlserver/SqlServerSinkOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/sqlserver/SqlServerSinkOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/sqlserver/SqlServerSinkOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/sqlserver/SqlServerSinkOperator.java
index 0d04f38b6..47dc8657c 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/sqlserver/SqlServerSinkOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/sqlserver/SqlServerSinkOperator.java
@@ -48,12 +48,12 @@ import java.util.List;
import java.util.function.Supplier;
/**
- * SqlServer sink operation
+ * SqlServer sink operator
*/
@Service
-public class SqlServerSinkOperation extends AbstractSinkOperator {
+public class SqlServerSinkOperator extends AbstractSinkOperator {
- private static final Logger LOGGER =
LoggerFactory.getLogger(SqlServerSinkOperation.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(SqlServerSinkOperator.class);
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/tdsqlpostgresql/TDSQLPostgreSQLSinkOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/tdsqlpostgresql/TDSQLPostgreSQLSinkOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/tdsqlpostgresql/TDSQLPostgreSQLSinkOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/tdsqlpostgresql/TDSQLPostgreSQLSinkOperator.java
index 1cb2616a3..896ff0094 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/tdsqlpostgresql/TDSQLPostgreSQLSinkOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/tdsqlpostgresql/TDSQLPostgreSQLSinkOperator.java
@@ -48,12 +48,12 @@ import java.util.List;
import java.util.function.Supplier;
/**
- * TDSQLPostgreSQL sink operation
+ * TDSQLPostgreSQL sink operator
*/
@Service
-public class TDSQLPostgreSQLSinkOperation extends AbstractSinkOperator {
+public class TDSQLPostgreSQLSinkOperator extends AbstractSinkOperator {
- private static final Logger LOGGER =
LoggerFactory.getLogger(TDSQLPostgreSQLSinkOperation.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(TDSQLPostgreSQLSinkOperator.class);
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/AbstractSourceOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/AbstractSourceOperator.java
similarity index 98%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/AbstractSourceOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/AbstractSourceOperator.java
index 7a6a52e0c..94a72b35d 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/AbstractSourceOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/AbstractSourceOperator.java
@@ -47,11 +47,11 @@ import java.util.List;
import java.util.Objects;
/**
- * Default operation of stream source.
+ * Default operator of stream source.
*/
-public abstract class AbstractSourceOperation implements StreamSourceOperation
{
+public abstract class AbstractSourceOperator implements StreamSourceOperator {
- private static final Logger LOGGER =
LoggerFactory.getLogger(AbstractSourceOperation.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(AbstractSourceOperator.class);
@Autowired
protected StreamSourceEntityMapper sourceMapper;
@Autowired
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/SourceOperationFactory.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/SourceOperatorFactory.java
similarity index 82%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/SourceOperationFactory.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/SourceOperatorFactory.java
index 09f26046f..d55e6a9ae 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/SourceOperationFactory.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/SourceOperatorFactory.java
@@ -26,19 +26,19 @@ import org.springframework.stereotype.Service;
import java.util.List;
/**
- * Factory for {@link StreamSourceOperation}.
+ * Factory for {@link StreamSourceOperator}.
*/
@Service
-public class SourceOperationFactory {
+public class SourceOperatorFactory {
@Autowired
- private List<StreamSourceOperation> sourceOperationList;
+ private List<StreamSourceOperator> sourceOperatorList;
/**
- * Get a sink operation instance via the given sourceType
+ * Get a sink operator instance via the given sourceType
*/
- public StreamSourceOperation getInstance(SourceType sourceType) {
- return sourceOperationList.stream()
+ public StreamSourceOperator getInstance(SourceType sourceType) {
+ return sourceOperatorList.stream()
.filter(inst -> inst.accept(sourceType))
.findFirst()
.orElseThrow(() -> new
BusinessException(ErrorCodeEnum.SOURCE_TYPE_NOT_SUPPORT,
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/SourceSnapshotOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/SourceSnapshotOperator.java
similarity index 98%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/SourceSnapshotOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/SourceSnapshotOperator.java
index e6171d1a6..ddcdc0dde 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/SourceSnapshotOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/SourceSnapshotOperator.java
@@ -48,9 +48,9 @@ import java.util.concurrent.TimeUnit;
* Operate the source snapshot
*/
@Service
-public class SourceSnapshotOperation implements AutoCloseable {
+public class SourceSnapshotOperator implements AutoCloseable {
- private static final Logger LOGGER =
LoggerFactory.getLogger(SourceSnapshotOperation.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(SourceSnapshotOperator.class);
private final ExecutorService executorService = new ThreadPoolExecutor(
1,
1,
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceOperator.java
index be5dc4ad2..234eebd32 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceOperator.java
@@ -28,9 +28,9 @@ import
org.apache.inlong.manager.dao.entity.StreamSourceEntity;
import java.util.function.Supplier;
/**
- * Interface of the source operation
+ * Interface of the source operator
*/
-public interface StreamSourceOperation {
+public interface StreamSourceOperator {
/**
* Determines whether the current instance matches the specified type.
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceServiceImpl.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceServiceImpl.java
index 0a375f909..62ccb3295 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceServiceImpl.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceServiceImpl.java
@@ -64,7 +64,7 @@ public class StreamSourceServiceImpl implements
StreamSourceService {
private static final Logger LOGGER =
LoggerFactory.getLogger(StreamSourceServiceImpl.class);
@Autowired
- private SourceOperationFactory operationFactory;
+ private SourceOperatorFactory operationFactory;
@Autowired
private StreamSourceEntityMapper sourceMapper;
@Autowired
@@ -84,7 +84,7 @@ public class StreamSourceServiceImpl implements
StreamSourceService {
// According to the source type, save source information
String sourceType = request.getSourceType();
- StreamSourceOperation operation =
operationFactory.getInstance(SourceType.forType(sourceType));
+ StreamSourceOperator operation =
operationFactory.getInstance(SourceType.forType(sourceType));
// Remove id in sourceField when save
List<StreamField> streamFields = request.getFieldList();
if (CollectionUtils.isNotEmpty(streamFields)) {
@@ -104,7 +104,7 @@ public class StreamSourceServiceImpl implements
StreamSourceService {
LOGGER.error("source not found by id={}", id);
throw new BusinessException(ErrorCodeEnum.SOURCE_INFO_NOT_FOUND);
}
- StreamSourceOperation operation =
operationFactory.getInstance(SourceType.forType(entity.getSourceType()));
+ StreamSourceOperator operation =
operationFactory.getInstance(SourceType.forType(entity.getSourceType()));
StreamSource streamSource = operation.getByEntity(entity);
LOGGER.debug("success to get source by id={}", id);
return streamSource;
@@ -147,7 +147,7 @@ public class StreamSourceServiceImpl implements
StreamSourceService {
List<SourceListResponse> responseList = Lists.newArrayList();
for (Map.Entry<SourceType, Page<StreamSourceEntity>> entry :
sourceMap.entrySet()) {
SourceType sourceType = entry.getKey();
- StreamSourceOperation operation =
operationFactory.getInstance(sourceType);
+ StreamSourceOperator operation =
operationFactory.getInstance(sourceType);
PageInfo<? extends SourceListResponse> pageInfo =
operation.getPageInfo(entry.getValue());
if (null != pageInfo &&
CollectionUtils.isNotEmpty(pageInfo.getList())) {
responseList.addAll(pageInfo.getList());
@@ -172,7 +172,7 @@ public class StreamSourceServiceImpl implements
StreamSourceService {
InlongGroupEntity groupEntity =
groupCheckService.checkGroupStatus(groupId, operator);
String sourceType = request.getSourceType();
- StreamSourceOperation operation =
operationFactory.getInstance(SourceType.forType(sourceType));
+ StreamSourceOperator operation =
operationFactory.getInstance(SourceType.forType(sourceType));
// Remove id in sourceField when save
List<StreamField> streamFields = request.getFieldList();
if (CollectionUtils.isNotEmpty(streamFields)) {
@@ -237,7 +237,7 @@ public class StreamSourceServiceImpl implements
StreamSourceService {
Preconditions.checkNotNull(entity,
ErrorCodeEnum.SOURCE_INFO_NOT_FOUND.getMessage());
groupCheckService.checkGroupStatus(entity.getInlongGroupId(),
operator);
- StreamSourceOperation operation =
operationFactory.getInstance(SourceType.forType(entity.getSourceType()));
+ StreamSourceOperator operation =
operationFactory.getInstance(SourceType.forType(entity.getSourceType()));
SourceRequest sourceRequest = new SourceRequest();
CommonBeanUtils.copyProperties(entity, sourceRequest, true);
operation.restartOpt(sourceRequest, operator);
@@ -255,7 +255,7 @@ public class StreamSourceServiceImpl implements
StreamSourceService {
Preconditions.checkNotNull(entity,
ErrorCodeEnum.SOURCE_INFO_NOT_FOUND.getMessage());
groupCheckService.checkGroupStatus(entity.getInlongGroupId(),
operator);
- StreamSourceOperation operation =
operationFactory.getInstance(SourceType.forType(entity.getSourceType()));
+ StreamSourceOperator operation =
operationFactory.getInstance(SourceType.forType(entity.getSourceType()));
SourceRequest sourceRequest = new SourceRequest();
CommonBeanUtils.copyProperties(entity, sourceRequest, true);
operation.stopOpt(sourceRequest, operator);
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/autopush/AutoPushSourceOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/autopush/AutoPushSourceOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/autopush/AutoPushSourceOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/autopush/AutoPushSourceOperator.java
index 5ff8dd143..5c5d8b588 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/autopush/AutoPushSourceOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/autopush/AutoPushSourceOperator.java
@@ -34,17 +34,17 @@ import
org.apache.inlong.manager.common.pojo.source.autopush.AutoPushSourceReque
import org.apache.inlong.manager.common.util.CommonBeanUtils;
import org.apache.inlong.manager.common.util.Preconditions;
import org.apache.inlong.manager.dao.entity.StreamSourceEntity;
-import org.apache.inlong.manager.service.source.AbstractSourceOperation;
+import org.apache.inlong.manager.service.source.AbstractSourceOperator;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.function.Supplier;
/**
- * DataProxy SDK source operation
+ * DataProxy SDK source operator
*/
@Service
-public class AutoPushSourceOperation extends AbstractSourceOperation {
+public class AutoPushSourceOperator extends AbstractSourceOperator {
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/binlog/BinlogSourceOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/binlog/BinlogSourceOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/binlog/BinlogSourceOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/binlog/BinlogSourceOperator.java
index bf4c5d12c..abec6c3bb 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/binlog/BinlogSourceOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/binlog/BinlogSourceOperator.java
@@ -34,17 +34,17 @@ import
org.apache.inlong.manager.common.pojo.source.mysql.MySQLBinlogSourceReque
import org.apache.inlong.manager.common.util.CommonBeanUtils;
import org.apache.inlong.manager.common.util.Preconditions;
import org.apache.inlong.manager.dao.entity.StreamSourceEntity;
-import org.apache.inlong.manager.service.source.AbstractSourceOperation;
+import org.apache.inlong.manager.service.source.AbstractSourceOperator;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.function.Supplier;
/**
- * Binlog source operation
+ * Binlog source operator
*/
@Service
-public class BinlogSourceOperation extends AbstractSourceOperation {
+public class BinlogSourceOperator extends AbstractSourceOperator {
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/file/FileSourceOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/file/FileSourceOperator.java
similarity index 96%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/file/FileSourceOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/file/FileSourceOperator.java
index d81d17fc9..fca19a456 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/file/FileSourceOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/file/FileSourceOperator.java
@@ -34,17 +34,17 @@ import
org.apache.inlong.manager.common.pojo.source.file.FileSourceRequest;
import org.apache.inlong.manager.common.util.CommonBeanUtils;
import org.apache.inlong.manager.common.util.Preconditions;
import org.apache.inlong.manager.dao.entity.StreamSourceEntity;
-import org.apache.inlong.manager.service.source.AbstractSourceOperation;
+import org.apache.inlong.manager.service.source.AbstractSourceOperator;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.function.Supplier;
/**
- * File source operation, such as get or set file source info.
+ * File source operator, such as get or set file source info.
*/
@Service
-public class FileSourceOperation extends AbstractSourceOperation {
+public class FileSourceOperator extends AbstractSourceOperator {
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/kafka/KafkaSourceOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/kafka/KafkaSourceOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/kafka/KafkaSourceOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/kafka/KafkaSourceOperator.java
index 0d44b6bf2..5b78edfde 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/kafka/KafkaSourceOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/kafka/KafkaSourceOperator.java
@@ -34,17 +34,17 @@ import
org.apache.inlong.manager.common.pojo.source.kafka.KafkaSourceRequest;
import org.apache.inlong.manager.common.util.CommonBeanUtils;
import org.apache.inlong.manager.common.util.Preconditions;
import org.apache.inlong.manager.dao.entity.StreamSourceEntity;
-import org.apache.inlong.manager.service.source.AbstractSourceOperation;
+import org.apache.inlong.manager.service.source.AbstractSourceOperator;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.function.Supplier;
/**
- * kafka stream source operation.
+ * kafka stream source operator.
*/
@Service
-public class KafkaSourceOperation extends AbstractSourceOperation {
+public class KafkaSourceOperator extends AbstractSourceOperator {
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/mongo/MongoDBSourceOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/mongo/MongoDBSourceOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/mongo/MongoDBSourceOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/mongo/MongoDBSourceOperator.java
index 10f66be1c..25470a872 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/mongo/MongoDBSourceOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/mongo/MongoDBSourceOperator.java
@@ -34,17 +34,17 @@ import
org.apache.inlong.manager.common.pojo.source.mongodb.MongoDBSourceRequest
import org.apache.inlong.manager.common.util.CommonBeanUtils;
import org.apache.inlong.manager.common.util.Preconditions;
import org.apache.inlong.manager.dao.entity.StreamSourceEntity;
-import org.apache.inlong.manager.service.source.AbstractSourceOperation;
+import org.apache.inlong.manager.service.source.AbstractSourceOperator;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.function.Supplier;
/**
- * MongoDB source operation.
+ * MongoDB source operator.
*/
@Service
-public class MongoDBSourceOperation extends AbstractSourceOperation {
+public class MongoDBSourceOperator extends AbstractSourceOperator {
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/oracle/OracleSourceOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/oracle/OracleSourceOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/oracle/OracleSourceOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/oracle/OracleSourceOperator.java
index 8d23d089f..cde6ea93a 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/oracle/OracleSourceOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/oracle/OracleSourceOperator.java
@@ -34,17 +34,17 @@ import
org.apache.inlong.manager.common.pojo.source.oracle.OracleSourceRequest;
import org.apache.inlong.manager.common.util.CommonBeanUtils;
import org.apache.inlong.manager.common.util.Preconditions;
import org.apache.inlong.manager.dao.entity.StreamSourceEntity;
-import org.apache.inlong.manager.service.source.AbstractSourceOperation;
+import org.apache.inlong.manager.service.source.AbstractSourceOperator;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.function.Supplier;
/**
- * Oracle source operation
+ * Oracle source operator
*/
@Service
-public class OracleSourceOperation extends AbstractSourceOperation {
+public class OracleSourceOperator extends AbstractSourceOperator {
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/postgres/PostgresSourceOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/postgres/PostgresSourceOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/postgres/PostgresSourceOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/postgres/PostgresSourceOperator.java
index 68af23fa8..dc3d6dc29 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/postgres/PostgresSourceOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/postgres/PostgresSourceOperator.java
@@ -34,17 +34,17 @@ import
org.apache.inlong.manager.common.pojo.source.postgres.PostgresSourceReque
import org.apache.inlong.manager.common.util.CommonBeanUtils;
import org.apache.inlong.manager.common.util.Preconditions;
import org.apache.inlong.manager.dao.entity.StreamSourceEntity;
-import org.apache.inlong.manager.service.source.AbstractSourceOperation;
+import org.apache.inlong.manager.service.source.AbstractSourceOperator;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.function.Supplier;
/**
- * postgres stream source operation.
+ * postgres stream source operator.
*/
@Service
-public class PostgresSourceOperation extends AbstractSourceOperation {
+public class PostgresSourceOperator extends AbstractSourceOperator {
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/pulsar/PulsarSourceOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/pulsar/PulsarSourceOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/pulsar/PulsarSourceOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/pulsar/PulsarSourceOperator.java
index f02e5d71a..baa467682 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/pulsar/PulsarSourceOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/pulsar/PulsarSourceOperator.java
@@ -34,17 +34,17 @@ import
org.apache.inlong.manager.common.pojo.source.pulsar.PulsarSourceRequest;
import org.apache.inlong.manager.common.util.CommonBeanUtils;
import org.apache.inlong.manager.common.util.Preconditions;
import org.apache.inlong.manager.dao.entity.StreamSourceEntity;
-import org.apache.inlong.manager.service.source.AbstractSourceOperation;
+import org.apache.inlong.manager.service.source.AbstractSourceOperator;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.function.Supplier;
/**
- * Pulsar stream source operation
+ * Pulsar stream source operator
*/
@Service
-public class PulsarSourceOperation extends AbstractSourceOperation {
+public class PulsarSourceOperator extends AbstractSourceOperator {
@Autowired
private ObjectMapper objectMapper;
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/sqlserver/SqlServerSourceOperation.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/sqlserver/SqlServerSourceOperator.java
similarity index 97%
rename from
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/sqlserver/SqlServerSourceOperation.java
rename to
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/sqlserver/SqlServerSourceOperator.java
index 38017c19a..6fa9a1c15 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/sqlserver/SqlServerSourceOperation.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/sqlserver/SqlServerSourceOperator.java
@@ -34,17 +34,17 @@ import
org.apache.inlong.manager.common.pojo.source.sqlserver.SqlServerSourceReq
import org.apache.inlong.manager.common.util.CommonBeanUtils;
import org.apache.inlong.manager.common.util.Preconditions;
import org.apache.inlong.manager.dao.entity.StreamSourceEntity;
-import org.apache.inlong.manager.service.source.AbstractSourceOperation;
+import org.apache.inlong.manager.service.source.AbstractSourceOperator;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.function.Supplier;
/**
- * SqlServer source operation
+ * SqlServer source operator
*/
@Service
-public class SqlServerSourceOperation extends AbstractSourceOperation {
+public class SqlServerSourceOperator extends AbstractSourceOperator {
@Autowired
private ObjectMapper objectMapper;
