software.chronicle.datagrid.internal.map.remote

Class RemoteMapView<K,V>

java.lang.Object

software.chronicle.datagrid.internal.map.VanillaMapView<K,V>

software.chronicle.datagrid.internal.map.remote.RemoteMapView<K,V>

All Implemented Interfaces:

ConcurrentMap<K,V>, Function<K,V>, Map<K,V>, KeyedVisitable<K,V>, Updatable<MapView<K,V>>, MapView<K,V>, Assetted<Object>, KeyedView

public final class RemoteMapView<K,V>
extends VanillaMapView<K,V>

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Field Summary

Fields inherited from class software.chronicle.datagrid.internal.map.VanillaMapView

asset, context, keyClass, putReturnsNull, removeReturnsNull, valueType

Constructor Summary

Constructors

Constructor and Description
RemoteMapView(@NotNull RequestContext context, @NotNull Asset asset, @NotNull KeyValueStore<K,V> kvStore)

Method Summary

Modifier and Type	Method and Description
<A,R> R	applyTo(@NotNull net.openhft.chronicle.core.util.SerializableBiFunction<MapView<K,V>,A,R> function, A arg) Apply a function to an Updatable which is assumed to not change the visited in any significant way.
<R> R	applyTo(@NotNull net.openhft.chronicle.core.util.SerializableFunction<MapView<K,V>,R> function) Apply a function to an Updatable which is assumed to not change the visited in any significant way.
<T,R> R	applyToKey(K key, @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<V,T,R> function, T argument) Apply a function which takes an argument.
<R> R	applyToKey(K key, @NotNull net.openhft.chronicle.core.util.SerializableFunction<V,R> function) Apply a function to the visitable and return the result.
void	asyncUpdate(@NotNull net.openhft.chronicle.core.util.SerializableUpdater<MapView<K,V>> updateFunction) Update an Updatable potentially asynchronously.
<A> void	asyncUpdate(@NotNull net.openhft.chronicle.core.util.SerializableUpdaterWithArg<MapView<K,V>,A> updateFunction, A arg) Update an Updatable potentially asynchronously.
<T> void	asyncUpdateKey(K key, @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<V,T,V> updateFunction, T argument) Apply a function to visitable potentially asynchronously.
void	asyncUpdateKey(K key, @NotNull net.openhft.chronicle.core.util.SerializableFunction<V,V> updateFunction) Apply a function to visitable potentially asynchronously.
V	compute(K key, @NotNull BiFunction<? super K,? super V,? extends V> remappingFunction)
V	computeIfAbsent(K key, @NotNull Function<? super K,? extends V> mappingFunction)
V	computeIfPresent(K key, @NotNull BiFunction<? super K,? super V,? extends V> remappingFunction)
boolean	containsValue(Object value)
boolean	equals(Object o)
int	hashCode()
V	merge(K key, V value, BiFunction<? super V,? super V,? extends V> remappingFunction)
V	putIfAbsent(K key, V value)
@NotNull Reference<V>	referenceFor(K key) Obtain a reference the value for a key
void	registerKeySubscriber(@NotNull Subscriber<? super K> subscriber, @NotNull Filter filter, @NotNull Set<RequestContext.Operation> contextOperations) Add a Subscription for the keys changed on this Map
boolean	remove(@NotNull Object key, Object value)
V	replace(K key, V value)
boolean	replace(K key, V oldValue, V newValue)
void	replaceAll(BiFunction<? super K,? super V,? extends V> function)
<R> R	syncUpdate(@NotNull net.openhft.chronicle.core.util.SerializableUpdater<MapView<K,V>> updateFunction, @NotNull net.openhft.chronicle.core.util.SerializableFunction<MapView<K,V>,R> returnFunction) Apply a function to update an Updatable and apply a second function to derive some information from it.
<UA,RA,R> R	syncUpdate(@NotNull net.openhft.chronicle.core.util.SerializableUpdaterWithArg<MapView<K,V>,UA> updateFunction, UA ua, @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<MapView<K,V>,RA,R> returnFunction, RA returnArgument) Apply a function to update an Updatable and apply a second function to derive some information from it.
<T,RT,R> R	syncUpdateKey(K key, @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<V,T,V> updateFunction, T updateArgument, @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<V,RT,R> returnFunction, RT returnArgument) Apply a function to update the state of a visible, and apply a function to return a result object synchronously.
<R> R	syncUpdateKey(K key, @NotNull net.openhft.chronicle.core.util.SerializableFunction<V,V> updateFunction, @NotNull net.openhft.chronicle.core.util.SerializableFunction<V,R> returnFunction) Apply a function to update the state of a visible, and apply a function to return a result object synchronously.

Methods inherited from class software.chronicle.datagrid.internal.map.VanillaMapView

asset, checkKey, checkValue, clear, containsKey, entrySet, get, getAndPut, getAndRemove, getUsing, isEmpty, keySet, keyType, longSize, put, putAll, registerKeySubscriber, registerSubscriber, registerSubscriber, registerTopicSubscriber, remove, set, toString, underlying, values, valueType

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface software.chronicle.datagrid.map.MapView

