Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[INLONG-9781][Manager] Add offline sync task type definition #9787

Merged
merged 2 commits into from
Mar 7, 2024
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -31,10 +31,18 @@ public enum GroupMode {
STANDARD("standard"),

/**
* DataSync mode(only Data Synchronization): group init only with sort in InLong Cluster
* StreamSource -> Sort -> StreamSink
* DataSync mode(only Data Synchronization): real-time data sync in stream way, group init only with
* sort in InLong Cluster.
* StreamSource -> Sort -> Sink
*/
DATASYNC("datasync");
DATASYNC("datasync"),

/**
* DataSync mode(only Data Synchronization): offline data sync in batch way, group init only with sort
* in InLong Cluster.
* BatchSource -> Sort -> Sink
*/
DATASYNC_BATCH("datasync_offline");

@Getter
private final String mode;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,8 @@ public abstract class InlongGroupInfo extends BaseInlongGroup {
@ApiModelProperty(value = "Whether to enable create resource? 0: disable, 1: enable")
private Integer enableCreateResource;

@ApiModelProperty(value = "Standard mode(include Data Ingestion and Synchronization): 0, DataSync mode(only Data Synchronization): 1")
@ApiModelProperty(value = "Standard mode(include Data Ingestion and Synchronization): 0, DataSync mode(only Data Synchronization, real-time data sync in stream way): 1,"
+ " DataSync mode(only Data Synchronization, offline data sync in batch way): 2")
private Integer inlongGroupMode;

@ApiModelProperty(value = "Data report type, default is 0.\n"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,8 @@ public class InlongGroupPageRequest extends PageRequest {
@ApiModelProperty(value = "The inlong cluster tag list")
private List<String> clusterTagList;

@ApiModelProperty(value = "Standard mode(include Data Ingestion and Synchronization): 0, DataSync mode(only Data Synchronization): 1")
@ApiModelProperty(value = "Standard mode(include Data Ingestion and Synchronization): 0, DataSync mode(only Data Synchronization, real-time data sync in stream way): 1,"
+ " DataSync mode(only Data Synchronization, offline data sync in batch way): 2")
private Integer inlongGroupMode;

@ApiModelProperty(value = "Current user", hidden = true)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -86,8 +86,9 @@ public abstract class InlongGroupRequest extends BaseInlongGroup {
@Range(min = 0, max = 1, message = "default is 1, only supports [0: disable, 1: enable]")
private Integer enableCreateResource;

@ApiModelProperty(value = "Standard mode(include Data Ingestion and Synchronization): 0, DataSync mode(only Data Synchronization): 1")
@Range(min = 0, max = 1, message = "default is 0, only supports [0: Standard, 1: DataSync]")
@ApiModelProperty(value = "Standard mode(include Data Ingestion and Synchronization): 0, DataSync mode(only Data Synchronization, real-time data sync in stream way): 1,"
+ " DataSync mode(only Data Synchronization, offline data sync in batch way): 2")
@Range(min = 0, max = 2, message = "default is 0, only supports [0: Standard, 1: DataSync, 2: DataSyncOffline]")
private Integer inlongGroupMode;

@ApiModelProperty(value = "Data report type, default is 0.\n"
Expand Down
Loading