Package com.atlan.cache

Class OffHeapAssetCache

java.lang.Object

com.atlan.cache.AbstractOffHeapCache<String,Asset>

com.atlan.cache.OffHeapObjectCache<Asset>

com.atlan.cache.OffHeapAssetCache

All Implemented Interfaces:

AtlanCloseable, AutoCloseable

public class OffHeapAssetCache
extends OffHeapObjectCache<Asset>

Generic class through which to cache any assets efficiently, off-heap, to avoid risking extreme memory usage.

Constructor Summary

Constructors

Constructor	Description
OffHeapAssetCache(AtlanClient client, String name)	Construct new asset cache.

Method Summary

Modifier and Type	Method	Description
void	add(Asset asset)	Add an asset into the cache.
void	extendedWith(OffHeapAssetCache other, boolean closeOriginal)	Extend this cache with all the entries from the provided cache.
void	extendedWith(OffHeapAssetCache other, boolean closeOriginal, Predicate<Asset> isValid)	Extend this cache with all the entries from the provided cache.

Methods inherited from class com.atlan.cache.OffHeapObjectCache

deserializeKey, deserializeValue, serializeKey, serializeValue

Methods inherited from class com.atlan.cache.AbstractOffHeapCache

close, containsKey, entrySet, get, getName, getSize, isEmpty, isNotClosed, isNotEmpty, put, putAll, size, values

Methods inherited from class java.lang.Object

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

Constructor Details

OffHeapAssetCache

public OffHeapAssetCache(AtlanClient client,
 String name)

Construct new asset cache.

Parameters:

client - connectivity to the Atlan tenant

name - must be unique across the running code

Method Details

add

public void add(Asset asset)

Add an asset into the cache. Note: the object MUST have a real (not a placeholder) UUID to be cached.

Parameters:

asset - to add to the cache

extendedWith

public void extendedWith(OffHeapAssetCache other,
 boolean closeOriginal)

Extend this cache with all the entries from the provided cache.

Parameters:

other - other cache with which to extend this one

closeOriginal - if true, close the provided cache after the extension is complete

extendedWith

public void extendedWith(OffHeapAssetCache other,
 boolean closeOriginal,
 Predicate<Asset> isValid)

Extend this cache with all the entries from the provided cache.

Parameters:

other - other cache with which to extend this one

closeOriginal - if true, close the provided cache after the extension is complete

isValid - boolean method that takes a single asset as an argument, and only when evaluated to true for an asset in the other cache will that entry from the other cache be included in this one