org.commonjava.storage.pathmapped.pathdb.datastax

Class CassandraPathDB

java.lang.Object

org.commonjava.storage.pathmapped.pathdb.datastax.CassandraPathDB

All Implemented Interfaces:

Closeable, AutoCloseable, org.commonjava.storage.pathmapped.spi.PathDB, org.commonjava.storage.pathmapped.spi.PathDBAdmin

public class CassandraPathDB
extends Object
implements org.commonjava.storage.pathmapped.spi.PathDB, org.commonjava.storage.pathmapped.spi.PathDBAdmin, Closeable

Nested Class Summary

Nested classes/interfaces inherited from interface org.commonjava.storage.pathmapped.spi.PathDB

org.commonjava.storage.pathmapped.spi.PathDB.FileType

Constructor Summary

Constructors

Constructor and Description
CassandraPathDB(org.commonjava.storage.pathmapped.config.PathMappedStorageConfig config)
CassandraPathDB(org.commonjava.storage.pathmapped.config.PathMappedStorageConfig config, com.datastax.driver.core.Session session, String keyspace) Deprecated.
CassandraPathDB(org.commonjava.storage.pathmapped.config.PathMappedStorageConfig config, com.datastax.driver.core.Session session, String keyspace, int replicationFactor)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	copy(String fromFileSystem, String fromPath, String toFileSystem, String toPath)
boolean	delete(String fileSystem, String path)
org.commonjava.storage.pathmapped.spi.PathDB.FileType	exists(String fileSystem, String path) Check if the specified path exist.
boolean	existsFile(String fileSystem, String path)
long	getFileLastModified(String fileSystem, String path)
long	getFileLength(String fileSystem, String path)
org.commonjava.storage.pathmapped.model.Filesystem	getFilesystem(String filesystem)
Set<String>	getFileSystemContaining(Collection<String> candidates, String path)
List<? extends org.commonjava.storage.pathmapped.model.Filesystem>	getFilesystems()
String	getFirstFileSystemContaining(List<String> candidates, String path) Get the first fileSystem in the candidates containing the path.
org.commonjava.storage.pathmapped.model.PathMap	getPathMap(String fileSystem, String path)
com.datastax.driver.core.Session	getSession()
String	getStorageFile(String fileSystem, String path)
void	insert(String fileSystem, String path, Date creation, Date expiration, String fileId, long size, String fileStorage, String checksum)
boolean	isDirectory(String fileSystem, String path)
boolean	isFile(String fileSystem, String path)
List<org.commonjava.storage.pathmapped.model.PathMap>	list(String fileSystem, String path, boolean recursive, int limit, org.commonjava.storage.pathmapped.spi.PathDB.FileType fileType)
List<org.commonjava.storage.pathmapped.model.PathMap>	list(String fileSystem, String path, org.commonjava.storage.pathmapped.spi.PathDB.FileType fileType) List files under specified path.
List<org.commonjava.storage.pathmapped.model.Reclaim>	listOrphanedFiles(int limit)
void	makeDirs(String fileSystem, String path)
void	removeFromReclaim(org.commonjava.storage.pathmapped.model.Reclaim reclaim)
void	traverse(String fileSystem, String path, java.util.function.Consumer<org.commonjava.storage.pathmapped.model.PathMap> consumer, int limit, org.commonjava.storage.pathmapped.spi.PathDB.FileType fileType)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.commonjava.storage.pathmapped.spi.PathDB

listOrphanedFiles

Constructor Detail

CassandraPathDB

@Deprecated
public CassandraPathDB(org.commonjava.storage.pathmapped.config.PathMappedStorageConfig config,
                                   com.datastax.driver.core.Session session,
                                   String keyspace)

Deprecated.

CassandraPathDB

public CassandraPathDB(org.commonjava.storage.pathmapped.config.PathMappedStorageConfig config,
                       com.datastax.driver.core.Session session,
                       String keyspace,
                       int replicationFactor)

CassandraPathDB

public CassandraPathDB(org.commonjava.storage.pathmapped.config.PathMappedStorageConfig config)

Method Detail

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

getSession

public com.datastax.driver.core.Session getSession()

getFileSystemContaining

public Set<String> getFileSystemContaining(Collection<String> candidates,
                                           String path)

Specified by:

getFileSystemContaining in interface org.commonjava.storage.pathmapped.spi.PathDB

getFirstFileSystemContaining

public String getFirstFileSystemContaining(List<String> candidates,
                                           String path)

Get the first fileSystem in the candidates containing the path. The CQL query results are not returned in the order in which the key was specified in the IN clause. The results are returned in the natural order of the column so we can not rely on the query like '...limit 1'.

