Class ServiceConfig.DispatcherConfig.Builder
java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<ServiceConfig.DispatcherConfig.Builder>
com.google.protobuf.GeneratedMessageV3.Builder<ServiceConfig.DispatcherConfig.Builder>
org.tensorflow.proto.data.experimental.ServiceConfig.DispatcherConfig.Builder
- All Implemented Interfaces:
Message.Builder, MessageLite.Builder, MessageLiteOrBuilder, MessageOrBuilder, Cloneable, ServiceConfig.DispatcherConfigOrBuilder
- Enclosing class:
ServiceConfig.DispatcherConfig
public static final class ServiceConfig.DispatcherConfig.Builder
extends GeneratedMessageV3.Builder<ServiceConfig.DispatcherConfig.Builder>
implements ServiceConfig.DispatcherConfigOrBuilder
Configuration for a tf.data service DispatchServer. Next id: 13Protobuf type
tensorflow.data.experimental.DispatcherConfig-
Method Summary
Modifier and TypeMethodDescriptionaddAllWorkerAddresses(Iterable<String> values) (Optional.)addRepeatedField(Descriptors.FieldDescriptor field, Object value) addWorkerAddresses(String value) (Optional.)(Optional.)build()clear()How long to wait before garbage-collecting a client that hasn't heartbeated to the dispatcher.(Optional.) tf.data service deployment mode.Whether to run in fault tolerant mode, where dispatcher state is saved across restarts.Whether dynamically sharded jobs should be eligible for garbage collection.How often the dispatcher should scan through to delete old and unused jobs.How long a job needs to be unused before it becomes a candidate for garbage collection.The port for the dispatcher to bind to.The protocol for the dispatcher to use when connecting to workers.A work directory to use for storing dispatcher state, and for recovering during restarts.(Optional.)The maximum number of snapshots that a worker can concurrently process at a given point in time.How long to wait for a worker to heartbeat before considering it missing.clone()longHow long to wait before garbage-collecting a client that hasn't heartbeated to the dispatcher.(Optional.) tf.data service deployment mode.int(Optional.) tf.data service deployment mode.static final Descriptors.DescriptorbooleanWhether to run in fault tolerant mode, where dispatcher state is saved across restarts.booleanWhether dynamically sharded jobs should be eligible for garbage collection.longHow often the dispatcher should scan through to delete old and unused jobs.longHow long a job needs to be unused before it becomes a candidate for garbage collection.longgetPort()The port for the dispatcher to bind to.The protocol for the dispatcher to use when connecting to workers.The protocol for the dispatcher to use when connecting to workers.A work directory to use for storing dispatcher state, and for recovering during restarts.A work directory to use for storing dispatcher state, and for recovering during restarts.getWorkerAddresses(int index) (Optional.)getWorkerAddressesBytes(int index) (Optional.)int(Optional.)(Optional.)longThe maximum number of snapshots that a worker can concurrently process at a given point in time.longHow long to wait for a worker to heartbeat before considering it missing.protected GeneratedMessageV3.FieldAccessorTablefinal booleanmergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry) mergeUnknownFields(UnknownFieldSet unknownFields) setClientTimeoutMs(long value) How long to wait before garbage-collecting a client that hasn't heartbeated to the dispatcher.(Optional.) tf.data service deployment mode.setDeploymentModeValue(int value) (Optional.) tf.data service deployment mode.setFaultTolerantMode(boolean value) Whether to run in fault tolerant mode, where dispatcher state is saved across restarts.setField(Descriptors.FieldDescriptor field, Object value) setGcDynamicShardingJobs(boolean value) Whether dynamically sharded jobs should be eligible for garbage collection.setJobGcCheckIntervalMs(long value) How often the dispatcher should scan through to delete old and unused jobs.setJobGcTimeoutMs(long value) How long a job needs to be unused before it becomes a candidate for garbage collection.setPort(long value) The port for the dispatcher to bind to.setProtocol(String value) The protocol for the dispatcher to use when connecting to workers.setProtocolBytes(ByteString value) The protocol for the dispatcher to use when connecting to workers.setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value) setUnknownFields(UnknownFieldSet unknownFields) setWorkDir(String value) A work directory to use for storing dispatcher state, and for recovering during restarts.setWorkDirBytes(ByteString value) A work directory to use for storing dispatcher state, and for recovering during restarts.setWorkerAddresses(int index, String value) (Optional.)setWorkerMaxConcurrentSnapshots(long value) The maximum number of snapshots that a worker can concurrently process at a given point in time.setWorkerTimeoutMs(long value) How long to wait for a worker to heartbeat before considering it missing.Methods inherited from class GeneratedMessageV3.Builder
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, getUnknownFieldSetBuilder, hasField, hasOneof, internalGetMapField, internalGetMutableMapField, isClean, markClean, mergeUnknownLengthDelimitedField, mergeUnknownVarintField, newBuilderForField, onBuilt, onChanged, parseUnknownField, setUnknownFieldSetBuilder, setUnknownFieldsProto3Methods inherited from class AbstractMessage.Builder
findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toStringMethods inherited from class AbstractMessageLite.Builder
addAll, addAll, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, newUninitializedMessageExceptionMethods inherited from class Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface Message.Builder
mergeDelimitedFrom, mergeDelimitedFromMethods inherited from interface MessageLite.Builder
mergeFromMethods inherited from interface MessageOrBuilder
findInitializationErrors, getAllFields, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
-
Method Details
-
getDescriptor
-
internalGetFieldAccessorTable
- Specified by:
internalGetFieldAccessorTablein classGeneratedMessageV3.Builder<ServiceConfig.DispatcherConfig.Builder>
-
clear
- Specified by:
clearin interfaceMessage.Builder- Specified by:
clearin interfaceMessageLite.Builder- Overrides:
clearin classGeneratedMessageV3.Builder<ServiceConfig.DispatcherConfig.Builder>
-
getDescriptorForType
- Specified by:
getDescriptorForTypein interfaceMessage.Builder- Specified by:
getDescriptorForTypein interfaceMessageOrBuilder- Overrides:
getDescriptorForTypein classGeneratedMessageV3.Builder<ServiceConfig.DispatcherConfig.Builder>
-
getDefaultInstanceForType
- Specified by:
getDefaultInstanceForTypein interfaceMessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfaceMessageOrBuilder
-
build
- Specified by:
buildin interfaceMessage.Builder- Specified by:
buildin interfaceMessageLite.Builder
-
buildPartial
- Specified by:
buildPartialin interfaceMessage.Builder- Specified by:
buildPartialin interfaceMessageLite.Builder
-
clone
- Specified by:
clonein interfaceMessage.Builder- Specified by:
clonein interfaceMessageLite.Builder- Overrides:
clonein classGeneratedMessageV3.Builder<ServiceConfig.DispatcherConfig.Builder>
-
setField
public ServiceConfig.DispatcherConfig.Builder setField(Descriptors.FieldDescriptor field, Object value) - Specified by:
setFieldin interfaceMessage.Builder- Overrides:
setFieldin classGeneratedMessageV3.Builder<ServiceConfig.DispatcherConfig.Builder>
-
clearField
- Specified by:
clearFieldin interfaceMessage.Builder- Overrides:
clearFieldin classGeneratedMessageV3.Builder<ServiceConfig.DispatcherConfig.Builder>
-
clearOneof
- Specified by:
clearOneofin interfaceMessage.Builder- Overrides:
clearOneofin classGeneratedMessageV3.Builder<ServiceConfig.DispatcherConfig.Builder>
-
setRepeatedField
public ServiceConfig.DispatcherConfig.Builder setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value) - Specified by:
setRepeatedFieldin interfaceMessage.Builder- Overrides:
setRepeatedFieldin classGeneratedMessageV3.Builder<ServiceConfig.DispatcherConfig.Builder>
-
addRepeatedField
public ServiceConfig.DispatcherConfig.Builder addRepeatedField(Descriptors.FieldDescriptor field, Object value) - Specified by:
addRepeatedFieldin interfaceMessage.Builder- Overrides:
addRepeatedFieldin classGeneratedMessageV3.Builder<ServiceConfig.DispatcherConfig.Builder>
-
mergeFrom
- Specified by:
mergeFromin interfaceMessage.Builder- Overrides:
mergeFromin classAbstractMessage.Builder<ServiceConfig.DispatcherConfig.Builder>
-
mergeFrom
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitializedin interfaceMessageLiteOrBuilder- Overrides:
isInitializedin classGeneratedMessageV3.Builder<ServiceConfig.DispatcherConfig.Builder>
-
mergeFrom
public ServiceConfig.DispatcherConfig.Builder mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry) throws IOException - Specified by:
mergeFromin interfaceMessage.Builder- Specified by:
mergeFromin interfaceMessageLite.Builder- Overrides:
mergeFromin classAbstractMessage.Builder<ServiceConfig.DispatcherConfig.Builder>- Throws:
IOException
-
getPort
public long getPort()The port for the dispatcher to bind to. A value of 0 indicates that the dispatcher may bind to any available port.
int64 port = 1;- Specified by:
getPortin interfaceServiceConfig.DispatcherConfigOrBuilder- Returns:
- The port.
-
setPort
The port for the dispatcher to bind to. A value of 0 indicates that the dispatcher may bind to any available port.
int64 port = 1;- Parameters:
value- The port to set.- Returns:
- This builder for chaining.
-
clearPort
The port for the dispatcher to bind to. A value of 0 indicates that the dispatcher may bind to any available port.
int64 port = 1;- Returns:
- This builder for chaining.
-
getProtocol
The protocol for the dispatcher to use when connecting to workers.
string protocol = 2;- Specified by:
getProtocolin interfaceServiceConfig.DispatcherConfigOrBuilder- Returns:
- The protocol.
-
getProtocolBytes
The protocol for the dispatcher to use when connecting to workers.
string protocol = 2;- Specified by:
getProtocolBytesin interfaceServiceConfig.DispatcherConfigOrBuilder- Returns:
- The bytes for protocol.
-
setProtocol
The protocol for the dispatcher to use when connecting to workers.
string protocol = 2;- Parameters:
value- The protocol to set.- Returns:
- This builder for chaining.
-
clearProtocol
The protocol for the dispatcher to use when connecting to workers.
string protocol = 2;- Returns:
- This builder for chaining.
-
setProtocolBytes
The protocol for the dispatcher to use when connecting to workers.
string protocol = 2;- Parameters:
value- The bytes for protocol to set.- Returns:
- This builder for chaining.
-
getWorkDir
A work directory to use for storing dispatcher state, and for recovering during restarts. The empty string indicates not to use any work directory.
string work_dir = 3;- Specified by:
getWorkDirin interfaceServiceConfig.DispatcherConfigOrBuilder- Returns:
- The workDir.
-
getWorkDirBytes
A work directory to use for storing dispatcher state, and for recovering during restarts. The empty string indicates not to use any work directory.
string work_dir = 3;- Specified by:
getWorkDirBytesin interfaceServiceConfig.DispatcherConfigOrBuilder- Returns:
- The bytes for workDir.
-
setWorkDir
A work directory to use for storing dispatcher state, and for recovering during restarts. The empty string indicates not to use any work directory.
string work_dir = 3;- Parameters:
value- The workDir to set.- Returns:
- This builder for chaining.
-
clearWorkDir
A work directory to use for storing dispatcher state, and for recovering during restarts. The empty string indicates not to use any work directory.
string work_dir = 3;- Returns:
- This builder for chaining.
-
setWorkDirBytes
A work directory to use for storing dispatcher state, and for recovering during restarts. The empty string indicates not to use any work directory.
string work_dir = 3;- Parameters:
value- The bytes for workDir to set.- Returns:
- This builder for chaining.
-
getFaultTolerantMode
public boolean getFaultTolerantMode()Whether to run in fault tolerant mode, where dispatcher state is saved across restarts. Requires that `work_dir` is nonempty.
bool fault_tolerant_mode = 4;- Specified by:
getFaultTolerantModein interfaceServiceConfig.DispatcherConfigOrBuilder- Returns:
- The faultTolerantMode.
-
setFaultTolerantMode
Whether to run in fault tolerant mode, where dispatcher state is saved across restarts. Requires that `work_dir` is nonempty.
bool fault_tolerant_mode = 4;- Parameters:
value- The faultTolerantMode to set.- Returns:
- This builder for chaining.
-
clearFaultTolerantMode
Whether to run in fault tolerant mode, where dispatcher state is saved across restarts. Requires that `work_dir` is nonempty.
bool fault_tolerant_mode = 4;- Returns:
- This builder for chaining.
-
getWorkerAddressesList
(Optional.) If the job uses auto-sharding, it needs to specify a fixed list of worker addresses that will register with the dispatcher. The worker addresses should be in the format "host" or "host:port", where "port" is an integer, named port, or %port% to match any port.
repeated string worker_addresses = 7;- Specified by:
getWorkerAddressesListin interfaceServiceConfig.DispatcherConfigOrBuilder- Returns:
- A list containing the workerAddresses.
-
getWorkerAddressesCount
public int getWorkerAddressesCount()(Optional.) If the job uses auto-sharding, it needs to specify a fixed list of worker addresses that will register with the dispatcher. The worker addresses should be in the format "host" or "host:port", where "port" is an integer, named port, or %port% to match any port.
repeated string worker_addresses = 7;- Specified by:
getWorkerAddressesCountin interfaceServiceConfig.DispatcherConfigOrBuilder- Returns:
- The count of workerAddresses.
-
getWorkerAddresses
(Optional.) If the job uses auto-sharding, it needs to specify a fixed list of worker addresses that will register with the dispatcher. The worker addresses should be in the format "host" or "host:port", where "port" is an integer, named port, or %port% to match any port.
repeated string worker_addresses = 7;- Specified by:
getWorkerAddressesin interfaceServiceConfig.DispatcherConfigOrBuilder- Parameters:
index- The index of the element to return.- Returns:
- The workerAddresses at the given index.
-
getWorkerAddressesBytes
(Optional.) If the job uses auto-sharding, it needs to specify a fixed list of worker addresses that will register with the dispatcher. The worker addresses should be in the format "host" or "host:port", where "port" is an integer, named port, or %port% to match any port.
repeated string worker_addresses = 7;- Specified by:
getWorkerAddressesBytesin interfaceServiceConfig.DispatcherConfigOrBuilder- Parameters:
index- The index of the value to return.- Returns:
- The bytes of the workerAddresses at the given index.
-
setWorkerAddresses
(Optional.) If the job uses auto-sharding, it needs to specify a fixed list of worker addresses that will register with the dispatcher. The worker addresses should be in the format "host" or "host:port", where "port" is an integer, named port, or %port% to match any port.
repeated string worker_addresses = 7;- Parameters:
index- The index to set the value at.value- The workerAddresses to set.- Returns:
- This builder for chaining.
-
addWorkerAddresses
(Optional.) If the job uses auto-sharding, it needs to specify a fixed list of worker addresses that will register with the dispatcher. The worker addresses should be in the format "host" or "host:port", where "port" is an integer, named port, or %port% to match any port.
repeated string worker_addresses = 7;- Parameters:
value- The workerAddresses to add.- Returns:
- This builder for chaining.
-
addAllWorkerAddresses
(Optional.) If the job uses auto-sharding, it needs to specify a fixed list of worker addresses that will register with the dispatcher. The worker addresses should be in the format "host" or "host:port", where "port" is an integer, named port, or %port% to match any port.
repeated string worker_addresses = 7;- Parameters:
values- The workerAddresses to add.- Returns:
- This builder for chaining.
-
clearWorkerAddresses
(Optional.) If the job uses auto-sharding, it needs to specify a fixed list of worker addresses that will register with the dispatcher. The worker addresses should be in the format "host" or "host:port", where "port" is an integer, named port, or %port% to match any port.
repeated string worker_addresses = 7;- Returns:
- This builder for chaining.
-
addWorkerAddressesBytes
(Optional.) If the job uses auto-sharding, it needs to specify a fixed list of worker addresses that will register with the dispatcher. The worker addresses should be in the format "host" or "host:port", where "port" is an integer, named port, or %port% to match any port.
repeated string worker_addresses = 7;- Parameters:
value- The bytes of the workerAddresses to add.- Returns:
- This builder for chaining.
-
getDeploymentModeValue
public int getDeploymentModeValue()(Optional.) tf.data service deployment mode. Supported values are "REMOTE", "COLOCATED", and "HYBRID". If unspecified, it is assumed to be "REMOTE".
.tensorflow.data.DeploymentMode deployment_mode = 9;- Specified by:
getDeploymentModeValuein interfaceServiceConfig.DispatcherConfigOrBuilder- Returns:
- The enum numeric value on the wire for deploymentMode.
-
setDeploymentModeValue
(Optional.) tf.data service deployment mode. Supported values are "REMOTE", "COLOCATED", and "HYBRID". If unspecified, it is assumed to be "REMOTE".
.tensorflow.data.DeploymentMode deployment_mode = 9;- Parameters:
value- The enum numeric value on the wire for deploymentMode to set.- Returns:
- This builder for chaining.
-
getDeploymentMode
(Optional.) tf.data service deployment mode. Supported values are "REMOTE", "COLOCATED", and "HYBRID". If unspecified, it is assumed to be "REMOTE".
.tensorflow.data.DeploymentMode deployment_mode = 9;- Specified by:
getDeploymentModein interfaceServiceConfig.DispatcherConfigOrBuilder- Returns:
- The deploymentMode.
-
setDeploymentMode
(Optional.) tf.data service deployment mode. Supported values are "REMOTE", "COLOCATED", and "HYBRID". If unspecified, it is assumed to be "REMOTE".
.tensorflow.data.DeploymentMode deployment_mode = 9;- Parameters:
value- The deploymentMode to set.- Returns:
- This builder for chaining.
-
clearDeploymentMode
(Optional.) tf.data service deployment mode. Supported values are "REMOTE", "COLOCATED", and "HYBRID". If unspecified, it is assumed to be "REMOTE".
.tensorflow.data.DeploymentMode deployment_mode = 9;- Returns:
- This builder for chaining.
-
getJobGcCheckIntervalMs
public long getJobGcCheckIntervalMs()How often the dispatcher should scan through to delete old and unused jobs. A value of 0 indicates that the decision should be left up to the runtime.
int64 job_gc_check_interval_ms = 5;- Specified by:
getJobGcCheckIntervalMsin interfaceServiceConfig.DispatcherConfigOrBuilder- Returns:
- The jobGcCheckIntervalMs.
-
setJobGcCheckIntervalMs
How often the dispatcher should scan through to delete old and unused jobs. A value of 0 indicates that the decision should be left up to the runtime.
int64 job_gc_check_interval_ms = 5;- Parameters:
value- The jobGcCheckIntervalMs to set.- Returns:
- This builder for chaining.
-
clearJobGcCheckIntervalMs
How often the dispatcher should scan through to delete old and unused jobs. A value of 0 indicates that the decision should be left up to the runtime.
int64 job_gc_check_interval_ms = 5;- Returns:
- This builder for chaining.
-
getJobGcTimeoutMs
public long getJobGcTimeoutMs()How long a job needs to be unused before it becomes a candidate for garbage collection. A value of -1 indicates that jobs should never be garbage collected. A value of 0 indicates that the decision should be left up to the runtime. Note: This does not apply to dynamic sharding unless users explicitly opt-in by enabling `gc_dynamic_sharding_jobs` below.
int64 job_gc_timeout_ms = 6;- Specified by:
getJobGcTimeoutMsin interfaceServiceConfig.DispatcherConfigOrBuilder- Returns:
- The jobGcTimeoutMs.
-
setJobGcTimeoutMs
How long a job needs to be unused before it becomes a candidate for garbage collection. A value of -1 indicates that jobs should never be garbage collected. A value of 0 indicates that the decision should be left up to the runtime. Note: This does not apply to dynamic sharding unless users explicitly opt-in by enabling `gc_dynamic_sharding_jobs` below.
int64 job_gc_timeout_ms = 6;- Parameters:
value- The jobGcTimeoutMs to set.- Returns:
- This builder for chaining.
-
clearJobGcTimeoutMs
How long a job needs to be unused before it becomes a candidate for garbage collection. A value of -1 indicates that jobs should never be garbage collected. A value of 0 indicates that the decision should be left up to the runtime. Note: This does not apply to dynamic sharding unless users explicitly opt-in by enabling `gc_dynamic_sharding_jobs` below.
int64 job_gc_timeout_ms = 6;- Returns:
- This builder for chaining.
-
getGcDynamicShardingJobs
public boolean getGcDynamicShardingJobs()Whether dynamically sharded jobs should be eligible for garbage collection. These jobs are not garbage collected by default, since if a job is garbage collected and then re-created, it will revisit all data from the start. If revisiting data is acceptible and you want automatic reclamation of iterator memory, set `gc_dynamic_sharding_jobs` to `true`.
bool gc_dynamic_sharding_jobs = 11;- Specified by:
getGcDynamicShardingJobsin interfaceServiceConfig.DispatcherConfigOrBuilder- Returns:
- The gcDynamicShardingJobs.
-
setGcDynamicShardingJobs
Whether dynamically sharded jobs should be eligible for garbage collection. These jobs are not garbage collected by default, since if a job is garbage collected and then re-created, it will revisit all data from the start. If revisiting data is acceptible and you want automatic reclamation of iterator memory, set `gc_dynamic_sharding_jobs` to `true`.
bool gc_dynamic_sharding_jobs = 11;- Parameters:
value- The gcDynamicShardingJobs to set.- Returns:
- This builder for chaining.
-
clearGcDynamicShardingJobs
Whether dynamically sharded jobs should be eligible for garbage collection. These jobs are not garbage collected by default, since if a job is garbage collected and then re-created, it will revisit all data from the start. If revisiting data is acceptible and you want automatic reclamation of iterator memory, set `gc_dynamic_sharding_jobs` to `true`.
bool gc_dynamic_sharding_jobs = 11;- Returns:
- This builder for chaining.
-
getClientTimeoutMs
public long getClientTimeoutMs()How long to wait before garbage-collecting a client that hasn't heartbeated to the dispatcher. A value of 0 indicates that the timeout should be left to the runtime.
int64 client_timeout_ms = 8;- Specified by:
getClientTimeoutMsin interfaceServiceConfig.DispatcherConfigOrBuilder- Returns:
- The clientTimeoutMs.
-
setClientTimeoutMs
How long to wait before garbage-collecting a client that hasn't heartbeated to the dispatcher. A value of 0 indicates that the timeout should be left to the runtime.
int64 client_timeout_ms = 8;- Parameters:
value- The clientTimeoutMs to set.- Returns:
- This builder for chaining.
-
clearClientTimeoutMs
How long to wait before garbage-collecting a client that hasn't heartbeated to the dispatcher. A value of 0 indicates that the timeout should be left to the runtime.
int64 client_timeout_ms = 8;- Returns:
- This builder for chaining.
-
getWorkerTimeoutMs
public long getWorkerTimeoutMs()How long to wait for a worker to heartbeat before considering it missing. A value of 0 indicates that the timeout should be left to the runtime.
int64 worker_timeout_ms = 10;- Specified by:
getWorkerTimeoutMsin interfaceServiceConfig.DispatcherConfigOrBuilder- Returns:
- The workerTimeoutMs.
-
setWorkerTimeoutMs
How long to wait for a worker to heartbeat before considering it missing. A value of 0 indicates that the timeout should be left to the runtime.
int64 worker_timeout_ms = 10;- Parameters:
value- The workerTimeoutMs to set.- Returns:
- This builder for chaining.
-
clearWorkerTimeoutMs
How long to wait for a worker to heartbeat before considering it missing. A value of 0 indicates that the timeout should be left to the runtime.
int64 worker_timeout_ms = 10;- Returns:
- This builder for chaining.
-
getWorkerMaxConcurrentSnapshots
public long getWorkerMaxConcurrentSnapshots()The maximum number of snapshots that a worker can concurrently process at a given point in time. This is a tradeoff between worker resource usage and snapshot wall time. A value of 0 indicates that the decision should be left up to the runtime.
int64 worker_max_concurrent_snapshots = 12;- Specified by:
getWorkerMaxConcurrentSnapshotsin interfaceServiceConfig.DispatcherConfigOrBuilder- Returns:
- The workerMaxConcurrentSnapshots.
-
setWorkerMaxConcurrentSnapshots
The maximum number of snapshots that a worker can concurrently process at a given point in time. This is a tradeoff between worker resource usage and snapshot wall time. A value of 0 indicates that the decision should be left up to the runtime.
int64 worker_max_concurrent_snapshots = 12;- Parameters:
value- The workerMaxConcurrentSnapshots to set.- Returns:
- This builder for chaining.
-
clearWorkerMaxConcurrentSnapshots
The maximum number of snapshots that a worker can concurrently process at a given point in time. This is a tradeoff between worker resource usage and snapshot wall time. A value of 0 indicates that the decision should be left up to the runtime.
int64 worker_max_concurrent_snapshots = 12;- Returns:
- This builder for chaining.
-
setUnknownFields
- Specified by:
setUnknownFieldsin interfaceMessage.Builder- Overrides:
setUnknownFieldsin classGeneratedMessageV3.Builder<ServiceConfig.DispatcherConfig.Builder>
-
mergeUnknownFields
public final ServiceConfig.DispatcherConfig.Builder mergeUnknownFields(UnknownFieldSet unknownFields) - Specified by:
mergeUnknownFieldsin interfaceMessage.Builder- Overrides:
mergeUnknownFieldsin classGeneratedMessageV3.Builder<ServiceConfig.DispatcherConfig.Builder>
-