Package be.panako.strategy.olaf.storage

Class OlafStorageKV

java.lang.Object

be.panako.strategy.olaf.storage.OlafStorageKV

All Implemented Interfaces:

OlafStorage

public class OlafStorageKV
extends Object
implements OlafStorage

Constructor Summary

Constructors

Constructor	Description
OlafStorageKV()

Method Summary

Modifier and Type	Method	Description
void	addToDeleteQueue(long key, int val1, int val2)
void	addToQueryQueue(long queryHash)
void	addToStoreQueue(long fingerprintHash, int resourceIdentifier, int t1)
void	clear()
void	clearStoreQueue()
void	close()
void	deleteMetadata(long resourceID)
long	entries(boolean printStats)
static OlafStorageKV	getInstance()
OlafResourceMetadata	getMetadata(long resourceID)
void	processDeleteQueue()
void	processQueryQueue(Map<Long,List<OlafHit>> matchAccumulator, int range)
void	processQueryQueue(Map<Long,List<OlafHit>> matchAccumulator, int range, Set<Integer> resourcesToAvoid)
void	processStoreQueue()
void	storeMetadata(long resourceID, String resourcePath, float duration, int fingerprints)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

OlafStorageKV

public OlafStorageKV()

Method Details

getInstance

public static OlafStorageKV 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,
 String resourcePath,
 float duration,
 int fingerprints)

Specified by:

storeMetadata in interface OlafStorage

getMetadata

public OlafResourceMetadata getMetadata(long resourceID)

Specified by:

getMetadata in interface OlafStorage

addToStoreQueue

public void addToStoreQueue(long fingerprintHash,
 int resourceIdentifier,
 int t1)

Specified by:

addToStoreQueue in interface OlafStorage

processStoreQueue

public void processStoreQueue()

Specified by:

processStoreQueue in interface OlafStorage

clearStoreQueue

public void clearStoreQueue()

addToDeleteQueue

public void addToDeleteQueue(long key,
 int val1,
 int val2)

processDeleteQueue

public void processDeleteQueue()

addToQueryQueue

public void addToQueryQueue(long queryHash)

Specified by:

addToQueryQueue in interface OlafStorage

processQueryQueue

public void processQueryQueue(Map<Long,List<OlafHit>> matchAccumulator,
 int range)

Specified by:

processQueryQueue in interface OlafStorage

processQueryQueue

public void processQueryQueue(Map<Long,List<OlafHit>> matchAccumulator,
 int range,
 Set<Integer> resourcesToAvoid)

Specified by:

processQueryQueue in interface OlafStorage

entries

public long entries(boolean printStats)

deleteMetadata

public void deleteMetadata(long resourceID)

clear

public void clear()