Some or all of the information on this page might not apply to Cloud de Confiance by S3NS. See Differences from Google Cloud for more details.

Interface FlinkJobOrBuilder (4.52.0)

public interface FlinkJobOrBuilder extends MessageOrBuilder

Implements

MessageOrBuilder

Methods

containsProperties(String key)

public abstract boolean containsProperties(String key)

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.

map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL];

Parameter
Name	Description
`key`	`String`

Returns
Type	Description
`boolean`

getArgs(int index)

public abstract String getArgs(int index)

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.

repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];

Parameter
Name	Description
`index`	`int` The index of the element to return.

Returns
Type	Description
`String`	The args at the given index.

getArgsBytes(int index)

public abstract ByteString getArgsBytes(int index)

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.

repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];

Parameter
Name	Description
`index`	`int` The index of the value to return.

Returns
Type	Description
`ByteString`	The bytes of the args at the given index.

getArgsCount()

public abstract int getArgsCount()

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.

repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];

Returns
Type	Description
`int`	The count of args.

getArgsList()

public abstract List<String> getArgsList()

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.

repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];

Returns
Type	Description
`List<String>`	A list containing the args.

getDriverCase()

public abstract FlinkJob.DriverCase getDriverCase()

Returns
Type	Description
`FlinkJob.DriverCase`

getJarFileUris(int index)

public abstract String getJarFileUris(int index)

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

repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];

Parameter
Name	Description
`index`	`int` The index of the element to return.

Returns
Type	Description
`String`	The jarFileUris at the given index.

getJarFileUrisBytes(int index)

public abstract ByteString getJarFileUrisBytes(int index)

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

repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];

Parameter
Name	Description
`index`	`int` The index of the value to return.

Returns
Type	Description
`ByteString`	The bytes of the jarFileUris at the given index.

getJarFileUrisCount()

public abstract int getJarFileUrisCount()

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

repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];

Returns
Type	Description
`int`	The count of jarFileUris.

getJarFileUrisList()

public abstract List<String> getJarFileUrisList()

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

repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];

Returns
Type	Description
`List<String>`	A list containing the jarFileUris.

getLoggingConfig()

public abstract LoggingConfig getLoggingConfig()

Optional. The runtime log config for job execution.

.google.cloud.dataproc.v1.LoggingConfig logging_config = 8 [(.google.api.field_behavior) = OPTIONAL];

Returns
Type	Description
`LoggingConfig`	The loggingConfig.

getLoggingConfigOrBuilder()

public abstract LoggingConfigOrBuilder getLoggingConfigOrBuilder()

Optional. The runtime log config for job execution.

.google.cloud.dataproc.v1.LoggingConfig logging_config = 8 [(.google.api.field_behavior) = OPTIONAL];

Returns
Type	Description
`LoggingConfigOrBuilder`

getMainClass()

public abstract String getMainClass()

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.

string main_class = 2;

Returns
Type	Description
`String`	The mainClass.

getMainClassBytes()

public abstract ByteString getMainClassBytes()

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.

string main_class = 2;

Returns
Type	Description
`ByteString`	The bytes for mainClass.

getMainJarFileUri()

public abstract String getMainJarFileUri()

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

string main_jar_file_uri = 1;

Returns
Type	Description
`String`	The mainJarFileUri.

getMainJarFileUriBytes()

public abstract ByteString getMainJarFileUriBytes()

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

string main_jar_file_uri = 1;

Returns
Type	Description
`ByteString`	The bytes for mainJarFileUri.

getProperties() (deprecated)

public abstract Map<String,String> getProperties()

Use #getPropertiesMap() instead.

Returns
Type	Description
`Map<String,String>`

getPropertiesCount()

public abstract int getPropertiesCount()

map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL];

Returns
Type	Description
`int`

getPropertiesMap()

public abstract Map<String,String> getPropertiesMap()

map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL];

Returns
Type	Description
`Map<String,String>`

getPropertiesOrDefault(String key, String defaultValue)

public abstract String getPropertiesOrDefault(String key, String defaultValue)

map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL];

Parameters
Name	Description
`key`	`String`
`defaultValue`	`String`

Returns
Type	Description
`String`

getPropertiesOrThrow(String key)

public abstract String getPropertiesOrThrow(String key)

map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL];

Parameter
Name	Description
`key`	`String`

Returns
Type	Description
`String`

getSavepointUri()

public abstract String getSavepointUri()

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

string savepoint_uri = 9 [(.google.api.field_behavior) = OPTIONAL];

Returns
Type	Description
`String`	The savepointUri.

getSavepointUriBytes()

public abstract ByteString getSavepointUriBytes()

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

string savepoint_uri = 9 [(.google.api.field_behavior) = OPTIONAL];

Returns
Type	Description
`ByteString`	The bytes for savepointUri.

hasLoggingConfig()

public abstract boolean hasLoggingConfig()

Optional. The runtime log config for job execution.

.google.cloud.dataproc.v1.LoggingConfig logging_config = 8 [(.google.api.field_behavior) = OPTIONAL];

Returns
Type	Description
`boolean`	Whether the loggingConfig field is set.

hasMainClass()

public abstract boolean hasMainClass()

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.

string main_class = 2;

Returns
Type	Description
`boolean`	Whether the mainClass field is set.

hasMainJarFileUri()

public abstract boolean hasMainJarFileUri()

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

string main_jar_file_uri = 1;

Returns
Type	Description
`boolean`	Whether the mainJarFileUri field is set.