Class TransientStoreOverflowRecordFilter
java.lang.Object
org.nuxeo.ecm.core.work.BaseOverflowRecordFilter
org.nuxeo.ecm.core.transientstore.computation.TransientStoreOverflowRecordFilter
- All Implemented Interfaces:
RecordFilter
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
-
Method Summary
Modifier and TypeMethodDescriptionprotected byte[]
fetchValue
(String recordKey) Fetches a value previously stored byBaseOverflowRecordFilter.storeValue(String, byte[])
protected TransientStore
void
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
-
TransientStoreOverflowRecordFilter
public TransientStoreOverflowRecordFilter()
-
-
Method Details
-
init
Description copied from interface:RecordFilter
Initialiaze the filter.- Specified by:
init
in interfaceRecordFilter
- Overrides:
init
in classBaseOverflowRecordFilter
-
getTransientStore
-
storeValue
Description copied from class:BaseOverflowRecordFilter
Sets the value associated to the key.- Specified by:
storeValue
in classBaseOverflowRecordFilter
-
fetchValue
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
-