Package org.apache.storm.blobstore

Class BlobStoreFile

java.lang.Object

org.apache.storm.blobstore.BlobStoreFile

Direct Known Subclasses:

HdfsBlobStoreFile, LocalFsBlobStoreFile

public abstract class BlobStoreFile
extends Object

Provides an base implementation for creating a blobstore based on file backed storage.

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	BLOBSTORE_DATA_FILE
static final org.slf4j.Logger	LOG
protected static final String	TMP_EXT
protected static final Pattern	TMP_NAME_PATTERN

Constructor Summary

Constructors

Constructor	Description
BlobStoreFile()

Method Summary

Modifier and Type	Method	Description
abstract void	cancel()
abstract void	commit()
abstract void	delete()
abstract long	getFileLength()
abstract InputStream	getInputStream()
abstract String	getKey()
abstract SettableBlobMeta	getMetadata()
abstract long	getModTime()
abstract OutputStream	getOutputStream()
abstract boolean	isTmp()
abstract void	setMetadata(SettableBlobMeta meta)

Methods inherited from class java.lang.Object

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

Field Details

LOG

public static final org.slf4j.Logger LOG

TMP_EXT

protected static final String TMP_EXT

See Also:

• Constant Field Values

TMP_NAME_PATTERN

protected static final Pattern TMP_NAME_PATTERN

BLOBSTORE_DATA_FILE

protected static final String BLOBSTORE_DATA_FILE

See Also:

• Constant Field Values

Constructor Details

BlobStoreFile

public BlobStoreFile()

Method Details

delete

public abstract void delete()
                     throws IOException

Throws:

IOException

getKey

public abstract String getKey()

isTmp

public abstract boolean isTmp()

getMetadata

public abstract SettableBlobMeta getMetadata()

setMetadata

public abstract void setMetadata(SettableBlobMeta meta)

getModTime

public abstract long getModTime()
                         throws IOException

Throws:

IOException

getInputStream

public abstract InputStream getInputStream()
                                    throws IOException

Throws:

IOException

getOutputStream

public abstract OutputStream getOutputStream()
                                      throws IOException

Throws:

IOException

commit

public abstract void commit()
                     throws IOException

Throws:

IOException

cancel

public abstract void cancel()
                     throws IOException

Throws:

IOException

getFileLength

public abstract long getFileLength()
                            throws IOException

Throws:

IOException