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	getDefaultInstance()
ServiceConfig.DispatcherConfig	getDefaultInstanceForType()
final static com.google.protobuf.Descriptors.Descriptor	getDescriptor()
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.
	getParserForType()
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	getSerializedSize()
final com.google.protobuf.UnknownFieldSet	getUnknownFields()
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	isInitialized()
static ServiceConfig.DispatcherConfig.Builder	newBuilder(ServiceConfig.DispatcherConfig prototype)
static ServiceConfig.DispatcherConfig.Builder	newBuilder()
ServiceConfig.DispatcherConfig.Builder	newBuilderForType()
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	toBuilder()
void	writeTo(com.google.protobuf.CodedOutputStream output)

Inherited Methods

From class java.lang.Object

boolean	equals(Object arg0)
final Class<?>	getClass()
int	hashCode()
final void	notify()
final void	notifyAll()
String	toString()
final void	wait(long arg0, int arg1)
final void	wait(long arg0)
final void	wait()

From interface org.tensorflow.proto.data.experimental.ServiceConfig.DispatcherConfigOrBuilder

abstract boolean	getFaultTolerantMode() Whether to run in fault tolerant mode, where dispatcher state is saved across restarts.
abstract long	getJobGcCheckIntervalMs() How often the dispatcher should scan through to delete old and unused jobs.
abstract long	getJobGcTimeoutMs() How long a job needs to be unused before it becomes a candidate for garbage collection.
abstract long	getPort() The port for the dispatcher to bind to.
abstract String	getProtocol() The protocol for the dispatcher to use when connecting to workers.
abstract com.google.protobuf.ByteString	getProtocolBytes() The protocol for the dispatcher to use when connecting to workers.
abstract String	getWorkDir() A work directory to use for storing dispatcher state, and for recovering during restarts.
abstract com.google.protobuf.ByteString	getWorkDirBytes() A work directory to use for storing dispatcher state, and for recovering during restarts.

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

public static ServiceConfig.DispatcherConfig.Builder newBuilder (ServiceConfig.DispatcherConfig prototype)

public static ServiceConfig.DispatcherConfig.Builder newBuilder ()

public ServiceConfig.DispatcherConfig.Builder newBuilderForType ()

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 ServiceConfig.DispatcherConfig.Builder toBuilder ()

public void writeTo (com.google.protobuf.CodedOutputStream output)

Throws

IOException