edu.iu.dsc.tws.data.utils

Class DataNodeLocatorUtils

java.lang.Object

edu.iu.dsc.tws.data.utils.DataNodeLocatorUtils

All Implemented Interfaces:

IDataNodeLocatorUtils

public class DataNodeLocatorUtils
extends java.lang.Object
implements IDataNodeLocatorUtils

This class is to find out the location of the datanodes corresponding to the input file names. It retrieve the location of the input file(s) using the HDFSUtils class.

Constructor Summary

Constructors

Constructor and Description
DataNodeLocatorUtils(Config cfg)

Method Summary

Modifier and Type	Method and Description
java.util.List<java.lang.String>	findDataNodesLocation(java.util.List<java.lang.String> inputFileList) This method receives the input data list for each vertex and find the location of the datanodes in the HDFS and returns the data node list.
java.util.List<java.lang.String>	findDataNodesLocation(java.lang.String inputFileName) This method receives the input file name of a vertex and find the location of the datanodes in the HDFS and returns the data node list.

Methods inherited from class java.lang.Object

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

Constructor Detail

DataNodeLocatorUtils

public DataNodeLocatorUtils(Config cfg)

Method Detail

findDataNodesLocation

public java.util.List<java.lang.String> findDataNodesLocation(java.util.List<java.lang.String> inputFileList)

This method receives the input data list for each vertex and find the location of the datanodes in the HDFS and returns the data node list.

Specified by:

findDataNodesLocation in interface IDataNodeLocatorUtils

findDataNodesLocation

public java.util.List<java.lang.String> findDataNodesLocation(java.lang.String inputFileName)

This method receives the input file name of a vertex and find the location of the datanodes in the HDFS and returns the data node list.

Specified by:

findDataNodesLocation in interface IDataNodeLocatorUtils

Returns:

datanodes list