apply, size

Methods inherited from interface java.util.concurrent.ConcurrentMap

forEach, getOrDefault

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Methods inherited from interface software.chronicle.datagrid.tree.KeyedView

keyedView

Constructor Detail

RemoteMapView

public RemoteMapView(@NotNull
                     @NotNull RequestContext context,
                     @NotNull
                     @NotNull Asset asset,
                     @NotNull
                     @NotNull KeyValueStore<K,V> kvStore)

Method Detail

containsValue

public boolean containsValue(Object value)

Specified by:

containsValue in interface Map<K,V>

Overrides:

containsValue in class VanillaMapView<K,V>

registerKeySubscriber

public void registerKeySubscriber(@NotNull
                                  @NotNull Subscriber<? super K> subscriber,
                                  @NotNull
                                  @NotNull Filter filter,
                                  @NotNull
                                  @NotNull Set<RequestContext.Operation> contextOperations)

Description copied from interface: MapView

Add a Subscription for the keys changed on this Map

Any given instance of a subscriber must at most be registered once with a DataGrid instance at any given time.

This method is asynchronous and the provided subscriber will be eligible for receiving events as some later unspecified time.

Specified by:

registerKeySubscriber in interface MapView<K,V>

Overrides:

registerKeySubscriber in class VanillaMapView<K,V>

Parameters:

subscriber - to add

filter - a list of filter operations

contextOperations - which optional operations to consider (e.g. bootstrap and ending after bootstrap)

replaceAll

public void replaceAll(BiFunction<? super K,? super V,? extends V> function)

equals

public boolean equals(Object o)

Specified by:

equals in interface Map<K,V>

Overrides:

equals in class VanillaMapView<K,V>

referenceFor

@NotNull
public @NotNull Reference<V> referenceFor(K key)

Description copied from interface: MapView

Obtain a reference the value for a key

Specified by:

referenceFor in interface MapView<K,V>

Overrides:

referenceFor in class VanillaMapView<K,V>

Parameters:

key - to bind the reference to

Returns:

a reference object.

hashCode

public int hashCode()

Specified by:

hashCode in interface Map<K,V>

Overrides:

hashCode in class VanillaMapView<K,V>

putIfAbsent

@Nullable
public V putIfAbsent(@NotNull
                               K key,
                               V value)

Specified by:

putIfAbsent in interface ConcurrentMap<K,V>

Specified by:

putIfAbsent in interface Map<K,V>

Overrides:

putIfAbsent in class VanillaMapView<K,V>

remove

public boolean remove(@NotNull
                      @NotNull Object key,
                      Object value)

Specified by:

remove in interface ConcurrentMap<K,V>

Specified by:

remove in interface Map<K,V>

Overrides:

remove in class VanillaMapView<K,V>

replace

public boolean replace(@NotNull
                       K key,
                       @NotNull
                       V oldValue,
                       @NotNull
                       V newValue)

Specified by:

replace in interface ConcurrentMap<K,V>

Specified by:

replace in interface Map<K,V>

Overrides:

replace in class VanillaMapView<K,V>

replace

@Nullable
public V replace(@NotNull
                           K key,
                           @NotNull
                           V value)

Specified by:

replace in interface ConcurrentMap<K,V>

Specified by:

replace in interface Map<K,V>

Overrides:

replace in class VanillaMapView<K,V>

computeIfAbsent

@NotNull
public V computeIfAbsent(K key,
                                  @NotNull
                                  @NotNull Function<? super K,? extends V> mappingFunction)

computeIfPresent

@NotNull
public V computeIfPresent(K key,
                                   @NotNull
                                   @NotNull BiFunction<? super K,? super V,? extends V> remappingFunction)

compute

@NotNull
public V compute(K key,
                          @NotNull
                          @NotNull BiFunction<? super K,? super V,? extends V> remappingFunction)

merge

@NotNull
public V merge(K key,
                        V value,
                        BiFunction<? super V,? super V,? extends V> remappingFunction)

applyTo

@Nullable
public <A,R> R applyTo(@NotNull
                                 @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<MapView<K,V>,A,R> function,
                                 A arg)

Description copied from interface: Updatable

Apply a function to an Updatable which is assumed to not change the visited in any significant way. This might not trigger an event.

Type Parameters:

A - argument type.

R - return type.

Parameters:

function - to apply to derive data from this Updatable.

arg - argument to apply

Returns:

derived data.

asyncUpdate

public <A> void asyncUpdate(@NotNull
                            @NotNull net.openhft.chronicle.core.util.SerializableUpdaterWithArg<MapView<K,V>,A> updateFunction,
                            A arg)

Description copied from interface: Updatable

Update an Updatable potentially asynchronously. This function is assumed to update Updatable.

Type Parameters:

A - argument type.

Parameters:

updateFunction - to apply.

arg - argument to apply

syncUpdate

@Nullable
public <UA,RA,R> R syncUpdate(@NotNull
                                        @NotNull net.openhft.chronicle.core.util.SerializableUpdaterWithArg<MapView<K,V>,UA> updateFunction,
                                        UA ua,
                                        @NotNull
                                        @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<MapView<K,V>,RA,R> returnFunction,
                                        RA returnArgument)

