Package com.atlan.cache

Class OffHeapFailureCache

java.lang.Object

com.atlan.cache.AbstractOffHeapCache<String,AssetBatch.FailedBatch>

com.atlan.cache.OffHeapFailureCache

All Implemented Interfaces:

AtlanCloseable, AutoCloseable

public class OffHeapFailureCache
extends AbstractOffHeapCache<String,AssetBatch.FailedBatch>

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

Constructor Summary

Constructors

Constructor	Description
OffHeapFailureCache(AtlanClient client, String name)	Construct new cache for failures.

Method Summary

Modifier and Type	Method	Description
String	deserializeKey(byte[] bytes)
AssetBatch.FailedBatch	deserializeValue(byte[] bytes)
void	extendedWith(OffHeapFailureCache other, boolean closeOriginal)	Extend this cache with all the entries from the provided cache.
byte[]	serializeKey(String key)
byte[]	serializeValue(AssetBatch.FailedBatch value)

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

OffHeapFailureCache

public OffHeapFailureCache(AtlanClient client,
 String name)

Construct new cache for failures.

Parameters:

client - connectivity to the Atlan tenant

name - to distinguish which cache is which

Method Details

serializeKey

public byte[] serializeKey(String key)

Specified by:

serializeKey in class AbstractOffHeapCache<String,AssetBatch.FailedBatch>

deserializeKey

public String deserializeKey(byte[] bytes)

Specified by:

deserializeKey in class AbstractOffHeapCache<String,AssetBatch.FailedBatch>

serializeValue

public byte[] serializeValue(AssetBatch.FailedBatch value)

Specified by:

serializeValue in class AbstractOffHeapCache<String,AssetBatch.FailedBatch>

deserializeValue

public AssetBatch.FailedBatch deserializeValue(byte[] bytes)

Specified by:

deserializeValue in class AbstractOffHeapCache<String,AssetBatch.FailedBatch>

extendedWith

public void extendedWith(OffHeapFailureCache 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