org.apache.ignite.tensorflow.cluster.util

Class TensorFlowClusterResolver

java.lang.Object

org.apache.ignite.tensorflow.cluster.util.TensorFlowClusterResolver

public class TensorFlowClusterResolver
extends Object

TensorFlow cluster resolver based on Ignite Cache affinity.

Field Summary

Fields

Modifier and Type	Field and Description
static String	CHIEF_JOB_NAME TensorFlow chief job name.
static String	WORKER_JOB_NAME TensorFlow worker job name.

Constructor Summary

Constructors

Constructor and Description
TensorFlowClusterResolver(Ignite ignite, String portPoolName, int portFrom, int portCnt) Constructs a new instance of TensorFlow cluster resolver.

Method Summary

Modifier and Type	Method and Description
void	destroy() Destroys TensorFlow cluster resolver.
void	releasePorts(TensorFlowClusterSpec spec) Releases ports acquired for the given cluster specification.
TensorFlowClusterSpec	resolveAndAcquirePorts(String upstreamCacheName) Resolves TensorFlow cluster and acquires required ports.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

WORKER_JOB_NAME

public static final String WORKER_JOB_NAME

TensorFlow worker job name.

See Also:

Constant Field Values

CHIEF_JOB_NAME

public static final String CHIEF_JOB_NAME

TensorFlow chief job name.

See Also:

Constant Field Values

Constructor Detail

TensorFlowClusterResolver

public TensorFlowClusterResolver(Ignite ignite,
                                 String portPoolName,
                                 int portFrom,
                                 int portCnt)

Constructs a new instance of TensorFlow cluster resolver.

Parameters:

ignite - Ignite instance.

Method Detail

resolveAndAcquirePorts

public TensorFlowClusterSpec resolveAndAcquirePorts(String upstreamCacheName)

Resolves TensorFlow cluster and acquires required ports.

Parameters:

upstreamCacheName - Upstream cache name.

Returns:

TensorFlow cluster specification.

releasePorts

public void releasePorts(TensorFlowClusterSpec spec)

Releases ports acquired for the given cluster specification.

Parameters:

spec - TensorFlow cluster specification.

destroy

public void destroy()

Destroys TensorFlow cluster resolver.