public class TensorFlowUserScriptRunner extends AsyncNativeProcessRunner
|Constructor and Description|
Constructs a new instance of TensorFlow user script runner.
|Modifier and Type||Method and Description|
Method that should be called after starting the process.
Method that should be called before starting the process.
getException, isCompleted, start, stop
public TensorFlowUserScriptRunner(Ignite ignite, ExecutorService executor, TensorFlowJobArchive jobArchive, TensorFlowClusterSpec clusterSpec, Consumer<String> out, Consumer<String> err)
ignite- Ignite instance.
executor- Executor to be used in
jobArchive- Job archive that will be extracted and used as working directory for the native process.
clusterSpec- TensorFlow cluster specification.
out- Output stream data consumer.
err- Error stream data consumer.
public NativeProcessRunner doBefore()