Specified by:

getFirstFileSystemContaining in interface org.commonjava.storage.pathmapped.spi.PathDB

list

public List<org.commonjava.storage.pathmapped.model.PathMap> list(String fileSystem,
                                                                  String path,
                                                                  org.commonjava.storage.pathmapped.spi.PathDB.FileType fileType)

List files under specified path.

Specified by:

list in interface org.commonjava.storage.pathmapped.spi.PathDB

list

public List<org.commonjava.storage.pathmapped.model.PathMap> list(String fileSystem,
                                                                  String path,
                                                                  boolean recursive,
                                                                  int limit,
                                                                  org.commonjava.storage.pathmapped.spi.PathDB.FileType fileType)

Specified by:

list in interface org.commonjava.storage.pathmapped.spi.PathDB

traverse

public void traverse(String fileSystem,
                     String path,
                     java.util.function.Consumer<org.commonjava.storage.pathmapped.model.PathMap> consumer,
                     int limit,
                     org.commonjava.storage.pathmapped.spi.PathDB.FileType fileType)

Specified by:

traverse in interface org.commonjava.storage.pathmapped.spi.PathDB

getFileLength

public long getFileLength(String fileSystem,
                          String path)

Specified by:

getFileLength in interface org.commonjava.storage.pathmapped.spi.PathDB

getPathMap

public org.commonjava.storage.pathmapped.model.PathMap getPathMap(String fileSystem,
                                                                  String path)

Specified by:

getPathMap in interface org.commonjava.storage.pathmapped.spi.PathDB

getFileLastModified

public long getFileLastModified(String fileSystem,
                                String path)

Specified by:

getFileLastModified in interface org.commonjava.storage.pathmapped.spi.PathDB

exists

public org.commonjava.storage.pathmapped.spi.PathDB.FileType exists(String fileSystem,
                                                                    String path)

Check if the specified path exist. If the path does not end with /, e.g., "foo/bar", we need to check both "foo/bar" and "foo/bar/".

Specified by:

exists in interface org.commonjava.storage.pathmapped.spi.PathDB

Returns:

FileType.{file/dir} if exist. Null if not exist.

existsFile

public boolean existsFile(String fileSystem,
                          String path)

Specified by:

existsFile in interface org.commonjava.storage.pathmapped.spi.PathDB

insert

public void insert(String fileSystem,
                   String path,
                   Date creation,
                   Date expiration,
                   String fileId,
                   long size,
                   String fileStorage,
                   String checksum)

Specified by:

insert in interface org.commonjava.storage.pathmapped.spi.PathDB

isDirectory

public boolean isDirectory(String fileSystem,
                           String path)

Specified by:

isDirectory in interface org.commonjava.storage.pathmapped.spi.PathDB

isFile

public boolean isFile(String fileSystem,
                      String path)

Specified by:

isFile in interface org.commonjava.storage.pathmapped.spi.PathDB

delete

public boolean delete(String fileSystem,
                      String path)

Specified by:

delete in interface org.commonjava.storage.pathmapped.spi.PathDB

getStorageFile

public String getStorageFile(String fileSystem,
                             String path)

Specified by:

getStorageFile in interface org.commonjava.storage.pathmapped.spi.PathDB

copy

public boolean copy(String fromFileSystem,
                    String fromPath,
                    String toFileSystem,
                    String toPath)

Specified by:

copy in interface org.commonjava.storage.pathmapped.spi.PathDB

makeDirs

public void makeDirs(String fileSystem,
                     String path)

Specified by:

makeDirs in interface org.commonjava.storage.pathmapped.spi.PathDB

listOrphanedFiles

public List<org.commonjava.storage.pathmapped.model.Reclaim> listOrphanedFiles(int limit)

Specified by:

listOrphanedFiles in interface org.commonjava.storage.pathmapped.spi.PathDB

removeFromReclaim

public void removeFromReclaim(org.commonjava.storage.pathmapped.model.Reclaim reclaim)

Specified by:

removeFromReclaim in interface org.commonjava.storage.pathmapped.spi.PathDB

getFilesystem

public org.commonjava.storage.pathmapped.model.Filesystem getFilesystem(String filesystem)

Specified by:

getFilesystem in interface org.commonjava.storage.pathmapped.spi.PathDBAdmin

getFilesystems

public List<? extends org.commonjava.storage.pathmapped.model.Filesystem> getFilesystems()

Specified by:

getFilesystems in interface org.commonjava.storage.pathmapped.spi.PathDBAdmin