public final class SparkSqlBatch extends GeneratedMessageV3 implements SparkSqlBatchOrBuilder
A configuration for running [Apache Spark SQL](http://spark.apache.org/sql/) queries as a batch workload.Protobuf type
google.cloud.dataproc.v1.SparkSqlBatch| Modifier and Type | Class and Description |
|---|---|
static class |
SparkSqlBatch.Builder
A configuration for running
[Apache Spark SQL](http://spark.apache.org/sql/) queries as a batch workload.
|
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.UnusedPrivateParameterAbstractMessageLite.InternalOneOfEnum| Modifier and Type | Field and Description |
|---|---|
static int |
JAR_FILE_URIS_FIELD_NUMBER |
static int |
QUERY_FILE_URI_FIELD_NUMBER |
static int |
QUERY_VARIABLES_FIELD_NUMBER |
alwaysUseFieldBuilders, unknownFieldsmemoizedSizememoizedHashCodecanUseUnsafe, 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, writeStringNoTagfindInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toStringaddAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeToclone, finalize, getClass, notify, notifyAll, wait, wait, waitfindInitializationErrors, getAllFields, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneoftoByteArray, toByteString, writeDelimitedTo, writeTopublic static final int QUERY_FILE_URI_FIELD_NUMBER
public static final int QUERY_VARIABLES_FIELD_NUMBER
public static final int JAR_FILE_URIS_FIELD_NUMBER
protected Object newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
newInstance in class GeneratedMessageV3public final UnknownFieldSet getUnknownFields()
getUnknownFields in interface MessageOrBuildergetUnknownFields in class GeneratedMessageV3public static final Descriptors.Descriptor getDescriptor()
protected MapField internalGetMapField(int number)
internalGetMapField in class GeneratedMessageV3protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable in class GeneratedMessageV3public 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];getQueryFileUri in interface SparkSqlBatchOrBuilderpublic 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];getQueryFileUriBytes in interface SparkSqlBatchOrBuilderpublic int getQueryVariablesCount()
SparkSqlBatchOrBuilderOptional. 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];
getQueryVariablesCount in interface SparkSqlBatchOrBuilderpublic 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];
containsQueryVariables in interface SparkSqlBatchOrBuilder@Deprecated public Map<String,String> getQueryVariables()
getQueryVariablesMap() instead.getQueryVariables in interface SparkSqlBatchOrBuilderpublic 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];
getQueryVariablesMap in interface SparkSqlBatchOrBuilderpublic 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];
getQueryVariablesOrDefault in interface SparkSqlBatchOrBuilderpublic 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];
getQueryVariablesOrThrow in interface SparkSqlBatchOrBuilderpublic 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];getJarFileUrisList in interface SparkSqlBatchOrBuilderpublic 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];getJarFileUrisCount in interface SparkSqlBatchOrBuilderpublic 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];getJarFileUris in interface SparkSqlBatchOrBuilderindex - The index of the element to return.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];getJarFileUrisBytes in interface SparkSqlBatchOrBuilderindex - The index of the value to return.public final boolean isInitialized()
isInitialized in interface MessageLiteOrBuilderisInitialized in class GeneratedMessageV3public void writeTo(CodedOutputStream output) throws IOException
writeTo in interface MessageLitewriteTo in class GeneratedMessageV3IOExceptionpublic int getSerializedSize()
getSerializedSize in interface MessageLitegetSerializedSize in class GeneratedMessageV3public boolean equals(Object obj)
equals in interface Messageequals in class AbstractMessagepublic int hashCode()
hashCode in interface MessagehashCode in class AbstractMessagepublic static SparkSqlBatch parseFrom(ByteBuffer data) throws InvalidProtocolBufferException
InvalidProtocolBufferExceptionpublic static SparkSqlBatch parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry) throws InvalidProtocolBufferException
InvalidProtocolBufferExceptionpublic static SparkSqlBatch parseFrom(ByteString data) throws InvalidProtocolBufferException
InvalidProtocolBufferExceptionpublic static SparkSqlBatch parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry) throws InvalidProtocolBufferException
InvalidProtocolBufferExceptionpublic static SparkSqlBatch parseFrom(byte[] data) throws InvalidProtocolBufferException
InvalidProtocolBufferExceptionpublic static SparkSqlBatch parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry) throws InvalidProtocolBufferException
InvalidProtocolBufferExceptionpublic static SparkSqlBatch parseFrom(InputStream input) throws IOException
IOExceptionpublic static SparkSqlBatch parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic static SparkSqlBatch parseDelimitedFrom(InputStream input) throws IOException
IOExceptionpublic static SparkSqlBatch parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic static SparkSqlBatch parseFrom(CodedInputStream input) throws IOException
IOExceptionpublic static SparkSqlBatch parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic SparkSqlBatch.Builder newBuilderForType()
newBuilderForType in interface MessagenewBuilderForType in interface MessageLitepublic static SparkSqlBatch.Builder newBuilder()
public static SparkSqlBatch.Builder newBuilder(SparkSqlBatch prototype)
public SparkSqlBatch.Builder toBuilder()
toBuilder in interface MessagetoBuilder in interface MessageLiteprotected SparkSqlBatch.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)
newBuilderForType in class GeneratedMessageV3public static SparkSqlBatch getDefaultInstance()
public static Parser<SparkSqlBatch> parser()
public Parser<SparkSqlBatch> getParserForType()
getParserForType in interface MessagegetParserForType in interface MessageLitegetParserForType in class GeneratedMessageV3public SparkSqlBatch getDefaultInstanceForType()
getDefaultInstanceForType in interface MessageLiteOrBuildergetDefaultInstanceForType in interface MessageOrBuilderCopyright © 2022 Google LLC. All rights reserved.