Package org.nuxeo.ecm.core.transientstore.computation

Class TransientStoreOverflowRecordFilter

java.lang.Object

org.nuxeo.ecm.core.work.BaseOverflowRecordFilter

org.nuxeo.ecm.core.transientstore.computation.TransientStoreOverflowRecordFilter

All Implemented Interfaces:

RecordFilter

public class TransientStoreOverflowRecordFilter
extends BaseOverflowRecordFilter

Filter that use a Transient Store to pass big record value. The TTL needs to be configured at the TransientStore level.

Since:

11.1

Field Summary

Fields inherited from class org.nuxeo.ecm.core.work.BaseOverflowRecordFilter

DEFAULT_PREFIX, DEFAULT_STORE_NAME, DEFAULT_STORE_TTL, DEFAULT_THRESHOLD_SIZE, prefix, PREFIX_OPTION, STORE_NAME_OPTION, STORE_TTL_OPTION, storeName, storeTTL, THRESHOLD_SIZE_OPTION, thresholdSize

Constructor Summary

Constructors

Constructor	Description
TransientStoreOverflowRecordFilter()

Method Summary

Modifier and Type	Method	Description
protected byte[]	fetchValue(String recordKey)	Fetches a value previously stored by BaseOverflowRecordFilter.storeValue(String, byte[])
protected TransientStore	getTransientStore()
void	init(Map<String,String> options)	Initialiaze the filter.
protected void	storeValue(String recordKey, byte[] data)	Sets the value associated to the key.

Methods inherited from class org.nuxeo.ecm.core.work.BaseOverflowRecordFilter

afterRead, beforeAppend, getPrefix, getPrefixedKey, getStoreName, getStoreTTL, getThresholdSize, getUniqRecordKey, parseIntOrDefault, setPrefix, setStoreName, setStoreTTL, setThresholdSize

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.nuxeo.lib.stream.computation.RecordFilter

afterAppend

Constructor Detail

TransientStoreOverflowRecordFilter

public TransientStoreOverflowRecordFilter()

Method Detail

init

public void init(Map<String,String> options)

Description copied from interface: RecordFilter

Initialiaze the filter.

Specified by:

init in interface RecordFilter

Overrides:

init in class BaseOverflowRecordFilter

getTransientStore

protected TransientStore getTransientStore()

storeValue

protected void storeValue(String recordKey,
                          byte[] data)

Description copied from class: BaseOverflowRecordFilter

Sets the value associated to the key.

Specified by:

storeValue in class BaseOverflowRecordFilter

fetchValue

protected byte[] fetchValue(String recordKey)

Description copied from class: BaseOverflowRecordFilter

Fetches a value previously stored by BaseOverflowRecordFilter.storeValue(String, byte[])

Specified by:

fetchValue in class BaseOverflowRecordFilter

Returns:

the value, or null if there is no value