public final class SparkSqlJob extends GeneratedMessageV3 implements SparkSqlJobOrBuilder
A Dataproc job for running [Apache Spark SQL](http://spark.apache.org/sql/) queries.Protobuf type
google.cloud.dataproc.v1.SparkSqlJob
Modifier and Type | Class and Description |
---|---|
static class |
SparkSqlJob.Builder
A Dataproc job for running [Apache Spark
SQL](http://spark.apache.org/sql/) queries.
|
static class |
SparkSqlJob.QueriesCase |
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.UnusedPrivateParameter
AbstractMessageLite.InternalOneOfEnum
Modifier and Type | Field and Description |
---|---|
static int |
JAR_FILE_URIS_FIELD_NUMBER |
static int |
LOGGING_CONFIG_FIELD_NUMBER |
static int |
PROPERTIES_FIELD_NUMBER |
static int |
QUERY_FILE_URI_FIELD_NUMBER |
static int |
QUERY_LIST_FIELD_NUMBER |
static int |
SCRIPT_VARIABLES_FIELD_NUMBER |
alwaysUseFieldBuilders, unknownFields
memoizedSize
memoizedHashCode
canUseUnsafe, 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, writeStringNoTag
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
findInitializationErrors, getAllFields, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof
toByteArray, toByteString, writeDelimitedTo, writeTo
public static final int QUERY_FILE_URI_FIELD_NUMBER
public static final int QUERY_LIST_FIELD_NUMBER
public static final int SCRIPT_VARIABLES_FIELD_NUMBER
public static final int PROPERTIES_FIELD_NUMBER
public static final int JAR_FILE_URIS_FIELD_NUMBER
public static final int LOGGING_CONFIG_FIELD_NUMBER
protected Object newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
newInstance
in class GeneratedMessageV3
public final UnknownFieldSet getUnknownFields()
getUnknownFields
in interface MessageOrBuilder
getUnknownFields
in class GeneratedMessageV3
public static final Descriptors.Descriptor getDescriptor()
protected MapField internalGetMapField(int number)
internalGetMapField
in class GeneratedMessageV3
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable
in class GeneratedMessageV3
public SparkSqlJob.QueriesCase getQueriesCase()
getQueriesCase
in interface SparkSqlJobOrBuilder
public boolean hasQueryFileUri()
The HCFS URI of the script that contains SQL queries.
string query_file_uri = 1;
hasQueryFileUri
in interface SparkSqlJobOrBuilder
public String getQueryFileUri()
The HCFS URI of the script that contains SQL queries.
string query_file_uri = 1;
getQueryFileUri
in interface SparkSqlJobOrBuilder
public ByteString getQueryFileUriBytes()
The HCFS URI of the script that contains SQL queries.
string query_file_uri = 1;
getQueryFileUriBytes
in interface SparkSqlJobOrBuilder
public boolean hasQueryList()
A list of queries.
.google.cloud.dataproc.v1.QueryList query_list = 2;
hasQueryList
in interface SparkSqlJobOrBuilder
public QueryList getQueryList()
A list of queries.
.google.cloud.dataproc.v1.QueryList query_list = 2;
getQueryList
in interface SparkSqlJobOrBuilder
public QueryListOrBuilder getQueryListOrBuilder()
A list of queries.
.google.cloud.dataproc.v1.QueryList query_list = 2;
getQueryListOrBuilder
in interface SparkSqlJobOrBuilder
public int getScriptVariablesCount()
SparkSqlJobOrBuilder
Optional. Mapping of query variable names to values (equivalent to the Spark SQL command: SET `name="value";`).
map<string, string> script_variables = 3 [(.google.api.field_behavior) = OPTIONAL];
getScriptVariablesCount
in interface SparkSqlJobOrBuilder
public boolean containsScriptVariables(String key)
Optional. Mapping of query variable names to values (equivalent to the Spark SQL command: SET `name="value";`).
map<string, string> script_variables = 3 [(.google.api.field_behavior) = OPTIONAL];
containsScriptVariables
in interface SparkSqlJobOrBuilder
@Deprecated public Map<String,String> getScriptVariables()
getScriptVariablesMap()
instead.getScriptVariables
in interface SparkSqlJobOrBuilder
public Map<String,String> getScriptVariablesMap()
Optional. Mapping of query variable names to values (equivalent to the Spark SQL command: SET `name="value";`).
map<string, string> script_variables = 3 [(.google.api.field_behavior) = OPTIONAL];
getScriptVariablesMap
in interface SparkSqlJobOrBuilder
public String getScriptVariablesOrDefault(String key, String defaultValue)
Optional. Mapping of query variable names to values (equivalent to the Spark SQL command: SET `name="value";`).
map<string, string> script_variables = 3 [(.google.api.field_behavior) = OPTIONAL];
getScriptVariablesOrDefault
in interface SparkSqlJobOrBuilder
public String getScriptVariablesOrThrow(String key)
Optional. Mapping of query variable names to values (equivalent to the Spark SQL command: SET `name="value";`).
map<string, string> script_variables = 3 [(.google.api.field_behavior) = OPTIONAL];
getScriptVariablesOrThrow
in interface SparkSqlJobOrBuilder
public int getPropertiesCount()
SparkSqlJobOrBuilder
Optional. A mapping of property names to values, used to configure Spark SQL's SparkConf. Properties that conflict with values set by the Dataproc API may be overwritten.
map<string, string> properties = 4 [(.google.api.field_behavior) = OPTIONAL];
getPropertiesCount
in interface SparkSqlJobOrBuilder
public boolean containsProperties(String key)
Optional. A mapping of property names to values, used to configure Spark SQL's SparkConf. Properties that conflict with values set by the Dataproc API may be overwritten.
map<string, string> properties = 4 [(.google.api.field_behavior) = OPTIONAL];
containsProperties
in interface SparkSqlJobOrBuilder
@Deprecated public Map<String,String> getProperties()
getPropertiesMap()
instead.getProperties
in interface SparkSqlJobOrBuilder
public Map<String,String> getPropertiesMap()
Optional. A mapping of property names to values, used to configure Spark SQL's SparkConf. Properties that conflict with values set by the Dataproc API may be overwritten.
map<string, string> properties = 4 [(.google.api.field_behavior) = OPTIONAL];
getPropertiesMap
in interface SparkSqlJobOrBuilder
public String getPropertiesOrDefault(String key, String defaultValue)
Optional. A mapping of property names to values, used to configure Spark SQL's SparkConf. Properties that conflict with values set by the Dataproc API may be overwritten.
map<string, string> properties = 4 [(.google.api.field_behavior) = OPTIONAL];
getPropertiesOrDefault
in interface SparkSqlJobOrBuilder
public String getPropertiesOrThrow(String key)
Optional. A mapping of property names to values, used to configure Spark SQL's SparkConf. Properties that conflict with values set by the Dataproc API may be overwritten.
map<string, string> properties = 4 [(.google.api.field_behavior) = OPTIONAL];
getPropertiesOrThrow
in interface SparkSqlJobOrBuilder
public ProtocolStringList getJarFileUrisList()
Optional. HCFS URIs of jar files to be added to the Spark CLASSPATH.
repeated string jar_file_uris = 56 [(.google.api.field_behavior) = OPTIONAL];
getJarFileUrisList
in interface SparkSqlJobOrBuilder
public int getJarFileUrisCount()
Optional. HCFS URIs of jar files to be added to the Spark CLASSPATH.
repeated string jar_file_uris = 56 [(.google.api.field_behavior) = OPTIONAL];
getJarFileUrisCount
in interface SparkSqlJobOrBuilder
public String getJarFileUris(int index)
Optional. HCFS URIs of jar files to be added to the Spark CLASSPATH.
repeated string jar_file_uris = 56 [(.google.api.field_behavior) = OPTIONAL];
getJarFileUris
in interface SparkSqlJobOrBuilder
index
- 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 = 56 [(.google.api.field_behavior) = OPTIONAL];
getJarFileUrisBytes
in interface SparkSqlJobOrBuilder
index
- The index of the value to return.public boolean hasLoggingConfig()
Optional. The runtime log config for job execution.
.google.cloud.dataproc.v1.LoggingConfig logging_config = 6 [(.google.api.field_behavior) = OPTIONAL];
hasLoggingConfig
in interface SparkSqlJobOrBuilder
public LoggingConfig getLoggingConfig()
Optional. The runtime log config for job execution.
.google.cloud.dataproc.v1.LoggingConfig logging_config = 6 [(.google.api.field_behavior) = OPTIONAL];
getLoggingConfig
in interface SparkSqlJobOrBuilder
public LoggingConfigOrBuilder getLoggingConfigOrBuilder()
Optional. The runtime log config for job execution.
.google.cloud.dataproc.v1.LoggingConfig logging_config = 6 [(.google.api.field_behavior) = OPTIONAL];
getLoggingConfigOrBuilder
in interface SparkSqlJobOrBuilder
public final boolean isInitialized()
isInitialized
in interface MessageLiteOrBuilder
isInitialized
in class GeneratedMessageV3
public void writeTo(CodedOutputStream output) throws IOException
writeTo
in interface MessageLite
writeTo
in class GeneratedMessageV3
IOException
public int getSerializedSize()
getSerializedSize
in interface MessageLite
getSerializedSize
in class GeneratedMessageV3
public boolean equals(Object obj)
equals
in interface Message
equals
in class AbstractMessage
public int hashCode()
hashCode
in interface Message
hashCode
in class AbstractMessage
public static SparkSqlJob parseFrom(ByteBuffer data) throws InvalidProtocolBufferException
InvalidProtocolBufferException
public static SparkSqlJob parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry) throws InvalidProtocolBufferException
InvalidProtocolBufferException
public static SparkSqlJob parseFrom(ByteString data) throws InvalidProtocolBufferException
InvalidProtocolBufferException
public static SparkSqlJob parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry) throws InvalidProtocolBufferException
InvalidProtocolBufferException
public static SparkSqlJob parseFrom(byte[] data) throws InvalidProtocolBufferException
InvalidProtocolBufferException
public static SparkSqlJob parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry) throws InvalidProtocolBufferException
InvalidProtocolBufferException
public static SparkSqlJob parseFrom(InputStream input) throws IOException
IOException
public static SparkSqlJob parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static SparkSqlJob parseDelimitedFrom(InputStream input) throws IOException
IOException
public static SparkSqlJob parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static SparkSqlJob parseFrom(CodedInputStream input) throws IOException
IOException
public static SparkSqlJob parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public SparkSqlJob.Builder newBuilderForType()
newBuilderForType
in interface Message
newBuilderForType
in interface MessageLite
public static SparkSqlJob.Builder newBuilder()
public static SparkSqlJob.Builder newBuilder(SparkSqlJob prototype)
public SparkSqlJob.Builder toBuilder()
toBuilder
in interface Message
toBuilder
in interface MessageLite
protected SparkSqlJob.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)
newBuilderForType
in class GeneratedMessageV3
public static SparkSqlJob getDefaultInstance()
public static Parser<SparkSqlJob> parser()
public Parser<SparkSqlJob> getParserForType()
getParserForType
in interface Message
getParserForType
in interface MessageLite
getParserForType
in class GeneratedMessageV3
public SparkSqlJob getDefaultInstanceForType()
getDefaultInstanceForType
in interface MessageLiteOrBuilder
getDefaultInstanceForType
in interface MessageOrBuilder
Copyright © 2022 Google LLC. All rights reserved.