public final class FlinkJob extends com.google.protobuf.GeneratedMessageV3 implements FlinkJobOrBuilder
A Dataproc job for running Apache Flink applications on YARN.Protobuf type
google.cloud.dataproc.v1.FlinkJob| Modifier and Type | Class and Description |
|---|---|
static class |
FlinkJob.Builder
A Dataproc job for running Apache Flink applications on YARN.
|
static class |
FlinkJob.DriverCase |
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| Modifier and Type | Field and Description |
|---|---|
static int |
ARGS_FIELD_NUMBER |
static int |
JAR_FILE_URIS_FIELD_NUMBER |
static int |
LOGGING_CONFIG_FIELD_NUMBER |
static int |
MAIN_CLASS_FIELD_NUMBER |
static int |
MAIN_JAR_FILE_URI_FIELD_NUMBER |
static int |
PROPERTIES_FIELD_NUMBER |
static int |
SAVEPOINT_URI_FIELD_NUMBER |
| Modifier and Type | Method and Description |
|---|---|
boolean |
containsProperties(String key)
Optional.
|
boolean |
equals(Object obj) |
String |
getArgs(int index)
Optional.
|
com.google.protobuf.ByteString |
getArgsBytes(int index)
Optional.
|
int |
getArgsCount()
Optional.
|
com.google.protobuf.ProtocolStringList |
getArgsList()
Optional.
|
static FlinkJob |
getDefaultInstance() |
FlinkJob |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
FlinkJob.DriverCase |
getDriverCase() |
String |
getJarFileUris(int index)
Optional.
|
com.google.protobuf.ByteString |
getJarFileUrisBytes(int index)
Optional.
|
int |
getJarFileUrisCount()
Optional.
|
com.google.protobuf.ProtocolStringList |
getJarFileUrisList()
Optional.
|
LoggingConfig |
getLoggingConfig()
Optional.
|
LoggingConfigOrBuilder |
getLoggingConfigOrBuilder()
Optional.
|
String |
getMainClass()
The name of the driver's main class.
|
com.google.protobuf.ByteString |
getMainClassBytes()
The name of the driver's main class.
|
String |
getMainJarFileUri()
The HCFS URI of the jar file that contains the main class.
|
com.google.protobuf.ByteString |
getMainJarFileUriBytes()
The HCFS URI of the jar file that contains the main class.
|
com.google.protobuf.Parser<FlinkJob> |
getParserForType() |
Map<String,String> |
getProperties()
Deprecated.
|
int |
getPropertiesCount()
Optional.
|
Map<String,String> |
getPropertiesMap()
Optional.
|
String |
getPropertiesOrDefault(String key,
String defaultValue)
Optional.
|
String |
getPropertiesOrThrow(String key)
Optional.
|
String |
getSavepointUri()
Optional.
|
com.google.protobuf.ByteString |
getSavepointUriBytes()
Optional.
|
int |
getSerializedSize() |
int |
hashCode() |
boolean |
hasLoggingConfig()
Optional.
|
boolean |
hasMainClass()
The name of the driver's main class.
|
boolean |
hasMainJarFileUri()
The HCFS URI of the jar file that contains the main class.
|
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable |
internalGetFieldAccessorTable() |
protected com.google.protobuf.MapFieldReflectionAccessor |
internalGetMapFieldReflection(int number) |
boolean |
isInitialized() |
static FlinkJob.Builder |
newBuilder() |
static FlinkJob.Builder |
newBuilder(FlinkJob prototype) |
FlinkJob.Builder |
newBuilderForType() |
protected FlinkJob.Builder |
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) |
protected Object |
newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused) |
static FlinkJob |
parseDelimitedFrom(InputStream input) |
static FlinkJob |
parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkJob |
parseFrom(byte[] data) |
static FlinkJob |
parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkJob |
parseFrom(ByteBuffer data) |
static FlinkJob |
parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkJob |
parseFrom(com.google.protobuf.ByteString data) |
static FlinkJob |
parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkJob |
parseFrom(com.google.protobuf.CodedInputStream input) |
static FlinkJob |
parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkJob |
parseFrom(InputStream input) |
static FlinkJob |
parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static com.google.protobuf.Parser<FlinkJob> |
parser() |
FlinkJob.Builder |
toBuilder() |
void |
writeTo(com.google.protobuf.CodedOutputStream output) |
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, internalGetMapField, isStringEmpty, makeExtensionsImmutable, makeMutableCopy, 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, writeStringNoTagfindInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toStringaddAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeToclone, finalize, getClass, notify, notifyAll, wait, wait, waitpublic static final int MAIN_JAR_FILE_URI_FIELD_NUMBER
public static final int MAIN_CLASS_FIELD_NUMBER
public static final int ARGS_FIELD_NUMBER
public static final int JAR_FILE_URIS_FIELD_NUMBER
public static final int SAVEPOINT_URI_FIELD_NUMBER
public static final int PROPERTIES_FIELD_NUMBER
public static final int LOGGING_CONFIG_FIELD_NUMBER
protected Object newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
newInstance in class com.google.protobuf.GeneratedMessageV3public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.MapFieldReflectionAccessor internalGetMapFieldReflection(int number)
internalGetMapFieldReflection in class com.google.protobuf.GeneratedMessageV3protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessageV3public FlinkJob.DriverCase getDriverCase()
getDriverCase in interface FlinkJobOrBuilderpublic boolean hasMainJarFileUri()
The HCFS URI of the jar file that contains the main class.
string main_jar_file_uri = 1;hasMainJarFileUri in interface FlinkJobOrBuilderpublic String getMainJarFileUri()
The HCFS URI of the jar file that contains the main class.
string main_jar_file_uri = 1;getMainJarFileUri in interface FlinkJobOrBuilderpublic com.google.protobuf.ByteString getMainJarFileUriBytes()
The HCFS URI of the jar file that contains the main class.
string main_jar_file_uri = 1;getMainJarFileUriBytes in interface FlinkJobOrBuilderpublic boolean hasMainClass()
The name of the driver's main class. The jar file that contains the class must be in the default CLASSPATH or specified in [jarFileUris][google.cloud.dataproc.v1.FlinkJob.jar_file_uris].
string main_class = 2;hasMainClass in interface FlinkJobOrBuilderpublic String getMainClass()
The name of the driver's main class. The jar file that contains the class must be in the default CLASSPATH or specified in [jarFileUris][google.cloud.dataproc.v1.FlinkJob.jar_file_uris].
string main_class = 2;getMainClass in interface FlinkJobOrBuilderpublic com.google.protobuf.ByteString getMainClassBytes()
The name of the driver's main class. The jar file that contains the class must be in the default CLASSPATH or specified in [jarFileUris][google.cloud.dataproc.v1.FlinkJob.jar_file_uris].
string main_class = 2;getMainClassBytes in interface FlinkJobOrBuilderpublic com.google.protobuf.ProtocolStringList getArgsList()
Optional. The arguments to pass to the driver. Do not include arguments, such as `--conf`, that can be set as job properties, since a collision might occur that causes an incorrect job submission.
repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];getArgsList in interface FlinkJobOrBuilderpublic int getArgsCount()
Optional. The arguments to pass to the driver. Do not include arguments, such as `--conf`, that can be set as job properties, since a collision might occur that causes an incorrect job submission.
repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];getArgsCount in interface FlinkJobOrBuilderpublic String getArgs(int index)
Optional. The arguments to pass to the driver. Do not include arguments, such as `--conf`, that can be set as job properties, since a collision might occur that causes an incorrect job submission.
repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];getArgs in interface FlinkJobOrBuilderindex - The index of the element to return.public com.google.protobuf.ByteString getArgsBytes(int index)
Optional. The arguments to pass to the driver. Do not include arguments, such as `--conf`, that can be set as job properties, since a collision might occur that causes an incorrect job submission.
repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];getArgsBytes in interface FlinkJobOrBuilderindex - The index of the value to return.public com.google.protobuf.ProtocolStringList getJarFileUrisList()
Optional. HCFS URIs of jar files to add to the CLASSPATHs of the Flink driver and tasks.
repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];getJarFileUrisList in interface FlinkJobOrBuilderpublic int getJarFileUrisCount()
Optional. HCFS URIs of jar files to add to the CLASSPATHs of the Flink driver and tasks.
repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];getJarFileUrisCount in interface FlinkJobOrBuilderpublic String getJarFileUris(int index)
Optional. HCFS URIs of jar files to add to the CLASSPATHs of the Flink driver and tasks.
repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];getJarFileUris in interface FlinkJobOrBuilderindex - The index of the element to return.public com.google.protobuf.ByteString getJarFileUrisBytes(int index)
Optional. HCFS URIs of jar files to add to the CLASSPATHs of the Flink driver and tasks.
repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];getJarFileUrisBytes in interface FlinkJobOrBuilderindex - The index of the value to return.public String getSavepointUri()
Optional. HCFS URI of the savepoint, which contains the last saved progress for starting the current job.
string savepoint_uri = 9 [(.google.api.field_behavior) = OPTIONAL];getSavepointUri in interface FlinkJobOrBuilderpublic com.google.protobuf.ByteString getSavepointUriBytes()
Optional. HCFS URI of the savepoint, which contains the last saved progress for starting the current job.
string savepoint_uri = 9 [(.google.api.field_behavior) = OPTIONAL];getSavepointUriBytes in interface FlinkJobOrBuilderpublic int getPropertiesCount()
FlinkJobOrBuilderOptional. A mapping of property names to values, used to configure Flink. Properties that conflict with values set by the Dataproc API might be overwritten. Can include properties set in `/etc/flink/conf/flink-defaults.conf` and classes in user code.
map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL];
getPropertiesCount in interface FlinkJobOrBuilderpublic boolean containsProperties(String key)
Optional. A mapping of property names to values, used to configure Flink. Properties that conflict with values set by the Dataproc API might be overwritten. Can include properties set in `/etc/flink/conf/flink-defaults.conf` and classes in user code.
map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL];
containsProperties in interface FlinkJobOrBuilder@Deprecated public Map<String,String> getProperties()
getPropertiesMap() instead.getProperties in interface FlinkJobOrBuilderpublic Map<String,String> getPropertiesMap()
Optional. A mapping of property names to values, used to configure Flink. Properties that conflict with values set by the Dataproc API might be overwritten. Can include properties set in `/etc/flink/conf/flink-defaults.conf` and classes in user code.
map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL];
getPropertiesMap in interface FlinkJobOrBuilderpublic String getPropertiesOrDefault(String key, String defaultValue)
Optional. A mapping of property names to values, used to configure Flink. Properties that conflict with values set by the Dataproc API might be overwritten. Can include properties set in `/etc/flink/conf/flink-defaults.conf` and classes in user code.
map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL];
getPropertiesOrDefault in interface FlinkJobOrBuilderpublic String getPropertiesOrThrow(String key)
Optional. A mapping of property names to values, used to configure Flink. Properties that conflict with values set by the Dataproc API might be overwritten. Can include properties set in `/etc/flink/conf/flink-defaults.conf` and classes in user code.
map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL];
getPropertiesOrThrow in interface FlinkJobOrBuilderpublic boolean hasLoggingConfig()
Optional. The runtime log config for job execution.
.google.cloud.dataproc.v1.LoggingConfig logging_config = 8 [(.google.api.field_behavior) = OPTIONAL];
hasLoggingConfig in interface FlinkJobOrBuilderpublic LoggingConfig getLoggingConfig()
Optional. The runtime log config for job execution.
.google.cloud.dataproc.v1.LoggingConfig logging_config = 8 [(.google.api.field_behavior) = OPTIONAL];
getLoggingConfig in interface FlinkJobOrBuilderpublic LoggingConfigOrBuilder getLoggingConfigOrBuilder()
Optional. The runtime log config for job execution.
.google.cloud.dataproc.v1.LoggingConfig logging_config = 8 [(.google.api.field_behavior) = OPTIONAL];
getLoggingConfigOrBuilder in interface FlinkJobOrBuilderpublic final boolean isInitialized()
isInitialized in interface com.google.protobuf.MessageLiteOrBuilderisInitialized in class com.google.protobuf.GeneratedMessageV3public void writeTo(com.google.protobuf.CodedOutputStream output)
throws IOException
writeTo in interface com.google.protobuf.MessageLitewriteTo in class com.google.protobuf.GeneratedMessageV3IOExceptionpublic int getSerializedSize()
getSerializedSize in interface com.google.protobuf.MessageLitegetSerializedSize in class com.google.protobuf.GeneratedMessageV3public boolean equals(Object obj)
equals in interface com.google.protobuf.Messageequals in class com.google.protobuf.AbstractMessagepublic int hashCode()
hashCode in interface com.google.protobuf.MessagehashCode in class com.google.protobuf.AbstractMessagepublic static FlinkJob parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static FlinkJob parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static FlinkJob parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static FlinkJob parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static FlinkJob parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static FlinkJob parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static FlinkJob parseFrom(InputStream input) throws IOException
IOExceptionpublic static FlinkJob parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic static FlinkJob parseDelimitedFrom(InputStream input) throws IOException
IOExceptionpublic static FlinkJob parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic static FlinkJob parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
IOExceptionpublic static FlinkJob parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic FlinkJob.Builder newBuilderForType()
newBuilderForType in interface com.google.protobuf.MessagenewBuilderForType in interface com.google.protobuf.MessageLitepublic static FlinkJob.Builder newBuilder()
public static FlinkJob.Builder newBuilder(FlinkJob prototype)
public FlinkJob.Builder toBuilder()
toBuilder in interface com.google.protobuf.MessagetoBuilder in interface com.google.protobuf.MessageLiteprotected FlinkJob.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
newBuilderForType in class com.google.protobuf.GeneratedMessageV3public static FlinkJob getDefaultInstance()
public static com.google.protobuf.Parser<FlinkJob> parser()
public com.google.protobuf.Parser<FlinkJob> getParserForType()
getParserForType in interface com.google.protobuf.MessagegetParserForType in interface com.google.protobuf.MessageLitegetParserForType in class com.google.protobuf.GeneratedMessageV3public FlinkJob getDefaultInstanceForType()
getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuildergetDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilderCopyright © 2024 Google LLC. All rights reserved.