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
Inherited Members
com.google.protobuf.GeneratedMessageV3.Builder.getUnknownFieldSetBuilder()
com.google.protobuf.GeneratedMessageV3.Builder.mergeUnknownLengthDelimitedField(int,com.google.protobuf.ByteString)
com.google.protobuf.GeneratedMessageV3.Builder.mergeUnknownVarintField(int,int)
com.google.protobuf.GeneratedMessageV3.Builder.parseUnknownField(com.google.protobuf.CodedInputStream,com.google.protobuf.ExtensionRegistryLite,int)
com.google.protobuf.GeneratedMessageV3.Builder.setUnknownFieldSetBuilder(com.google.protobuf.UnknownFieldSet.Builder)
Static Methods
getDescriptor()
public static final Descriptors.Descriptor getDescriptor()
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];
| Parameter |
|---|
| Name | Description |
value | String
The jarFileUris to add.
|
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.
|
addRepeatedField(Descriptors.FieldDescriptor field, Object value)
public SparkSqlBatch.Builder addRepeatedField(Descriptors.FieldDescriptor field, Object value)
Overrides
build()
public SparkSqlBatch build()
buildPartial()
public SparkSqlBatch buildPartial()
clear()
public SparkSqlBatch.Builder clear()
Overrides
clearField(Descriptors.FieldDescriptor field)
public SparkSqlBatch.Builder clearField(Descriptors.FieldDescriptor field)
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)
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()
clone()
public SparkSqlBatch.Builder clone()
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 |
|---|
| Name | Description |
key | String
|
getDefaultInstanceForType()
public SparkSqlBatch getDefaultInstanceForType()
getDescriptorForType()
public Descriptors.Descriptor getDescriptorForType()
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];
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];
| 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()
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 |
|---|
| Type | Description |
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];
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];
| Parameter |
|---|
| Name | Description |
key | String
|
internalGetFieldAccessorTable()
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Overrides
internalGetMapField(int number)
protected MapField internalGetMapField(int number)
| Parameter |
|---|
| Name | Description |
number | int
|
Overrides
internalGetMutableMapField(int number)
protected MapField internalGetMutableMapField(int number)
| Parameter |
|---|
| Name | Description |
number | int
|
Overrides
isInitialized()
public final boolean isInitialized()
Overrides
mergeFrom(SparkSqlBatch other)
public SparkSqlBatch.Builder mergeFrom(SparkSqlBatch other)
public SparkSqlBatch.Builder mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Overrides
mergeFrom(Message other)
public SparkSqlBatch.Builder mergeFrom(Message other)
| Parameter |
|---|
| Name | Description |
other | Message
|
Overrides
mergeUnknownFields(UnknownFieldSet unknownFields)
public final SparkSqlBatch.Builder mergeUnknownFields(UnknownFieldSet unknownFields)
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];
| Parameter |
|---|
| Name | Description |
key | String
|
setField(Descriptors.FieldDescriptor field, Object value)
public SparkSqlBatch.Builder setField(Descriptors.FieldDescriptor field, Object value)
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.
|
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.
|
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.
|
setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)
public SparkSqlBatch.Builder setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)
Overrides
setUnknownFields(UnknownFieldSet unknownFields)
public final SparkSqlBatch.Builder setUnknownFields(UnknownFieldSet unknownFields)
Overrides
