public interface ObjectStoreLink
Modifier and Type | Interface and Description |
---|---|
static class |
ObjectStoreLink.ObjectStoreData
Tuple for data and metadata stored in Plasma.
|
Modifier and Type | Method and Description |
---|---|
boolean |
contains(byte[] objectId)
Check if the object is present and has been sealed in the PlasmaStore.
|
void |
delete(byte[] objectId)
Removes object with given objectId from plasma store.
|
long |
evict(long numBytes)
Evict some objects to recover given count of bytes.
|
List<ObjectStoreLink.ObjectStoreData> |
get(byte[][] objectIds,
int timeoutMs)
Get buffer pairs (data & metadata) from the PlasmaStore based on objectIds.
|
List<byte[]> |
get(byte[][] objectIds,
int timeoutMs,
boolean isMetadata)
Get buffers from the PlasmaStore based on objectIds.
|
default byte[] |
get(byte[] objectId,
int timeoutMs,
boolean isMetadata)
Get a buffer from the PlasmaStore based on the objectId.
|
byte[] |
hash(byte[] objectId)
Compute the hash of an object in the object store.
|
List<byte[]> |
list()
List all objects in the PlasmaStore.
|
void |
put(byte[] objectId,
byte[] value,
byte[] metadata)
Put value in the local plasma store with object ID objectId.
|
void |
release(byte[] objectId)
Release the reference of the object.
|
void put(byte[] objectId, byte[] value, byte[] metadata) throws DuplicateObjectException, PlasmaOutOfMemoryException
objectId
- The object ID of the value to be put.value
- The value to put in the object store.metadata
- encodes whatever metadata the user wishes to encode.DuplicateObjectException
PlasmaOutOfMemoryException
default byte[] get(byte[] objectId, int timeoutMs, boolean isMetadata)
objectId
- The object ID used to identify the object.timeoutMs
- The number of milliseconds that the get call should block before timing out
and returning. Pass -1 if the call should block and 0 if the call should return immediately.isMetadata
- false if get data, otherwise get metadata.List<byte[]> get(byte[][] objectIds, int timeoutMs, boolean isMetadata)
objectIds
- List of object IDs used to identify some objects.timeoutMs
- The number of milliseconds that the get call should block before timing out
and returning. Pass -1 if the call should block and 0 if the call should return immediately.isMetadata
- false if get data, otherwise get metadata.List<ObjectStoreLink.ObjectStoreData> get(byte[][] objectIds, int timeoutMs)
objectIds
- List of object IDs used to identify some objects.timeoutMs
- The number of milliseconds that the get call should block before timing out
and returning. Pass -1 if the call should block and 0 if the call should return immediately.byte[] hash(byte[] objectId)
objectId
- The object ID used to identify the object.long evict(long numBytes)
numBytes
- The number of bytes to attempt to recover.void release(byte[] objectId)
objectId
- The object ID used to release the reference of the object.void delete(byte[] objectId)
objectId
- used to identify an object.boolean contains(byte[] objectId)
objectId
- used to identify an object.List<byte[]> list()
Copyright © 2022 The Apache Software Foundation. All rights reserved.