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