org.galagosearch.tupleflow.execution
Class SSHStageExecutor

java.lang.Object
  org.galagosearch.tupleflow.execution.RemoteStageExecutor
      org.galagosearch.tupleflow.execution.SSHStageExecutor

All Implemented Interfaces:

StageExecutor

public class SSHStageExecutor
extends RemoteStageExecutor

This will eventually allow you to run TupleFlow workers on other machines using SSH. For now, it doesn't work. If you really need job distribution, try the Grid Engine plugin.

Author:

trevor

Nested Class Summary

class	SSHStageExecutor.SSHStageExecutionContext
class	SSHStageExecutor.StageTask

Constructor Summary

SSHStageExecutor(java.lang.String commandName, java.util.List<java.lang.String> machines)

Method Summary

void	shutdown()
StageExecutionStatus	submit(java.lang.String stageName, java.util.ArrayList<java.lang.String> jobPaths, java.lang.String temporary)

Methods inherited from class org.galagosearch.tupleflow.execution.RemoteStageExecutor

execute

Methods inherited from class java.lang.Object

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

Constructor Detail

SSHStageExecutor

public SSHStageExecutor(java.lang.String commandName,
                        java.util.List<java.lang.String> machines)

Method Detail

submit

public StageExecutionStatus submit(java.lang.String stageName,
                                   java.util.ArrayList<java.lang.String> jobPaths,
                                   java.lang.String temporary)

Specified by:

submit in class RemoteStageExecutor

shutdown

public void shutdown()

Specified by:

shutdown in interface StageExecutor

Specified by:

shutdown in class RemoteStageExecutor