Package org.nuxeo.ecm.core.work

Class KeyValueStoreOverflowRecordFilter

java.lang.Object

org.nuxeo.ecm.core.work.BaseOverflowRecordFilter

org.nuxeo.ecm.core.work.KeyValueStoreOverflowRecordFilter

All Implemented Interfaces:

RecordFilter

public class KeyValueStoreOverflowRecordFilter
extends BaseOverflowRecordFilter

Filter that use a KeyValueStore to pass big record value

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
KeyValueStoreOverflowRecordFilter()

Method Summary

Modifier and Type	Method	Description
protected byte[]	fetchValue(String recordKey)	Fetches a value previously stored by BaseOverflowRecordFilter.storeValue(String, byte[])
protected KeyValueStore	getKeyValueStore()
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 Details

KeyValueStoreOverflowRecordFilter

public KeyValueStoreOverflowRecordFilter()

Method Details

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

getKeyValueStore

protected KeyValueStore getKeyValueStore()

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