Class SparkSqlBatch.Builder (4.37.0)

public static final class SparkSqlBatch.Builder extends GeneratedMessageV3.Builder<SparkSqlBatch.Builder> implements SparkSqlBatchOrBuilder

A configuration for running Apache Spark SQL queries as a batch workload.

Protobuf type google.cloud.dataproc.v1.SparkSqlBatch

Static Methods

getDescriptor()

public static final Descriptors.Descriptor getDescriptor()
Returns
TypeDescription
Descriptor

Methods

addAllJarFileUris(Iterable<String> values)

public SparkSqlBatch.Builder addAllJarFileUris(Iterable<String> values)

Optional. HCFS URIs of jar files to be added to the Spark CLASSPATH.

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

Parameter
NameDescription
valuesIterable<String>

The jarFileUris to add.

Returns
TypeDescription
SparkSqlBatch.Builder

This builder for chaining.

addJarFileUris(String value)

public SparkSqlBatch.Builder addJarFileUris(String value)

Optional. HCFS URIs of jar files to be added to the Spark CLASSPATH.

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

Parameter
NameDescription
valueString

The jarFileUris to add.

Returns
TypeDescription
SparkSqlBatch.Builder

This builder for chaining.

addJarFileUrisBytes(ByteString value)

public SparkSqlBatch.Builder addJarFileUrisBytes(ByteString value)

Optional. HCFS URIs of jar files to be added to the Spark CLASSPATH.

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

Parameter
NameDescription
valueByteString

The bytes of the jarFileUris to add.

Returns
TypeDescription
SparkSqlBatch.Builder

This builder for chaining.

addRepeatedField(Descriptors.FieldDescriptor field, Object value)

public SparkSqlBatch.Builder addRepeatedField(Descriptors.FieldDescriptor field, Object value)
Parameters
NameDescription
fieldFieldDescriptor
valueObject
Returns
TypeDescription
SparkSqlBatch.Builder
Overrides

build()

public SparkSqlBatch build()
Returns
TypeDescription
SparkSqlBatch

buildPartial()

public SparkSqlBatch buildPartial()
Returns
TypeDescription
SparkSqlBatch

clear()

public SparkSqlBatch.Builder clear()
Returns
TypeDescription
SparkSqlBatch.Builder
Overrides

clearField(Descriptors.FieldDescriptor field)

public SparkSqlBatch.Builder clearField(Descriptors.FieldDescriptor field)
Parameter
NameDescription
fieldFieldDescriptor
Returns
TypeDescription
SparkSqlBatch.Builder
Overrides

clearJarFileUris()

public SparkSqlBatch.Builder clearJarFileUris()

Optional. HCFS URIs of jar files to be added to the Spark CLASSPATH.

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

Returns
TypeDescription
SparkSqlBatch.Builder

This builder for chaining.

clearOneof(Descriptors.OneofDescriptor oneof)

public SparkSqlBatch.Builder clearOneof(Descriptors.OneofDescriptor oneof)
Parameter
NameDescription
oneofOneofDescriptor
Returns
TypeDescription
SparkSqlBatch.Builder
Overrides

clearQueryFileUri()

public SparkSqlBatch.Builder clearQueryFileUri()

Required. The HCFS URI of the script that contains Spark SQL queries to execute.

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

Returns
TypeDescription
SparkSqlBatch.Builder

This builder for chaining.

clearQueryVariables()

public SparkSqlBatch.Builder clearQueryVariables()
Returns
TypeDescription
SparkSqlBatch.Builder

clone()

public SparkSqlBatch.Builder clone()
Returns
TypeDescription
SparkSqlBatch.Builder
Overrides

containsQueryVariables(String key)

public boolean containsQueryVariables(String key)

Optional. Mapping of query variable names to values (equivalent to the Spark SQL command: SET name="value";).

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

Parameter
NameDescription
keyString
Returns
TypeDescription
boolean

getDefaultInstanceForType()

