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
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];
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];
| Name | Description |
| value | String
The jarFileUris to add.
|
Returns
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];
| Name | Description |
| value | ByteString
The bytes of the jarFileUris to add.
|
Returns
addRepeatedField(Descriptors.FieldDescriptor field, Object value)
public SparkSqlBatch.Builder addRepeatedField(Descriptors.FieldDescriptor field, Object value)
Parameters
Returns
Overrides
build()
public SparkSqlBatch build()
Returns
buildPartial()
public SparkSqlBatch buildPartial()
Returns
clear()
public SparkSqlBatch.Builder clear()
Returns
Overrides
clearField(Descriptors.FieldDescriptor field)
public SparkSqlBatch.Builder clearField(Descriptors.FieldDescriptor field)
Parameter
Returns
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];
clearOneof(Descriptors.OneofDescriptor oneof)
public SparkSqlBatch.Builder clearOneof(Descriptors.OneofDescriptor oneof)
Parameter
Returns
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];
clearQueryVariables()
public SparkSqlBatch.Builder clearQueryVariables()
Returns
clone()
public SparkSqlBatch.Builder clone()
Returns
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];
getDefaultInstanceForType()
public SparkSqlBatch getDefaultInstanceForType()
Returns
getDescriptorForType()
public Descriptors.Descriptor getDescriptorForType()
Returns
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];
| 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 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];
| 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 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];
| Type | Description |
| 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];
getMutableQueryVariables()
public Map<String,String> getMutableQueryVariables()
Use alternate mutation accessors instead.
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];
| Type | Description |
| 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];
| Type | Description |
| ByteString | The bytes for queryFileUri.
|
getQueryVariables()
public Map<String,String> getQueryVariables()
Returns
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];
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];
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];
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];
internalGetFieldAccessorTable()
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Returns
Overrides
internalGetMapField(int number)
protected MapField internalGetMapField(int number)
Parameter
Returns
Overrides
internalGetMutableMapField(int number)
protected MapField internalGetMutableMapField(int number)
Parameter
Returns
Overrides
isInitialized()
public final boolean isInitialized()
Returns
Overrides
mergeFrom(SparkSqlBatch other)
public SparkSqlBatch.Builder mergeFrom(SparkSqlBatch other)
Parameter
Returns
public SparkSqlBatch.Builder mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Overrides
Exceptions
mergeFrom(Message other)
public SparkSqlBatch.Builder mergeFrom(Message other)
Parameter
Returns
Overrides
mergeUnknownFields(UnknownFieldSet unknownFields)
public final SparkSqlBatch.Builder mergeUnknownFields(UnknownFieldSet unknownFields)
Parameter
Returns
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];
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];
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];
setField(Descriptors.FieldDescriptor field, Object value)
public SparkSqlBatch.Builder setField(Descriptors.FieldDescriptor field, Object value)
Parameters
Returns
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];
| Name | Description |
| index | int
The index to set the value at.
|
| value | String
The jarFileUris to set.
|
Returns
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];
| Name | Description |
| value | String
The queryFileUri to set.
|
Returns
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];
| Name | Description |
| value | ByteString
The bytes for queryFileUri to set.
|
Returns
setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)
public SparkSqlBatch.Builder setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)
Parameters
Returns
Overrides
setUnknownFields(UnknownFieldSet unknownFields)
public final SparkSqlBatch.Builder setUnknownFields(UnknownFieldSet unknownFields)
Parameter
Returns
Overrides
