Skip to content

Commit 0be71ef

Browse files
committed
[hotfix-33089][hbase-side]optimze code
1 parent b15b8b7 commit 0be71ef

1 file changed

Lines changed: 3 additions & 9 deletions

File tree

core/src/main/java/com/dtstack/flink/sql/table/AbstractTableParser.java

Lines changed: 3 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -115,15 +115,9 @@ public void parseFieldsInfo(String fieldsInfo, AbstractTableInfo tableInfo) {
115115
* because some no-sql database is not primary key. eg :redis、hbase etc...
116116
*/
117117
if (tableInfo instanceof AbstractSideTableInfo) {
118-
List<String> pks = new ArrayList<>();
119-
tableInfo.getPrimaryKeys().stream().forEach(pk -> {
120-
if (!tableInfo.getFieldList().contains(pk)) {
121-
pks.add(String.format("%s varchar", pk));
122-
}
123-
});
124-
pks.stream().forEach(pk -> {
125-
handleKeyNotHaveAlias(pk, tableInfo);
126-
});
118+
tableInfo.getPrimaryKeys().stream()
119+
.filter(pk -> !tableInfo.getFieldList().contains(pk))
120+
.forEach(pk -> handleKeyNotHaveAlias(String.format("%s varchar", pk), tableInfo));
127121
}
128122

129123
tableInfo.finish();

0 commit comments

Comments
 (0)