Dela via


ArmHDInsightContainersModelFactory.FlinkJobProperties Method

Definition

Initializes a new instance of FlinkJobProperties.

public static Azure.ResourceManager.HDInsight.Containers.Models.FlinkJobProperties FlinkJobProperties (string runId = default, string jobName = default, string jobJarDirectory = default, string jarName = default, string entryClass = default, string args = default, string savePointName = default, Azure.ResourceManager.HDInsight.Containers.Models.FlinkJobAction? action = default, System.Collections.Generic.IDictionary<string,string> flinkConfiguration = default, string jobId = default, string status = default, string jobOutput = default, string actionResult = default, string lastSavePoint = default);
static member FlinkJobProperties : string * string * string * string * string * string * string * Nullable<Azure.ResourceManager.HDInsight.Containers.Models.FlinkJobAction> * System.Collections.Generic.IDictionary<string, string> * string * string * string * string * string -> Azure.ResourceManager.HDInsight.Containers.Models.FlinkJobProperties
Public Shared Function FlinkJobProperties (Optional runId As String = Nothing, Optional jobName As String = Nothing, Optional jobJarDirectory As String = Nothing, Optional jarName As String = Nothing, Optional entryClass As String = Nothing, Optional args As String = Nothing, Optional savePointName As String = Nothing, Optional action As Nullable(Of FlinkJobAction) = Nothing, Optional flinkConfiguration As IDictionary(Of String, String) = Nothing, Optional jobId As String = Nothing, Optional status As String = Nothing, Optional jobOutput As String = Nothing, Optional actionResult As String = Nothing, Optional lastSavePoint As String = Nothing) As FlinkJobProperties

Parameters

runId
String

Run id of job.

jobName
String

Name of job.

jobJarDirectory
String

A string property that specifies the directory where the job JAR is located.

jarName
String

A string property that represents the name of the job JAR.

entryClass
String

A string property that specifies the entry class for the Flink job.

args
String

A string property representing additional JVM arguments for the Flink job. It should be space separated value.

savePointName
String

A string property that represents the name of the savepoint for the Flink job.

action
Nullable<FlinkJobAction>

A string property that indicates the action to be performed on the Flink job. It can have one of the following enum values => NEW, UPDATE, STATELESS_UPDATE, STOP, START, CANCEL, SAVEPOINT, LIST_SAVEPOINT, or DELETE.

flinkConfiguration
IDictionary<String,String>

Additional properties used to configure Flink jobs. It allows users to set properties such as parallelism and jobSavePointDirectory. It accepts additional key-value pairs as properties, where the keys are strings and the values are strings as well.

jobId
String

Unique id for identifying a job.

status
String

Status of job.

jobOutput
String

Output of job.

actionResult
String

Action result of job.

lastSavePoint
String

The last savepoint.

Returns

A new FlinkJobProperties instance for mocking.

Applies to