FlinkJobProfile Class

Reference

Definition

Namespace:: Azure.ResourceManager.HDInsight.Containers.Models

Assembly:: Azure.ResourceManager.HDInsight.Containers.dll

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

Source:: FlinkJobProfile.cs

Important

Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.

Job specifications for flink clusters in application deployment mode. The specification is immutable even if job properties are changed by calling the RunJob API, please use the ListJob API to get the latest job information.

public class FlinkJobProfile : System.ClientModel.Primitives.IJsonModel<Azure.ResourceManager.HDInsight.Containers.Models.FlinkJobProfile>, System.ClientModel.Primitives.IPersistableModel<Azure.ResourceManager.HDInsight.Containers.Models.FlinkJobProfile>

type FlinkJobProfile = class
    interface IJsonModel<FlinkJobProfile>
    interface IPersistableModel<FlinkJobProfile>

Public Class FlinkJobProfile
Implements IJsonModel(Of FlinkJobProfile), IPersistableModel(Of FlinkJobProfile)

Inheritance: Object
FlinkJobProfile

Implements: IJsonModel<FlinkJobProfile> IPersistableModel<FlinkJobProfile> IPersistableModel<T>

Constructors

FlinkJobProfile(String, String, UpgradeMode)

Initializes a new instance of FlinkJobProfile.

Properties

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. If not specified, the entry point is auto-detected from the flink job jar package.
JarName	A string property that represents the name of the job JAR.
JobJarDirectory	A string property that specifies the directory where the job JAR is located.
SavePointName	A string property that represents the name of the savepoint for the Flink job.
UpgradeMode	A string property that indicates the upgrade mode to be performed on the Flink job. It can have one of the following enum values => STATELESS_UPDATE, UPDATE, LAST_STATE_UPDATE.

Explicit Interface Implementations

IJsonModel<FlinkJobProfile>.Create(Utf8JsonReader, ModelReaderWriterOptions)	Reads one JSON value (including objects or arrays) from the provided reader and converts it to a model.
IJsonModel<FlinkJobProfile>.Write(Utf8JsonWriter, ModelReaderWriterOptions)	Writes the model to the provided Utf8JsonWriter.
IPersistableModel<FlinkJobProfile>.Create(BinaryData, ModelReaderWriterOptions)	Converts the provided BinaryData into a model.
IPersistableModel<FlinkJobProfile>.GetFormatFromOptions(ModelReaderWriterOptions)	Gets the data interchange format (JSON, Xml, etc) that the model uses when communicating with the service.
IPersistableModel<FlinkJobProfile>.Write(ModelReaderWriterOptions)	Writes the model into a BinaryData.

Applies to