Class RpcOptions.RPCOptions
java.lang.Object
com.google.protobuf.AbstractMessageLite
com.google.protobuf.AbstractMessage
com.google.protobuf.GeneratedMessageV3
org.tensorflow.proto.RpcOptions.RPCOptions
- All Implemented Interfaces:
Message, MessageLite, MessageLiteOrBuilder, MessageOrBuilder, Serializable, RpcOptions.RPCOptionsOrBuilder
- Enclosing class:
RpcOptions
public static final class RpcOptions.RPCOptions
extends GeneratedMessageV3
implements RpcOptions.RPCOptionsOrBuilder
RPC options for distributed runtime.Protobuf type
tensorflow.RPCOptions- See Also:
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final classRPC options for distributed runtime.Nested classes/interfaces inherited from class GeneratedMessageV3
GeneratedMessageV3.BuilderParent, GeneratedMessageV3.ExtendableBuilder<MessageType, BuilderType>, GeneratedMessageV3.ExtendableMessage<MessageType>, GeneratedMessageV3.ExtendableMessageOrBuilder<MessageType>, GeneratedMessageV3.FieldAccessorTable, GeneratedMessageV3.UnusedPrivateParameterNested classes/interfaces inherited from class AbstractMessageLite
AbstractMessageLite.InternalOneOfEnum -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intFields inherited from class GeneratedMessageV3
alwaysUseFieldBuilders, unknownFieldsFields inherited from class AbstractMessage
memoizedSizeFields inherited from class AbstractMessageLite
memoizedHashCode -
Method Summary
Modifier and TypeMethodDescriptionbooleanbooleanSetting cache_rpc_response to true will enable sender side caching of response for RecvTensorAsync and RecvBufAsync to allow receiver to retry requests .The compression algorithm to be used.The compression algorithm to be used.intIf compression_algorithm is set, the compression level to be used.static RpcOptions.RPCOptionsstatic final Descriptors.DescriptorbooleanDisables TCP connection sharing when opening a new RPC channel.intSetting num_channels_per_target > 0 allows uses of multiple channels to communicate to the same target.intfinal UnknownFieldSetbooleanIf true, always use RPC to contact the session target.inthashCode()protected GeneratedMessageV3.FieldAccessorTablefinal booleannewBuilder(RpcOptions.RPCOptions prototype) protected RpcOptions.RPCOptions.Builderprotected Objectstatic RpcOptions.RPCOptionsparseDelimitedFrom(InputStream input) static RpcOptions.RPCOptionsparseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry) static RpcOptions.RPCOptionsparseFrom(byte[] data) static RpcOptions.RPCOptionsparseFrom(byte[] data, ExtensionRegistryLite extensionRegistry) static RpcOptions.RPCOptionsparseFrom(ByteString data) static RpcOptions.RPCOptionsparseFrom(ByteString data, ExtensionRegistryLite extensionRegistry) static RpcOptions.RPCOptionsparseFrom(CodedInputStream input) static RpcOptions.RPCOptionsparseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry) static RpcOptions.RPCOptionsparseFrom(InputStream input) static RpcOptions.RPCOptionsparseFrom(InputStream input, ExtensionRegistryLite extensionRegistry) static RpcOptions.RPCOptionsparseFrom(ByteBuffer data) static RpcOptions.RPCOptionsparseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry) static Parser<RpcOptions.RPCOptions> parser()voidwriteTo(CodedOutputStream output) Methods inherited from class GeneratedMessageV3
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof, internalGetMapField, 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, writeStringNoTagMethods inherited from class AbstractMessage
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toStringMethods inherited from class AbstractMessageLite
addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeToMethods inherited from interface MessageLite
toByteArray, toByteString, writeDelimitedTo, writeToMethods inherited from interface MessageOrBuilder
findInitializationErrors, getAllFields, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof
-
Field Details
-
USE_RPC_FOR_INPROCESS_MASTER_FIELD_NUMBER
public static final int USE_RPC_FOR_INPROCESS_MASTER_FIELD_NUMBER- See Also:
-
COMPRESSION_ALGORITHM_FIELD_NUMBER
public static final int COMPRESSION_ALGORITHM_FIELD_NUMBER- See Also:
-
COMPRESSION_LEVEL_FIELD_NUMBER
public static final int COMPRESSION_LEVEL_FIELD_NUMBER- See Also:
-
CACHE_RPC_RESPONSE_FIELD_NUMBER
public static final int CACHE_RPC_RESPONSE_FIELD_NUMBER- See Also:
-
DISABLE_SESSION_CONNECTION_SHARING_FIELD_NUMBER
public static final int DISABLE_SESSION_CONNECTION_SHARING_FIELD_NUMBER- See Also:
-
NUM_CHANNELS_PER_TARGET_FIELD_NUMBER
public static final int NUM_CHANNELS_PER_TARGET_FIELD_NUMBER- See Also:
-
-
Method Details
-
newInstance
- Overrides:
newInstancein classGeneratedMessageV3
-
getUnknownFields
- Specified by:
getUnknownFieldsin interfaceMessageOrBuilder- Overrides:
getUnknownFieldsin classGeneratedMessageV3
-
getDescriptor
-
internalGetFieldAccessorTable
- Specified by:
internalGetFieldAccessorTablein classGeneratedMessageV3
-
getUseRpcForInprocessMaster
public boolean getUseRpcForInprocessMaster()If true, always use RPC to contact the session target. If false (the default option), TensorFlow may use an optimized transport for client-master communication that avoids the RPC stack. This option is primarily for used testing the RPC stack.
bool use_rpc_for_inprocess_master = 1;- Specified by:
getUseRpcForInprocessMasterin interfaceRpcOptions.RPCOptionsOrBuilder- Returns:
- The useRpcForInprocessMaster.
-
getCompressionAlgorithm
The compression algorithm to be used. One of "deflate", "gzip".
string compression_algorithm = 2;- Specified by:
getCompressionAlgorithmin interfaceRpcOptions.RPCOptionsOrBuilder- Returns:
- The compressionAlgorithm.
-
getCompressionAlgorithmBytes
The compression algorithm to be used. One of "deflate", "gzip".
string compression_algorithm = 2;- Specified by:
getCompressionAlgorithmBytesin interfaceRpcOptions.RPCOptionsOrBuilder- Returns:
- The bytes for compressionAlgorithm.
-
getCompressionLevel
public int getCompressionLevel()If compression_algorithm is set, the compression level to be used. From 0 (no compression), up to 3.
int32 compression_level = 3;- Specified by:
getCompressionLevelin interfaceRpcOptions.RPCOptionsOrBuilder- Returns:
- The compressionLevel.
-
getCacheRpcResponse
public boolean getCacheRpcResponse()Setting cache_rpc_response to true will enable sender side caching of response for RecvTensorAsync and RecvBufAsync to allow receiver to retry requests . This is only necessary when the network fabric is experiencing a significant error rate. Without it we'll fail a step on an network error, while with it we'll be able to complete long steps (like complex initializations) in the face of some network errors during RecvTensor.
bool cache_rpc_response = 4;- Specified by:
getCacheRpcResponsein interfaceRpcOptions.RPCOptionsOrBuilder- Returns:
- The cacheRpcResponse.
-
getDisableSessionConnectionSharing
public boolean getDisableSessionConnectionSharing()Disables TCP connection sharing when opening a new RPC channel.
bool disable_session_connection_sharing = 5;- Specified by:
getDisableSessionConnectionSharingin interfaceRpcOptions.RPCOptionsOrBuilder- Returns:
- The disableSessionConnectionSharing.
-
getNumChannelsPerTarget
public int getNumChannelsPerTarget()Setting num_channels_per_target > 0 allows uses of multiple channels to communicate to the same target. This can be used to improve the aggregate throughput on high speed links (e.g 100G) where single connection is not sufficient to maximize link utilization. Note that a single RPC only goes on a single channel, this only helps in situations where there are multiple transfers to the same target overlapping in time.
int32 num_channels_per_target = 6;- Specified by:
getNumChannelsPerTargetin interfaceRpcOptions.RPCOptionsOrBuilder- Returns:
- The numChannelsPerTarget.
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitializedin interfaceMessageLiteOrBuilder- Overrides:
isInitializedin classGeneratedMessageV3
-
writeTo
- Specified by:
writeToin interfaceMessageLite- Overrides:
writeToin classGeneratedMessageV3- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()- Specified by:
getSerializedSizein interfaceMessageLite- Overrides:
getSerializedSizein classGeneratedMessageV3
-
equals
- Specified by:
equalsin interfaceMessage- Overrides:
equalsin classAbstractMessage
-
hashCode
public int hashCode()- Specified by:
hashCodein interfaceMessage- Overrides:
hashCodein classAbstractMessage
-
parseFrom
public static RpcOptions.RPCOptions parseFrom(ByteBuffer data) throws InvalidProtocolBufferException - Throws:
InvalidProtocolBufferException
-
parseFrom
public static RpcOptions.RPCOptions parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry) throws InvalidProtocolBufferException - Throws:
InvalidProtocolBufferException
-
parseFrom
public static RpcOptions.RPCOptions parseFrom(ByteString data) throws InvalidProtocolBufferException - Throws:
InvalidProtocolBufferException
-
parseFrom
public static RpcOptions.RPCOptions parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry) throws InvalidProtocolBufferException - Throws:
InvalidProtocolBufferException
-
parseFrom
- Throws:
InvalidProtocolBufferException
-
parseFrom
public static RpcOptions.RPCOptions parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry) throws InvalidProtocolBufferException - Throws:
InvalidProtocolBufferException
-
parseFrom
- Throws:
IOException
-
parseFrom
public static RpcOptions.RPCOptions parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry) throws IOException - Throws:
IOException
-
parseDelimitedFrom
- Throws:
IOException
-
parseDelimitedFrom
public static RpcOptions.RPCOptions parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry) throws IOException - Throws:
IOException
-
parseFrom
- Throws:
IOException
-
parseFrom
public static RpcOptions.RPCOptions parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry) throws IOException - Throws:
IOException
-
newBuilderForType
- Specified by:
newBuilderForTypein interfaceMessage- Specified by:
newBuilderForTypein interfaceMessageLite
-
newBuilder
-
newBuilder
-
toBuilder
- Specified by:
toBuilderin interfaceMessage- Specified by:
toBuilderin interfaceMessageLite
-
newBuilderForType
- Specified by:
newBuilderForTypein classGeneratedMessageV3
-
getDefaultInstance
-
parser
-
getParserForType
- Specified by:
getParserForTypein interfaceMessage- Specified by:
getParserForTypein interfaceMessageLite- Overrides:
getParserForTypein classGeneratedMessageV3
-
getDefaultInstanceForType
- Specified by:
getDefaultInstanceForTypein interfaceMessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfaceMessageOrBuilder
-