org.apache.ignite.tensorflow.core

Interface ProcessManager<R>

Type Parameters:

R - Type of task to be run.

All Known Implementing Classes:

LongRunningProcessManager, NativeProcessManager, ProcessManagerWrapper, TensorFlowServerManager

public interface ProcessManager<R>

Process manager that allows to run and maintain processes in the cluster.

Method Summary

Modifier and Type	Method and Description
Map<UUID,List<LongRunningProcessStatus>>	clear(Map<UUID,List<UUID>> procIds) Clears metadata of the given processes.
Map<UUID,List<LongRunningProcessStatus>>	ping(Map<UUID,List<UUID>> procIds) Pings the given processes.
Map<UUID,List<UUID>>	start(List<R> specifications) Starts the processes by the given specifications.
Map<UUID,List<LongRunningProcessStatus>>	stop(Map<UUID,List<UUID>> procIds, boolean clear) Stops the given processes.

Method Detail

start

Map<UUID,List<UUID>> start(List<R> specifications)

Starts the processes by the given specifications.

Parameters:

specifications - Process specifications.

Returns:

Map of node identifier as a key and list of started process identifiers as a value.

ping

Map<UUID,List<LongRunningProcessStatus>> ping(Map<UUID,List<UUID>> procIds)

Pings the given processes.

Parameters:

procIds - Map of node identifier as a key and list of process identifiers as a value.

Returns:

Map of node identifier as a key and list of process statuses as a value.

stop

Map<UUID,List<LongRunningProcessStatus>> stop(Map<UUID,List<UUID>> procIds,
                                              boolean clear)

Stops the given processes.

Parameters:

procIds - Map of node identifier as a key and list of process identifiers as a value.

Returns:

Map of node identifier as a key and list of process statuses as a value.

clear

Map<UUID,List<LongRunningProcessStatus>> clear(Map<UUID,List<UUID>> procIds)

Clears metadata of the given processes.

Parameters:

procIds - Map of node identifier as a key and list of process identifiers as a value.

Returns:

Map of node identifier as a key and list of process statuses as a value.