ServiceConfig.DispatcherConfig

public static final class ServiceConfig.DispatcherConfig

 Configuration for a tf.data service DispatchServer.
 
Protobuf type 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
final boolean
static ServiceConfig.DispatcherConfig.Builder
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
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 ServiceConfig.DispatcherConfig getDefaultInstance ()

public ServiceConfig.DispatcherConfig getDefaultInstanceForType ()

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 ()