org.apache.reef.proto

Class ClientRuntimeProtocol.JobSubmissionProto

java.lang.Object

com.google.protobuf.AbstractMessageLite

com.google.protobuf.AbstractMessage

com.google.protobuf.GeneratedMessage

org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto

All Implemented Interfaces:

com.google.protobuf.Message, com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Serializable, ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

Enclosing class:

ClientRuntimeProtocol

public static final class ClientRuntimeProtocol.JobSubmissionProto
extends com.google.protobuf.GeneratedMessage
implements ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

Protobuf type JobSubmissionProto

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ClientRuntimeProtocol.JobSubmissionProto.Builder Protobuf type JobSubmissionProto

Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessage

com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessage.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessage.ExtendableBuilder>, com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessage.ExtendableMessage>, com.google.protobuf.GeneratedMessage.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessage.ExtendableMessage>, com.google.protobuf.GeneratedMessage.FieldAccessorTable, com.google.protobuf.GeneratedMessage.GeneratedExtension<ContainingType extends com.google.protobuf.Message,Type>

Field Summary

Fields

Modifier and Type	Field and Description
static int	CONFIGURATION_FIELD_NUMBER
static int	DRIVER_MEMORY_FIELD_NUMBER
static int	GLOBAL_FILE_FIELD_NUMBER
static int	IDENTIFIER_FIELD_NUMBER
static int	LOCAL_FILE_FIELD_NUMBER
static com.google.protobuf.Parser<ClientRuntimeProtocol.JobSubmissionProto>	PARSER
static int	PRIORITY_FIELD_NUMBER
static int	QUEUE_FIELD_NUMBER
static int	REMOTE_ID_FIELD_NUMBER
static int	USER_NAME_FIELD_NUMBER

Method Summary

Methods

Modifier and Type	Method and Description
boolean	equals(Object obj)
String	getConfiguration() required string configuration = 5;
com.google.protobuf.ByteString	getConfigurationBytes() required string configuration = 5;
static ClientRuntimeProtocol.JobSubmissionProto	getDefaultInstance()
ClientRuntimeProtocol.JobSubmissionProto	getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor	getDescriptor()
int	getDriverMemory() optional int32 driver_memory = 8;
ReefServiceProtos.FileResourceProto	getGlobalFile(int index) repeated .FileResourceProto global_file = 11;
int	getGlobalFileCount() repeated .FileResourceProto global_file = 11;
List<ReefServiceProtos.FileResourceProto>	getGlobalFileList() repeated .FileResourceProto global_file = 11;
ReefServiceProtos.FileResourceProtoOrBuilder	getGlobalFileOrBuilder(int index) repeated .FileResourceProto global_file = 11;
List<? extends ReefServiceProtos.FileResourceProtoOrBuilder>	getGlobalFileOrBuilderList() repeated .FileResourceProto global_file = 11;
String	getIdentifier() required string identifier = 1;
com.google.protobuf.ByteString	getIdentifierBytes() required string identifier = 1;
ReefServiceProtos.FileResourceProto	getLocalFile(int index) repeated .FileResourceProto local_File = 12;
int	getLocalFileCount() repeated .FileResourceProto local_File = 12;
List<ReefServiceProtos.FileResourceProto>	getLocalFileList() repeated .FileResourceProto local_File = 12;
ReefServiceProtos.FileResourceProtoOrBuilder	getLocalFileOrBuilder(int index) repeated .FileResourceProto local_File = 12;
List<? extends ReefServiceProtos.FileResourceProtoOrBuilder>	getLocalFileOrBuilderList() repeated .FileResourceProto local_File = 12;
com.google.protobuf.Parser<ClientRuntimeProtocol.JobSubmissionProto>	getParserForType()
int	getPriority() optional int32 priority = 9;
String	getQueue() optional string queue = 10;
com.google.protobuf.ByteString	getQueueBytes() optional string queue = 10;
String	getRemoteId() required string remote_id = 2;
com.google.protobuf.ByteString	getRemoteIdBytes() required string remote_id = 2;
int	getSerializedSize()
com.google.protobuf.UnknownFieldSet	getUnknownFields()
String	getUserName() required string user_name = 6;
com.google.protobuf.ByteString	getUserNameBytes() required string user_name = 6;
boolean	hasConfiguration() required string configuration = 5;
boolean	hasDriverMemory() optional int32 driver_memory = 8;
int	hashCode()
boolean	hasIdentifier() required string identifier = 1;
boolean	hasPriority() optional int32 priority = 9;
boolean	hasQueue() optional string queue = 10;
boolean	hasRemoteId() required string remote_id = 2;
boolean	hasUserName() required string user_name = 6;
boolean	isInitialized()
static ClientRuntimeProtocol.JobSubmissionProto.Builder	newBuilder()
static ClientRuntimeProtocol.JobSubmissionProto.Builder	newBuilder(ClientRuntimeProtocol.JobSubmissionProto prototype)
ClientRuntimeProtocol.JobSubmissionProto.Builder	newBuilderForType()
static ClientRuntimeProtocol.JobSubmissionProto	parseDelimitedFrom(InputStream input)
static ClientRuntimeProtocol.JobSubmissionProto	parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ClientRuntimeProtocol.JobSubmissionProto	parseFrom(byte[] data)
static ClientRuntimeProtocol.JobSubmissionProto	parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ClientRuntimeProtocol.JobSubmissionProto	parseFrom(com.google.protobuf.ByteString data)
static ClientRuntimeProtocol.JobSubmissionProto	parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ClientRuntimeProtocol.JobSubmissionProto	parseFrom(com.google.protobuf.CodedInputStream input)
static ClientRuntimeProtocol.JobSubmissionProto	parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ClientRuntimeProtocol.JobSubmissionProto	parseFrom(InputStream input)
static ClientRuntimeProtocol.JobSubmissionProto	parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
ClientRuntimeProtocol.JobSubmissionProto.Builder	toBuilder()
void	writeTo(com.google.protobuf.CodedOutputStream output)