public SparkSqlBatch getDefaultInstanceForType()
Returns
TypeDescription
SparkSqlBatch

getDescriptorForType()

public Descriptors.Descriptor getDescriptorForType()
Returns
TypeDescription
Descriptor
Overrides

getJarFileUris(int index)

public String getJarFileUris(int index)

Optional. HCFS URIs of jar files to be added to the Spark CLASSPATH.

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

Parameter
NameDescription
indexint

The index of the element to return.

Returns
TypeDescription
String

The jarFileUris at the given index.

getJarFileUrisBytes(int index)

public ByteString getJarFileUrisBytes(int index)

Optional. HCFS URIs of jar files to be added to the Spark CLASSPATH.

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

Parameter
NameDescription
indexint

The index of the value to return.

Returns
TypeDescription
ByteString

The bytes of the jarFileUris at the given index.

getJarFileUrisCount()

public int getJarFileUrisCount()

Optional. HCFS URIs of jar files to be added to the Spark CLASSPATH.

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

Returns
TypeDescription
int

The count of jarFileUris.

getJarFileUrisList()

public ProtocolStringList getJarFileUrisList()

Optional. HCFS URIs of jar files to be added to the Spark CLASSPATH.

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

Returns
TypeDescription
ProtocolStringList

A list containing the jarFileUris.

getMutableQueryVariables() (deprecated)

public Map<String,String> getMutableQueryVariables()

Use alternate mutation accessors instead.

Returns
TypeDescription
Map<String,String>

getQueryFileUri()

public String getQueryFileUri()

Required. The HCFS URI of the script that contains Spark SQL queries to execute.

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

Returns
TypeDescription
String

The queryFileUri.

getQueryFileUriBytes()

public ByteString getQueryFileUriBytes()

Required. The HCFS URI of the script that contains Spark SQL queries to execute.

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

Returns
TypeDescription
ByteString

The bytes for queryFileUri.

getQueryVariables() (deprecated)

public Map<String,String> getQueryVariables()
Returns
TypeDescription
Map<String,String>

getQueryVariablesCount()

public int getQueryVariablesCount()

Optional. Mapping of query variable names to values (equivalent to the Spark SQL command: SET name="value";).

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

Returns
TypeDescription
int

getQueryVariablesMap()

public Map<String,String> getQueryVariablesMap()

Optional. Mapping of query variable names to values (equivalent to the Spark SQL command: SET name="value";).

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

Returns
TypeDescription
Map<String,String>

getQueryVariablesOrDefault(String key, String defaultValue)

public String getQueryVariablesOrDefault(String key, String defaultValue)

Optional. Mapping of query variable names to values (equivalent to the Spark SQL command: SET name="value";).

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

Parameters
NameDescription
keyString
defaultValueString
Returns
TypeDescription
String

getQueryVariablesOrThrow(String key)

public String getQueryVariablesOrThrow(String key)

Optional. Mapping of query variable names to values (equivalent to the Spark SQL command: SET name="value";).

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

Parameter
NameDescription
keyString
Returns
TypeDescription
String

internalGetFieldAccessorTable()

protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Returns
TypeDescription
FieldAccessorTable
Overrides

internalGetMapFieldReflection(int number)

protected MapFieldReflectionAccessor internalGetMapFieldReflection(int number)
Parameter
NameDescription
numberint
Returns
TypeDescription
com.google.protobuf.MapFieldReflectionAccessor
Overrides
com.google.protobuf.GeneratedMessageV3.Builder.internalGetMapFieldReflection(int)

internalGetMutableMapFieldReflection(int number)

protected MapFieldReflectionAccessor internalGetMutableMapFieldReflection(int number)
Parameter
NameDescription
numberint
Returns
TypeDescription
com.google.protobuf.MapFieldReflectionAccessor
Overrides
com.google.protobuf.GeneratedMessageV3.Builder.internalGetMutableMapFieldReflection(int)

isInitialized()

public final boolean isInitialized()
Returns
TypeDescription
boolean
Overrides

