org.elasticsearch.common.blobstore.fs

Class FsBlobContainer

java.lang.Object

org.elasticsearch.common.blobstore.support.AbstractBlobContainer

org.elasticsearch.common.blobstore.fs.FsBlobContainer

All Implemented Interfaces:

BlobContainer

public class FsBlobContainer
extends AbstractBlobContainer

Field Summary

Fields

Modifier and Type	Field and Description
protected FsBlobStore	blobStore
protected File	path

Constructor Summary

Constructors

Constructor and Description
FsBlobContainer(FsBlobStore blobStore, BlobPath blobPath, File path)

Method Summary

Modifier and Type	Method and Description
boolean	blobExists(String blobName)
OutputStream	createOutput(String blobName) Creates a new OutputStream for the given blob name
boolean	deleteBlob(String blobName)
File	filePath()
com.google.common.collect.ImmutableMap<String,BlobMetaData>	listBlobs()
com.google.common.collect.ImmutableMap<String,BlobMetaData>	listBlobsByPrefix(String blobNamePrefix)
InputStream	openInput(String name) Creates a new InputStream for the given blob name

Methods inherited from class org.elasticsearch.common.blobstore.support.AbstractBlobContainer

deleteBlobsByPrefix, path

Methods inherited from class java.lang.Object

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

Field Detail

blobStore

protected final FsBlobStore blobStore

path

protected final File path

Constructor Detail

FsBlobContainer

public FsBlobContainer(FsBlobStore blobStore,
                       BlobPath blobPath,
                       File path)

Method Detail

filePath

public File filePath()

listBlobs

public com.google.common.collect.ImmutableMap<String,BlobMetaData> listBlobs()
                                                                      throws IOException

Throws:

IOException

listBlobsByPrefix

public com.google.common.collect.ImmutableMap<String,BlobMetaData> listBlobsByPrefix(String blobNamePrefix)
                                                                              throws IOException

Throws:

IOException

deleteBlob

public boolean deleteBlob(String blobName)
                   throws IOException

Throws:

IOException

blobExists

public boolean blobExists(String blobName)

openInput

public InputStream openInput(String name)
                      throws IOException

Description copied from interface: BlobContainer

Creates a new InputStream for the given blob name

Throws:

IOException

createOutput

public OutputStream createOutput(String blobName)
                          throws IOException

Description copied from interface: BlobContainer

Creates a new OutputStream for the given blob name

Throws:

IOException