Methods inherited from class com.google.protobuf.GeneratedMessage

getAllFields, getDescriptorForType, getField, getRepeatedField, getRepeatedFieldCount, hasField, newFileScopedGeneratedExtension, newMessageScopedGeneratedExtension

Methods inherited from class com.google.protobuf.AbstractMessage

findInitializationErrors, getInitializationErrorString, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite

toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.MessageOrBuilder

findInitializationErrors, getAllFields, getDescriptorForType, getField, getInitializationErrorString, getRepeatedField, getRepeatedFieldCount, hasField

Methods inherited from interface com.google.protobuf.MessageLite

toByteArray, toByteString, writeDelimitedTo, writeTo

Field Detail

PARSER

public static com.google.protobuf.Parser<ClientRuntimeProtocol.JobSubmissionProto> PARSER

IDENTIFIER_FIELD_NUMBER

public static final int IDENTIFIER_FIELD_NUMBER

See Also:

Constant Field Values

REMOTE_ID_FIELD_NUMBER

public static final int REMOTE_ID_FIELD_NUMBER

See Also:

Constant Field Values

CONFIGURATION_FIELD_NUMBER

public static final int CONFIGURATION_FIELD_NUMBER

See Also:

Constant Field Values

USER_NAME_FIELD_NUMBER

public static final int USER_NAME_FIELD_NUMBER

See Also:

Constant Field Values

DRIVER_MEMORY_FIELD_NUMBER

public static final int DRIVER_MEMORY_FIELD_NUMBER

See Also:

Constant Field Values

PRIORITY_FIELD_NUMBER

public static final int PRIORITY_FIELD_NUMBER

See Also:

Constant Field Values

QUEUE_FIELD_NUMBER

public static final int QUEUE_FIELD_NUMBER

See Also:

Constant Field Values

GLOBAL_FILE_FIELD_NUMBER

public static final int GLOBAL_FILE_FIELD_NUMBER

See Also:

Constant Field Values

LOCAL_FILE_FIELD_NUMBER

public static final int LOCAL_FILE_FIELD_NUMBER

See Also:

Constant Field Values

Method Detail

getDefaultInstance

public static ClientRuntimeProtocol.JobSubmissionProto getDefaultInstance()

getDefaultInstanceForType

public ClientRuntimeProtocol.JobSubmissionProto getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

getUnknownFields

public final com.google.protobuf.UnknownFieldSet getUnknownFields()

Specified by:

getUnknownFields in interface com.google.protobuf.MessageOrBuilder

Overrides:

getUnknownFields in class com.google.protobuf.GeneratedMessage

getDescriptor

public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

getParserForType

public com.google.protobuf.Parser<ClientRuntimeProtocol.JobSubmissionProto> getParserForType()

