Package com.here.platform.data.client.blobstore.volatil

Class VolatileWriteVolume

java.lang.Object

com.here.platform.data.client.blobstore.volatil.VolatileWriteVolume

All Implemented Interfaces:

DeleteSupport, VolatileWriteBlobstore, WriteBlobstore

public class VolatileWriteVolume
extends Object
implements VolatileWriteBlobstore, DeleteSupport

Constructor Summary

Constructors

Constructor	Description
VolatileWriteVolume(VolatileWriteVolumeConfiguration config, InternalSettings settings, BlobstoreClientExt blobstoreExt)
VolatileWriteVolume(VolatileWriteVolumeConfiguration config, InternalSettings settings, BlobstoreClientExt blobstoreExt, VolatileBlobstoreService service)

Method Summary

Modifier and Type	Method	Description
scala.Option<CrcAlgorithm>	crc()
scala.concurrent.Future<org.apache.pekko.Done>	deleteBlob(String dataHandle)
scala.Option<DigestAlgorithm>	digest()
static int	MAX_SIZE_VOLATILE_PARTITION()
scala.concurrent.Future<BlobMetadata>	putBlob(String dataHandle, org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> data, boolean applyCompression)
scala.concurrent.Future<org.apache.pekko.Done>	updateBlobTtl(String dataHandle, long ttlSeconds)

Methods inherited from class java.lang.Object

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

Constructor Details

VolatileWriteVolume

public VolatileWriteVolume(VolatileWriteVolumeConfiguration config,
 InternalSettings settings,
 BlobstoreClientExt blobstoreExt,
 VolatileBlobstoreService service)

VolatileWriteVolume

public VolatileWriteVolume(VolatileWriteVolumeConfiguration config,
 InternalSettings settings,
 BlobstoreClientExt blobstoreExt)

Method Details

MAX_SIZE_VOLATILE_PARTITION

public static int MAX_SIZE_VOLATILE_PARTITION()

putBlob

public scala.concurrent.Future<BlobMetadata> putBlob(String dataHandle,
 org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> data,
 boolean applyCompression)

Specified by:

putBlob in interface WriteBlobstore

deleteBlob

public scala.concurrent.Future<org.apache.pekko.Done> deleteBlob(String dataHandle)

Specified by:

deleteBlob in interface DeleteSupport

digest

public scala.Option<DigestAlgorithm> digest()

Specified by:

digest in interface WriteBlobstore

crc

public scala.Option<CrcAlgorithm> crc()

Specified by:

crc in interface WriteBlobstore

updateBlobTtl

public scala.concurrent.Future<org.apache.pekko.Done> updateBlobTtl(String dataHandle,
 long ttlSeconds)

Specified by:

updateBlobTtl in interface VolatileWriteBlobstore