Description copied from interface: Updatable

Apply a function to update an Updatable and apply a second function to derive some information from it.

Type Parameters:

UA - update argument type

RA - return argument type

R - return type

Parameters:

updateFunction - to apply the update.

ua - update argument

returnFunction - to derive some data

returnArgument - return argument

Returns:

a value derived from applying the provided parameters

applyTo

@Nullable
public <R> R applyTo(@NotNull
                               @NotNull net.openhft.chronicle.core.util.SerializableFunction<MapView<K,V>,R> function)

Description copied from interface: Updatable

Apply a function to an Updatable which is assumed to not change the visited in any significant way. This might not trigger an event.

Type Parameters:

R - return type.

Parameters:

function - to apply to derive data from this Updatable.

Returns:

derived data.

asyncUpdate

public void asyncUpdate(@NotNull
                        @NotNull net.openhft.chronicle.core.util.SerializableUpdater<MapView<K,V>> updateFunction)

Description copied from interface: Updatable

Update an Updatable potentially asynchronously. This function is assumed to update Updatable.

Parameters:

updateFunction - to apply.

syncUpdate

@Nullable
public <R> R syncUpdate(@NotNull
                                  @NotNull net.openhft.chronicle.core.util.SerializableUpdater<MapView<K,V>> updateFunction,
                                  @NotNull
                                  @NotNull net.openhft.chronicle.core.util.SerializableFunction<MapView<K,V>,R> returnFunction)

Description copied from interface: Updatable

Apply a function to update an Updatable and apply a second function to derive some information from it.

Type Parameters:

R - data type to return.

Parameters:

updateFunction - to apply the update.

returnFunction - to derive some data

Returns:

value derived.

applyToKey

@Nullable
public <R> R applyToKey(K key,
                                  @NotNull
                                  @NotNull net.openhft.chronicle.core.util.SerializableFunction<V,R> function)

Description copied from interface: KeyedVisitable

Apply a function to the visitable and return the result. This function is assumed to not change the value in any significant way.

Type Parameters:

R - data type to return.

Parameters:

key - to visit within this collection.

function - to apply e.g. call a getter

Returns:

the result of the code called.

applyToKey

@Nullable
public <T,R> R applyToKey(K key,
                                    @NotNull
                                    @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<V,T,R> function,
                                    T argument)

Description copied from interface: KeyedVisitable

Apply a function which takes an argument. This argument may contain a combination of data. This function is assumed to not change the value in any significant way.

Type Parameters:

T - type of the argument

R - type of the return value.

Parameters:

key - to visit within this collection.

function - to apply

argument - for the functions use.

Returns:

data derived.

asyncUpdateKey

public void asyncUpdateKey(K key,
                           @NotNull
                           @NotNull net.openhft.chronicle.core.util.SerializableFunction<V,V> updateFunction)

Description copied from interface: KeyedVisitable

Apply a function to visitable potentially asynchronously. This function is assumed to replace the value and trigger and events or replicated changes.

Parameters:

key - to visit within this collection.

updateFunction - to update the state of the visibility.

asyncUpdateKey

public <T> void asyncUpdateKey(K key,
                               @NotNull
                               @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<V,T,V> updateFunction,
                               T argument)

Description copied from interface: KeyedVisitable

Apply a function to visitable potentially asynchronously. This argument may contain a combination of data. This function is assumed to replace the value and trigger and events or replicated changes.

Type Parameters:

T - type of the argument

Parameters:

key - to update within this collection

updateFunction - to update the state of the visitable.

argument - for the functions use.

syncUpdateKey

@Nullable
public <R> R syncUpdateKey(K key,
                                     @NotNull
                                     @NotNull net.openhft.chronicle.core.util.SerializableFunction<V,V> updateFunction,
                                     @NotNull
                                     @NotNull net.openhft.chronicle.core.util.SerializableFunction<V,R> returnFunction)

Description copied from interface: KeyedVisitable

Apply a function to update the state of a visible, and apply a function to return a result object synchronously.

Type Parameters:

R - data type to return.

Parameters:

key - to update within this collection.

updateFunction - update to apply to the value.

returnFunction - derive an object to return

Returns:

the result of the code called.

syncUpdateKey

@Nullable
public <T,RT,R> R syncUpdateKey(K key,
                                          @NotNull
                                          @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<V,T,V> updateFunction,
                                          @Nullable
                                          T updateArgument,
                                          @NotNull
                                          @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<V,RT,R> returnFunction,
                                          @Nullable
                                          RT returnArgument)

Description copied from interface: KeyedVisitable

Apply a function to update the state of a visible, and apply a function to return a result object synchronously. This argument may contain a combination of data. Optionally the arguments could be null.

Type Parameters:

T - update argument type.

RT - return argument type.

R - data type to return.

Parameters:

key - to update within this collection

updateFunction - update to apply to the value.

updateArgument - for the update function to use.

returnFunction - derive an object to return

returnArgument - for the return value function to use

Returns:

the result of the code called.