Share via


FlinkJobProperties Class

Definition

Properties of flink job.

public class FlinkJobProperties : Azure.ResourceManager.HDInsight.Containers.Models.ClusterJobProperties, System.ClientModel.Primitives.IJsonModel<Azure.ResourceManager.HDInsight.Containers.Models.FlinkJobProperties>, System.ClientModel.Primitives.IPersistableModel<Azure.ResourceManager.HDInsight.Containers.Models.FlinkJobProperties>
type FlinkJobProperties = class
    inherit ClusterJobProperties
    interface IJsonModel<FlinkJobProperties>
    interface IPersistableModel<FlinkJobProperties>
Public Class FlinkJobProperties
Inherits ClusterJobProperties
Implements IJsonModel(Of FlinkJobProperties), IPersistableModel(Of FlinkJobProperties)
Inheritance
FlinkJobProperties
Implements

Constructors

FlinkJobProperties()

Initializes a new instance of FlinkJobProperties.

Properties

Action

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.

ActionResult

Action result of job.

Args

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

EntryClass

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

FlinkConfiguration

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.

JarName

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

JobId

Unique id for identifying a job.

JobJarDirectory

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

JobName

Name of job.

JobOutput

Output of job.

LastSavePoint

The last savepoint.

RunId

Run id of job.

SavePointName

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

Status

Status of job.

Explicit Interface Implementations

IJsonModel<ClusterJobProperties>.Create(Utf8JsonReader, ModelReaderWriterOptions)

Reads one JSON value (including objects or arrays) from the provided reader and converts it to a model.

(Inherited from ClusterJobProperties)
IJsonModel<ClusterJobProperties>.Write(Utf8JsonWriter, ModelReaderWriterOptions)

Writes the model to the provided Utf8JsonWriter.

(Inherited from ClusterJobProperties)
IJsonModel<FlinkJobProperties>.Create(Utf8JsonReader, ModelReaderWriterOptions)

Reads one JSON value (including objects or arrays) from the provided reader and converts it to a model.

IJsonModel<FlinkJobProperties>.Write(Utf8JsonWriter, ModelReaderWriterOptions)

Writes the model to the provided Utf8JsonWriter.

IPersistableModel<ClusterJobProperties>.Create(BinaryData, ModelReaderWriterOptions)

Converts the provided BinaryData into a model.

(Inherited from ClusterJobProperties)
IPersistableModel<ClusterJobProperties>.GetFormatFromOptions(ModelReaderWriterOptions)

Gets the data interchange format (JSON, Xml, etc) that the model uses when communicating with the service.

(Inherited from ClusterJobProperties)
IPersistableModel<ClusterJobProperties>.Write(ModelReaderWriterOptions)

Writes the model into a BinaryData.

(Inherited from ClusterJobProperties)
IPersistableModel<FlinkJobProperties>.Create(BinaryData, ModelReaderWriterOptions)

Converts the provided BinaryData into a model.

IPersistableModel<FlinkJobProperties>.GetFormatFromOptions(ModelReaderWriterOptions)

Gets the data interchange format (JSON, Xml, etc) that the model uses when communicating with the service.

IPersistableModel<FlinkJobProperties>.Write(ModelReaderWriterOptions)

Writes the model into a BinaryData.

Applies to