public class DataManager
extends java.lang.Object
| Constructor and Description |
|---|
DataManager(HadoopClusterParameters hadoop_cluster) |
| 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
|
public DataManager(HadoopClusterParameters hadoop_cluster)
hadoop_cluster - Hadoop cluster informationpublic java.lang.String getPathRemoteProMDir()
public java.lang.String[] moveExecutable(java.lang.String executable)
executable - Path to the executable file in the local computerpublic java.lang.String[] retrieveResultFile(java.lang.String remote_file,
java.lang.String output_file)
remote_file - Path to the executable file in the remote HDFSoutput_file - Name for the output file in the local computerpublic boolean existsInLocalFileSystem(java.lang.String path)
path - Path to checkpublic boolean existsInHDFS(java.lang.String path)
path - Path to check