public static final class
ServiceConfig.DispatcherConfig
Configuration for a tf.data service DispatchServer.
tensorflow.data.experimental.DispatcherConfig
Nested Classes
class | ServiceConfig.DispatcherConfig.Builder | Configuration for a tf.data service DispatchServer. |
Constants
int | FAULT_TOLERANT_MODE_FIELD_NUMBER | |
int | JOB_GC_CHECK_INTERVAL_MS_FIELD_NUMBER | |
int | JOB_GC_TIMEOUT_MS_FIELD_NUMBER | |
int | PORT_FIELD_NUMBER | |
int | PROTOCOL_FIELD_NUMBER | |
int | WORK_DIR_FIELD_NUMBER |
Public Methods
boolean |
equals(Object obj)
|
static ServiceConfig.DispatcherConfig | |
ServiceConfig.DispatcherConfig | |
final static com.google.protobuf.Descriptors.Descriptor | |
boolean |
getFaultTolerantMode()
Whether to run in fault tolerant mode, where dispatcher state is saved across restarts. |
long |
getJobGcCheckIntervalMs()
How often the dispatcher should scan through to delete old and unused jobs. |
long |
getJobGcTimeoutMs()
How long a job needs to be unused before it becomes a candidate for garbage collection. |
|
|
long |
getPort()
The port for the dispatcher to bind to. |
String |
getProtocol()
The protocol for the dispatcher to use when connecting to workers. |
com.google.protobuf.ByteString |
getProtocolBytes()
The protocol for the dispatcher to use when connecting to workers. |
int | |
final com.google.protobuf.UnknownFieldSet | |
String |
getWorkDir()
A work directory to use for storing dispatcher state, and for recovering during restarts. |
com.google.protobuf.ByteString |
getWorkDirBytes()
A work directory to use for storing dispatcher state, and for recovering during restarts. |
int |
hashCode()
|
final boolean | |
static ServiceConfig.DispatcherConfig.Builder |
newBuilder(ServiceConfig.DispatcherConfig prototype)
|
static ServiceConfig.DispatcherConfig.Builder | |
ServiceConfig.DispatcherConfig.Builder | |
static ServiceConfig.DispatcherConfig |
parseDelimitedFrom(InputStream input)
|
static ServiceConfig.DispatcherConfig |
parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
|
static ServiceConfig.DispatcherConfig |
parseFrom(ByteBuffer data)
|
static ServiceConfig.DispatcherConfig |
parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
|
static ServiceConfig.DispatcherConfig |
parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
|
static ServiceConfig.DispatcherConfig |
parseFrom(com.google.protobuf.CodedInputStream input)
|
static ServiceConfig.DispatcherConfig |
parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
|
static ServiceConfig.DispatcherConfig |
parseFrom(com.google.protobuf.ByteString data)
|
static ServiceConfig.DispatcherConfig |
parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
|
static ServiceConfig.DispatcherConfig |
parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
|
static
|
parser()
|
ServiceConfig.DispatcherConfig.Builder | |
void |
writeTo(com.google.protobuf.CodedOutputStream output)
|
Inherited Methods
Constants
public static final int FAULT_TOLERANT_MODE_FIELD_NUMBER
Constant Value:
4
public static final int JOB_GC_CHECK_INTERVAL_MS_FIELD_NUMBER
Constant Value:
5
public static final int JOB_GC_TIMEOUT_MS_FIELD_NUMBER
Constant Value:
6
public static final int PORT_FIELD_NUMBER
Constant Value:
1
public static final int PROTOCOL_FIELD_NUMBER
Constant Value:
2
public static final int WORK_DIR_FIELD_NUMBER
Constant Value:
3
Public Methods
public boolean equals (Object obj)
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor ()
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;
public long getJobGcCheckIntervalMs ()
How often the dispatcher should scan through to delete old and unused jobs.
int64 job_gc_check_interval_ms = 5;
public long getJobGcTimeoutMs ()
How long a job needs to be unused before it becomes a candidate for garbage collection.
int64 job_gc_timeout_ms = 6;
public
getParserForType
()
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;
public String getProtocol ()
The protocol for the dispatcher to use when connecting to workers.
string protocol = 2;
public com.google.protobuf.ByteString getProtocolBytes ()
The protocol for the dispatcher to use when connecting to workers.
string protocol = 2;
public int getSerializedSize ()
public final com.google.protobuf.UnknownFieldSet getUnknownFields ()
public String 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;
public com.google.protobuf.ByteString 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;
public int hashCode ()
public final boolean isInitialized ()
public static ServiceConfig.DispatcherConfig.Builder newBuilder (ServiceConfig.DispatcherConfig prototype)
public static ServiceConfig.DispatcherConfig parseDelimitedFrom (InputStream input)
Throws
IOException |
---|
public static ServiceConfig.DispatcherConfig parseDelimitedFrom (InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
Throws
IOException |
---|
public static ServiceConfig.DispatcherConfig parseFrom (ByteBuffer data)
Throws
InvalidProtocolBufferException |
---|
public static ServiceConfig.DispatcherConfig parseFrom (com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
Throws
IOException |
---|
public static ServiceConfig.DispatcherConfig parseFrom (ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
Throws
InvalidProtocolBufferException |
---|
public static ServiceConfig.DispatcherConfig parseFrom (com.google.protobuf.CodedInputStream input)
Throws
IOException |
---|
public static ServiceConfig.DispatcherConfig parseFrom (byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
Throws
InvalidProtocolBufferException |
---|
public static ServiceConfig.DispatcherConfig parseFrom (com.google.protobuf.ByteString data)
Throws
InvalidProtocolBufferException |
---|
public static ServiceConfig.DispatcherConfig parseFrom (InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
Throws
IOException |
---|
public static ServiceConfig.DispatcherConfig parseFrom (com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
Throws
InvalidProtocolBufferException |
---|
public
static
parser
()
public void writeTo (com.google.protobuf.CodedOutputStream output)
Throws
IOException |
---|