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/03/06 07:12:48 UTC
[incubator-inlong] branch master updated: [INLONG-2939][Manager] Add strictly ordered flag in manager client (#2940)
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/incubator-inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 75f37f1 [INLONG-2939][Manager] Add strictly ordered flag in manager client (#2940)
75f37f1 is described below
commit 75f37f1b07a387dece7c84434800f6d7bff337da
Author: kipshi <48...@users.noreply.github.com>
AuthorDate: Sun Mar 6 15:12:43 2022 +0800
[INLONG-2939][Manager] Add strictly ordered flag in manager client (#2940)
---
.../java/org/apache/inlong/manager/client/api/InlongStreamConf.java | 3 +++
.../apache/inlong/manager/client/api/util/InlongStreamTransfer.java | 1 +
2 files changed, 4 insertions(+)
diff --git a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/InlongStreamConf.java b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/InlongStreamConf.java
index 3b0c934..f9fc1ea 100644
--- a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/InlongStreamConf.java
+++ b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/InlongStreamConf.java
@@ -39,6 +39,9 @@ public class InlongStreamConf {
@ApiModelProperty("Inlong stream description")
private String description;
+ @ApiModelProperty("Is Inlong stream strictly ordered")
+ private boolean strictlyOrdered = false;
+
@ApiModelProperty("Stream source field list")
private List<StreamField> streamFields;
diff --git a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongStreamTransfer.java b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongStreamTransfer.java
index d97379f..694670b 100644
--- a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongStreamTransfer.java
+++ b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongStreamTransfer.java
@@ -35,6 +35,7 @@ public class InlongStreamTransfer {
dataStreamInfo.setName(streamConf.getName());
dataStreamInfo.setDataEncoding(streamConf.getCharset().name());
dataStreamInfo.setMqResourceObj(streamId);
+ dataStreamInfo.setSyncSend(streamConf.isStrictlyOrdered() ? 1 : 0);
dataStreamInfo.setDataSeparator(String.valueOf(streamConf.getDataSeparator().getAsciiCode()));
dataStreamInfo.setDescription(streamConf.getDescription());
dataStreamInfo.setCreator(groupInfo.getCreator());