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
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
Returns
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
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];
Parameter
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];
Returns
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];
Returns
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];
Parameter
Returns
getDefaultInstanceForType()
public SparkSqlBatch getDefaultInstanceForType()
Returns
getDescriptor()
public static final Descriptors.Descriptor getDescriptor()
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];
Parameter
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];
Parameter
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];
Returns
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];
Returns
getMutableQueryVariables()
public Map<String,String> getMutableQueryVariables()
Use alternate mutation accessors instead.
Returns
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
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];
Returns
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];
Returns
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
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
Returns
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
Returns
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];
Parameter
Returns
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
Returns
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
Returns
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];
Parameters
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];
Parameter
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];
Parameter
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