public class CacheTableLRU extends CacheTable
CacheTable.CacheCompiledConditionWithRouteToCache
InMemoryTable.TableState
Table.OnErrorAction
siddhiAppContext, tableDefinition, tableMap
Constructor and Description |
---|
CacheTableLRU() |
Modifier and Type | Method and Description |
---|---|
protected StreamEvent |
addRequiredFields(ComplexEvent event,
SiddhiAppContext siddhiAppContext,
boolean cacheExpiryEnabled) |
void |
deleteEntriesUsingCachePolicy(int numRowsToDelete) |
void |
deleteOneEntryUsingCachePolicy() |
void |
updateCachePolicyAttribute(StreamEvent streamEvent) |
addAndTrimUptoMaxSize, addStreamEventUptoMaxSize, compileCondition, deleteAll, generateCacheCompileCondition, init, initCacheTable, updateOrAddAndTrimUptoMaxSize
add, compileCondition, compileUpdateSet, connectAndLoadCache, contains, delete, destroy, disconnect, find, getTableDefinition, isStateful, reduceEventsForUpdateOrInsert, size, update, updateOrAdd
addEvents, connectWithRetry, containsEvent, deleteEvents, find, getHandler, getIsConnected, getIsTryingToConnect, initTable, onAddError, onDeleteError, onUpdateError, onUpdateOrAddError, setIsConnectedToFalse, shutdown, updateEvents, updateOrAddEvents, waitWhileConnect
public void deleteOneEntryUsingCachePolicy()
deleteOneEntryUsingCachePolicy
in class CacheTable
public void deleteEntriesUsingCachePolicy(int numRowsToDelete)
deleteEntriesUsingCachePolicy
in class CacheTable
protected StreamEvent addRequiredFields(ComplexEvent event, SiddhiAppContext siddhiAppContext, boolean cacheExpiryEnabled)
addRequiredFields
in class CacheTable
public void updateCachePolicyAttribute(StreamEvent streamEvent)
updateCachePolicyAttribute
in class CacheTable
Copyright © 2021. All rights reserved.