de.mpg.biochem.mars.io

Class MoleculeArchiveAmazonS3Source

java.lang.Object

de.mpg.biochem.mars.io.MoleculeArchiveAmazonS3Source

All Implemented Interfaces:

MoleculeArchiveSource, MoleculeArchiveStorage, java.lang.AutoCloseable

public class MoleculeArchiveAmazonS3Source
extends java.lang.Object
implements MoleculeArchiveSource

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	bucketName
protected java.lang.String	containerPath
protected java.lang.String	fileExtension
protected MoleculeArchiveAmazonS3KeyValueAccess	keyValueAccess
protected com.amazonaws.services.s3.AmazonS3	s3

Fields inherited from interface de.mpg.biochem.mars.io.MoleculeArchiveSource

INDEXES_FILE_NAME, METADATA_SUBDIRECTORY_NAME, MOLECULES_SUBDIRECTORY_NAME, PROPERTIES_FILE_NAME, ROVER_FILE_EXTENSION

Fields inherited from interface de.mpg.biochem.mars.io.MoleculeArchiveStorage

MOLECULE_ARCHIVE_ENDING, MOLECULE_ARCHIVE_STORE_ENDING, N5_DATASET_DIRECTORY_ENDING

Constructor Summary

Constructors

Constructor and Description
MoleculeArchiveAmazonS3Source(com.amazonaws.services.s3.AmazonS3 s3, com.amazonaws.services.s3.AmazonS3URI containerURI) Opens an If the bucket and/or container does not exist, it will not be created and all subsequent attempts to read attributes, groups, or datasets will fail.
MoleculeArchiveAmazonS3Source(com.amazonaws.services.s3.AmazonS3 s3, java.lang.String bucketName) Opens an If the bucket does not exist, it will not be created and all subsequent attempts to read attributes, groups, or datasets will fail.
MoleculeArchiveAmazonS3Source(com.amazonaws.services.s3.AmazonS3 s3, java.lang.String bucketName, java.lang.String containerPath) Opens an If the bucket and/or container does not exist, it will not be created and all subsequent attempts to read attributes, groups, or datasets will fail.

Method Summary

Modifier and Type	Method and Description
boolean	exists(java.lang.String pathName) Test whether a group or dataset exists at a given path.
java.lang.String	getArchiveType()
java.io.InputStream	getIndexesInputStream()
java.io.OutputStream	getIndexesOutputStream()
java.io.InputStream	getInputStream()
java.io.InputStream	getMetadataInputStream(java.lang.String metaUID)
java.io.OutputStream	getMetadataOutputStream(java.lang.String metaUID)
java.util.List<java.lang.String>	getMetadataUIDs()
java.io.InputStream	getMoleculeInputStream(java.lang.String UID)
java.io.OutputStream	getMoleculeOutputStream(java.lang.String UID)
java.util.List<java.lang.String>	getMoleculeUIDs()
java.lang.String	getName()
java.io.OutputStream	getOutputStream()
java.lang.String	getPath()
java.io.InputStream	getPropertiesInputStream()
java.io.OutputStream	getPropertiesOutputStream()
java.io.InputStream	getRoverInputStream()
java.io.OutputStream	getRoverOutputStream()
java.lang.String	getURI()
void	initializeLocation()
boolean	isReachable()
boolean	isVirtual()
java.lang.String[]	list(java.lang.String pathName) List all groups (including datasets) in a group.
java.lang.String[]	listDirectories(java.lang.String pathName) List all groups (including datasets) in a group.
java.lang.String[]	listFiles(java.lang.String pathName) List all groups (including datasets) in a group.
void	removeMetadata(java.lang.String metaUID)
void	removeMolecule(java.lang.String UID)
void	setPath(java.lang.String path)

Methods inherited from class java.lang.Object

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

Methods inherited from interface de.mpg.biochem.mars.io.MoleculeArchiveStorage

close, deepList, deepList, deepList, deepList, deepList, deepListHelper, getGroupSeparator, groupPath

