@Generated(value="io.swagger.codegen.languages.JavaClientCodegen", date="2023-09-07T10:41:28.432+08:00") public class SubmitFlinkSqlJobRequest extends Object
Modifier and Type | Class and Description |
---|---|
static class |
SubmitFlinkSqlJobRequest.JobTypeEnum
作业类型, run_mode为edge_node时, 作业类型须为flink_sql_edge_job, run_mode为shared_cluster跟exclusive_cluster时, 作业类型须为flink_sql_job
|
static class |
SubmitFlinkSqlJobRequest.RunModeEnum
作业运行模式,共享或者独享或者边缘节点
|
Constructor and Description |
---|
SubmitFlinkSqlJobRequest() |
public SubmitFlinkSqlJobRequest name(String name)
public String getName()
public void setName(String name)
public SubmitFlinkSqlJobRequest desc(String desc)
public String getDesc()
public void setDesc(String desc)
public SubmitFlinkSqlJobRequest templateId(Long templateId)
public Long getTemplateId()
public void setTemplateId(Long templateId)
public SubmitFlinkSqlJobRequest queueName(String queueName)
public String getQueueName()
public void setQueueName(String queueName)
public SubmitFlinkSqlJobRequest sqlBody(String sqlBody)
public String getSqlBody()
public void setSqlBody(String sqlBody)
public SubmitFlinkSqlJobRequest runMode(SubmitFlinkSqlJobRequest.RunModeEnum runMode)
public SubmitFlinkSqlJobRequest.RunModeEnum getRunMode()
public void setRunMode(SubmitFlinkSqlJobRequest.RunModeEnum runMode)
public SubmitFlinkSqlJobRequest cuNumber(Integer cuNumber)
public Integer getCuNumber()
public void setCuNumber(Integer cuNumber)
public SubmitFlinkSqlJobRequest parallelNumber(Integer parallelNumber)
public Integer getParallelNumber()
public void setParallelNumber(Integer parallelNumber)
public SubmitFlinkSqlJobRequest checkpointEnabled(Boolean checkpointEnabled)
public Boolean getCheckpointEnabled()
public void setCheckpointEnabled(Boolean checkpointEnabled)
public SubmitFlinkSqlJobRequest checkpointMode(Integer checkpointMode)
public Integer getCheckpointMode()
public void setCheckpointMode(Integer checkpointMode)
public SubmitFlinkSqlJobRequest checkpointInterval(Integer checkpointInterval)
public Integer getCheckpointInterval()
public void setCheckpointInterval(Integer checkpointInterval)
public SubmitFlinkSqlJobRequest obsBucket(String obsBucket)
public String getObsBucket()
public void setObsBucket(String obsBucket)
public SubmitFlinkSqlJobRequest logEnabled(Boolean logEnabled)
public Boolean getLogEnabled()
public void setLogEnabled(Boolean logEnabled)
public SubmitFlinkSqlJobRequest smnTopic(String smnTopic)
public String getSmnTopic()
public void setSmnTopic(String smnTopic)
public SubmitFlinkSqlJobRequest restartWhenException(Boolean restartWhenException)
public Boolean getRestartWhenException()
public void setRestartWhenException(Boolean restartWhenException)
public SubmitFlinkSqlJobRequest idleStateRetention(Integer idleStateRetention)
public Integer getIdleStateRetention()
public void setIdleStateRetention(Integer idleStateRetention)
public SubmitFlinkSqlJobRequest jobType(SubmitFlinkSqlJobRequest.JobTypeEnum jobType)
public SubmitFlinkSqlJobRequest.JobTypeEnum getJobType()
public void setJobType(SubmitFlinkSqlJobRequest.JobTypeEnum jobType)
public SubmitFlinkSqlJobRequest edgeGroupIds(List<String> edgeGroupIds)
public SubmitFlinkSqlJobRequest addEdgeGroupIdsItem(String edgeGroupIdsItem)
public SubmitFlinkSqlJobRequest dirtyDataStrategy(String dirtyDataStrategy)
public String getDirtyDataStrategy()
public void setDirtyDataStrategy(String dirtyDataStrategy)
public SubmitFlinkSqlJobRequest udfJarUrl(String udfJarUrl)
public String getUdfJarUrl()
public void setUdfJarUrl(String udfJarUrl)
Copyright © 2023. All rights reserved.