org.apache.ignite.tensorflow.cluster

Class TensorFlowClusterGateway

java.lang.Object

org.apache.ignite.tensorflow.cluster.TensorFlowClusterGateway

All Implemented Interfaces:

Serializable, AutoCloseable, IgniteBiPredicate<UUID,Optional<TensorFlowCluster>>

public class TensorFlowClusterGateway
extends Object
implements IgniteBiPredicate<UUID,Optional<TensorFlowCluster>>, AutoCloseable

TensorFlow cluster gateway that allows to subscribe on changes in cluster configuration.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TensorFlowClusterGateway(SerializableConsumer<TensorFlowClusterGateway> unsubscribeCb) Constructs a new instance of TensorFlow cluster gateway.

Method Summary

Modifier and Type	Method and Description
boolean	apply(UUID uuid, Optional<TensorFlowCluster> cluster) Predicate body.
void	close()
void	subscribe(Consumer<Optional<TensorFlowCluster>> subscriber) Subscribers the specified subscriber on the upstream events.
void	unsubscribe(Consumer<Optional<TensorFlowCluster>> subscriber) Unsubscribe the specified subscriber.

Methods inherited from class java.lang.Object

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

Constructor Detail

TensorFlowClusterGateway

public TensorFlowClusterGateway(SerializableConsumer<TensorFlowClusterGateway> unsubscribeCb)

Constructs a new instance of TensorFlow cluster gateway.

Parameters:

unsubscribeCb - Callback that will be called on unsubscribe.

Method Detail

subscribe

public void subscribe(Consumer<Optional<TensorFlowCluster>> subscriber)

Subscribers the specified subscriber on the upstream events.

Parameters:

subscriber - Subscriber.

unsubscribe

public void unsubscribe(Consumer<Optional<TensorFlowCluster>> subscriber)

Unsubscribe the specified subscriber.

Parameters:

subscriber - Subscriber.

apply

public boolean apply(UUID uuid,
                     Optional<TensorFlowCluster> cluster)

Predicate body.

Specified by:

apply in interface IgniteBiPredicate<UUID,Optional<TensorFlowCluster>>

Parameters:

uuid - First parameter.

cluster - Second parameter.

Returns:

Return value.

close

public void close()

Specified by:

close in interface AutoCloseable