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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected byte[]
fetchValue(String recordKey)
Fetches a value previously stored byBaseOverflowRecordFilter.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
-
-
-
-
Method Detail
-
init
public void init(Map<String,String> options)
Description copied from interface:RecordFilter
Initialiaze the filter.- Specified by:
init
in interfaceRecordFilter
- Overrides:
init
in classBaseOverflowRecordFilter
-
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 classBaseOverflowRecordFilter
-
fetchValue
protected byte[] fetchValue(String recordKey)
Description copied from class:BaseOverflowRecordFilter
Fetches a value previously stored byBaseOverflowRecordFilter.storeValue(String, byte[])
- Specified by:
fetchValue
in classBaseOverflowRecordFilter
- Returns:
- the value, or
null
if there is no value
-
-