Class PanakoStorageKV
java.lang.Object
be.panako.strategy.panako.storage.PanakoStorageKV
- All Implemented Interfaces:
PanakoStorage
public class PanakoStorageKV extends java.lang.Object implements PanakoStorage
-
Constructor Summary
Constructors Constructor Description PanakoStorageKV()
-
Method Summary
Modifier and Type Method Description void
addToDeleteQueue(long fingerprintHash, int resourceIdentifier, int t1, int f1)
void
addToQueryQueue(long queryHash)
void
addToStoreQueue(long fingerprintHash, int resourceIdentifier, int t1, int f1)
void
clear()
void
clearStoreQueue()
void
close()
void
deleteMetadata(long resourceID)
long
entries(boolean printStats)
static PanakoStorageKV
getInstance()
PanakoResourceMetadata
getMetadata(long resourceID)
void
processDeleteQueue()
void
processQueryQueue(java.util.Map<java.lang.Long,java.util.List<PanakoHit>> matchAccumulator, int range)
void
processQueryQueue(java.util.Map<java.lang.Long,java.util.List<PanakoHit>> matchAccumulator, int range, java.util.Set<java.lang.Integer> resourcesToAvoid)
void
processStoreQueue()
void
storeMetadata(long resourceID, java.lang.String resourcePath, float duration, int fingerprints)
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Constructor Details
-
PanakoStorageKV
public PanakoStorageKV()
-
-
Method Details
-
getInstance
- Returns:
- Returns or creates a storage instance. This should be a thread safe operation.
-
close
public void close() -
storeMetadata
public void storeMetadata(long resourceID, java.lang.String resourcePath, float duration, int fingerprints)- Specified by:
storeMetadata
in interfacePanakoStorage
-
getMetadata
- Specified by:
getMetadata
in interfacePanakoStorage
-
addToStoreQueue
public void addToStoreQueue(long fingerprintHash, int resourceIdentifier, int t1, int f1)- Specified by:
addToStoreQueue
in interfacePanakoStorage
-
processStoreQueue
public void processStoreQueue()- Specified by:
processStoreQueue
in interfacePanakoStorage
-
clearStoreQueue
public void clearStoreQueue() -
addToDeleteQueue
public void addToDeleteQueue(long fingerprintHash, int resourceIdentifier, int t1, int f1) -
processDeleteQueue
public void processDeleteQueue() -
addToQueryQueue
public void addToQueryQueue(long queryHash)- Specified by:
addToQueryQueue
in interfacePanakoStorage
-
processQueryQueue
public void processQueryQueue(java.util.Map<java.lang.Long,java.util.List<PanakoHit>> matchAccumulator, int range)- Specified by:
processQueryQueue
in interfacePanakoStorage
-
processQueryQueue
public void processQueryQueue(java.util.Map<java.lang.Long,java.util.List<PanakoHit>> matchAccumulator, int range, java.util.Set<java.lang.Integer> resourcesToAvoid)- Specified by:
processQueryQueue
in interfacePanakoStorage
-
entries
public long entries(boolean printStats) -
deleteMetadata
public void deleteMetadata(long resourceID) -
clear
public void clear()
-