public static final class ServiceConfig.WorkerConfig extends com.google.protobuf.GeneratedMessageV3 implements ServiceConfig.WorkerConfigOrBuilder
Configuration for a tf.data service WorkerServer. Next id: 11Protobuf type
tensorflow.data.experimental.WorkerConfig
Modifier and Type | Class and Description |
---|---|
static class |
ServiceConfig.WorkerConfig.Builder
Configuration for a tf.data service WorkerServer.
|
com.google.protobuf.GeneratedMessageV3.BuilderParent, com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType,BuilderType>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable, com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter
Modifier and Type | Field and Description |
---|---|
static int |
DATA_TRANSFER_ADDRESS_FIELD_NUMBER |
static int |
DATA_TRANSFER_PROTOCOL_FIELD_NUMBER |
static int |
DISPATCHER_ADDRESS_FIELD_NUMBER |
static int |
DISPATCHER_TIMEOUT_MS_FIELD_NUMBER |
static int |
HEARTBEAT_INTERVAL_MS_FIELD_NUMBER |
static int |
PORT_FIELD_NUMBER |
static int |
PROTOCOL_FIELD_NUMBER |
static int |
SHUTDOWN_QUIET_PERIOD_MS_FIELD_NUMBER |
static int |
WORKER_ADDRESS_FIELD_NUMBER |
static int |
WORKER_TAGS_FIELD_NUMBER |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
String |
getDataTransferAddress()
The data transfer address of the worker server.
|
com.google.protobuf.ByteString |
getDataTransferAddressBytes()
The data transfer address of the worker server.
|
String |
getDataTransferProtocol()
The protocol for the worker to use when transferring data to clients.
|
com.google.protobuf.ByteString |
getDataTransferProtocolBytes()
The protocol for the worker to use when transferring data to clients.
|
static ServiceConfig.WorkerConfig |
getDefaultInstance() |
ServiceConfig.WorkerConfig |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
String |
getDispatcherAddress()
The address of the dispatcher to register with.
|
com.google.protobuf.ByteString |
getDispatcherAddressBytes()
The address of the dispatcher to register with.
|
long |
getDispatcherTimeoutMs()
How long to retry requests to the dispatcher before giving up and reporting
an error.
|
long |
getHeartbeatIntervalMs()
How often the worker should heartbeat to the master.
|
com.google.protobuf.Parser<ServiceConfig.WorkerConfig> |
getParserForType() |
long |
getPort()
The port for the worker to bind to.
|
String |
getProtocol()
The protocol for the worker to use when connecting to the dispatcher.
|
com.google.protobuf.ByteString |
getProtocolBytes()
The protocol for the worker to use when connecting to the dispatcher.
|
int |
getSerializedSize() |
long |
getShutdownQuietPeriodMs()
When shutting down a worker, how long to wait for the gRPC server to
process the final requests.
|
com.google.protobuf.UnknownFieldSet |
getUnknownFields() |
String |
getWorkerAddress()
The address of the worker server.
|
com.google.protobuf.ByteString |
getWorkerAddressBytes()
The address of the worker server.
|
String |
getWorkerTags(int index)
Tags attached to the worker.
|
com.google.protobuf.ByteString |
getWorkerTagsBytes(int index)
Tags attached to the worker.
|
int |
getWorkerTagsCount()
Tags attached to the worker.
|
com.google.protobuf.ProtocolStringList |
getWorkerTagsList()
Tags attached to the worker.
|
int |
hashCode() |
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable |
internalGetFieldAccessorTable() |
boolean |
isInitialized() |
static ServiceConfig.WorkerConfig.Builder |
newBuilder() |
static ServiceConfig.WorkerConfig.Builder |
newBuilder(ServiceConfig.WorkerConfig prototype) |
ServiceConfig.WorkerConfig.Builder |
newBuilderForType() |
protected ServiceConfig.WorkerConfig.Builder |
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) |
protected Object |
newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused) |
static ServiceConfig.WorkerConfig |
parseDelimitedFrom(InputStream input) |
static ServiceConfig.WorkerConfig |
parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ServiceConfig.WorkerConfig |
parseFrom(byte[] data) |
static ServiceConfig.WorkerConfig |
parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ServiceConfig.WorkerConfig |
parseFrom(ByteBuffer data) |
static ServiceConfig.WorkerConfig |
parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ServiceConfig.WorkerConfig |
parseFrom(com.google.protobuf.ByteString data) |
static ServiceConfig.WorkerConfig |
parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ServiceConfig.WorkerConfig |
parseFrom(com.google.protobuf.CodedInputStream input) |
static ServiceConfig.WorkerConfig |
parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ServiceConfig.WorkerConfig |
parseFrom(InputStream input) |
static ServiceConfig.WorkerConfig |
parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static com.google.protobuf.Parser<ServiceConfig.WorkerConfig> |
parser() |
ServiceConfig.WorkerConfig.Builder |
toBuilder() |
void |
writeTo(com.google.protobuf.CodedOutputStream output) |
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, writeStringNoTag
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public static final int PORT_FIELD_NUMBER
public static final int PROTOCOL_FIELD_NUMBER
public static final int DISPATCHER_ADDRESS_FIELD_NUMBER
public static final int WORKER_ADDRESS_FIELD_NUMBER
public static final int WORKER_TAGS_FIELD_NUMBER
public static final int HEARTBEAT_INTERVAL_MS_FIELD_NUMBER
public static final int DISPATCHER_TIMEOUT_MS_FIELD_NUMBER
public static final int DATA_TRANSFER_PROTOCOL_FIELD_NUMBER
public static final int DATA_TRANSFER_ADDRESS_FIELD_NUMBER
public static final int SHUTDOWN_QUIET_PERIOD_MS_FIELD_NUMBER
protected Object newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
newInstance
in class com.google.protobuf.GeneratedMessageV3
public final com.google.protobuf.UnknownFieldSet getUnknownFields()
getUnknownFields
in interface com.google.protobuf.MessageOrBuilder
getUnknownFields
in class com.google.protobuf.GeneratedMessageV3
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable
in class com.google.protobuf.GeneratedMessageV3
public long getPort()
The port for the worker to bind to. A value of 0 indicates that the worker may bind to any available port.
int64 port = 1;
getPort
in interface ServiceConfig.WorkerConfigOrBuilder
public String getProtocol()
The protocol for the worker to use when connecting to the dispatcher.
string protocol = 2;
getProtocol
in interface ServiceConfig.WorkerConfigOrBuilder
public com.google.protobuf.ByteString getProtocolBytes()
The protocol for the worker to use when connecting to the dispatcher.
string protocol = 2;
getProtocolBytes
in interface ServiceConfig.WorkerConfigOrBuilder
public String getDispatcherAddress()
The address of the dispatcher to register with.
string dispatcher_address = 3;
getDispatcherAddress
in interface ServiceConfig.WorkerConfigOrBuilder
public com.google.protobuf.ByteString getDispatcherAddressBytes()
The address of the dispatcher to register with.
string dispatcher_address = 3;
getDispatcherAddressBytes
in interface ServiceConfig.WorkerConfigOrBuilder
public String getWorkerAddress()
The address of the worker server. The substring "%port%", if specified, will be replaced with the worker's bound port. This is useful when the port is set to `0`.
string worker_address = 4;
getWorkerAddress
in interface ServiceConfig.WorkerConfigOrBuilder
public com.google.protobuf.ByteString getWorkerAddressBytes()
The address of the worker server. The substring "%port%", if specified, will be replaced with the worker's bound port. This is useful when the port is set to `0`.
string worker_address = 4;
getWorkerAddressBytes
in interface ServiceConfig.WorkerConfigOrBuilder
public com.google.protobuf.ProtocolStringList getWorkerTagsList()
Tags attached to the worker. This allows reading from selected workers. For example, by applying a "COLOCATED" tag, tf.data service is able to read from the local tf.data worker if one exists, then from off-TF-host workers, to avoid cross-TF-host reads.
repeated string worker_tags = 10;
getWorkerTagsList
in interface ServiceConfig.WorkerConfigOrBuilder
public int getWorkerTagsCount()
Tags attached to the worker. This allows reading from selected workers. For example, by applying a "COLOCATED" tag, tf.data service is able to read from the local tf.data worker if one exists, then from off-TF-host workers, to avoid cross-TF-host reads.
repeated string worker_tags = 10;
getWorkerTagsCount
in interface ServiceConfig.WorkerConfigOrBuilder
public String getWorkerTags(int index)
Tags attached to the worker. This allows reading from selected workers. For example, by applying a "COLOCATED" tag, tf.data service is able to read from the local tf.data worker if one exists, then from off-TF-host workers, to avoid cross-TF-host reads.
repeated string worker_tags = 10;
getWorkerTags
in interface ServiceConfig.WorkerConfigOrBuilder
public com.google.protobuf.ByteString getWorkerTagsBytes(int index)
Tags attached to the worker. This allows reading from selected workers. For example, by applying a "COLOCATED" tag, tf.data service is able to read from the local tf.data worker if one exists, then from off-TF-host workers, to avoid cross-TF-host reads.
repeated string worker_tags = 10;
getWorkerTagsBytes
in interface ServiceConfig.WorkerConfigOrBuilder
public long getHeartbeatIntervalMs()
How often the worker should heartbeat to the master. A value of 0 indicates that the decision should be left up to the runtime.
int64 heartbeat_interval_ms = 5;
getHeartbeatIntervalMs
in interface ServiceConfig.WorkerConfigOrBuilder
public long getDispatcherTimeoutMs()
How long to retry requests to the dispatcher before giving up and reporting an error. A value of 0 indicates that the decision should be left up to the runtime.
int64 dispatcher_timeout_ms = 6;
getDispatcherTimeoutMs
in interface ServiceConfig.WorkerConfigOrBuilder
public String getDataTransferProtocol()
The protocol for the worker to use when transferring data to clients.
string data_transfer_protocol = 7;
getDataTransferProtocol
in interface ServiceConfig.WorkerConfigOrBuilder
public com.google.protobuf.ByteString getDataTransferProtocolBytes()
The protocol for the worker to use when transferring data to clients.
string data_transfer_protocol = 7;
getDataTransferProtocolBytes
in interface ServiceConfig.WorkerConfigOrBuilder
public String getDataTransferAddress()
The data transfer address of the worker server. The substring "%port%", if specified, will be replaced with the worker's bound port. This is useful when the port is set to `0`.
string data_transfer_address = 8;
getDataTransferAddress
in interface ServiceConfig.WorkerConfigOrBuilder
public com.google.protobuf.ByteString getDataTransferAddressBytes()
The data transfer address of the worker server. The substring "%port%", if specified, will be replaced with the worker's bound port. This is useful when the port is set to `0`.
string data_transfer_address = 8;
getDataTransferAddressBytes
in interface ServiceConfig.WorkerConfigOrBuilder
public long getShutdownQuietPeriodMs()
When shutting down a worker, how long to wait for the gRPC server to process the final requests. This is used to achieve clean shutdown in unit tests.
int64 shutdown_quiet_period_ms = 9;
getShutdownQuietPeriodMs
in interface ServiceConfig.WorkerConfigOrBuilder
public final boolean isInitialized()
isInitialized
in interface com.google.protobuf.MessageLiteOrBuilder
isInitialized
in class com.google.protobuf.GeneratedMessageV3
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
writeTo
in interface com.google.protobuf.MessageLite
writeTo
in class com.google.protobuf.GeneratedMessageV3
IOException
public int getSerializedSize()
getSerializedSize
in interface com.google.protobuf.MessageLite
getSerializedSize
in class com.google.protobuf.GeneratedMessageV3
public boolean equals(Object obj)
equals
in interface com.google.protobuf.Message
equals
in class com.google.protobuf.AbstractMessage
public int hashCode()
hashCode
in interface com.google.protobuf.Message
hashCode
in class com.google.protobuf.AbstractMessage
public static ServiceConfig.WorkerConfig parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static ServiceConfig.WorkerConfig parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static ServiceConfig.WorkerConfig parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static ServiceConfig.WorkerConfig parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static ServiceConfig.WorkerConfig parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static ServiceConfig.WorkerConfig parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static ServiceConfig.WorkerConfig parseFrom(InputStream input) throws IOException
IOException
public static ServiceConfig.WorkerConfig parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static ServiceConfig.WorkerConfig parseDelimitedFrom(InputStream input) throws IOException
IOException
public static ServiceConfig.WorkerConfig parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static ServiceConfig.WorkerConfig parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
IOException
public static ServiceConfig.WorkerConfig parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public ServiceConfig.WorkerConfig.Builder newBuilderForType()
newBuilderForType
in interface com.google.protobuf.Message
newBuilderForType
in interface com.google.protobuf.MessageLite
public static ServiceConfig.WorkerConfig.Builder newBuilder()
public static ServiceConfig.WorkerConfig.Builder newBuilder(ServiceConfig.WorkerConfig prototype)
public ServiceConfig.WorkerConfig.Builder toBuilder()
toBuilder
in interface com.google.protobuf.Message
toBuilder
in interface com.google.protobuf.MessageLite
protected ServiceConfig.WorkerConfig.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
newBuilderForType
in class com.google.protobuf.GeneratedMessageV3
public static ServiceConfig.WorkerConfig getDefaultInstance()
public static com.google.protobuf.Parser<ServiceConfig.WorkerConfig> parser()
public com.google.protobuf.Parser<ServiceConfig.WorkerConfig> getParserForType()
getParserForType
in interface com.google.protobuf.Message
getParserForType
in interface com.google.protobuf.MessageLite
getParserForType
in class com.google.protobuf.GeneratedMessageV3
public ServiceConfig.WorkerConfig getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder
Copyright © 2015–2022. All rights reserved.