This is an automated email from the ASF dual-hosted git repository.
azexin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new c4b26c6cdd9 Clean pipeline api module (#28139)
c4b26c6cdd9 is described below
commit c4b26c6cdd9c43a9ae4062e6efe1f69166b3f24f
Author: Hongsheng Zhong <[email protected]>
AuthorDate: Thu Aug 17 14:11:02 2023 +0800
Clean pipeline api module (#28139)
---
.../data/pipeline/api/config/TableNameSchemaNameMapping.java | 5 -----
.../data/pipeline/api/metadata/model/PipelineTableMetaData.java | 3 +++
2 files changed, 3 insertions(+), 5 deletions(-)
diff --git
a/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/TableNameSchemaNameMapping.java
b/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/TableNameSchemaNameMapping.java
index 32dbc1620ef..5b37485ce61 100644
---
a/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/TableNameSchemaNameMapping.java
+++
b/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/TableNameSchemaNameMapping.java
@@ -33,11 +33,6 @@ public final class TableNameSchemaNameMapping {
private final Map<LogicTableName, String> mapping;
- /**
- * Convert table name and schema name mapping from schemas.
- *
- * @param tableSchemaMap table name and schema name map
- */
public TableNameSchemaNameMapping(final Map<String, String>
tableSchemaMap) {
mapping = null == tableSchemaMap ? Collections.emptyMap() :
getLogicTableNameMap(tableSchemaMap);
}
diff --git
a/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/metadata/model/PipelineTableMetaData.java
b/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/metadata/model/PipelineTableMetaData.java
index 17df4192867..e593a95b751 100644
---
a/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/metadata/model/PipelineTableMetaData.java
+++
b/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/metadata/model/PipelineTableMetaData.java
@@ -17,9 +17,11 @@
package org.apache.shardingsphere.data.pipeline.api.metadata.model;
+import lombok.AccessLevel;
import lombok.EqualsAndHashCode;
import lombok.Getter;
import lombok.NonNull;
+import lombok.RequiredArgsConstructor;
import lombok.ToString;
import lombok.extern.slf4j.Slf4j;
@@ -33,6 +35,7 @@ import java.util.stream.Collectors;
/**
* Pipeline table meta data.
*/
+@RequiredArgsConstructor(access = AccessLevel.PRIVATE)
@Slf4j
@EqualsAndHashCode(of = "name")
@ToString