Google Cloud Dataproc v1 API - Class FlinkJob (5.16.0)

public sealed class FlinkJob : IMessage<FlinkJob>, IEquatable<FlinkJob>, IDeepCloneable<FlinkJob>, IBufferMessage, IMessage

Reference documentation and code samples for the Google Cloud Dataproc v1 API class FlinkJob.

A Dataproc job for running Apache Flink applications on YARN.

Inheritance

object > FlinkJob

Implements

IMessage FlinkJob, IEquatable FlinkJob, IDeepCloneable FlinkJob, IBufferMessage, IMessage

Inherited Members

object.GetHashCode()

object.GetType()

object.ToString()

Namespace

Google.Cloud.Dataproc.V1

Assembly

Google.Cloud.Dataproc.V1.dll

Constructors

FlinkJob()

public FlinkJob()

FlinkJob(FlinkJob)

public FlinkJob(FlinkJob other)

Parameter
Name	Description
`other`	`FlinkJob`

Properties

Args

public RepeatedField<string> Args { get; }

Optional. The arguments to pass to the driver. Do not include arguments, such as --conf, that can be set as job properties, since a collision might occur that causes an incorrect job submission.

Property Value
Type	Description
`RepeatedFieldstring`

DriverCase

public FlinkJob.DriverOneofCase DriverCase { get; }

Property Value
Type	Description
`FlinkJobDriverOneofCase`

HasMainClass

public bool HasMainClass { get; }

Gets whether the "main_class" field is set

Property Value
Type	Description
`bool`

HasMainJarFileUri

public bool HasMainJarFileUri { get; }

Gets whether the "main_jar_file_uri" field is set

Property Value
Type	Description
`bool`

JarFileUris

public RepeatedField<string> JarFileUris { get; }

Optional. HCFS URIs of jar files to add to the CLASSPATHs of the Flink driver and tasks.

Property Value
Type	Description
`RepeatedFieldstring`

LoggingConfig

public LoggingConfig LoggingConfig { get; set; }

Optional. The runtime log config for job execution.

Property Value
Type	Description
`LoggingConfig`

MainClass

public string MainClass { get; set; }

The name of the driver's main class. The jar file that contains the class must be in the default CLASSPATH or specified in [jarFileUris][google.cloud.dataproc.v1.FlinkJob.jar_file_uris].

Property Value
Type	Description
`string`

MainJarFileUri

public string MainJarFileUri { get; set; }

The HCFS URI of the jar file that contains the main class.

Property Value
Type	Description
`string`

Properties

public MapField<string, string> Properties { get; }

Optional. A mapping of property names to values, used to configure Flink. Properties that conflict with values set by the Dataproc API might be overwritten. Can include properties set in /etc/flink/conf/flink-defaults.conf and classes in user code.

Property Value
Type	Description
`MapFieldstringstring`

SavepointUri

public string SavepointUri { get; set; }

Optional. HCFS URI of the savepoint, which contains the last saved progress for starting the current job.

Property Value
Type	Description
`string`