Field Detail

s3

protected final com.amazonaws.services.s3.AmazonS3 s3

bucketName

protected final java.lang.String bucketName

containerPath

protected java.lang.String containerPath

fileExtension

protected java.lang.String fileExtension

keyValueAccess

protected final MoleculeArchiveAmazonS3KeyValueAccess keyValueAccess

Constructor Detail

MoleculeArchiveAmazonS3Source

public MoleculeArchiveAmazonS3Source(com.amazonaws.services.s3.AmazonS3 s3,
                                     java.lang.String bucketName)
                              throws java.io.IOException

Opens an If the bucket does not exist, it will not be created and all subsequent attempts to read attributes, groups, or datasets will fail.

Parameters:

s3 - AmazonS3 location.

bucketName - the name of the bucket.

Throws:

java.io.IOException - thrown when reading or writing to the location fails.

MoleculeArchiveAmazonS3Source

public MoleculeArchiveAmazonS3Source(com.amazonaws.services.s3.AmazonS3 s3,
                                     com.amazonaws.services.s3.AmazonS3URI containerURI)
                              throws java.io.IOException

Opens an If the bucket and/or container does not exist, it will not be created and all subsequent attempts to read attributes, groups, or datasets will fail.

Parameters:

s3 - AmazonS3 location.

containerURI - the container uri.

Throws:

java.io.IOException - thrown when reading or writing to the location fails.

MoleculeArchiveAmazonS3Source

public MoleculeArchiveAmazonS3Source(com.amazonaws.services.s3.AmazonS3 s3,
                                     java.lang.String bucketName,
                                     java.lang.String containerPath)
                              throws java.io.IOException

Opens an If the bucket and/or container does not exist, it will not be created and all subsequent attempts to read attributes, groups, or datasets will fail.

Parameters:

s3 - AmazonS3 location.

bucketName - the name of the bucket.

containerPath - the object path within the bucket.

Throws:

java.io.IOException - thrown when reading or writing to the location fails.

Method Detail

setPath

public void setPath(java.lang.String path)

Specified by:

setPath in interface MoleculeArchiveSource

getPath

public java.lang.String getPath()

Specified by:

getPath in interface MoleculeArchiveSource

getName

public java.lang.String getName()

Specified by:

getName in interface MoleculeArchiveSource

initializeLocation

public void initializeLocation()
                        throws java.io.IOException

Specified by:

initializeLocation in interface MoleculeArchiveSource

Throws:

java.io.IOException

isVirtual

public boolean isVirtual()

Specified by:

isVirtual in interface MoleculeArchiveSource

isReachable

public boolean isReachable()

Specified by:

isReachable in interface MoleculeArchiveSource

getArchiveType

public java.lang.String getArchiveType()
                                throws java.io.IOException

Specified by:

getArchiveType in interface MoleculeArchiveSource

Throws:

java.io.IOException

getInputStream

public java.io.InputStream getInputStream()
                                   throws java.io.IOException

Specified by:

getInputStream in interface MoleculeArchiveSource

Throws:

java.io.IOException

getOutputStream

public java.io.OutputStream getOutputStream()
                                     throws java.io.IOException

Specified by:

getOutputStream in interface MoleculeArchiveSource

Throws:

java.io.IOException

getRoverInputStream

public java.io.InputStream getRoverInputStream()
                                        throws java.io.IOException

Specified by:

getRoverInputStream in interface MoleculeArchiveSource

Throws:

java.io.IOException

getRoverOutputStream

public java.io.OutputStream getRoverOutputStream()
                                          throws java.io.IOException

Specified by:

getRoverOutputStream in interface MoleculeArchiveSource

Throws:

java.io.IOException

getPropertiesInputStream

public java.io.InputStream getPropertiesInputStream()
                                             throws java.io.IOException

Specified by:

getPropertiesInputStream in interface MoleculeArchiveSource

Throws:

java.io.IOException

getPropertiesOutputStream

public java.io.OutputStream getPropertiesOutputStream()
                                               throws java.io.IOException

