Package com.google.cloud.dataproc.v1
Class SparkSqlBatch
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite
-
- com.google.protobuf.AbstractMessage
-
- com.google.protobuf.GeneratedMessageV3
-
- com.google.cloud.dataproc.v1.SparkSqlBatch
-
- All Implemented Interfaces:
SparkSqlBatchOrBuilder
,com.google.protobuf.Message
,com.google.protobuf.MessageLite
,com.google.protobuf.MessageLiteOrBuilder
,com.google.protobuf.MessageOrBuilder
,Serializable
public final class SparkSqlBatch extends com.google.protobuf.GeneratedMessageV3 implements SparkSqlBatchOrBuilder
A configuration for running [Apache Spark SQL](https://spark.apache.org/sql/) queries as a batch workload.
Protobuf typegoogle.cloud.dataproc.v1.SparkSqlBatch
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
SparkSqlBatch.Builder
A configuration for running [Apache Spark SQL](https://spark.apache.org/sql/) queries as a batch workload.-
Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageV3
com.google.protobuf.GeneratedMessageV3.BuilderParent, com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT,BuilderT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable, com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter
-
-
Field Summary
Fields Modifier and Type Field Description static int
JAR_FILE_URIS_FIELD_NUMBER
static int
QUERY_FILE_URI_FIELD_NUMBER
static int
QUERY_VARIABLES_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description boolean
containsQueryVariables(String key)
Optional.boolean
equals(Object obj)
static SparkSqlBatch
getDefaultInstance()
SparkSqlBatch
getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor
getDescriptor()
String
getJarFileUris(int index)
Optional.com.google.protobuf.ByteString
getJarFileUrisBytes(int index)
Optional.int
getJarFileUrisCount()
Optional.com.google.protobuf.ProtocolStringList
getJarFileUrisList()
Optional.com.google.protobuf.Parser<SparkSqlBatch>
getParserForType()
String
getQueryFileUri()
Required.com.google.protobuf.ByteString
getQueryFileUriBytes()
Required.Map<String,String>
getQueryVariables()
Deprecated.int
getQueryVariablesCount()
Optional.Map<String,String>
getQueryVariablesMap()
Optional.String
getQueryVariablesOrDefault(String key, String defaultValue)
Optional.String
getQueryVariablesOrThrow(String key)
Optional.int
getSerializedSize()
int
hashCode()
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable()
protected com.google.protobuf.MapField
internalGetMapField(int number)
boolean
isInitialized()
static SparkSqlBatch.Builder
newBuilder()
static SparkSqlBatch.Builder
newBuilder(SparkSqlBatch prototype)
SparkSqlBatch.Builder
newBuilderForType()
protected SparkSqlBatch.Builder
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
protected Object
newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
static SparkSqlBatch
parseDelimitedFrom(InputStream input)
static SparkSqlBatch
parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SparkSqlBatch
parseFrom(byte[] data)
static SparkSqlBatch
parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SparkSqlBatch
parseFrom(com.google.protobuf.ByteString data)
static SparkSqlBatch
parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SparkSqlBatch
parseFrom(com.google.protobuf.CodedInputStream input)
static SparkSqlBatch
parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SparkSqlBatch
parseFrom(InputStream input)
static SparkSqlBatch
parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SparkSqlBatch
parseFrom(ByteBuffer data)
static SparkSqlBatch
parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<SparkSqlBatch>
parser()
SparkSqlBatch.Builder
toBuilder()
void
writeTo(com.google.protobuf.CodedOutputStream output)
-
Methods inherited from class com.google.protobuf.GeneratedMessageV3
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, isStringEmpty, makeExtensionsImmutable, makeMutableCopy, 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
-
Methods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
-
Methods inherited from class com.google.protobuf.AbstractMessageLite
addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
-
-
-
Field Detail
-
QUERY_FILE_URI_FIELD_NUMBER
public static final int QUERY_FILE_URI_FIELD_NUMBER
- See Also:
- Constant Field Values
-
QUERY_VARIABLES_FIELD_NUMBER
public static final int QUERY_VARIABLES_FIELD_NUMBER
- See Also:
- Constant Field Values
-
JAR_FILE_URIS_FIELD_NUMBER
public static final int JAR_FILE_URIS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
-
Method Detail
-
newInstance
protected Object newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
- Overrides:
newInstance
in classcom.google.protobuf.GeneratedMessageV3
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetMapField
protected com.google.protobuf.MapField internalGetMapField(int number)
- Overrides:
internalGetMapField
in classcom.google.protobuf.GeneratedMessageV3
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTable
in classcom.google.protobuf.GeneratedMessageV3
-
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];
- Specified by:
getQueryFileUri
in interfaceSparkSqlBatchOrBuilder
- Returns:
- The queryFileUri.
-
getQueryFileUriBytes
public com.google.protobuf.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];
- Specified by:
getQueryFileUriBytes
in interfaceSparkSqlBatchOrBuilder
- Returns:
- The bytes for queryFileUri.
-
getQueryVariablesCount
public int getQueryVariablesCount()
Description copied from interface:SparkSqlBatchOrBuilder
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];
- Specified by:
getQueryVariablesCount
in interfaceSparkSqlBatchOrBuilder
-
containsQueryVariables
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];
- Specified by:
containsQueryVariables
in interfaceSparkSqlBatchOrBuilder
-
getQueryVariables
@Deprecated public Map<String,String> getQueryVariables()
Deprecated.UsegetQueryVariablesMap()
instead.- Specified by:
getQueryVariables
in interfaceSparkSqlBatchOrBuilder
-
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];
- Specified by:
getQueryVariablesMap
in interfaceSparkSqlBatchOrBuilder
-
getQueryVariablesOrDefault
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];
- Specified by:
getQueryVariablesOrDefault
in interfaceSparkSqlBatchOrBuilder
-
getQueryVariablesOrThrow
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];
- Specified by:
getQueryVariablesOrThrow
in interfaceSparkSqlBatchOrBuilder
-
getJarFileUrisList
public com.google.protobuf.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];
- Specified by:
getJarFileUrisList
in interfaceSparkSqlBatchOrBuilder
- Returns:
- A list containing the jarFileUris.
-
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];
- Specified by:
getJarFileUrisCount
in interfaceSparkSqlBatchOrBuilder
- Returns:
- The count of jarFileUris.
-
getJarFileUris
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];
- Specified by:
getJarFileUris
in interfaceSparkSqlBatchOrBuilder
- Parameters:
index
- The index of the element to return.- Returns:
- The jarFileUris at the given index.
-
getJarFileUrisBytes
public com.google.protobuf.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];
- Specified by:
getJarFileUrisBytes
in interfaceSparkSqlBatchOrBuilder
- Parameters:
index
- The index of the value to return.- Returns:
- The bytes of the jarFileUris at the given index.
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classcom.google.protobuf.GeneratedMessageV3
-
writeTo
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
- Specified by:
writeTo
in interfacecom.google.protobuf.MessageLite
- Overrides:
writeTo
in classcom.google.protobuf.GeneratedMessageV3
- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSize
in interfacecom.google.protobuf.MessageLite
- Overrides:
getSerializedSize
in classcom.google.protobuf.GeneratedMessageV3
-
equals
public boolean equals(Object obj)
- Specified by:
equals
in interfacecom.google.protobuf.Message
- Overrides:
equals
in classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()
- Specified by:
hashCode
in interfacecom.google.protobuf.Message
- Overrides:
hashCode
in classcom.google.protobuf.AbstractMessage
-
parseFrom
public static SparkSqlBatch parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static SparkSqlBatch parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static SparkSqlBatch parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static SparkSqlBatch parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static SparkSqlBatch parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static SparkSqlBatch parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static SparkSqlBatch parseFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static SparkSqlBatch parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static SparkSqlBatch parseDelimitedFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static SparkSqlBatch parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseFrom
public static SparkSqlBatch parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static SparkSqlBatch parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
newBuilderForType
public SparkSqlBatch.Builder newBuilderForType()
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.Message
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.MessageLite
-
newBuilder
public static SparkSqlBatch.Builder newBuilder()
-
newBuilder
public static SparkSqlBatch.Builder newBuilder(SparkSqlBatch prototype)
-
toBuilder
public SparkSqlBatch.Builder toBuilder()
- Specified by:
toBuilder
in interfacecom.google.protobuf.Message
- Specified by:
toBuilder
in interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected SparkSqlBatch.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
- Specified by:
newBuilderForType
in classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstance
public static SparkSqlBatch getDefaultInstance()
-
parser
public static com.google.protobuf.Parser<SparkSqlBatch> parser()
-
getParserForType
public com.google.protobuf.Parser<SparkSqlBatch> getParserForType()
- Specified by:
getParserForType
in interfacecom.google.protobuf.Message
- Specified by:
getParserForType
in interfacecom.google.protobuf.MessageLite
- Overrides:
getParserForType
in classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
public SparkSqlBatch getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageOrBuilder
-
-