You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/04/25 12:11:41 UTC
[incubator-inlong] branch master updated (0b331d54b -> 8d2b59745)
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
from 0b331d54b [INLONG-3930][Doc] Add more deployment and development guides in Readme (#3931)
add 8d2b59745 [INLONG-3920][Manager] Add primary key in Binlog source (#3927)
No new revisions were added by this update.
Summary of changes:
.../manager/client/api/source/KafkaSource.java | 2 +-
.../client/api/source/MySQLBinlogSource.java | 3 +
.../api/util/InlongStreamSourceTransfer.java | 7 +-
.../common/pojo/source/binlog/BinlogSourceDTO.java | 4 +
.../source/binlog/BinlogSourceListResponse.java | 3 +
.../pojo/source/binlog/BinlogSourceRequest.java | 3 +
.../pojo/source/binlog/BinlogSourceResponse.java | 3 +
.../common/pojo/source/kafka}/KafkaOffset.java | 2 +-
.../service/sort/util/ExtractNodeUtils.java | 115 ++++++++++++++++++++-
.../service/sort/util/TransformNodeUtils.java | 3 +
10 files changed, 138 insertions(+), 7 deletions(-)
rename inlong-manager/{manager-client/src/main/java/org/apache/inlong/manager/client/api => manager-common/src/main/java/org/apache/inlong/manager/common/pojo/source/kafka}/KafkaOffset.java (96%)