Specified by:

getParserForType in interface com.google.protobuf.Message

Specified by:

getParserForType in interface com.google.protobuf.MessageLite

Overrides:

getParserForType in class com.google.protobuf.GeneratedMessage

hasIdentifier

public boolean hasIdentifier()

required string identifier = 1;

 the job identifier
 

Specified by:

hasIdentifier in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getIdentifier

public String getIdentifier()

required string identifier = 1;

 the job identifier
 

Specified by:

getIdentifier in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getIdentifierBytes

public com.google.protobuf.ByteString getIdentifierBytes()

required string identifier = 1;

 the job identifier
 

Specified by:

getIdentifierBytes in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

hasRemoteId

public boolean hasRemoteId()

required string remote_id = 2;

 the remote identifier
 

Specified by:

hasRemoteId in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getRemoteId

public String getRemoteId()

required string remote_id = 2;

 the remote identifier
 

Specified by:

getRemoteId in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getRemoteIdBytes

public com.google.protobuf.ByteString getRemoteIdBytes()

required string remote_id = 2;

 the remote identifier
 

Specified by:

getRemoteIdBytes in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

hasConfiguration

public boolean hasConfiguration()

required string configuration = 5;

 the runtime configuration
 

Specified by:

hasConfiguration in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getConfiguration

public String getConfiguration()

required string configuration = 5;

 the runtime configuration
 

Specified by:

getConfiguration in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getConfigurationBytes

public com.google.protobuf.ByteString getConfigurationBytes()

required string configuration = 5;

 the runtime configuration
 

Specified by:

getConfigurationBytes in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

hasUserName

public boolean hasUserName()

required string user_name = 6;

 the user name
 

Specified by:

hasUserName in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getUserName

public String getUserName()

required string user_name = 6;

 the user name
 

Specified by:

getUserName in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getUserNameBytes

public com.google.protobuf.ByteString getUserNameBytes()

required string user_name = 6;

 the user name
 

Specified by:

getUserNameBytes in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

hasDriverMemory

public boolean hasDriverMemory()

optional int32 driver_memory = 8;

optional SIZE   driver_size    = 7; // Removed in REEF 0.3 in favor of driver_memory below.
 

Specified by:

hasDriverMemory in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getDriverMemory

public int getDriverMemory()

optional int32 driver_memory = 8;

optional SIZE   driver_size    = 7; // Removed in REEF 0.3 in favor of driver_memory below.
 

Specified by:

getDriverMemory in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

hasPriority

public boolean hasPriority()

optional int32 priority = 9;

Specified by:

hasPriority in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getPriority

public int getPriority()

optional int32 priority = 9;

Specified by:

getPriority in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

hasQueue

public boolean hasQueue()

optional string queue = 10;

Specified by:

hasQueue in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getQueue

public String getQueue()

optional string queue = 10;

Specified by:

getQueue in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getQueueBytes

public com.google.protobuf.ByteString getQueueBytes()

optional string queue = 10;

Specified by:

getQueueBytes in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getGlobalFileList

public List<ReefServiceProtos.FileResourceProto> getGlobalFileList()

repeated .FileResourceProto global_file = 11;

 files that should be placed on the driver and all subsequent evaluators
 

Specified by:

getGlobalFileList in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getGlobalFileOrBuilderList

public List<? extends ReefServiceProtos.FileResourceProtoOrBuilder> getGlobalFileOrBuilderList()

repeated .FileResourceProto global_file = 11;

 files that should be placed on the driver and all subsequent evaluators
 

Specified by:

getGlobalFileOrBuilderList in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getGlobalFileCount

public int getGlobalFileCount()

repeated .FileResourceProto global_file = 11;

 files that should be placed on the driver and all subsequent evaluators
 

Specified by:

getGlobalFileCount in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getGlobalFile

public ReefServiceProtos.FileResourceProto getGlobalFile(int index)

repeated .FileResourceProto global_file = 11;

 files that should be placed on the driver and all subsequent evaluators
 

Specified by:

getGlobalFile in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getGlobalFileOrBuilder

public ReefServiceProtos.FileResourceProtoOrBuilder getGlobalFileOrBuilder(int index)

repeated .FileResourceProto global_file = 11;

 files that should be placed on the driver and all subsequent evaluators
 

Specified by:

getGlobalFileOrBuilder in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getLocalFileList

