public abstract class CacheTable extends InMemoryTable
Modifier and Type | Class and Description |
---|---|
class |
CacheTable.CacheCompiledConditionWithRouteToCache
wrapper to send routeToCache bool with cache compiled condition
|
InMemoryTable.TableState
siddhiAppContext, tableDefinition, tableMap
Constructor and Description |
---|
CacheTable() |
Modifier and Type | Method and Description |
---|---|
void |
addAndTrimUptoMaxSize(ComplexEventChunk<StreamEvent> addingEventChunk) |
protected abstract StreamEvent |
addRequiredFields(ComplexEvent event,
SiddhiAppContext siddhiAppContext,
boolean cacheExpiryEnabled) |
void |
addStreamEventUptoMaxSize(StreamEvent streamEvent) |
CompiledCondition |
compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext,
boolean updateCachePolicyAttribute) |
void |
deleteAll() |
abstract void |
deleteEntriesUsingCachePolicy(int numRowsToDelete) |
abstract void |
deleteOneEntryUsingCachePolicy() |
CacheTable.CacheCompiledConditionWithRouteToCache |
generateCacheCompileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder storeMatchingMetaInfoHolder,
SiddhiQueryContext siddhiQueryContext,
List<VariableExpressionExecutor> storeVariableExpressionExecutors) |
void |
init(io.siddhi.query.api.definition.TableDefinition tableDefinition,
StreamEventFactory storeEventPool,
StreamEventCloner storeEventCloner,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext,
RecordTableHandler recordTableHandler) |
void |
initCacheTable(io.siddhi.query.api.definition.TableDefinition cacheTableDefinition,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext,
RecordTableHandler recordTableHandler,
boolean cacheExpiryEnabled,
int maxSize,
String cachePolicy) |
abstract void |
updateCachePolicyAttribute(StreamEvent streamEvent) |
void |
updateOrAddAndTrimUptoMaxSize(ComplexEventChunk<StateEvent> updateOrAddingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
AddingStreamEventExtractor addingStreamEventExtractor,
int maxTableSize) |
add, compileCondition, compileUpdateSet, connectAndLoadCache, contains, delete, destroy, disconnect, find, getTableDefinition, isStateful, reduceEventsForUpdateOrInsert, size, update, updateOrAdd
addEvents, connectWithRetry, containsEvent, deleteEvents, find, getHandler, getIsConnected, getIsTryingToConnect, initTable, setIsConnectedToFalse, shutdown, updateEvents, updateOrAddEvents, waitWhileConnect
public void init(io.siddhi.query.api.definition.TableDefinition tableDefinition, StreamEventFactory storeEventPool, StreamEventCloner storeEventCloner, ConfigReader configReader, SiddhiAppContext siddhiAppContext, RecordTableHandler recordTableHandler)
init
in class InMemoryTable
public void initCacheTable(io.siddhi.query.api.definition.TableDefinition cacheTableDefinition, ConfigReader configReader, SiddhiAppContext siddhiAppContext, RecordTableHandler recordTableHandler, boolean cacheExpiryEnabled, int maxSize, String cachePolicy)
public void addStreamEventUptoMaxSize(StreamEvent streamEvent)
public void addAndTrimUptoMaxSize(ComplexEventChunk<StreamEvent> addingEventChunk)
public void updateOrAddAndTrimUptoMaxSize(ComplexEventChunk<StateEvent> updateOrAddingEventChunk, CompiledCondition compiledCondition, CompiledUpdateSet compiledUpdateSet, AddingStreamEventExtractor addingStreamEventExtractor, int maxTableSize)
public void deleteAll()
public abstract void deleteOneEntryUsingCachePolicy()
public abstract void deleteEntriesUsingCachePolicy(int numRowsToDelete)
protected abstract StreamEvent addRequiredFields(ComplexEvent event, SiddhiAppContext siddhiAppContext, boolean cacheExpiryEnabled)
public CacheTable.CacheCompiledConditionWithRouteToCache generateCacheCompileCondition(io.siddhi.query.api.expression.Expression condition, MatchingMetaInfoHolder storeMatchingMetaInfoHolder, SiddhiQueryContext siddhiQueryContext, List<VariableExpressionExecutor> storeVariableExpressionExecutors)
public CompiledCondition compileCondition(io.siddhi.query.api.expression.Expression condition, MatchingMetaInfoHolder matchingMetaInfoHolder, List<VariableExpressionExecutor> variableExpressionExecutors, Map<String,Table> tableMap, SiddhiQueryContext siddhiQueryContext, boolean updateCachePolicyAttribute)
public abstract void updateCachePolicyAttribute(StreamEvent streamEvent)
Copyright © 2019. All rights reserved.