FlinkJobProfileArgs

data class FlinkJobProfileArgs(val args: Output<String>? = null, val entryClass: Output<String>? = null, val jarName: Output<String>, val jobJarDirectory: Output<String>, val savePointName: Output<String>? = null, val upgradeMode: Output<Either<String, UpgradeMode>>) : ConvertibleToJava<FlinkJobProfileArgs>

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.

Constructors

Link copied to clipboard
constructor(args: Output<String>? = null, entryClass: Output<String>? = null, jarName: Output<String>, jobJarDirectory: Output<String>, savePointName: Output<String>? = null, upgradeMode: Output<Either<String, UpgradeMode>>)

Properties

Link copied to clipboard
val args: Output<String>? = null

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

Link copied to clipboard
val entryClass: Output<String>? = null

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.

Link copied to clipboard
val jarName: Output<String>

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

Link copied to clipboard
val jobJarDirectory: Output<String>

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

Link copied to clipboard
val savePointName: Output<String>? = null

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

Link copied to clipboard
val upgradeMode: Output<Either<String, 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.

Functions

Link copied to clipboard
open override fun toJava(): FlinkJobProfileArgs