FlinkJobProperties Class

Definition

Namespace:

Azure.ResourceManager.HDInsight.Containers.Models

Assembly:

Azure.ResourceManager.HDInsight.Containers.dll

Package:

Azure.ResourceManager.HDInsight.Containers v1.0.0-beta.3

Source:

FlinkJobProperties.cs

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

Object

ClusterJobProperties

FlinkJobProperties

Implements

IJsonModel<FlinkJobProperties> IPersistableModel<FlinkJobProperties> IPersistableModel<T>

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.