public List<ReefServiceProtos.FileResourceProto> getLocalFileList()

repeated .FileResourceProto local_File = 12;

 files that should be placed on the driver only
 

Specified by:

getLocalFileList in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getLocalFileOrBuilderList

public List<? extends ReefServiceProtos.FileResourceProtoOrBuilder> getLocalFileOrBuilderList()

repeated .FileResourceProto local_File = 12;

 files that should be placed on the driver only
 

Specified by:

getLocalFileOrBuilderList in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getLocalFileCount

public int getLocalFileCount()

repeated .FileResourceProto local_File = 12;

 files that should be placed on the driver only
 

Specified by:

getLocalFileCount in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getLocalFile

public ReefServiceProtos.FileResourceProto getLocalFile(int index)

repeated .FileResourceProto local_File = 12;

 files that should be placed on the driver only
 

Specified by:

getLocalFile in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

getLocalFileOrBuilder

public ReefServiceProtos.FileResourceProtoOrBuilder getLocalFileOrBuilder(int index)

repeated .FileResourceProto local_File = 12;

 files that should be placed on the driver only
 

Specified by:

getLocalFileOrBuilder in interface ClientRuntimeProtocol.JobSubmissionProtoOrBuilder

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessage

writeTo

public void writeTo(com.google.protobuf.CodedOutputStream output)
             throws IOException

Specified by:

writeTo in interface com.google.protobuf.MessageLite

Overrides:

writeTo in class com.google.protobuf.AbstractMessage

Throws:

IOException

getSerializedSize

public int getSerializedSize()

Specified by:

getSerializedSize in interface com.google.protobuf.MessageLite

Overrides:

getSerializedSize in class com.google.protobuf.AbstractMessage

equals

public boolean equals(Object obj)

Specified by:

equals in interface com.google.protobuf.Message

Overrides:

equals in class com.google.protobuf.AbstractMessage

hashCode

public int hashCode()

Specified by:

hashCode in interface com.google.protobuf.Message

Overrides:

hashCode in class com.google.protobuf.AbstractMessage

parseFrom

public static ClientRuntimeProtocol.JobSubmissionProto parseFrom(com.google.protobuf.ByteString data)
                                                          throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static ClientRuntimeProtocol.JobSubmissionProto parseFrom(com.google.protobuf.ByteString data,
                                                 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                          throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static ClientRuntimeProtocol.JobSubmissionProto parseFrom(byte[] data)
                                                          throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static ClientRuntimeProtocol.JobSubmissionProto parseFrom(byte[] data,
                                                 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                          throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static ClientRuntimeProtocol.JobSubmissionProto parseFrom(InputStream input)
                                                          throws IOException

Throws:

IOException

parseFrom

public static ClientRuntimeProtocol.JobSubmissionProto parseFrom(InputStream input,
                                                 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                          throws IOException

Throws:

IOException

parseDelimitedFrom

public static ClientRuntimeProtocol.JobSubmissionProto parseDelimitedFrom(InputStream input)
                                                                   throws IOException

Throws:

IOException

parseDelimitedFrom

public static ClientRuntimeProtocol.JobSubmissionProto parseDelimitedFrom(InputStream input,
                                                          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                                   throws IOException

Throws:

IOException

parseFrom

public static ClientRuntimeProtocol.JobSubmissionProto parseFrom(com.google.protobuf.CodedInputStream input)
                                                          throws IOException

Throws:

IOException

parseFrom

public static ClientRuntimeProtocol.JobSubmissionProto parseFrom(com.google.protobuf.CodedInputStream input,
                                                 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                          throws IOException

Throws:

IOException

newBuilder

public static ClientRuntimeProtocol.JobSubmissionProto.Builder newBuilder()

newBuilderForType

public ClientRuntimeProtocol.JobSubmissionProto.Builder newBuilderForType()

Specified by:

newBuilderForType in interface com.google.protobuf.Message

Specified by:

newBuilderForType in interface com.google.protobuf.MessageLite

newBuilder

public static ClientRuntimeProtocol.JobSubmissionProto.Builder newBuilder(ClientRuntimeProtocol.JobSubmissionProto prototype)

toBuilder

public ClientRuntimeProtocol.JobSubmissionProto.Builder toBuilder()

Specified by:

toBuilder in interface com.google.protobuf.Message

Specified by:

toBuilder in interface com.google.protobuf.MessageLite