org.apache.ignite.tensorflow.cluster

Class TensorFlowClusterMaintainer

java.lang.Object

org.apache.ignite.tensorflow.cluster.TensorFlowClusterMaintainer

All Implemented Interfaces:

Serializable, Service

public class TensorFlowClusterMaintainer
extends Object
implements Service

TensorFlow cluster service that maintains TensorFlow cluster.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TensorFlowClusterMaintainer(UUID clusterId, TensorFlowJobArchive jobArchive, String topicName) Constructs a new instance of TensorFlow cluster service.

Method Summary

Modifier and Type	Method and Description
void	cancel(ServiceContext ctx) Cancels this service.
void	execute(ServiceContext ctx) Starts execution of this service.
void	init(ServiceContext ctx) Pre-initializes service before execution.

Methods inherited from class java.lang.Object

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

Constructor Detail

TensorFlowClusterMaintainer

public TensorFlowClusterMaintainer(UUID clusterId,
                                   TensorFlowJobArchive jobArchive,
                                   String topicName)

Constructs a new instance of TensorFlow cluster service.

Parameters:

clusterId - Cluster identifier.

jobArchive - Job archive.

topicName - Topic name.

Method Detail

cancel

public void cancel(ServiceContext ctx)

Cancels this service. Ignite will automatically call this method whenever any of the cancel methods on IgniteServices API are called.

Note that Ignite cannot guarantee that the service exits from Service.execute(ServiceContext) method whenever cancel(ServiceContext) method is called. It is up to the user to make sure that the service code properly reacts to cancellations.

Specified by:

cancel in interface Service

Parameters:

ctx - Service execution context.

init

public void init(ServiceContext ctx)

Pre-initializes service before execution. This method is guaranteed to be called before service deployment is complete (this guarantees that this method will be called before method Service.execute(ServiceContext) is called).

Specified by:

init in interface Service

Parameters:

ctx - Service execution context.

execute

public void execute(ServiceContext ctx)

Starts execution of this service. This method is automatically invoked whenever an instance of the service is deployed on a grid node. Note that service is considered deployed even after it exits the execute method and can be cancelled (or undeployed) only by calling any of the cancel methods on IgniteServices API. Also note that service is not required to exit from execute method until Service.cancel(ServiceContext) method was called.

Specified by:

execute in interface Service

Parameters:

ctx - Service execution context.