org.processmining.hadoop.common.data_manager

Class DataManager

java.lang.Object

org.processmining.hadoop.common.data_manager.DataManager

public class DataManager
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
DataManager(HadoopClusterParameters hadoop_cluster)

Method Summary

Modifier and Type	Method and Description
boolean	existsInHDFS(java.lang.String path) Check if a file exists in the HDFS of the remote server accessible by the connection manager
boolean	existsInLocalFileSystem(java.lang.String path) Check if a file exists in the local filesystem of the remote server accessible by the connection manager
java.lang.String	getPathRemoteProMDir()
java.lang.String[]	moveExecutable(java.lang.String executable) Move the executable file (if necessary) to the remote host
java.lang.String[]	retrieveResultFile(java.lang.String remote_file, java.lang.String output_file) Retrieve the result of the execution of a map reduce job

Methods inherited from class java.lang.Object

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

Constructor Detail

DataManager

public DataManager(HadoopClusterParameters hadoop_cluster)

Parameters:

hadoop_cluster - Hadoop cluster information

Method Detail

getPathRemoteProMDir

public java.lang.String getPathRemoteProMDir()

moveExecutable

public java.lang.String[] moveExecutable(java.lang.String executable)

Move the executable file (if necessary) to the remote host

Parameters:

executable - Path to the executable file in the local computer

Returns:

A two-component array. 1.- The path corresponding to the executable file in the remote server 2.- The second component shows an error string ("" if there is no error)

retrieveResultFile

public java.lang.String[] retrieveResultFile(java.lang.String remote_file,
                                             java.lang.String output_file)

Retrieve the result of the execution of a map reduce job

Parameters:

remote_file - Path to the executable file in the remote HDFS

output_file - Name for the output file in the local computer

Returns:

A two-component array. 1.- The path corresponding to the executable file in the remote server 2.- The second component shows an error string ("" if there is no error)

existsInLocalFileSystem

public boolean existsInLocalFileSystem(java.lang.String path)

Check if a file exists in the local filesystem of the remote server accessible by the connection manager

Parameters:

path - Path to check

Returns:

true is the file exists in the local filesystem of the remote server

existsInHDFS

public boolean existsInHDFS(java.lang.String path)

Check if a file exists in the HDFS of the remote server accessible by the connection manager

Parameters:

path - Path to check

Returns:

true is the file exists in the HDFS of the remote server