org.wso2.carbon.analytics.datasource.hbase

Class HDFSAnalyticsFileSystem

java.lang.Object

org.wso2.carbon.analytics.datasource.hbase.HDFSAnalyticsFileSystem

All Implemented Interfaces:

org.wso2.carbon.analytics.datasource.core.fs.AnalyticsFileSystem

public class HDFSAnalyticsFileSystem
extends Object
implements org.wso2.carbon.analytics.datasource.core.fs.AnalyticsFileSystem

Hadoop Distributed File System (HDFS) AnalyticsFileSystem - implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	HDFSAnalyticsFileSystem.HDFSDataInput HDFS Implementation of AnalyticsFileSystem.DataInput
static class	HDFSAnalyticsFileSystem.HDFSOutputStream
static class	HDFSAnalyticsFileSystem.HDFSRuntimeException

Nested classes/interfaces inherited from interface org.wso2.carbon.analytics.datasource.core.fs.AnalyticsFileSystem

org.wso2.carbon.analytics.datasource.core.fs.AnalyticsFileSystem.DataInput

Constructor Summary

Constructors

Constructor and Description
HDFSAnalyticsFileSystem()
HDFSAnalyticsFileSystem(org.apache.hadoop.fs.FileSystem fs)

Method Summary

Methods

Modifier and Type	Method and Description
org.wso2.carbon.analytics.datasource.core.fs.AnalyticsFileSystem.DataInput	createInput(String source)
OutputStream	createOutput(String source)
void	delete(String source)
void	destroy()
boolean	exists(String source)
void	init(Map<String,String> properties)
long	length(String source)
List<String>	list(String source)
void	mkdir(String source)
void	renameFileInDirectory(String dirPath, String nameFrom, String nameTo)
void	sync(String source)

Methods inherited from class java.lang.Object

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

Constructor Detail

HDFSAnalyticsFileSystem

public HDFSAnalyticsFileSystem(org.apache.hadoop.fs.FileSystem fs)
                        throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

HDFSAnalyticsFileSystem

public HDFSAnalyticsFileSystem()

Method Detail

init

public void init(Map<String,String> properties)
          throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

init in interface org.wso2.carbon.analytics.datasource.core.fs.AnalyticsFileSystem

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

exists

public boolean exists(String source)
               throws IOException

Specified by:

exists in interface org.wso2.carbon.analytics.datasource.core.fs.AnalyticsFileSystem

Throws:

IOException

list

public List<String> list(String source)
                  throws IOException

Specified by:

list in interface org.wso2.carbon.analytics.datasource.core.fs.AnalyticsFileSystem

Throws:

IOException

delete

public void delete(String source)
            throws IOException

Specified by:

delete in interface org.wso2.carbon.analytics.datasource.core.fs.AnalyticsFileSystem

Throws:

IOException

mkdir

public void mkdir(String source)
           throws IOException

Specified by:

mkdir in interface org.wso2.carbon.analytics.datasource.core.fs.AnalyticsFileSystem

Throws:

IOException

createInput

public org.wso2.carbon.analytics.datasource.core.fs.AnalyticsFileSystem.DataInput createInput(String source)
                                                                                       throws IOException

Specified by:

createInput in interface org.wso2.carbon.analytics.datasource.core.fs.AnalyticsFileSystem

Throws:

IOException

createOutput

public OutputStream createOutput(String source)
                          throws IOException

Specified by:

createOutput in interface org.wso2.carbon.analytics.datasource.core.fs.AnalyticsFileSystem

Throws:

IOException

sync

public void sync(String source)
          throws IOException

Specified by:

sync in interface org.wso2.carbon.analytics.datasource.core.fs.AnalyticsFileSystem

Throws:

IOException

length

public long length(String source)
            throws IOException

Specified by:

length in interface org.wso2.carbon.analytics.datasource.core.fs.AnalyticsFileSystem

Throws:

IOException

destroy

public void destroy()
             throws IOException

Specified by:

destroy in interface org.wso2.carbon.analytics.datasource.core.fs.AnalyticsFileSystem

Throws:

IOException

renameFileInDirectory

public void renameFileInDirectory(String dirPath,
                         String nameFrom,
                         String nameTo)
                           throws IOException

Specified by:

renameFileInDirectory in interface org.wso2.carbon.analytics.datasource.core.fs.AnalyticsFileSystem

Throws:

IOException