org.processmining.hadoop.connection.implementations

Class SSHConnectionManager

java.lang.Object

org.processmining.hadoop.connection.implementations.SSHConnectionManager

All Implemented Interfaces:

RemoteConnectionManager

public class SSHConnectionManager
extends java.lang.Object
implements RemoteConnectionManager

Constructor Summary

Constructors

Constructor and Description
SSHConnectionManager(HadoopClusterParameters hadoop_cluster)
SSHConnectionManager(java.lang.String host, java.lang.String user, java.lang.String password)

Method Summary

Modifier and Type	Method and Description
java.lang.String[]	executeCommand(java.lang.String command) Execute the command in the remote host.
java.lang.String[]	executeCommand(java.lang.String command, java.lang.String input) Execute the command in the remote host.
java.lang.String[]	executeCommandASynchronously(java.lang.String command) Execute the command in the remote host.
java.lang.String[]	executeCommandASynchronously(java.lang.String command, java.lang.String input) Execute the command in the remote host.
java.lang.String	getFileFromRemoteHost(java.lang.String local_file, java.lang.String remote_file) Get the remote file and store it in the local host
boolean	hasAccess() Check if the connection information is valid and the user has access to the specified cluster with the provided password
java.lang.String	sendFileToRemoteHost(java.lang.String local_file, java.lang.String remote_file) Send the local file to the remote host

Methods inherited from class java.lang.Object

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

Constructor Detail

SSHConnectionManager

public SSHConnectionManager(HadoopClusterParameters hadoop_cluster)

SSHConnectionManager

public SSHConnectionManager(java.lang.String host,
                            java.lang.String user,
                            java.lang.String password)

Method Detail

hasAccess

public boolean hasAccess()

Check if the connection information is valid and the user has access to the specified cluster with the provided password

Specified by:

hasAccess in interface RemoteConnectionManager

Returns:

True if the user has access to the specified cluster with the provided password

executeCommand

public java.lang.String[] executeCommand(java.lang.String command)

Execute the command in the remote host. Return the standard output and the standard error as a result

Specified by:

executeCommand in interface RemoteConnectionManager

Parameters:

command - shell command to execute

Returns:

A two-component array. 1.- The first component is the standard output stream. 2.- The second component is the standard error stream. * ("" if there is no error) * (It it starts with the key word "CONNECTION_ERROR" there is an error with the connection)

executeCommand

public java.lang.String[] executeCommand(java.lang.String command,
                                         java.lang.String input)

Execute the command in the remote host. Return the standard output and the standard error as a result

Specified by:

executeCommand in interface RemoteConnectionManager

Parameters:

command - shell command to execute

input - Standard input

Returns:

A two-component array. 1.- The first component is the standard output stream. 2.- The second component is the standard error stream. * ("" if there is no error) * (It starts with the key word "CONNECTION_ERROR" there is an error with the connection)

executeCommandASynchronously

public java.lang.String[] executeCommandASynchronously(java.lang.String command)

Execute the command in the remote host. Return the standard output and the standard error as a result

Specified by:

executeCommandASynchronously in interface RemoteConnectionManager

Parameters:

command - shell command to execute

Returns:

A two-component array. 1.- The first component is the pid of the job in execution. 2.- The second component is the standard error stream. * ("" if there is no error) * (It starts with the key word "CONNECTION_ERROR" there is an error with the connection)

executeCommandASynchronously

public java.lang.String[] executeCommandASynchronously(java.lang.String command,
                                                       java.lang.String input)

Execute the command in the remote host. Return the standard output and the standard error as a result

Specified by:

executeCommandASynchronously in interface RemoteConnectionManager

Parameters:

command - shell command to execute

input - Standard input

Returns:

A two-component array. 1.- The first component is the pid of the job in execution. 2.- The second component is the standard error stream. * ("" if there is no error) * (It starts with the key word "CONNECTION_ERROR" there is an error with the connection)

getFileFromRemoteHost

public java.lang.String getFileFromRemoteHost(java.lang.String local_file,
                                              java.lang.String remote_file)

Get the remote file and store it in the local host

Specified by:

getFileFromRemoteHost in interface RemoteConnectionManager

Parameters:

local_file - Local path

remote_file - Remote path

Returns:

An error string ("" if there is no error)

sendFileToRemoteHost

public java.lang.String sendFileToRemoteHost(java.lang.String local_file,
                                             java.lang.String remote_file)

Send the local file to the remote host

Specified by:

sendFileToRemoteHost in interface RemoteConnectionManager

Parameters:

local_file - Local path

remote_file - Remote path

Returns:

An error string ("" if there is no error)