Specified by:

getPropertiesOutputStream in interface MoleculeArchiveSource

Throws:

java.io.IOException

getIndexesInputStream

public java.io.InputStream getIndexesInputStream()
                                          throws java.io.IOException

Specified by:

getIndexesInputStream in interface MoleculeArchiveSource

Throws:

java.io.IOException

getIndexesOutputStream

public java.io.OutputStream getIndexesOutputStream()
                                            throws java.io.IOException

Specified by:

getIndexesOutputStream in interface MoleculeArchiveSource

Throws:

java.io.IOException

getMoleculeInputStream

public java.io.InputStream getMoleculeInputStream(java.lang.String UID)
                                           throws java.io.IOException

Specified by:

getMoleculeInputStream in interface MoleculeArchiveSource

Throws:

java.io.IOException

getMoleculeOutputStream

public java.io.OutputStream getMoleculeOutputStream(java.lang.String UID)
                                             throws java.io.IOException

Specified by:

getMoleculeOutputStream in interface MoleculeArchiveSource

Throws:

java.io.IOException

removeMolecule

public void removeMolecule(java.lang.String UID)
                    throws java.io.IOException

Specified by:

removeMolecule in interface MoleculeArchiveSource

Throws:

java.io.IOException

getMetadataInputStream

public java.io.InputStream getMetadataInputStream(java.lang.String metaUID)
                                           throws java.io.IOException

Specified by:

getMetadataInputStream in interface MoleculeArchiveSource

Throws:

java.io.IOException

getMetadataOutputStream

public java.io.OutputStream getMetadataOutputStream(java.lang.String metaUID)
                                             throws java.io.IOException

Specified by:

getMetadataOutputStream in interface MoleculeArchiveSource

Throws:

java.io.IOException

getMoleculeUIDs

public java.util.List<java.lang.String> getMoleculeUIDs()

Specified by:

getMoleculeUIDs in interface MoleculeArchiveSource

getMetadataUIDs

public java.util.List<java.lang.String> getMetadataUIDs()

Specified by:

getMetadataUIDs in interface MoleculeArchiveSource

removeMetadata

public void removeMetadata(java.lang.String metaUID)
                    throws java.io.IOException

Specified by:

removeMetadata in interface MoleculeArchiveSource

Throws:

java.io.IOException

getURI

public java.lang.String getURI()

Specified by:

getURI in interface MoleculeArchiveStorage

exists

public boolean exists(java.lang.String pathName)
               throws java.io.IOException

Description copied from interface: MoleculeArchiveStorage

Test whether a group or dataset exists at a given path.

Specified by:

exists in interface MoleculeArchiveStorage

Parameters:

pathName - group path

Returns:

true if the path exists

Throws:

java.io.IOException - an exception is thrown if the source is not accessible

list

public java.lang.String[] list(java.lang.String pathName)
                        throws java.io.IOException

Description copied from interface: MoleculeArchiveStorage

List all groups (including datasets) in a group.

Specified by:

list in interface MoleculeArchiveStorage

Parameters:

pathName - group path

Returns:

list of children

Throws:

java.io.IOException - an exception is thrown if pathName is not a valid group

listDirectories

public java.lang.String[] listDirectories(java.lang.String pathName)
                                   throws java.io.IOException

Description copied from interface: MoleculeArchiveStorage

List all groups (including datasets) in a group.

Specified by:

listDirectories in interface MoleculeArchiveStorage

Parameters:

pathName - group path

Returns:

list of directories

Throws:

java.io.IOException - an exception is thrown if pathName is not a valid group

listFiles

public java.lang.String[] listFiles(java.lang.String pathName)
                             throws java.io.IOException

Description copied from interface: MoleculeArchiveStorage

List all groups (including datasets) in a group.

Specified by:

listFiles in interface MoleculeArchiveStorage

Parameters:

pathName - group path

Returns:

list of files

Throws:

java.io.IOException - an exception is thrown if pathName is not a valid group