mergeFrom(SparkSqlBatch other)

public SparkSqlBatch.Builder mergeFrom(SparkSqlBatch other)
Parameter
NameDescription
otherSparkSqlBatch
Returns
TypeDescription
SparkSqlBatch.Builder

mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)

public SparkSqlBatch.Builder mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
NameDescription
inputCodedInputStream
extensionRegistryExtensionRegistryLite
Returns
TypeDescription
SparkSqlBatch.Builder
Overrides
Exceptions
TypeDescription
IOException

mergeFrom(Message other)

public SparkSqlBatch.Builder mergeFrom(Message other)
Parameter
NameDescription
otherMessage
Returns
TypeDescription
SparkSqlBatch.Builder
Overrides

mergeUnknownFields(UnknownFieldSet unknownFields)

public final SparkSqlBatch.Builder mergeUnknownFields(UnknownFieldSet unknownFields)
Parameter
NameDescription
unknownFieldsUnknownFieldSet
Returns
TypeDescription
SparkSqlBatch.Builder
Overrides

putAllQueryVariables(Map<String,String> values)

public SparkSqlBatch.Builder putAllQueryVariables(Map<String,String> values)

Optional. Mapping of query variable names to values (equivalent to the Spark SQL command: SET name="value";).

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

Parameter
NameDescription
valuesMap<String,String>
Returns
TypeDescription
SparkSqlBatch.Builder

putQueryVariables(String key, String value)

public SparkSqlBatch.Builder putQueryVariables(String key, String value)

Optional. Mapping of query variable names to values (equivalent to the Spark SQL command: SET name="value";).

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

Parameters
NameDescription
keyString
valueString
Returns
TypeDescription
SparkSqlBatch.Builder

removeQueryVariables(String key)

public SparkSqlBatch.Builder removeQueryVariables(String key)

Optional. Mapping of query variable names to values (equivalent to the Spark SQL command: SET name="value";).

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

Parameter
NameDescription
keyString
Returns
TypeDescription
SparkSqlBatch.Builder

setField(Descriptors.FieldDescriptor field, Object value)

public SparkSqlBatch.Builder setField(Descriptors.FieldDescriptor field, Object value)
Parameters
NameDescription
fieldFieldDescriptor
valueObject
Returns
TypeDescription
SparkSqlBatch.Builder
Overrides

setJarFileUris(int index, String value)

public SparkSqlBatch.Builder setJarFileUris(int index, String value)

Optional. HCFS URIs of jar files to be added to the Spark CLASSPATH.

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

Parameters
NameDescription
indexint

The index to set the value at.

valueString

The jarFileUris to set.

Returns
TypeDescription
SparkSqlBatch.Builder

This builder for chaining.

setQueryFileUri(String value)

public SparkSqlBatch.Builder setQueryFileUri(String value)

Required. The HCFS URI of the script that contains Spark SQL queries to execute.

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

Parameter
NameDescription
valueString

The queryFileUri to set.

Returns
TypeDescription
SparkSqlBatch.Builder

This builder for chaining.

setQueryFileUriBytes(ByteString value)

public SparkSqlBatch.Builder setQueryFileUriBytes(ByteString value)

Required. The HCFS URI of the script that contains Spark SQL queries to execute.

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

Parameter
NameDescription
valueByteString

The bytes for queryFileUri to set.

Returns
TypeDescription
SparkSqlBatch.Builder

This builder for chaining.

setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)

public SparkSqlBatch.Builder setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)
Parameters
NameDescription
fieldFieldDescriptor
indexint
valueObject
Returns
TypeDescription
SparkSqlBatch.Builder
Overrides

setUnknownFields(UnknownFieldSet unknownFields)

public final SparkSqlBatch.Builder setUnknownFields(UnknownFieldSet unknownFields)
Parameter
NameDescription
unknownFieldsUnknownFieldSet
Returns
TypeDescription
SparkSqlBatch.Builder
Overrides