com.google.cloud.dataproc.v1

Class SparkRJob

java.lang.Object

com.google.protobuf.AbstractMessageLite

com.google.protobuf.AbstractMessage

com.google.protobuf.GeneratedMessageV3

com.google.cloud.dataproc.v1.SparkRJob

All Implemented Interfaces:

SparkRJobOrBuilder, Message, MessageLite, MessageLiteOrBuilder, MessageOrBuilder, Serializable

public final class SparkRJob
extends GeneratedMessageV3
implements SparkRJobOrBuilder

 A Dataproc job for running
 [Apache SparkR](https://spark.apache.org/docs/latest/sparkr.html)
 applications on YARN.
 

Protobuf type google.cloud.dataproc.v1.SparkRJob

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SparkRJob.Builder A Dataproc job for running [Apache SparkR](https://spark.apache.org/docs/latest/sparkr.html) applications on YARN.

Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageV3

GeneratedMessageV3.BuilderParent, GeneratedMessageV3.ExtendableBuilder<MessageType extends GeneratedMessageV3.ExtendableMessage,BuilderType extends GeneratedMessageV3.ExtendableBuilder<MessageType,BuilderType>>, GeneratedMessageV3.ExtendableMessage<MessageType extends GeneratedMessageV3.ExtendableMessage>, GeneratedMessageV3.ExtendableMessageOrBuilder<MessageType extends GeneratedMessageV3.ExtendableMessage>, GeneratedMessageV3.FieldAccessorTable, GeneratedMessageV3.UnusedPrivateParameter

Nested classes/interfaces inherited from class com.google.protobuf.AbstractMessageLite

AbstractMessageLite.InternalOneOfEnum

Field Summary

Fields

Modifier and Type	Field and Description
static int	ARCHIVE_URIS_FIELD_NUMBER
static int	ARGS_FIELD_NUMBER
static int	FILE_URIS_FIELD_NUMBER
static int	LOGGING_CONFIG_FIELD_NUMBER
static int	MAIN_R_FILE_URI_FIELD_NUMBER
static int	PROPERTIES_FIELD_NUMBER

Fields inherited from class com.google.protobuf.GeneratedMessageV3

alwaysUseFieldBuilders, unknownFields

Fields inherited from class com.google.protobuf.AbstractMessage

memoizedSize

Fields inherited from class com.google.protobuf.AbstractMessageLite

memoizedHashCode

Method Summary

Modifier and Type	Method and Description
boolean	containsProperties(String key) Optional.
boolean	equals(Object obj)
String	getArchiveUris(int index) Optional.
ByteString	getArchiveUrisBytes(int index) Optional.
int	getArchiveUrisCount() Optional.
ProtocolStringList	getArchiveUrisList() Optional.
String	getArgs(int index) Optional.
ByteString	getArgsBytes(int index) Optional.
int	getArgsCount() Optional.
ProtocolStringList	getArgsList() Optional.
static SparkRJob	getDefaultInstance()
SparkRJob	getDefaultInstanceForType()
static Descriptors.Descriptor	getDescriptor()
String	getFileUris(int index) Optional.
ByteString	getFileUrisBytes(int index) Optional.
int	getFileUrisCount() Optional.
ProtocolStringList	getFileUrisList() Optional.
LoggingConfig	getLoggingConfig() Optional.
LoggingConfigOrBuilder	getLoggingConfigOrBuilder() Optional.
String	getMainRFileUri() Required.
ByteString	getMainRFileUriBytes() Required.
Parser<SparkRJob>	getParserForType()
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.
int	getSerializedSize()
UnknownFieldSet	getUnknownFields()
int	hashCode()
boolean	hasLoggingConfig() Optional.
protected GeneratedMessageV3.FieldAccessorTable	internalGetFieldAccessorTable()
protected MapField	internalGetMapField(int number)
boolean	isInitialized()
static SparkRJob.Builder	newBuilder()
static SparkRJob.Builder	newBuilder(SparkRJob prototype)
SparkRJob.Builder	newBuilderForType()
protected SparkRJob.Builder	newBuilderForType(GeneratedMessageV3.BuilderParent parent)
protected Object	newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
static SparkRJob	parseDelimitedFrom(InputStream input)
static SparkRJob	parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
static SparkRJob	parseFrom(byte[] data)
static SparkRJob	parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
static SparkRJob	parseFrom(ByteBuffer data)
static SparkRJob	parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
static SparkRJob	parseFrom(ByteString data)
static SparkRJob	parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
static SparkRJob	parseFrom(CodedInputStream input)
static SparkRJob	parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
static SparkRJob	parseFrom(InputStream input)
static SparkRJob	parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
static Parser<SparkRJob>	parser()
SparkRJob.Builder	toBuilder()
void	writeTo(CodedOutputStream output)

Methods inherited from class com.google.protobuf.GeneratedMessageV3

canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof, isStringEmpty, makeExtensionsImmutable, mergeFromAndMakeImmutableInternal, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, newBooleanList, newBuilderForType, newDoubleList, newFloatList, newIntList, newLongList, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTag

Methods inherited from class com.google.protobuf.AbstractMessage

findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite

addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.MessageOrBuilder

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

Methods inherited from interface com.google.protobuf.MessageLite

toByteArray, toByteString, writeDelimitedTo, writeTo

Field Detail

MAIN_R_FILE_URI_FIELD_NUMBER

public static final int MAIN_R_FILE_URI_FIELD_NUMBER

See Also:

Constant Field Values

ARGS_FIELD_NUMBER

public static final int ARGS_FIELD_NUMBER

See Also:

Constant Field Values

FILE_URIS_FIELD_NUMBER

public static final int FILE_URIS_FIELD_NUMBER

See Also:

Constant Field Values

ARCHIVE_URIS_FIELD_NUMBER

public static final int ARCHIVE_URIS_FIELD_NUMBER

See Also:

Constant Field Values

PROPERTIES_FIELD_NUMBER

public static final int PROPERTIES_FIELD_NUMBER

See Also:

Constant Field Values

LOGGING_CONFIG_FIELD_NUMBER

public static final int LOGGING_CONFIG_FIELD_NUMBER

See Also:

Constant Field Values

Method Detail

newInstance

protected Object newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)

Overrides:

newInstance in class GeneratedMessageV3

getUnknownFields

public final UnknownFieldSet getUnknownFields()

Specified by:

getUnknownFields in interface MessageOrBuilder

Overrides:

getUnknownFields in class GeneratedMessageV3

getDescriptor

public static final Descriptors.Descriptor getDescriptor()

internalGetMapField

protected MapField internalGetMapField(int number)

Overrides:

internalGetMapField in class GeneratedMessageV3

internalGetFieldAccessorTable

protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()

Specified by:

internalGetFieldAccessorTable in class GeneratedMessageV3

getMainRFileUri

public String getMainRFileUri()

 Required. The HCFS URI of the main R file to use as the driver.
 Must be a .R file.
 

string main_r_file_uri = 1 [(.google.api.field_behavior) = REQUIRED];

Specified by:

getMainRFileUri in interface SparkRJobOrBuilder

Returns:

The mainRFileUri.

getMainRFileUriBytes

public ByteString getMainRFileUriBytes()

 Required. The HCFS URI of the main R file to use as the driver.
 Must be a .R file.
 

string main_r_file_uri = 1 [(.google.api.field_behavior) = REQUIRED];

Specified by:

getMainRFileUriBytes in interface SparkRJobOrBuilder

Returns:

The bytes for mainRFileUri.

getArgsList

public ProtocolStringList 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 = 2 [(.google.api.field_behavior) = OPTIONAL];

Specified by:

getArgsList in interface SparkRJobOrBuilder

Returns:

A list containing the args.

getArgsCount

public 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 = 2 [(.google.api.field_behavior) = OPTIONAL];

Specified by:

getArgsCount in interface SparkRJobOrBuilder

Returns:

The count of args.

getArgs

public 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 = 2 [(.google.api.field_behavior) = OPTIONAL];

Specified by:

getArgs in interface SparkRJobOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The args at the given index.

getArgsBytes

public 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 = 2 [(.google.api.field_behavior) = OPTIONAL];

Specified by:

getArgsBytes in interface SparkRJobOrBuilder

Parameters:

index - The index of the value to return.

Returns:

The bytes of the args at the given index.

getFileUrisList

public ProtocolStringList getFileUrisList()

 Optional. HCFS URIs of files to be placed in the working directory of
 each executor. Useful for naively parallel tasks.
 

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

Specified by:

getFileUrisList in interface SparkRJobOrBuilder

Returns:

A list containing the fileUris.

getFileUrisCount

public int getFileUrisCount()

 Optional. HCFS URIs of files to be placed in the working directory of
 each executor. Useful for naively parallel tasks.
 

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

Specified by:

getFileUrisCount in interface SparkRJobOrBuilder

Returns:

The count of fileUris.

getFileUris

public String getFileUris(int index)

 Optional. HCFS URIs of files to be placed in the working directory of
 each executor. Useful for naively parallel tasks.
 

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

Specified by:

getFileUris in interface SparkRJobOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The fileUris at the given index.

getFileUrisBytes

public ByteString getFileUrisBytes(int index)

 Optional. HCFS URIs of files to be placed in the working directory of
 each executor. Useful for naively parallel tasks.
 

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

Specified by:

getFileUrisBytes in interface SparkRJobOrBuilder

Parameters:

index - The index of the value to return.

Returns:

The bytes of the fileUris at the given index.

getArchiveUrisList

public ProtocolStringList getArchiveUrisList()

 Optional. HCFS URIs of archives to be extracted into the working directory
 of each executor. Supported file types:
 .jar, .tar, .tar.gz, .tgz, and .zip.
 

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

Specified by:

getArchiveUrisList in interface SparkRJobOrBuilder

Returns:

A list containing the archiveUris.

getArchiveUrisCount

public int getArchiveUrisCount()

 Optional. HCFS URIs of archives to be extracted into the working directory
 of each executor. Supported file types:
 .jar, .tar, .tar.gz, .tgz, and .zip.
 

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

Specified by:

getArchiveUrisCount in interface SparkRJobOrBuilder

Returns:

The count of archiveUris.

getArchiveUris

public String getArchiveUris(int index)

 Optional. HCFS URIs of archives to be extracted into the working directory
 of each executor. Supported file types:
 .jar, .tar, .tar.gz, .tgz, and .zip.
 

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

Specified by:

getArchiveUris in interface SparkRJobOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The archiveUris at the given index.

getArchiveUrisBytes

public ByteString getArchiveUrisBytes(int index)

 Optional. HCFS URIs of archives to be extracted into the working directory
 of each executor. Supported file types:
 .jar, .tar, .tar.gz, .tgz, and .zip.
 

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

Specified by:

getArchiveUrisBytes in interface SparkRJobOrBuilder

Parameters:

index - The index of the value to return.

Returns:

The bytes of the archiveUris at the given index.

getPropertiesCount

public int getPropertiesCount()

Description copied from interface: SparkRJobOrBuilder

 Optional. A mapping of property names to values, used to configure SparkR.
 Properties that conflict with values set by the 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 = 5 [(.google.api.field_behavior) = OPTIONAL];

Specified by:

getPropertiesCount in interface SparkRJobOrBuilder

containsProperties

public boolean containsProperties(String key)

 Optional. A mapping of property names to values, used to configure SparkR.
 Properties that conflict with values set by the 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 = 5 [(.google.api.field_behavior) = OPTIONAL];

Specified by:

containsProperties in interface SparkRJobOrBuilder

getProperties

@Deprecated
public Map<String,String> getProperties()

Deprecated.

Use getPropertiesMap() instead.

Specified by:

getProperties in interface SparkRJobOrBuilder

getPropertiesMap

public Map<String,String> getPropertiesMap()

 Optional. A mapping of property names to values, used to configure SparkR.
 Properties that conflict with values set by the 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 = 5 [(.google.api.field_behavior) = OPTIONAL];

Specified by:

getPropertiesMap in interface SparkRJobOrBuilder

getPropertiesOrDefault

public String getPropertiesOrDefault(String key,
                                     String defaultValue)

 Optional. A mapping of property names to values, used to configure SparkR.
 Properties that conflict with values set by the 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 = 5 [(.google.api.field_behavior) = OPTIONAL];

Specified by:

getPropertiesOrDefault in interface SparkRJobOrBuilder

getPropertiesOrThrow

public String getPropertiesOrThrow(String key)

 Optional. A mapping of property names to values, used to configure SparkR.
 Properties that conflict with values set by the 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 = 5 [(.google.api.field_behavior) = OPTIONAL];

Specified by:

getPropertiesOrThrow in interface SparkRJobOrBuilder

hasLoggingConfig

public boolean hasLoggingConfig()

 Optional. The runtime log config for job execution.
 

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

Specified by:

hasLoggingConfig in interface SparkRJobOrBuilder

Returns:

Whether the loggingConfig field is set.

getLoggingConfig

public LoggingConfig getLoggingConfig()

 Optional. The runtime log config for job execution.
 

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

Specified by:

getLoggingConfig in interface SparkRJobOrBuilder

Returns:

The loggingConfig.

getLoggingConfigOrBuilder

public LoggingConfigOrBuilder getLoggingConfigOrBuilder()

 Optional. The runtime log config for job execution.
 

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

Specified by:

getLoggingConfigOrBuilder in interface SparkRJobOrBuilder

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface MessageLiteOrBuilder

Overrides:

isInitialized in class GeneratedMessageV3

writeTo

public void writeTo(CodedOutputStream output)
             throws IOException

Specified by:

writeTo in interface MessageLite

Overrides:

writeTo in class GeneratedMessageV3

Throws:

IOException

getSerializedSize

public int getSerializedSize()

Specified by:

getSerializedSize in interface MessageLite

Overrides:

getSerializedSize in class GeneratedMessageV3

equals

public boolean equals(Object obj)

Specified by:

equals in interface Message

Overrides:

equals in class AbstractMessage

hashCode

public int hashCode()

Specified by:

hashCode in interface Message

Overrides:

hashCode in class AbstractMessage

parseFrom

public static SparkRJob parseFrom(ByteBuffer data)
                           throws InvalidProtocolBufferException

Throws:

InvalidProtocolBufferException

parseFrom

public static SparkRJob parseFrom(ByteBuffer data,
                                  ExtensionRegistryLite extensionRegistry)
                           throws InvalidProtocolBufferException

Throws:

InvalidProtocolBufferException

parseFrom

public static SparkRJob parseFrom(ByteString data)
                           throws InvalidProtocolBufferException

Throws:

InvalidProtocolBufferException

parseFrom

public static SparkRJob parseFrom(ByteString data,
                                  ExtensionRegistryLite extensionRegistry)
                           throws InvalidProtocolBufferException

Throws:

InvalidProtocolBufferException

parseFrom

public static SparkRJob parseFrom(byte[] data)
                           throws InvalidProtocolBufferException

Throws:

InvalidProtocolBufferException

parseFrom

public static SparkRJob parseFrom(byte[] data,
                                  ExtensionRegistryLite extensionRegistry)
                           throws InvalidProtocolBufferException

Throws:

InvalidProtocolBufferException

parseFrom

public static SparkRJob parseFrom(InputStream input)
                           throws IOException

Throws:

IOException

parseFrom

public static SparkRJob parseFrom(InputStream input,
                                  ExtensionRegistryLite extensionRegistry)
                           throws IOException

Throws:

IOException

parseDelimitedFrom

public static SparkRJob parseDelimitedFrom(InputStream input)
                                    throws IOException

Throws:

IOException

parseDelimitedFrom

public static SparkRJob parseDelimitedFrom(InputStream input,
                                           ExtensionRegistryLite extensionRegistry)
                                    throws IOException

Throws:

IOException

parseFrom

public static SparkRJob parseFrom(CodedInputStream input)
                           throws IOException

Throws:

IOException

parseFrom

public static SparkRJob parseFrom(CodedInputStream input,
                                  ExtensionRegistryLite extensionRegistry)
                           throws IOException

Throws:

IOException

newBuilderForType

public SparkRJob.Builder newBuilderForType()

Specified by:

newBuilderForType in interface Message

Specified by:

newBuilderForType in interface MessageLite

newBuilder

public static SparkRJob.Builder newBuilder()

newBuilder

public static SparkRJob.Builder newBuilder(SparkRJob prototype)

toBuilder

public SparkRJob.Builder toBuilder()

Specified by:

toBuilder in interface Message

Specified by:

toBuilder in interface MessageLite

newBuilderForType

protected SparkRJob.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)

Specified by:

newBuilderForType in class GeneratedMessageV3

getDefaultInstance

public static SparkRJob getDefaultInstance()

parser

public static Parser<SparkRJob> parser()

getParserForType

public Parser<SparkRJob> getParserForType()

Specified by:

getParserForType in interface Message

Specified by:

getParserForType in interface MessageLite

Overrides:

getParserForType in class GeneratedMessageV3

getDefaultInstanceForType

public SparkRJob getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface MessageOrBuilder