public interface SparkJobOrBuilder extends MessageOrBuilder
Modifier and Type | Method and Description |
---|---|
boolean |
containsProperties(java.lang.String key)
Optional.
|
java.lang.String |
getArchiveUris(int index)
Optional.
|
ByteString |
getArchiveUrisBytes(int index)
Optional.
|
int |
getArchiveUrisCount()
Optional.
|
java.util.List<java.lang.String> |
getArchiveUrisList()
Optional.
|
java.lang.String |
getArgs(int index)
Optional.
|
ByteString |
getArgsBytes(int index)
Optional.
|
int |
getArgsCount()
Optional.
|
java.util.List<java.lang.String> |
getArgsList()
Optional.
|
SparkJob.DriverCase |
getDriverCase() |
java.lang.String |
getFileUris(int index)
Optional.
|
ByteString |
getFileUrisBytes(int index)
Optional.
|
int |
getFileUrisCount()
Optional.
|
java.util.List<java.lang.String> |
getFileUrisList()
Optional.
|
java.lang.String |
getJarFileUris(int index)
Optional.
|
ByteString |
getJarFileUrisBytes(int index)
Optional.
|
int |
getJarFileUrisCount()
Optional.
|
java.util.List<java.lang.String> |
getJarFileUrisList()
Optional.
|
LoggingConfig |
getLoggingConfig()
Optional.
|
LoggingConfigOrBuilder |
getLoggingConfigOrBuilder()
Optional.
|
java.lang.String |
getMainClass()
The name of the driver's main class.
|
ByteString |
getMainClassBytes()
The name of the driver's main class.
|
java.lang.String |
getMainJarFileUri()
The HCFS URI of the jar file that contains the main class.
|
ByteString |
getMainJarFileUriBytes()
The HCFS URI of the jar file that contains the main class.
|
java.util.Map<java.lang.String,java.lang.String> |
getProperties()
Deprecated.
|
int |
getPropertiesCount()
Optional.
|
java.util.Map<java.lang.String,java.lang.String> |
getPropertiesMap()
Optional.
|
java.lang.String |
getPropertiesOrDefault(java.lang.String key,
java.lang.String defaultValue)
Optional.
|
java.lang.String |
getPropertiesOrThrow(java.lang.String key)
Optional.
|
boolean |
hasLoggingConfig()
Optional.
|
findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
isInitialized
java.lang.String getMainJarFileUri()
The HCFS URI of the jar file that contains the main class.
string main_jar_file_uri = 1;
ByteString getMainJarFileUriBytes()
The HCFS URI of the jar file that contains the main class.
string main_jar_file_uri = 1;
java.lang.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 `jar_file_uris`.
string main_class = 2;
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 `jar_file_uris`.
string main_class = 2;
java.util.List<java.lang.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 may occur that causes an incorrect job submission.
repeated string args = 3;
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 may occur that causes an incorrect job submission.
repeated string args = 3;
java.lang.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 may occur that causes an incorrect job submission.
repeated string args = 3;
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 may occur that causes an incorrect job submission.
repeated string args = 3;
java.util.List<java.lang.String> getJarFileUrisList()
Optional. HCFS URIs of jar files to add to the CLASSPATHs of the Spark driver and tasks.
repeated string jar_file_uris = 4;
int getJarFileUrisCount()
Optional. HCFS URIs of jar files to add to the CLASSPATHs of the Spark driver and tasks.
repeated string jar_file_uris = 4;
java.lang.String getJarFileUris(int index)
Optional. HCFS URIs of jar files to add to the CLASSPATHs of the Spark driver and tasks.
repeated string jar_file_uris = 4;
ByteString getJarFileUrisBytes(int index)
Optional. HCFS URIs of jar files to add to the CLASSPATHs of the Spark driver and tasks.
repeated string jar_file_uris = 4;
java.util.List<java.lang.String> getFileUrisList()
Optional. HCFS URIs of files to be copied to the working directory of Spark drivers and distributed tasks. Useful for naively parallel tasks.
repeated string file_uris = 5;
int getFileUrisCount()
Optional. HCFS URIs of files to be copied to the working directory of Spark drivers and distributed tasks. Useful for naively parallel tasks.
repeated string file_uris = 5;
java.lang.String getFileUris(int index)
Optional. HCFS URIs of files to be copied to the working directory of Spark drivers and distributed tasks. Useful for naively parallel tasks.
repeated string file_uris = 5;
ByteString getFileUrisBytes(int index)
Optional. HCFS URIs of files to be copied to the working directory of Spark drivers and distributed tasks. Useful for naively parallel tasks.
repeated string file_uris = 5;
java.util.List<java.lang.String> getArchiveUrisList()
Optional. HCFS URIs of archives to be extracted in the working directory of Spark drivers and tasks. Supported file types: .jar, .tar, .tar.gz, .tgz, and .zip.
repeated string archive_uris = 6;
int getArchiveUrisCount()
Optional. HCFS URIs of archives to be extracted in the working directory of Spark drivers and tasks. Supported file types: .jar, .tar, .tar.gz, .tgz, and .zip.
repeated string archive_uris = 6;
java.lang.String getArchiveUris(int index)
Optional. HCFS URIs of archives to be extracted in the working directory of Spark drivers and tasks. Supported file types: .jar, .tar, .tar.gz, .tgz, and .zip.
repeated string archive_uris = 6;
ByteString getArchiveUrisBytes(int index)
Optional. HCFS URIs of archives to be extracted in the working directory of Spark drivers and tasks. Supported file types: .jar, .tar, .tar.gz, .tgz, and .zip.
repeated string archive_uris = 6;
int getPropertiesCount()
Optional. A mapping of property names to values, used to configure Spark. Properties that conflict with values set by the Cloud Dataproc API may be overwritten. Can include properties set in /etc/spark/conf/spark-defaults.conf and classes in user code.
map<string, string> properties = 7;
boolean containsProperties(java.lang.String key)
Optional. A mapping of property names to values, used to configure Spark. Properties that conflict with values set by the Cloud Dataproc API may be overwritten. Can include properties set in /etc/spark/conf/spark-defaults.conf and classes in user code.
map<string, string> properties = 7;
@Deprecated java.util.Map<java.lang.String,java.lang.String> getProperties()
getPropertiesMap()
instead.java.util.Map<java.lang.String,java.lang.String> getPropertiesMap()
Optional. A mapping of property names to values, used to configure Spark. Properties that conflict with values set by the Cloud Dataproc API may be overwritten. Can include properties set in /etc/spark/conf/spark-defaults.conf and classes in user code.
map<string, string> properties = 7;
java.lang.String getPropertiesOrDefault(java.lang.String key, java.lang.String defaultValue)
Optional. A mapping of property names to values, used to configure Spark. Properties that conflict with values set by the Cloud Dataproc API may be overwritten. Can include properties set in /etc/spark/conf/spark-defaults.conf and classes in user code.
map<string, string> properties = 7;
java.lang.String getPropertiesOrThrow(java.lang.String key)
Optional. A mapping of property names to values, used to configure Spark. Properties that conflict with values set by the Cloud Dataproc API may be overwritten. Can include properties set in /etc/spark/conf/spark-defaults.conf and classes in user code.
map<string, string> properties = 7;
boolean hasLoggingConfig()
Optional. The runtime log config for job execution.
.google.cloud.dataproc.v1.LoggingConfig logging_config = 8;
LoggingConfig getLoggingConfig()
Optional. The runtime log config for job execution.
.google.cloud.dataproc.v1.LoggingConfig logging_config = 8;
LoggingConfigOrBuilder getLoggingConfigOrBuilder()
Optional. The runtime log config for job execution.
.google.cloud.dataproc.v1.LoggingConfig logging_config = 8;
SparkJob.DriverCase getDriverCase()