org.wso2.carbon.analytics.datasource.cassandra

Class CassandraAnalyticsFileSystem

java.lang.Object

org.wso2.carbon.analytics.datasource.cassandra.CassandraAnalyticsFileSystem

All Implemented Interfaces:

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

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

This class represents the Cassandra implementation of AnalyticsFileSystem.

Nested Class Summary

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
CassandraAnalyticsFileSystem()

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraAnalyticsFileSystem

public CassandraAnalyticsFileSystem()

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

createInput

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

Specified by:

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

Throws:

IOException

createOutput

public OutputStream createOutput(String path)
                          throws IOException

Specified by:

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

Throws:

IOException

delete

public void delete(String path)
            throws IOException

Specified by:

delete 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

exists

public boolean exists(String path)
               throws IOException

Specified by:

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

Throws:

IOException

length

public long length(String path)
            throws IOException

Specified by:

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

Throws:

IOException

setLength

public void setLength(String path,
             long length)
               throws IOException

Throws:

IOException

list

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

Specified by:

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

Throws:

IOException

mkdir

public void mkdir(String path)
           throws IOException

Specified by:

mkdir 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

sync

public void sync(String path)
          throws IOException

Specified by:

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

Throws:

IOException