org.apache.fluo.recipes.core.map

Class CollisionFreeMap<K,V>

java.lang.Object

org.apache.fluo.recipes.core.map.CollisionFreeMap<K,V>

Deprecated.

since 1.1.0 use CombineQueue

@Deprecated
public class CollisionFreeMap<K,V>
extends Object

See the project level documentation for information about this recipe.

Since:

1.0.0

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CollisionFreeMap.Initializer<K2,V2> Deprecated. since 1.1.0
static class	CollisionFreeMap.Optimizer Deprecated. since 1.1.0 use CombineQueue.Optimizer
static class	CollisionFreeMap.Options Deprecated. since 1.1.0

Method Summary

Modifier and Type	Method and Description
static void	configure(org.apache.fluo.api.config.FluoConfiguration fluoConfig, CollisionFreeMap.Options opts) Deprecated. This method configures a collision free map for use.
V	get(org.apache.fluo.api.client.SnapshotBase tx, K key) Deprecated. This method will retrieve the current value for key and any outstanding updates and combine them using the configured Combiner.
static <K2,V2> CollisionFreeMap.Initializer<K2,V2>	getInitializer(String mapId, int numBuckets, SimpleSerializer serializer) Deprecated. A CollisionFreeMap stores data in its own data format in the Fluo table.
static <K2,V2> CollisionFreeMap<K2,V2>	getInstance(String mapId, org.apache.fluo.api.config.SimpleConfiguration appConf) Deprecated.
void	update(org.apache.fluo.api.client.TransactionBase tx, Map<K,V> updates) Deprecated. Queues updates for a collision free map.

Methods inherited from class java.lang.Object

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

Method Detail

get

public V get(org.apache.fluo.api.client.SnapshotBase tx,
             K key)

Deprecated.

This method will retrieve the current value for key and any outstanding updates and combine them using the configured Combiner. The result from the combiner is returned.

update

public void update(org.apache.fluo.api.client.TransactionBase tx,
                   Map<K,V> updates)

Deprecated.

Queues updates for a collision free map. These updates will be made by an Observer executing another transaction. This method will not collide with other transaction queuing updates for the same keys.

Parameters:

tx - This transaction will be used to make the updates.

updates - The keys in the map should correspond to keys in the collision free map being updated. The values in the map will be queued for updating.

getInstance

public static <K2,V2> CollisionFreeMap<K2,V2> getInstance(String mapId,
                                                          org.apache.fluo.api.config.SimpleConfiguration appConf)

Deprecated.

getInitializer

public static <K2,V2> CollisionFreeMap.Initializer<K2,V2> getInitializer(String mapId,
                                                                         int numBuckets,
                                                                         SimpleSerializer serializer)

Deprecated.

A CollisionFreeMap stores data in its own data format in the Fluo table. When initializing a Fluo table with something like Map Reduce or Spark, data will need to be written in this format. Thats the purpose of this method, it provide a simple class that can do this conversion.

configure

public static void configure(org.apache.fluo.api.config.FluoConfiguration fluoConfig,
                             CollisionFreeMap.Options opts)

Deprecated.

This method configures a collision free map for use. It must be called before initializing Fluo.