Module org.elasticsearch.server

Package org.elasticsearch.common.blobstore.support

Class BlobContainerUtils

java.lang.Object

org.elasticsearch.common.blobstore.support.BlobContainerUtils

public class BlobContainerUtils
extends Object

Method Summary

Modifier and Type	Method	Description
static BytesReference	getRegisterBlobContents(long value)	Convert the long value into its representation in bytes for storage in a blob store register.
static long	getRegisterUsingConsistentRead(InputStream inputStream, String container, String key)	Many blob stores have consistent (linearizable/atomic) read semantics and in these casees it is safe to implement BlobContainer.getRegister(java.lang.String, org.elasticsearch.action.ActionListener<java.util.OptionalLong>) by simply reading the blob using this utility.

Methods inherited from class java.lang.Object

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

Method Details

getRegisterUsingConsistentRead

public static long getRegisterUsingConsistentRead(InputStream inputStream,
 String container,
 String key)
                                           throws IOException

Many blob stores have consistent (linearizable/atomic) read semantics and in these casees it is safe to implement BlobContainer.getRegister(java.lang.String, org.elasticsearch.action.ActionListener<java.util.OptionalLong>) by simply reading the blob using this utility. NB it is not safe for the supplied stream to resume a partial downloads, because the resumed stream may see a different state from the original.

Throws:

IOException

getRegisterBlobContents

public static BytesReference getRegisterBlobContents(long value)
                                              throws IOException

Convert the long value into its representation in bytes for storage in a blob store register.

Throws:

IOException