Interface FlinkJobOrBuilder (4.73.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()

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];

Returns
Type	Description
int

getPropertiesMap()

public abstract Map<String,String> getPropertiesMap()

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];

Returns
Type	Description
Map<String,String>

getPropertiesOrDefault(String key, String defaultValue)

public abstract String getPropertiesOrDefault(String key, String defaultValue)

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];

Parameters
Name	Description
key	String
defaultValue	String

Returns
Type	Description
String

getPropertiesOrThrow(String key)

public abstract String getPropertiesOrThrow(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
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.