Package eu.dnetlib.data.mdstore.manager.utils

Class HdfsClientMock

java.lang.Object

eu.dnetlib.data.mdstore.manager.utils.HdfsClientMock

All Implemented Interfaces:

HdfsClient

@Component
@Profile("dev")
public class HdfsClientMock
extends Object
implements HdfsClient

Constructor Summary

Constructors

Constructor	Description
HdfsClientMock()

Method Summary

Modifier and Type	Method	Description
void	deletePath(String path)
String	getHadoopCluster()
String	getHadoopUser()
String	getHdfsBasePath()
Set<String>	listContent(String hdfsPath)
Set<String>	listHadoopDirs()
List<Map<String,String>>	readParquetFiles(String hdfsPath, long limit)

Methods inherited from class java.lang.Object

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

Constructor Details

HdfsClientMock

public HdfsClientMock()

Method Details

getHadoopUser

public String getHadoopUser()

Specified by:

getHadoopUser in interface HdfsClient

getHadoopCluster

public String getHadoopCluster()

Specified by:

getHadoopCluster in interface HdfsClient

getHdfsBasePath

public String getHdfsBasePath()

Specified by:

getHdfsBasePath in interface HdfsClient

deletePath

public void deletePath(String path)
                throws MDStoreManagerException

Specified by:

deletePath in interface HdfsClient

Throws:

MDStoreManagerException

listHadoopDirs

public Set<String> listHadoopDirs()

Specified by:

listHadoopDirs in interface HdfsClient

listContent

public Set<String> listContent(String hdfsPath)

Specified by:

listContent in interface HdfsClient

readParquetFiles

public List<Map<String,String>> readParquetFiles(String hdfsPath,
 long limit)
                                          throws MDStoreManagerException

Specified by:

readParquetFiles in interface HdfsClient

Throws:

MDStoreManagerException