com.google.cloud.dataproc.v1

Interface FlinkJobOrBuilder

All Superinterfaces:

com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder

All Known Implementing Classes:

FlinkJob, FlinkJob.Builder

public interface FlinkJobOrBuilder
extends com.google.protobuf.MessageOrBuilder

Method Summary

Modifier and Type	Method and Description
boolean	containsProperties(String key) Optional.
String	getArgs(int index) Optional.
com.google.protobuf.ByteString	getArgsBytes(int index) Optional.
int	getArgsCount() Optional.
List<String>	getArgsList() Optional.
FlinkJob.DriverCase	getDriverCase()
String	getJarFileUris(int index) Optional.
com.google.protobuf.ByteString	getJarFileUrisBytes(int index) Optional.
int	getJarFileUrisCount() Optional.
List<String>	getJarFileUrisList() Optional.
LoggingConfig	getLoggingConfig() Optional.
LoggingConfigOrBuilder	getLoggingConfigOrBuilder() Optional.
String	getMainClass() The name of the driver's main class.
com.google.protobuf.ByteString	getMainClassBytes() The name of the driver's main class.
String	getMainJarFileUri() The HCFS URI of the jar file that contains the main class.
com.google.protobuf.ByteString	getMainJarFileUriBytes() The HCFS URI of the jar file that contains the main class.
Map<String,String>	getProperties() Deprecated.
int	getPropertiesCount() Optional.
Map<String,String>	getPropertiesMap() Optional.
String	getPropertiesOrDefault(String key, String defaultValue) Optional.
String	getPropertiesOrThrow(String key) Optional.
String	getSavepointUri() Optional.
com.google.protobuf.ByteString	getSavepointUriBytes() Optional.
boolean	hasLoggingConfig() Optional.
boolean	hasMainClass() The name of the driver's main class.
boolean	hasMainJarFileUri() The HCFS URI of the jar file that contains the main class.

Methods inherited from interface com.google.protobuf.MessageOrBuilder

findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Methods inherited from interface com.google.protobuf.MessageLiteOrBuilder

isInitialized

Method Detail

hasMainJarFileUri

boolean hasMainJarFileUri()

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

string main_jar_file_uri = 1;

Returns:

Whether the mainJarFileUri field is set.

getMainJarFileUri

String getMainJarFileUri()

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

string main_jar_file_uri = 1;

Returns:

The mainJarFileUri.

getMainJarFileUriBytes

com.google.protobuf.ByteString getMainJarFileUriBytes()

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

string main_jar_file_uri = 1;

Returns:

The bytes for mainJarFileUri.

hasMainClass

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][google.cloud.dataproc.v1.FlinkJob.jar_file_uris].
 

string main_class = 2;

Returns:

Whether the mainClass field is set.

getMainClass

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][google.cloud.dataproc.v1.FlinkJob.jar_file_uris].
 

string main_class = 2;

Returns:

The mainClass.

getMainClassBytes

com.google.protobuf.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][google.cloud.dataproc.v1.FlinkJob.jar_file_uris].
 

string main_class = 2;

Returns:

The bytes for mainClass.

getArgsList

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:

A list containing the args.

getArgsCount

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:

The count of args.

getArgs

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

Parameters:

index - The index of the element to return.

Returns:

The args at the given index.

getArgsBytes

com.google.protobuf.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];

Parameters:

index - The index of the value to return.

Returns:

The bytes of the args at the given index.

getJarFileUrisList

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:

A list containing the jarFileUris.

getJarFileUrisCount

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:

The count of jarFileUris.

getJarFileUris

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

Parameters:

index - The index of the element to return.

Returns:

The jarFileUris at the given index.

getJarFileUrisBytes

com.google.protobuf.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];

Parameters:

index - The index of the value to return.

Returns:

The bytes of the jarFileUris at the given index.

getSavepointUri

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:

The savepointUri.

getSavepointUriBytes

com.google.protobuf.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:

The bytes for savepointUri.

getPropertiesCount

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

containsProperties

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

getProperties

@Deprecated
Map<String,String> getProperties()

Deprecated.

Use getPropertiesMap() instead.

getPropertiesMap

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

getPropertiesOrDefault

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

getPropertiesOrThrow

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

hasLoggingConfig

boolean hasLoggingConfig()

 Optional. The runtime log config for job execution.
 

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

Returns:

Whether the loggingConfig field is set.

getLoggingConfig

LoggingConfig getLoggingConfig()

 Optional. The runtime log config for job execution.
 

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

Returns:

The loggingConfig.

getLoggingConfigOrBuilder

LoggingConfigOrBuilder getLoggingConfigOrBuilder()

 Optional. The runtime log config for job execution.
 

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

getDriverCase

FlinkJob.DriverCase getDriverCase()