com.yahoo.bullet.storage

Class MultiMemoryCountingCriteria

java.lang.Object

com.yahoo.bullet.storage.MultiMemoryCountingCriteria

All Implemented Interfaces:

Criteria<List<String>,Long>

public class MultiMemoryCountingCriteria
extends Object
implements Criteria<List<String>,Long>

An example of a simple criteria that counts the number of stored entries for the MultiMemoryCountingCriteria storage manager. retrieve(StorageManager) counts the keys in the default namespace (MultiMemoryStorageManager.getDefaultNamespace()) while apply(StorageManager, List) takes a List of String of namespaces to retrieve the total count for. If the List is empty or null, the total count is returned.

Constructor Summary

Constructors

Constructor and Description
MultiMemoryCountingCriteria()

Method Summary

Modifier and Type	Method and Description
<V extends Serializable> CompletableFuture<Long>	apply(StorageManager<V> storage, List<String> query) Applies the criteria to the StorageManager.
<V extends Serializable> CompletableFuture<Map<String,V>>	get(StorageManager<V> storage) Retrieves data from the given StorageManager as a CompletableFuture resolving to a key-value mapping of the raw data stored in the storage.
<V extends Serializable> CompletableFuture<Long>	retrieve(StorageManager<V> storage) Retrieves data from the given StorageManager as a CompletableFuture resolving to the specific return type of this Criteria.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.yahoo.bullet.storage.Criteria

checkType

Constructor Detail

MultiMemoryCountingCriteria

public MultiMemoryCountingCriteria()

Method Detail

get

public <V extends Serializable> CompletableFuture<Map<String,V>> get(StorageManager<V> storage)

Description copied from interface: Criteria

Retrieves data from the given StorageManager as a CompletableFuture resolving to a key-value mapping of the raw data stored in the storage.

Specified by:

get in interface Criteria<List<String>,Long>

Type Parameters:

V - The type of the data stored in the storage.

Parameters:

storage - The StorageManager to retrieve data from.

Returns:

A CompletableFuture that resolves to a Map of String keys to the raw data in the storage.

retrieve

public <V extends Serializable> CompletableFuture<Long> retrieve(StorageManager<V> storage)

Description copied from interface: Criteria

Retrieves data from the given StorageManager as a CompletableFuture resolving to the specific return type of this Criteria.

Specified by:

retrieve in interface Criteria<List<String>,Long>

Type Parameters:

V - The type of the data stored in the storage.

Parameters:

storage - The StorageManager to retrieve data from.

Returns:

A CompletableFuture that resolves to the return type of this Criteria.

apply

public <V extends Serializable> CompletableFuture<Long> apply(StorageManager<V> storage,
                                                              List<String> query)

Description copied from interface: Criteria

Applies the criteria to the StorageManager. This is left to the specific criteria to choose what to do.

Specified by:

apply in interface Criteria<List<String>,Long>

Type Parameters:

V - The type of the data stored in the storage.

Parameters:

storage - The StorageManager to apply this to.

query - The specific query to apply to this Criteria.

Returns:

A CompletableFuture that resolves to the return type of this Criteria.