| Modifier and Type | Class and Description |
|---|---|
static class |
LogDaoImpl.QueryType |
| Constructor and Description |
|---|
LogDaoImpl(DatabaseConfiguration config) |
LogDaoImpl(JDBCUtil jdbcUtil) |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<LogEntity> |
decomposeLog(byte[] id,
java.util.Set<java.util.Set<java.lang.String>> clusters) |
void |
delete(LogEntityPK logEntityPK) |
AttributeEntityPK |
getAttributeIdByKeyType(java.lang.String attr_key,
java.lang.String attr_type) |
int |
getLastSequenceNo(TraceEntityPK traceEntityPK) |
void |
injectToExistedLog(LogEntity logEntity) |
java.util.List<LogEntity> |
loadAll() |
java.util.Map<AttributeEntity,AttributeEntity> |
loadAttributes(LogEntityPK logEntityPK) |
LogEntity |
loadById(LogEntityPK logEntityPK) |
java.util.List<LogEntity> |
loadByName(java.lang.String s) |
java.util.List<ClassifierEntity> |
loadClassifierByLogId(LogEntityPK logEntityPK) |
TraceEntity |
loadClusteredTrace(java.lang.String traceId,
java.util.Set<java.util.Set<java.lang.String>> clusters) |
java.util.Map<TraceEntityPK,java.util.List<TraceEventAttrViewEntity>> |
loadCompleteEventsBuffered(java.util.List<TraceEntityPK> traceEntityPKs) |
java.util.List<TraceEventAttrViewEntity> |
loadCompleteEventsByTraceId(TraceEntityPK traceEntityPK) |
EventEntity |
loadEventById(byte[] bytes) |
java.util.List<TraceHasEventEntity> |
loadEventsByTraceId(TraceEntityPK traceEntityPK) |
java.util.Map<java.lang.String,ExtensionEntity> |
loadExtensions(java.util.Collection<AttributeEntity> attributeEntities) |
ExtensionEntity |
loadExtensionsById(byte[] extensionId) |
java.util.List<LogAttrViewEntity> |
loadLogAttributes(LogEntityPK logEntityPK) |
TraceBox |
loadTrace(TraceEntityPK traceEntityPK) |
java.util.List<TraceAttrViewEntity> |
loadTraceAttrById(TraceEntityPK traceEntityPK) |
java.util.Map<TraceEntityPK,java.util.List<TraceAttrViewEntity>> |
loadTraceAttrByIdBuffered(java.util.List<TraceEntityPK> traceEntityPKs) |
java.util.List<TraceEntityPK> |
loadTraceIdsByLogId(LogEntityPK logId) |
void |
save(LogEntity logEntity) |
void |
unProcessedAllEvents() |
void |
update(LogEntity logEntity) |
public LogDaoImpl(DatabaseConfiguration config)
public LogDaoImpl(JDBCUtil jdbcUtil)
public void injectToExistedLog(LogEntity logEntity)
injectToExistedLog in interface LogDaopublic void delete(LogEntityPK logEntityPK)
public LogEntity loadById(LogEntityPK logEntityPK)
public TraceEntity loadClusteredTrace(java.lang.String traceId, java.util.Set<java.util.Set<java.lang.String>> clusters)
loadClusteredTrace in interface LogDaopublic java.util.List<LogEntity> decomposeLog(byte[] id, java.util.Set<java.util.Set<java.lang.String>> clusters)
decomposeLog in interface LogDaopublic EventEntity loadEventById(byte[] bytes)
loadEventById in interface LogDaopublic java.util.List<TraceEntityPK> loadTraceIdsByLogId(LogEntityPK logId)
loadTraceIdsByLogId in interface LogDaopublic ExtensionEntity loadExtensionsById(byte[] extensionId)
loadExtensionsById in interface LogDaopublic java.util.List<ClassifierEntity> loadClassifierByLogId(LogEntityPK logEntityPK)
loadClassifierByLogId in interface LogDaopublic java.util.List<TraceAttrViewEntity> loadTraceAttrById(TraceEntityPK traceEntityPK)
loadTraceAttrById in interface LogDaopublic java.util.Map<TraceEntityPK,java.util.List<TraceAttrViewEntity>> loadTraceAttrByIdBuffered(java.util.List<TraceEntityPK> traceEntityPKs)
loadTraceAttrByIdBuffered in interface LogDaopublic java.util.List<LogAttrViewEntity> loadLogAttributes(LogEntityPK logEntityPK)
loadLogAttributes in interface LogDaopublic java.util.List<TraceHasEventEntity> loadEventsByTraceId(TraceEntityPK traceEntityPK)
loadEventsByTraceId in interface LogDaopublic java.util.List<TraceEventAttrViewEntity> loadCompleteEventsByTraceId(TraceEntityPK traceEntityPK)
loadCompleteEventsByTraceId in interface LogDaopublic java.util.Map<TraceEntityPK,java.util.List<TraceEventAttrViewEntity>> loadCompleteEventsBuffered(java.util.List<TraceEntityPK> traceEntityPKs)
loadCompleteEventsBuffered in interface LogDaopublic java.util.List<LogEntity> loadByName(java.lang.String s)
loadByName in interface LogDaopublic TraceBox loadTrace(TraceEntityPK traceEntityPK)
public int getLastSequenceNo(TraceEntityPK traceEntityPK)
getLastSequenceNo in interface LogDaopublic java.util.Map<AttributeEntity,AttributeEntity> loadAttributes(LogEntityPK logEntityPK)
loadAttributes in interface LogDaopublic AttributeEntityPK getAttributeIdByKeyType(java.lang.String attr_key, java.lang.String attr_type)
getAttributeIdByKeyType in interface LogDaopublic void unProcessedAllEvents()
unProcessedAllEvents in interface LogDaopublic java.util.Map<java.lang.String,ExtensionEntity> loadExtensions(java.util.Collection<AttributeEntity> attributeEntities)
loadExtensions in interface LogDao