Interface CoherenceAsyncRepository<T,ID>
-
- Type Parameters:
T
- the domain type the repository managesID
- the type of the id of the entity the repository manages
- All Superinterfaces:
AsyncCrudRepository<T,ID>
,ListenerSupport<T,ID>
,org.springframework.data.repository.Repository<T,ID>
public interface CoherenceAsyncRepository<T,ID> extends AsyncCrudRepository<T,ID>, ListenerSupport<T,ID>
Coherence-specific asynchronous repository interface.- Since:
- 3.0
- Author:
- Ryan Lubke
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
addListener(com.oracle.coherence.repository.AbstractRepositoryBase.Listener<? super T> listener)
Register a listener that will observe all repository events.void
addListener(com.tangosol.util.Filter<?> filter, com.oracle.coherence.repository.AbstractRepositoryBase.Listener<? super T> listener)
Register a listener that will observe all events for entities that satisfy the specified criteria.void
addListener(ID id, com.oracle.coherence.repository.AbstractRepositoryBase.Listener<? super T> listener)
Register a listener that will observe all events for a specific entity.CompletableFuture<BigDecimal>
average(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToBigDecimalFunction<? super T> extractor)
Return the average of the specified function.CompletableFuture<Double>
average(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToDoubleFunction<? super T> extractor)
Return the average of the specified function.CompletableFuture<Double>
average(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToIntFunction<? super T> extractor)
Return the average of the specified function.CompletableFuture<Double>
average(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToLongFunction<? super T> extractor)
Return the average of the specified function.CompletableFuture<BigDecimal>
average(com.tangosol.util.function.Remote.ToBigDecimalFunction<? super T> extractor)
Return the average of the specified function.CompletableFuture<Double>
average(com.tangosol.util.function.Remote.ToDoubleFunction<? super T> extractor)
Return the average of the specified function.CompletableFuture<Double>
average(com.tangosol.util.function.Remote.ToIntFunction<? super T> extractor)
Return the average of the specified function.CompletableFuture<Double>
average(com.tangosol.util.function.Remote.ToLongFunction<? super T> extractor)
Return the average of the specified function.CompletableFuture<Long>
count()
Returns the number of entities available.CompletableFuture<Long>
count(com.tangosol.util.Filter<?> filter)
Return the number of entities in this repository that satisfy specified filter.CompletableFuture<Void>
delete(T entity)
Deletes a given entity.CompletableFuture<T>
delete(T entity, boolean fReturn)
Delete the specified entity.CompletableFuture<Void>
deleteAll()
Deletes all entities managed by the repository.CompletableFuture<Boolean>
deleteAll(com.tangosol.util.Filter<?> filter)
Remove all entities based on the specified criteria.CompletableFuture<Map<ID,T>>
deleteAll(com.tangosol.util.Filter<?> filter, boolean fReturn)
Remove all entities based on the specified criteria.CompletableFuture<Void>
deleteAll(Iterable<? extends T> entities)
Deletes the given entities.CompletableFuture<Boolean>
deleteAll(Collection<? extends T> colEntities)
Remove the specified entities.CompletableFuture<Map<ID,T>>
deleteAll(Collection<? extends T> colEntities, boolean fReturn)
Remove the specified entities.CompletableFuture<Boolean>
deleteAll(Stream<? extends T> strEntities)
Remove the specified entities.CompletableFuture<Map<ID,T>>
deleteAll(Stream<? extends T> strEntities, boolean fReturn)
Remove the specified entities.CompletableFuture<Void>
deleteAllById(Iterable<? extends ID> ids)
Deletes all instances of the typeT
with the given IDs.CompletableFuture<Boolean>
deleteAllById(Collection<? extends ID> colIds)
Remove entities with the specified identifiers.CompletableFuture<Map<ID,T>>
deleteAllById(Collection<? extends ID> colIds, boolean fReturn)
Remove entities with the specified identifiers.CompletableFuture<Void>
deleteById(ID id)
Deletes the entity with the given id.CompletableFuture<T>
deleteById(ID id, boolean fReturn)
Remove the entity with a specified identifier.<R> CompletableFuture<Collection<? extends R>>
distinct(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return the set of distinct values for the specified extractor.<R> CompletableFuture<Collection<? extends R>>
distinct(com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return the set of distinct values for the specified extractor.CompletableFuture<Boolean>
existsById(ID id)
Returns whether an entity with the given id exists.CompletableFuture<Iterable<T>>
findAll()
Returns all instances of the type.CompletableFuture<Iterable<T>>
findAllById(Iterable<ID> ids)
Returns all instances of the typeT
with the given IDs.CompletableFuture<Optional<T>>
findById(ID id)
Retrieves an entity by its id.<R> CompletableFuture<R>
get(ID id, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return the value extracted from an entity with a given identifier.CompletableFuture<Collection<T>>
getAll(com.tangosol.util.Filter<?> filter)
Return all entities that satisfy the specified criteria.<R> CompletableFuture<Map<ID,R>>
getAll(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return a map of values extracted from a set of entities based on the specified criteria.<R> CompletableFuture<Void>
getAll(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor, BiConsumer<? super ID,? super R> callback)
Streams the id and the associated extracted value from a set of entities based on the specified criteria.CompletableFuture<Void>
getAll(com.tangosol.util.Filter<?> filter, Consumer<? super T> callback)
Stream all entities that satisfy the specified criteria.<R> CompletableFuture<Map<ID,R>>
getAll(com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return a map of values extracted from all entities in the repository.<R> CompletableFuture<Void>
getAll(com.tangosol.util.ValueExtractor<? super T,? extends R> extractor, BiConsumer<? super ID,? super R> callback)
Streams the id and the associated extracted value from all entities in the repository.<R> CompletableFuture<Map<ID,R>>
getAll(Collection<? extends ID> colIds, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return a map of values extracted from a set of entities with the given identifiers.<R> CompletableFuture<Void>
getAll(Collection<? extends ID> colIds, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor, BiConsumer<? super ID,? super R> callback)
Stream the entities associated with the specified ids to the provided callback.CompletableFuture<Void>
getAll(Collection<? extends ID> colIds, Consumer<? super T> callback)
Stream the entities associated with the specified ids to the provided callback.CompletableFuture<Void>
getAll(Consumer<? super T> callback)
Stream all entities all entities in this repository.CompletableFuture<Collection<T>>
getAllOrderedBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.Comparator<? super T> orderBy)
Return all entities that satisfy the specified criteria, sorted using specifiedRemote.Comparator
.<R extends Comparable<? super R>>
CompletableFuture<Collection<T>>getAllOrderedBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends R> orderBy)
Return all entities that satisfy the specified criteria, sorted using specifiedComparable
attribute.CompletableFuture<Collection<T>>
getAllOrderedBy(com.tangosol.util.function.Remote.Comparator<? super T> orderBy)
Return all entities in this repository, sorted using specifiedRemote.Comparator
.<R extends Comparable<? super R>>
CompletableFuture<Collection<T>>getAllOrderedBy(com.tangosol.util.ValueExtractor<? super T,? extends R> orderBy)
Return all entities in this repository, sorted using specifiedComparable
attribute.com.tangosol.net.AsyncNamedMap<ID,T>
getMap()
Return the underlyingAsyncNamedMap
that backs thisRepository
.<K> CompletableFuture<Map<K,Set<T>>>
groupBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends K> extractor)
Return the grouping of entities by the specified extractor.<K> CompletableFuture<Map<K,SortedSet<T>>>
groupBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends K> extractor, com.tangosol.util.function.Remote.Comparator<? super T> orderBy)
Return the grouping of entities by the specified extractor, ordered by the specified attribute within each group.<K,A,R,M extends Map<K,R>>
CompletableFuture<M>groupBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends K> extractor, com.tangosol.util.function.Remote.Supplier<M> mapFactory, com.tangosol.util.stream.RemoteCollector<? super T,A,R> collector)
Return the grouping of entities by the specified extractor.<K,A,R>
CompletableFuture<Map<K,R>>groupBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends K> extractor, com.tangosol.util.stream.RemoteCollector<? super T,A,R> collector)
Return the grouping of entities by the specified extractor.<K> CompletableFuture<Map<K,Set<T>>>
groupBy(com.tangosol.util.ValueExtractor<? super T,? extends K> extractor)
Return the grouping of entities by the specified extractor.<K> CompletableFuture<Map<K,SortedSet<T>>>
groupBy(com.tangosol.util.ValueExtractor<? super T,? extends K> extractor, com.tangosol.util.function.Remote.Comparator<? super T> orderBy)
Return the grouping of entities by the specified extractor, ordered by the specified attribute within each group.<K,A,R,M extends Map<K,R>>
CompletableFuture<M>groupBy(com.tangosol.util.ValueExtractor<? super T,? extends K> extractor, com.tangosol.util.function.Remote.Supplier<M> mapFactory, com.tangosol.util.stream.RemoteCollector<? super T,A,R> collector)
Return the grouping of entities by the specified extractor.<K,A,R>
CompletableFuture<Map<K,R>>groupBy(com.tangosol.util.ValueExtractor<? super T,? extends K> extractor, com.tangosol.util.stream.RemoteCollector<? super T,A,R> collector)
Return the grouping of entities by the specified extractor.com.oracle.coherence.repository.AbstractRepositoryBase.Listener.Builder<T>
listener()
Create newAbstractRepositoryBase.Listener.Builder
instance.CompletableFuture<BigDecimal>
max(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToBigDecimalFunction<? super T> extractor)
Return the maximum value of the specified function.<R extends Comparable<? super R>>
CompletableFuture<R>max(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToComparableFunction<? super T,R> extractor)
Return the maximum value of the specified function.CompletableFuture<Double>
max(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToDoubleFunction<? super T> extractor)
Return the maximum value of the specified function.CompletableFuture<Integer>
max(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToIntFunction<? super T> extractor)
Return the maximum value of the specified function.CompletableFuture<Long>
max(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToLongFunction<? super T> extractor)
Return the maximum value of the specified function.CompletableFuture<BigDecimal>
max(com.tangosol.util.function.Remote.ToBigDecimalFunction<? super T> extractor)
Return the maximum value of the specified function.<R extends Comparable<? super R>>
CompletableFuture<R>max(com.tangosol.util.function.Remote.ToComparableFunction<? super T,R> extractor)
Return the maximum value of the specified function.CompletableFuture<Double>
max(com.tangosol.util.function.Remote.ToDoubleFunction<? super T> extractor)
Return the maximum value of the specified function.CompletableFuture<Integer>
max(com.tangosol.util.function.Remote.ToIntFunction<? super T> extractor)
Return the maximum value of the specified function.CompletableFuture<Long>
max(com.tangosol.util.function.Remote.ToLongFunction<? super T> extractor)
Return the maximum value of the specified function.<R extends Comparable<? super R>>
CompletableFuture<Optional<T>>maxBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return the entity with the maximum value of the specified function.<R extends Comparable<? super R>>
CompletableFuture<Optional<T>>maxBy(com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return the entity with the maximum value of the specified function.CompletableFuture<BigDecimal>
min(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToBigDecimalFunction<? super T> extractor)
Return the minimum value of the specified function.<R extends Comparable<? super R>>
CompletableFuture<R>min(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToComparableFunction<? super T,R> extractor)
Return the minimum value of the specified function.CompletableFuture<Double>
min(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToDoubleFunction<? super T> extractor)
Return the minimum value of the specified function.CompletableFuture<Integer>
min(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToIntFunction<? super T> extractor)
Return the minimum value of the specified function.CompletableFuture<Long>
min(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToLongFunction<? super T> extractor)
Return the minimum value of the specified function.CompletableFuture<BigDecimal>
min(com.tangosol.util.function.Remote.ToBigDecimalFunction<? super T> extractor)
Return the minimum value of the specified function.<R extends Comparable<? super R>>
CompletableFuture<R>min(com.tangosol.util.function.Remote.ToComparableFunction<? super T,R> extractor)
Return the minimum value of the specified function.CompletableFuture<Double>
min(com.tangosol.util.function.Remote.ToDoubleFunction<? super T> extractor)
Return the minimum value of the specified function.CompletableFuture<Integer>
min(com.tangosol.util.function.Remote.ToIntFunction<? super T> extractor)
Return the minimum value of the specified function.CompletableFuture<Long>
min(com.tangosol.util.function.Remote.ToLongFunction<? super T> extractor)
Return the minimum value of the specified function.<R extends Comparable<? super R>>
CompletableFuture<Optional<T>>minBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return the entity with the minimum value of the specified function.<R extends Comparable<? super R>>
CompletableFuture<Optional<T>>minBy(com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return the entity with the minimum value of the specified function.void
removeListener(com.oracle.coherence.repository.AbstractRepositoryBase.Listener<? super T> listener)
Unregister a listener that observes all repository events.void
removeListener(com.tangosol.util.Filter<?> filter, com.oracle.coherence.repository.AbstractRepositoryBase.Listener<? super T> listener)
Unregister a listener that observes all events for entities that satisfy the specified criteria.void
removeListener(ID id, com.oracle.coherence.repository.AbstractRepositoryBase.Listener<? super T> listener)
Unregister a listener that observes all events for a specific entity.<S extends T>
CompletableFuture<S>save(S entity)
Saves a given entity.<S extends T>
CompletableFuture<Iterable<S>>saveAll(Iterable<S> entities)
Saves all given entities.CompletableFuture<Void>
saveAll(Stream<? extends T> strEntities)
Store all specified entities as a batch.CompletableFuture<BigDecimal>
sum(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToBigDecimalFunction<? super T> extractor)
Return the sum of the specified function.CompletableFuture<Double>
sum(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToDoubleFunction<? super T> extractor)
Return the sum of the specified function.CompletableFuture<Long>
sum(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToIntFunction<? super T> extractor)
Return the sum of the specified function.CompletableFuture<Long>
sum(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToLongFunction<? super T> extractor)
Return the sum of the specified function.CompletableFuture<BigDecimal>
sum(com.tangosol.util.function.Remote.ToBigDecimalFunction<? super T> extractor)
Return the sum of the specified function.CompletableFuture<Double>
sum(com.tangosol.util.function.Remote.ToDoubleFunction<? super T> extractor)
Return the sum of the specified function.CompletableFuture<Long>
sum(com.tangosol.util.function.Remote.ToIntFunction<? super T> extractor)
Return the sum of the specified function.CompletableFuture<Long>
sum(com.tangosol.util.function.Remote.ToLongFunction<? super T> extractor)
Return the sum of the specified function.<R extends Comparable<? super R>>
CompletableFuture<List<R>>top(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor, int cResults)
Return the top N highest values for the specified extractor.<R> CompletableFuture<List<R>>
top(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor, com.tangosol.util.function.Remote.Comparator<? super R> comparator, int cResults)
Return the top N highest values for the specified extractor.<R extends Comparable<? super R>>
CompletableFuture<List<R>>top(com.tangosol.util.ValueExtractor<? super T,? extends R> extractor, int cResults)
Return the top N highest values for the specified extractor.<R> CompletableFuture<List<R>>
top(com.tangosol.util.ValueExtractor<? super T,? extends R> extractor, com.tangosol.util.function.Remote.Comparator<? super R> comparator, int cResults)
Return the top N highest values for the specified extractor.CompletableFuture<List<T>>
topBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.Comparator<? super T> comparator, int cResults)
Return the top N entities with the highest values for the specified extractor.<R extends Comparable<? super R>>
CompletableFuture<List<T>>topBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor, int cResults)
Return the top N entities with the highest values for the specified extractor.CompletableFuture<List<T>>
topBy(com.tangosol.util.function.Remote.Comparator<? super T> comparator, int cResults)
Return the top N entities with the highest values for the specified extractor.<R extends Comparable<? super R>>
CompletableFuture<List<T>>topBy(com.tangosol.util.ValueExtractor<? super T,? extends R> extractor, int cResults)
Return the top N entities with the highest values for the specified extractor.<U,R>
CompletableFuture<R>update(ID id, com.tangosol.util.function.Remote.BiFunction<? super T,? super U,? extends R> updater, U value)
Update an entity using specified updater and the new value.<U,R>
CompletableFuture<R>update(ID id, com.tangosol.util.function.Remote.BiFunction<? super T,? super U,? extends R> updater, U value, com.oracle.coherence.repository.EntityFactory<? super ID,? extends T> factory)
Update an entity using specified updater function, and optionalEntityFactory
that will be used to create entity instance if it doesn't already exist in the repository.<R> CompletableFuture<R>
update(ID id, com.tangosol.util.function.Remote.Function<? super T,? extends R> updater)
Update an entity using specified updater function.<R> CompletableFuture<R>
update(ID id, com.tangosol.util.function.Remote.Function<? super T,? extends R> updater, com.oracle.coherence.repository.EntityFactory<? super ID,? extends T> factory)
Update an entity using specified updater function, and optionalEntityFactory
that will be used to create entity instance if it doesn't already exist in the repository.<U> CompletableFuture<Void>
update(ID id, com.tangosol.util.ValueUpdater<? super T,? super U> updater, U value)
Update an entity using specified updater and the new value.<U> CompletableFuture<Void>
update(ID id, com.tangosol.util.ValueUpdater<? super T,? super U> updater, U value, com.oracle.coherence.repository.EntityFactory<? super ID,? extends T> factory)
Update an entity using specified updater and the new value, and optionalEntityFactory
that will be used to create entity instance if it doesn't already exist in the repository.<U,R>
CompletableFuture<Map<ID,R>>updateAll(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.BiFunction<? super T,? super U,? extends R> updater, U value)
Update multiple entities using specified updater and the new value.<R> CompletableFuture<Map<ID,R>>
updateAll(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.Function<? super T,? extends R> updater)
Update multiple entities using specified updater function.<U> CompletableFuture<Void>
updateAll(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueUpdater<? super T,? super U> updater, U value)
Update multiple entities using specified updater and the new value.
-
-
-
Method Detail
-
getMap
com.tangosol.net.AsyncNamedMap<ID,T> getMap()
Return the underlyingAsyncNamedMap
that backs thisRepository
.- Returns:
- the underlying
AsyncNamedMap
that backs thisRepository
-
count
CompletableFuture<Long> count()
Description copied from interface:AsyncCrudRepository
Returns the number of entities available.- Specified by:
count
in interfaceAsyncCrudRepository<T,ID>
- Returns:
- the number of entities
-
count
CompletableFuture<Long> count(com.tangosol.util.Filter<?> filter)
Return the number of entities in this repository that satisfy specified filter.- Parameters:
filter
- the filter to evaluate- Returns:
- a
CompletableFuture
that will resolve to the number of entities in this repository that satisfy specified filter
-
delete
CompletableFuture<Void> delete(T entity)
Description copied from interface:AsyncCrudRepository
Deletes a given entity.- Specified by:
delete
in interfaceAsyncCrudRepository<T,ID>
- Parameters:
entity
- must not be null- Returns:
- a CompletableFuture that can be used to determine whether the operation completed
-
delete
CompletableFuture<T> delete(T entity, boolean fReturn)
Delete the specified entity.- Parameters:
entity
- the entity to removefReturn
- the flag specifying whether to return removed entity- Returns:
- a
CompletableFuture
that will resolve to the removed entity, ifffReturn == true
;null
otherwise
-
deleteAll
CompletableFuture<Void> deleteAll()
Deletes all entities managed by the repository.- Specified by:
deleteAll
in interfaceAsyncCrudRepository<T,ID>
- Returns:
- a CompletableFuture that can be used to determine whether the operation completed
-
deleteAll
CompletableFuture<Boolean> deleteAll(Collection<? extends T> colEntities)
Remove the specified entities.- Parameters:
colEntities
- the entities to remove- Returns:
- a
CompletableFuture
that will resolve totrue
if this repository changed as a result of the call
-
deleteAll
CompletableFuture<Map<ID,T>> deleteAll(Collection<? extends T> colEntities, boolean fReturn)
Remove the specified entities.- Parameters:
colEntities
- the entities to removefReturn
- the flag specifying whether to return removed entity- Returns:
- a
CompletableFuture
that will resolve to a map of removed entity identifiers as keys, and the removed entities as values ifffReturn == true
;null
otherwise
-
deleteAll
CompletableFuture<Boolean> deleteAll(com.tangosol.util.Filter<?> filter)
Remove all entities based on the specified criteria.- Parameters:
filter
- the criteria that should be used to select entities to remove- Returns:
- a
CompletableFuture
that will resolve totrue
if this repository changed as a result of the call
-
deleteAll
CompletableFuture<Map<ID,T>> deleteAll(com.tangosol.util.Filter<?> filter, boolean fReturn)
Remove all entities based on the specified criteria.- Parameters:
filter
- the criteria that should be used to select entities to removefReturn
- the flag specifying whether to return removed entity- Returns:
- a
CompletableFuture
that will resolve to a map of removed entity identifiers as keys, and the removed entities as values ifffReturn == true
;null
otherwise
-
deleteAll
CompletableFuture<Void> deleteAll(Iterable<? extends T> entities)
Description copied from interface:AsyncCrudRepository
Deletes the given entities.- Specified by:
deleteAll
in interfaceAsyncCrudRepository<T,ID>
- Parameters:
entities
- must not be null. Must not contain null elements- Returns:
- a CompletableFuture that can be used to determine whether the operation completed
-
deleteAll
CompletableFuture<Boolean> deleteAll(Stream<? extends T> strEntities)
Remove the specified entities.- Parameters:
strEntities
- the entities to remove- Returns:
- a
CompletableFuture
that will resolve totrue
if this repository changed as a result of the call
-
deleteAll
CompletableFuture<Map<ID,T>> deleteAll(Stream<? extends T> strEntities, boolean fReturn)
Remove the specified entities.- Parameters:
strEntities
- the entities to removefReturn
- the flag specifying whether to return removed entity- Returns:
- a
CompletableFuture
that will resolve to a map of removed entity identifiers as keys, and the removed entities as values ifffReturn == true
;null
otherwise
-
deleteAllById
CompletableFuture<Void> deleteAllById(Iterable<? extends ID> ids)
Description copied from interface:AsyncCrudRepository
Deletes all instances of the typeT
with the given IDs.- Specified by:
deleteAllById
in interfaceAsyncCrudRepository<T,ID>
- Parameters:
ids
- must not be null. Must not contain null elements- Returns:
- a CompletableFuture that can be used to determine whether the operation completed
-
deleteAllById
CompletableFuture<Boolean> deleteAllById(Collection<? extends ID> colIds)
Remove entities with the specified identifiers.- Parameters:
colIds
- the identifiers of the entities to remove- Returns:
- a
CompletableFuture
that will resolve totrue
if this repository changed as a result of the call
-
deleteAllById
CompletableFuture<Map<ID,T>> deleteAllById(Collection<? extends ID> colIds, boolean fReturn)
Remove entities with the specified identifiers.- Parameters:
colIds
- the identifiers of the entities to removefReturn
- the flag specifying whether to return removed entity- Returns:
- a
CompletableFuture
that will resolve to a map of removed entity identifiers as keys, and the removed entities as values ifffReturn == true
;null
otherwise
-
deleteById
CompletableFuture<Void> deleteById(ID id)
Description copied from interface:AsyncCrudRepository
Deletes the entity with the given id.- Specified by:
deleteById
in interfaceAsyncCrudRepository<T,ID>
- Parameters:
id
- must not be null- Returns:
- a CompletableFuture that can be used to determine whether the operation completed
-
deleteById
CompletableFuture<T> deleteById(ID id, boolean fReturn)
Remove the entity with a specified identifier.- Parameters:
id
- the identifier of an entity to removefReturn
- the flag specifying whether to return removed entity- Returns:
- a
CompletableFuture
that will resolve to the removed entity, ifffReturn == true
;null
otherwise
-
existsById
CompletableFuture<Boolean> existsById(ID id)
Description copied from interface:AsyncCrudRepository
Returns whether an entity with the given id exists.- Specified by:
existsById
in interfaceAsyncCrudRepository<T,ID>
- Parameters:
id
- must not be null- Returns:
- true if an entity with the given id exists, false otherwise
-
findById
CompletableFuture<Optional<T>> findById(ID id)
Description copied from interface:AsyncCrudRepository
Retrieves an entity by its id.- Specified by:
findById
in interfaceAsyncCrudRepository<T,ID>
- Parameters:
id
- must not be null- Returns:
- the entity with the given id or Optional#empty() if none found
-
findAll
CompletableFuture<Iterable<T>> findAll()
Description copied from interface:AsyncCrudRepository
Returns all instances of the type.- Specified by:
findAll
in interfaceAsyncCrudRepository<T,ID>
- Returns:
- all entities
-
findAllById
CompletableFuture<Iterable<T>> findAllById(Iterable<ID> ids)
Description copied from interface:AsyncCrudRepository
Returns all instances of the typeT
with the given IDs.If some or all ids are not found, no entities are returned for these IDs.
Note that the order of elements in the result is not guaranteed.
- Specified by:
findAllById
in interfaceAsyncCrudRepository<T,ID>
- Parameters:
ids
- must not be null nor contain any null values- Returns:
- guaranteed to be not null. The size can be equal or less than the number of given ids
-
get
<R> CompletableFuture<R> get(ID id, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return the value extracted from an entity with a given identifier.For example, you could extract
Person
'sname
attribute by calling a getter on a remotePerson
entity instance:people.get(ssn, Person::getName);
You could also extract aFragment
containing thePerson
'sname
andage
attributes by calling corresponding getters on the remotePerson
entity instance:Fragment<Person> person = people.get(ssn, Extractors.fragment(Person::getName, Person::getAge)); System.out.println("name: " + person.get(Person::getName)); System.out.println(" age: " + person.get(Person::getAge));
Finally, you can also extract nested fragments:Fragment<Person> person = people.get(ssn, Extractors.fragment(Person::getName, Person::getAge, Extractors.fragment(Person::getAddress, Address::getCity, Address::getState)); System.out.println(" name: " + person.get(Person::getName)); System.out.println(" age: " + person.get(Person::getAge)); Fragment<Address> address = person.getFragment(Person::getAddress); System.out.println(" city: " + address.get(Address::getCity)); System.out.println("state: " + address.get(Address::getState));
Note that the actual extraction (via the invocation of the specified getter method) will happen on the primary owner for the specified entity, and only the extracted value will be sent over the network to the client, which can significantly reduce the amount of data transferred.- Type Parameters:
R
- the type of the extracted value- Parameters:
id
- the entity's identifierextractor
- theValueExtractor
to extract value with- Returns:
- a
CompletableFuture
that will resolve to the extracted value
-
getAll
CompletableFuture<Void> getAll(Consumer<? super T> callback)
Stream all entities all entities in this repository.- Parameters:
callback
- aconsumer
of results as they become available- Returns:
- a
CompletableFuture
that can be used to determine whether the operation completed - See Also:
findAll()
-
getAll
CompletableFuture<Void> getAll(Collection<? extends ID> colIds, Consumer<? super T> callback)
Stream the entities associated with the specified ids to the provided callback.- Parameters:
colIds
- aCollection
of ids that may be present in this repositorycallback
- aconsumer
of results as they become available- Returns:
- a
CompletableFuture
that can be used to determine whether the operation completed - See Also:
findAllById(Iterable)
-
getAll
<R> CompletableFuture<Map<ID,R>> getAll(Collection<? extends ID> colIds, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return a map of values extracted from a set of entities with the given identifiers.- Type Parameters:
R
- the type of the extracted values- Parameters:
colIds
- the entity identifiersextractor
- theValueExtractor
to extract values with- Returns:
- a
CompletableFuture
that will resolve to a map of extracted values, keyed by entity id - See Also:
get(Object, ValueExtractor)
-
getAll
<R> CompletableFuture<Void> getAll(Collection<? extends ID> colIds, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor, BiConsumer<? super ID,? super R> callback)
Stream the entities associated with the specified ids to the provided callback.- Type Parameters:
R
- the type of the extracted values- Parameters:
colIds
- aCollection
of ids that may be present in this repositoryextractor
- theValueExtractor
to extract values withcallback
- aconsumer
of results as they become available- Returns:
- a
CompletableFuture
that can be used to determine whether the operation completed
-
getAll
CompletableFuture<Collection<T>> getAll(com.tangosol.util.Filter<?> filter)
Return all entities that satisfy the specified criteria.- Parameters:
filter
- the criteria to evaluate- Returns:
- a
CompletableFuture
that will resolve to all entities that satisfy the specified criteria
-
getAll
CompletableFuture<Void> getAll(com.tangosol.util.Filter<?> filter, Consumer<? super T> callback)
Stream all entities that satisfy the specified criteria.- Parameters:
filter
- the criteria to evaluatecallback
- a consumer of results as they become available- Returns:
- a
CompletableFuture
that can be used to determine whether the operation completed - See Also:
getAll(Filter)
-
getAll
<R> CompletableFuture<Map<ID,R>> getAll(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return a map of values extracted from a set of entities based on the specified criteria.- Type Parameters:
R
- the type of the extracted values- Parameters:
filter
- the criteria to use to select entities for extractionextractor
- theValueExtractor
to extract values with- Returns:
- a
CompletableFuture
that will resolve to a map of extracted values, keyed by entity id - See Also:
get(Object, ValueExtractor)
-
getAll
<R> CompletableFuture<Void> getAll(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor, BiConsumer<? super ID,? super R> callback)
Streams the id and the associated extracted value from a set of entities based on the specified criteria.- Type Parameters:
R
- the type of the extracted values- Parameters:
filter
- the criteria to use to select entities for extractionextractor
- theValueExtractor
to extract values withcallback
- aconsumer
of results as they become available- Returns:
- a
CompletableFuture
that can be used to determine whether the operation completed - See Also:
getAll(Filter, ValueExtractor)
-
getAll
<R> CompletableFuture<Map<ID,R>> getAll(com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return a map of values extracted from all entities in the repository.- Type Parameters:
R
- the type of the extracted values- Parameters:
extractor
- theValueExtractor
to extract values with- Returns:
- a
CompletableFuture
that will resolve to a map of extracted values, keyed by entity id - See Also:
get(Object, ValueExtractor)
-
getAll
<R> CompletableFuture<Void> getAll(com.tangosol.util.ValueExtractor<? super T,? extends R> extractor, BiConsumer<? super ID,? super R> callback)
Streams the id and the associated extracted value from all entities in the repository.- Type Parameters:
R
- the type of the extracted values- Parameters:
extractor
- theValueExtractor
to extract values withcallback
- aconsumer
of results as they become available- Returns:
- a
CompletableFuture
that can be used to determine whether the operation completed - See Also:
getAll(ValueExtractor)
-
getAllOrderedBy
<R extends Comparable<? super R>> CompletableFuture<Collection<T>> getAllOrderedBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends R> orderBy)
Return all entities that satisfy the specified criteria, sorted using specifiedComparable
attribute.- Type Parameters:
R
- the type of the extracted values- Parameters:
filter
- the criteria to evaluateorderBy
- theComparable
attribute to sort the results by- Returns:
- a
CompletableFuture
that will resolve to all entities that satisfy specified criteria, sorted using specifiedComparable
attribute.
-
getAllOrderedBy
CompletableFuture<Collection<T>> getAllOrderedBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.Comparator<? super T> orderBy)
Return all entities that satisfy the specified criteria, sorted using specifiedRemote.Comparator
.- Parameters:
filter
- the criteria to evaluateorderBy
- the comparator to sort the results with- Returns:
- a
CompletableFuture
that will resolve to all entities that satisfy specified criteria, sorted using specifiedRemote.Comparator
.
-
getAllOrderedBy
CompletableFuture<Collection<T>> getAllOrderedBy(com.tangosol.util.function.Remote.Comparator<? super T> orderBy)
Return all entities in this repository, sorted using specifiedRemote.Comparator
.- Parameters:
orderBy
- the comparator to sort the results with- Returns:
- a
CompletableFuture
that will resolve to all entities in this repository, sorted using specifiedRemote.Comparator
.
-
getAllOrderedBy
<R extends Comparable<? super R>> CompletableFuture<Collection<T>> getAllOrderedBy(com.tangosol.util.ValueExtractor<? super T,? extends R> orderBy)
Return all entities in this repository, sorted using specifiedComparable
attribute.- Type Parameters:
R
- the type of the extracted values- Parameters:
orderBy
- theComparable
attribute to sort the results by- Returns:
- a
CompletableFuture
that will resolve to all entities in this repository, sorted using specifiedComparable
attribute.
-
save
<S extends T> CompletableFuture<S> save(S entity)
Description copied from interface:AsyncCrudRepository
Saves a given entity. Use the returned instance for further operations as the save operation might have changed the entity instance completely.- Specified by:
save
in interfaceAsyncCrudRepository<T,ID>
- Type Parameters:
S
- the entity type- Parameters:
entity
- must not be null- Returns:
- the saved entity; will never be null
-
saveAll
<S extends T> CompletableFuture<Iterable<S>> saveAll(Iterable<S> entities)
Description copied from interface:AsyncCrudRepository
Saves all given entities.- Specified by:
saveAll
in interfaceAsyncCrudRepository<T,ID>
- Type Parameters:
S
- the entity type- Parameters:
entities
- must not be null nor must it contain null- Returns:
- the saved entities; will never be null. The returned Iterable will have the same size as the Iterable passed as an argument
-
saveAll
CompletableFuture<Void> saveAll(Stream<? extends T> strEntities)
Store all specified entities as a batch.- Parameters:
strEntities
- the entities to store- Returns:
- a
CompletableFuture
that can be used to determine whether the operation completed
-
update
<U> CompletableFuture<Void> update(ID id, com.tangosol.util.ValueUpdater<? super T,? super U> updater, U value)
Update an entity using specified updater and the new value.For example, you could update
Person
'sage
attribute by calling a setter on a remotePerson
entity instance:people.update(ssn, Person::setAge, 21);
Note that the actual update (via the invocation of the specified setter method) will happen on the primary owner for the specified entity, and the updater will have exclusive access to an entity during the execution.- Type Parameters:
U
- the type of value to update- Parameters:
id
- the entity's identifierupdater
- the updater function to usevalue
- the value to update entity with, which will be passed as an argument to the updater function- Returns:
- a
CompletableFuture
that can be used to determine whether the operation completed
-
update
<U> CompletableFuture<Void> update(ID id, com.tangosol.util.ValueUpdater<? super T,? super U> updater, U value, com.oracle.coherence.repository.EntityFactory<? super ID,? extends T> factory)
Update an entity using specified updater and the new value, and optionalEntityFactory
that will be used to create entity instance if it doesn't already exist in the repository.For example, you could update
Person
'sage
attribute by calling a setter on a remotePerson
entity instance:people.update(ssn, Person::setAge, 21, Person::new);
If the person with the specified identifier does not exist, theEntityFactory
will be used to create a new instance. In the example above, it will invoke a constructor on thePerson
class that takes identifier as an argument.Note that the actual update (via the invocation of the specified setter method) will happen on the primary owner for the specified entity, and the updater will have exclusive access to an entity during the execution.
- Type Parameters:
U
- the type of value to update- Parameters:
id
- the entity's identifierupdater
- the updater function to usevalue
- the value to update entity with, which will be passed as an argument to the updater functionfactory
- the entity factory to use to create new entity instance- Returns:
- a
CompletableFuture
that can be used to determine whether the operation completed
-
update
<R> CompletableFuture<R> update(ID id, com.tangosol.util.function.Remote.Function<? super T,? extends R> updater)
Update an entity using specified updater function.For example, you could increment
Person
'sage
attribute and return the updatedPerson
entity:people.update(ssn, person -> { person.setAge(person.getAge() + 1); return person; });
This variant of theupdate
method offers ultimate flexibility, as it allows you to return any value you want as the result of the invocation, at the cost of typically slightly more complex logic at the call site.Note that the actual update (via the evaluation of the specified function) will happen on the primary owner for the specified entity, and the updater will have exclusive access to an entity during the execution.
- Type Parameters:
R
- the type of return value of the updater function- Parameters:
id
- the entity's identifierupdater
- the updater function to use- Returns:
- a
CompletableFuture
that will resolve to the result of updater function evaluation
-
update
<R> CompletableFuture<R> update(ID id, com.tangosol.util.function.Remote.Function<? super T,? extends R> updater, com.oracle.coherence.repository.EntityFactory<? super ID,? extends T> factory)
Update an entity using specified updater function, and optionalEntityFactory
that will be used to create entity instance if it doesn't already exist in the repository.For example, you could increment
Person
'sage
attribute and return the updatedPerson
entity:people.update(ssn, person -> { person.setAge(person.getAge() + 1); return person; }, Person::new);
If the person with the specified identifier does not exist, theEntityFactory
will be used to create a new instance. In the example above, it will invoke a constructor on thePerson
class that takes identifier as an argument.This variant of the
update
method offers ultimate flexibility, as it allows you to return any value you want as the result of the invocation, at the cost of typically slightly more complex logic at the call site.Note that the actual update (via the evaluation of the specified function) will happen on the primary owner for the specified entity, and the updater will have exclusive access to an entity during the execution.
- Type Parameters:
R
- the type of return value of the updater function- Parameters:
id
- the entity's identifierupdater
- the updater function to usefactory
- the entity factory to use to create new entity instance- Returns:
- a
CompletableFuture
that will resolve to the result of updater function evaluation
-
update
<U,R> CompletableFuture<R> update(ID id, com.tangosol.util.function.Remote.BiFunction<? super T,? super U,? extends R> updater, U value)
Update an entity using specified updater and the new value.Unlike
update(Object, ValueUpdater, Object)
, which doesn't return anything, this method is typically used to invoke "fluent" methods on the target entity that return entity itself (although they are free to return any value they want).For example, you could use it to add an item to the
ShoppingCart
entity and return the updatedShoppingCart
instance in a single call:Item item = ... ShoppingCart cart = carts.update(cartId, ShoppingCart::addItem, item);
Note that the actual update (via the invocation of the specified setter method) will happen on the primary owner for the specified entity, and the updater will have exclusive access to an entity during the execution.- Type Parameters:
U
- the type of value to updateR
- the type of return value of the updater function- Parameters:
id
- the entity's identifierupdater
- the updater function to usevalue
- the value to update entity with, which will be passed as an argument to the updater function- Returns:
- a
CompletableFuture
that will resolve to the result of updater function evaluation
-
update
<U,R> CompletableFuture<R> update(ID id, com.tangosol.util.function.Remote.BiFunction<? super T,? super U,? extends R> updater, U value, com.oracle.coherence.repository.EntityFactory<? super ID,? extends T> factory)
Update an entity using specified updater function, and optionalEntityFactory
that will be used to create entity instance if it doesn't already exist in the repository.Unlike
update(Object, ValueUpdater, Object)
, which doesn't return anything, this method is typically used to invoke "fluent" methods on the target entity that return entity itself (although they are free to return any value they want).For example, you could use it to add an item to the
ShoppingCart
entity and return the updatedShoppingCart
instance in a single call:Item item = ... ShoppingCart cart = carts.update(cartId, ShoppingCart::addItem, item, ShoppingCart::new);
If the cart with the specified identifier does not exist, the specifiedEntityFactory
will be used to create a new instance. In the example above, it will invoke a constructor on theShoppingCart
class that takes identifier as an argument.Note that the actual update (via the evaluation of the specified function) will happen on the primary owner for the specified entity, and the updater will have exclusive access to an entity during the execution.
- Type Parameters:
U
- the type of value to updateR
- the type of return value of the updater function- Parameters:
id
- the entity's identifierupdater
- the updater function to usevalue
- the value to update entity with, which will be passed as an argument to the updater functionfactory
- the entity factory to use to create new entity instance- Returns:
- a
CompletableFuture
that will resolve to the result of updater function evaluation
-
updateAll
<U> CompletableFuture<Void> updateAll(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueUpdater<? super T,? super U> updater, U value)
Update multiple entities using specified updater and the new value.- Type Parameters:
U
- the type of value to update- Parameters:
filter
- the criteria to use to select entities to updateupdater
- the updater function to usevalue
- the value to update each entity with, which will be passed as an argument to the updater function- Returns:
- a
CompletableFuture
that can be used to determine whether the operation completed
-
updateAll
<R> CompletableFuture<Map<ID,R>> updateAll(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.Function<? super T,? extends R> updater)
Update multiple entities using specified updater function.- Type Parameters:
R
- the type of return value of the updater function- Parameters:
filter
- the criteria to use to select entities to updateupdater
- the updater function to use- Returns:
- a
CompletableFuture
that will resolve to a map of updater function results, keyed by entity id
-
updateAll
<U,R> CompletableFuture<Map<ID,R>> updateAll(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.BiFunction<? super T,? super U,? extends R> updater, U value)
Update multiple entities using specified updater and the new value.- Type Parameters:
U
- the type of value to updateR
- the type of return value of the updater function- Parameters:
filter
- the criteria to use to select entities to updateupdater
- the updater function to usevalue
- the value to update each entity with, which will be passed as an argument to the updater function- Returns:
- a
CompletableFuture
that will resolve to a map of updater function results, keyed by entity id
-
average
CompletableFuture<Double> average(com.tangosol.util.function.Remote.ToIntFunction<? super T> extractor)
Return the average of the specified function.- Parameters:
extractor
- the function to average; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the average of the specified function
-
average
CompletableFuture<Double> average(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToIntFunction<? super T> extractor)
Return the average of the specified function.- Parameters:
filter
- the entity selection criteriaextractor
- the function to average; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the average of the specified function
-
average
CompletableFuture<Double> average(com.tangosol.util.function.Remote.ToLongFunction<? super T> extractor)
Return the average of the specified function.- Parameters:
extractor
- the function to average; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the average of the specified function
-
average
CompletableFuture<Double> average(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToLongFunction<? super T> extractor)
Return the average of the specified function.- Parameters:
filter
- the entity selection criteriaextractor
- the function to average; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the average of the specified function
-
average
CompletableFuture<Double> average(com.tangosol.util.function.Remote.ToDoubleFunction<? super T> extractor)
Return the average of the specified function.- Parameters:
extractor
- the function to average; typically a method reference on the entity class, such asPerson::getWeight
- Returns:
- a
CompletableFuture
that will resolve to the average of the specified function
-
average
CompletableFuture<Double> average(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToDoubleFunction<? super T> extractor)
Return the average of the specified function.- Parameters:
filter
- the entity selection criteriaextractor
- the function to average; typically a method reference on the entity class, such asPerson::getWeight
- Returns:
- a
CompletableFuture
that will resolve to the average of the specified function
-
average
CompletableFuture<BigDecimal> average(com.tangosol.util.function.Remote.ToBigDecimalFunction<? super T> extractor)
Return the average of the specified function.- Parameters:
extractor
- the function to average; typically a method reference on the entity class, such asPerson::getSalary
- Returns:
- a
CompletableFuture
that will resolve to the average of the specified function
-
average
CompletableFuture<BigDecimal> average(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToBigDecimalFunction<? super T> extractor)
Return the average of the specified function.- Parameters:
filter
- the entity selection criteriaextractor
- the function to average; typically a method reference on the entity class, such asPerson::getSalary
- Returns:
- a
CompletableFuture
that will resolve to the average of the specified function
-
distinct
<R> CompletableFuture<Collection<? extends R>> distinct(com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return the set of distinct values for the specified extractor.- Type Parameters:
R
- the type of extracted values- Parameters:
extractor
- the extractor to get a value from; typically a method reference on the entity class, such asPerson::getName
- Returns:
- a
CompletableFuture
that will resolve to a set of distinct values for the specified extractor
-
distinct
<R> CompletableFuture<Collection<? extends R>> distinct(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return the set of distinct values for the specified extractor.- Type Parameters:
R
- the type of extracted values- Parameters:
filter
- the entity selection criteriaextractor
- the extractor to get a value from; typically a method reference on the entity class, such asPerson::getName
- Returns:
- a
CompletableFuture
that will resolve to a set of distinct values for the specified extractor
-
groupBy
<K> CompletableFuture<Map<K,Set<T>>> groupBy(com.tangosol.util.ValueExtractor<? super T,? extends K> extractor)
Return the grouping of entities by the specified extractor.- Type Parameters:
K
- the type of extracted grouping keys- Parameters:
extractor
- the extractor to get a grouping value from; typically a method reference on the entity class, such asPerson::getGender
- Returns:
- a
CompletableFuture
that will resolve to a grouping of entities by the specified extractor; the keys in the returned map will be distinct values extracted by the specifiedextractor
, and the values will be sets of entities that match each extracted key
-
groupBy
<K> CompletableFuture<Map<K,SortedSet<T>>> groupBy(com.tangosol.util.ValueExtractor<? super T,? extends K> extractor, com.tangosol.util.function.Remote.Comparator<? super T> orderBy)
Return the grouping of entities by the specified extractor, ordered by the specified attribute within each group.- Type Parameters:
K
- the type of extracted grouping keys- Parameters:
extractor
- the extractor to get a grouping value from; typically a method reference on the entity class, such asPerson::getGender
orderBy
- theRemote.Comparator
to sort the results within each group by- Returns:
- a
CompletableFuture
that will resolve to a grouping of entities by the specified extractor; the keys in the returned map will be distinct values extracted by the specifiedextractor
, and the values will be sets of entities that match each extracted key
-
groupBy
<K> CompletableFuture<Map<K,Set<T>>> groupBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends K> extractor)
Return the grouping of entities by the specified extractor.- Type Parameters:
K
- the type of extracted grouping keys- Parameters:
filter
- the entity selection criteriaextractor
- the extractor to get a grouping value from; typically a method reference on the entity class, such asPerson::getGender
- Returns:
- a
CompletableFuture
that will resolve to a grouping of entities by the specified extractor; the keys in the returned map will be distinct values extracted by the specifiedextractor
, and the values will be sets of entities that match each extracted key
-
groupBy
<K> CompletableFuture<Map<K,SortedSet<T>>> groupBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends K> extractor, com.tangosol.util.function.Remote.Comparator<? super T> orderBy)
Return the grouping of entities by the specified extractor, ordered by the specified attribute within each group.- Type Parameters:
K
- the type of extracted grouping keys- Parameters:
filter
- the entity selection criteriaextractor
- the extractor to get a grouping value from; typically a method reference on the entity class, such asPerson::getGender
orderBy
- theRemote.Comparator
to sort the results within each group by- Returns:
- a
CompletableFuture
that will resolve to a grouping of entities by the specified extractor; the keys in the returned map will be distinct values extracted by the specifiedextractor
, and the values will be sets of entities that match each extracted key
-
groupBy
<K,A,R> CompletableFuture<Map<K,R>> groupBy(com.tangosol.util.ValueExtractor<? super T,? extends K> extractor, com.tangosol.util.stream.RemoteCollector<? super T,A,R> collector)
Return the grouping of entities by the specified extractor.- Type Parameters:
K
- the type of extracted grouping keysA
- the type of collector's accumulatorR
- the type of collector's result- Parameters:
extractor
- the extractor to get a grouping value from; typically a method reference on the entity class, such asPerson::getGender
collector
- theRemoteCollector
to apply to grouped entities- Returns:
- a
CompletableFuture
that will resolve to a grouping of entities by the specified extractor; the keys in the returned map will be distinct values extracted by the specifiedextractor
, and the values will be results of the specifiedcollector
for each group - See Also:
RemoteCollectors
-
groupBy
<K,A,R> CompletableFuture<Map<K,R>> groupBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends K> extractor, com.tangosol.util.stream.RemoteCollector<? super T,A,R> collector)
Return the grouping of entities by the specified extractor.- Type Parameters:
K
- the type of extracted grouping keysA
- the type of collector's accumulatorR
- the type of collector's result- Parameters:
filter
- the entity selection criteriaextractor
- the extractor to get a grouping value from; typically a method reference on the entity class, such asPerson::getGender
collector
- theRemoteCollector
to apply to grouped entities- Returns:
- a
CompletableFuture
that will resolve to a grouping of entities by the specified extractor; the keys in the returned map will be distinct values extracted by the specifiedextractor
, and the values will be results of the specifiedcollector
for each group - See Also:
RemoteCollectors
-
groupBy
<K,A,R,M extends Map<K,R>> CompletableFuture<M> groupBy(com.tangosol.util.ValueExtractor<? super T,? extends K> extractor, com.tangosol.util.function.Remote.Supplier<M> mapFactory, com.tangosol.util.stream.RemoteCollector<? super T,A,R> collector)
Return the grouping of entities by the specified extractor.- Type Parameters:
K
- the type of extracted grouping keysA
- the type of collector's accumulatorR
- the type of collector's resultM
- the type of resultMap
- Parameters:
extractor
- the extractor to get a grouping value from; typically a method reference on the entity class, such asPerson::getGender
mapFactory
- the supplier to use to create resultMap
collector
- theRemoteCollector
to apply to grouped entities- Returns:
- a
CompletableFuture
that will resolve to a grouping of entities by the specified extractor; the keys in the returned map will be distinct values extracted by the specifiedextractor
, and the values will be results of the specifiedcollector
for each group - See Also:
RemoteCollectors
-
groupBy
<K,A,R,M extends Map<K,R>> CompletableFuture<M> groupBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends K> extractor, com.tangosol.util.function.Remote.Supplier<M> mapFactory, com.tangosol.util.stream.RemoteCollector<? super T,A,R> collector)
Return the grouping of entities by the specified extractor.- Type Parameters:
K
- the type of extracted grouping keysA
- the type of collector's accumulatorR
- the type of collector's resultM
- the type of resultMap
- Parameters:
filter
- the entity selection criteriaextractor
- the extractor to get a grouping value from; typically a method reference on the entity class, such asPerson::getGender
mapFactory
- the supplier to use to create resultMap
collector
- theRemoteCollector
to apply to grouped entities- Returns:
- a
CompletableFuture
that will resolve to a grouping of entities by the specified extractor; the keys in the returned map will be distinct values extracted by the specifiedextractor
, and the values will be results of the specifiedcollector
for each group - See Also:
RemoteCollectors
-
max
CompletableFuture<Integer> max(com.tangosol.util.function.Remote.ToIntFunction<? super T> extractor)
Return the maximum value of the specified function.- Parameters:
extractor
- the function to determine the maximum value for; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the maximum value of the specified function
-
max
CompletableFuture<Integer> max(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToIntFunction<? super T> extractor)
Return the maximum value of the specified function.- Parameters:
filter
- the entity selection criteriaextractor
- the function to determine the maximum value for; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the maximum value of the specified function
-
max
CompletableFuture<Long> max(com.tangosol.util.function.Remote.ToLongFunction<? super T> extractor)
Return the maximum value of the specified function.- Parameters:
extractor
- the function to determine the maximum value for; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the maximum value of the specified function
-
max
CompletableFuture<Long> max(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToLongFunction<? super T> extractor)
Return the maximum value of the specified function.- Parameters:
filter
- the entity selection criteriaextractor
- the function to determine the maximum value for; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the maximum value of the specified function
-
max
CompletableFuture<Double> max(com.tangosol.util.function.Remote.ToDoubleFunction<? super T> extractor)
Return the maximum value of the specified function.- Parameters:
extractor
- the function to determine the maximum value for; typically a method reference on the entity class, such asPerson::getWeight
- Returns:
- a
CompletableFuture
that will resolve to the maximum value of the specified function
-
max
CompletableFuture<Double> max(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToDoubleFunction<? super T> extractor)
Return the maximum value of the specified function.- Parameters:
filter
- the entity selection criteriaextractor
- the function to determine the maximum value for; typically a method reference on the entity class, such asPerson::getWeight
- Returns:
- a
CompletableFuture
that will resolve to the maximum value of the specified function
-
max
CompletableFuture<BigDecimal> max(com.tangosol.util.function.Remote.ToBigDecimalFunction<? super T> extractor)
Return the maximum value of the specified function.- Parameters:
extractor
- the function to determine the maximum value for; typically a method reference on the entity class, such asPerson::getSalary
- Returns:
- a
CompletableFuture
that will resolve to the maximum value of the specified function
-
max
CompletableFuture<BigDecimal> max(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToBigDecimalFunction<? super T> extractor)
Return the maximum value of the specified function.- Parameters:
filter
- the entity selection criteriaextractor
- the function to determine the maximum value for; typically a method reference on the entity class, such asPerson::getSalary
- Returns:
- a
CompletableFuture
that will resolve to the maximum value of the specified function
-
max
<R extends Comparable<? super R>> CompletableFuture<R> max(com.tangosol.util.function.Remote.ToComparableFunction<? super T,R> extractor)
Return the maximum value of the specified function.- Type Parameters:
R
- the type of the extracted value- Parameters:
extractor
- the function to determine the maximum value for; typically a method reference on the entity class, such asPerson::getName
- Returns:
- a
CompletableFuture
that will resolve to the maximum value of the specified function
-
max
<R extends Comparable<? super R>> CompletableFuture<R> max(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToComparableFunction<? super T,R> extractor)
Return the maximum value of the specified function.- Type Parameters:
R
- the type of the extracted value- Parameters:
filter
- the entity selection criteriaextractor
- the function to determine the maximum value for; typically a method reference on the entity class, such asPerson::getName
- Returns:
- a
CompletableFuture
that will resolve to the maximum value of the specified function
-
maxBy
<R extends Comparable<? super R>> CompletableFuture<Optional<T>> maxBy(com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return the entity with the maximum value of the specified function.- Type Parameters:
R
- the type of the extracted value- Parameters:
extractor
- the function to determine the maximum value for; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the entity with the maximum value of the specified function
-
maxBy
<R extends Comparable<? super R>> CompletableFuture<Optional<T>> maxBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return the entity with the maximum value of the specified function.- Type Parameters:
R
- the type of the extracted value- Parameters:
filter
- the entity selection criteriaextractor
- the function to determine the maximum value for; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the entity with the maximum value of the specified function
-
min
CompletableFuture<Integer> min(com.tangosol.util.function.Remote.ToIntFunction<? super T> extractor)
Return the minimum value of the specified function.- Parameters:
extractor
- the function to determine the minimum value for; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the minimum value of the specified function
-
min
CompletableFuture<Integer> min(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToIntFunction<? super T> extractor)
Return the minimum value of the specified function.- Parameters:
filter
- the entity selection criteriaextractor
- the function to determine the minimum value for; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the minimum value of the specified function
-
min
CompletableFuture<Long> min(com.tangosol.util.function.Remote.ToLongFunction<? super T> extractor)
Return the minimum value of the specified function.- Parameters:
extractor
- the function to determine the minimum value for; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the minimum value of the specified function
-
min
CompletableFuture<Long> min(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToLongFunction<? super T> extractor)
Return the minimum value of the specified function.- Parameters:
filter
- the entity selection criteriaextractor
- the function to determine the minimum value for; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the minimum value of the specified function
-
min
CompletableFuture<Double> min(com.tangosol.util.function.Remote.ToDoubleFunction<? super T> extractor)
Return the minimum value of the specified function.- Parameters:
extractor
- the function to determine the minimum value for; typically a method reference on the entity class, such asPerson::getWeight
- Returns:
- a
CompletableFuture
that will resolve to the minimum value of the specified function
-
min
CompletableFuture<Double> min(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToDoubleFunction<? super T> extractor)
Return the minimum value of the specified function.- Parameters:
filter
- the entity selection criteriaextractor
- the function to determine the minimum value for; typically a method reference on the entity class, such asPerson::getWeight
- Returns:
- a
CompletableFuture
that will resolve to the minimum value of the specified function
-
min
CompletableFuture<BigDecimal> min(com.tangosol.util.function.Remote.ToBigDecimalFunction<? super T> extractor)
Return the minimum value of the specified function.- Parameters:
extractor
- the function to determine the minimum value for; typically a method reference on the entity class, such asPerson::getSalary
- Returns:
- a
CompletableFuture
that will resolve to the minimum value of the specified function
-
min
CompletableFuture<BigDecimal> min(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToBigDecimalFunction<? super T> extractor)
Return the minimum value of the specified function.- Parameters:
filter
- the entity selection criteriaextractor
- the function to determine the minimum value for; typically a method reference on the entity class, such asPerson::getSalary
- Returns:
- a
CompletableFuture
that will resolve to the minimum value of the specified function
-
min
<R extends Comparable<? super R>> CompletableFuture<R> min(com.tangosol.util.function.Remote.ToComparableFunction<? super T,R> extractor)
Return the minimum value of the specified function.- Type Parameters:
R
- the type of the extracted value- Parameters:
extractor
- the function to determine the minimum value for; typically a method reference on the entity class, such asPerson::getName
- Returns:
- a
CompletableFuture
that will resolve to the minimum value of the specified function
-
min
<R extends Comparable<? super R>> CompletableFuture<R> min(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToComparableFunction<? super T,R> extractor)
Return the minimum value of the specified function.- Type Parameters:
R
- the type of the extracted value- Parameters:
filter
- the entity selection criteriaextractor
- the function to determine the minimum value for; typically a method reference on the entity class, such asPerson::getName
- Returns:
- a
CompletableFuture
that will resolve to the minimum value of the specified function
-
minBy
<R extends Comparable<? super R>> CompletableFuture<Optional<T>> minBy(com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return the entity with the minimum value of the specified function.- Type Parameters:
R
- the type of the extracted value- Parameters:
extractor
- the function to determine the minimum value for; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the entity with the minimum value of the specified function
-
minBy
<R extends Comparable<? super R>> CompletableFuture<Optional<T>> minBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor)
Return the entity with the minimum value of the specified function.- Type Parameters:
R
- the type of the extracted value- Parameters:
filter
- the entity selection criteriaextractor
- the function to determine the minimum value for; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the entity with the minimum value of the specified function
-
sum
CompletableFuture<Long> sum(com.tangosol.util.function.Remote.ToIntFunction<? super T> extractor)
Return the sum of the specified function.- Parameters:
extractor
- the function to sum; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the sum of the specified function
-
sum
CompletableFuture<Long> sum(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToIntFunction<? super T> extractor)
Return the sum of the specified function.- Parameters:
filter
- the entity selection criteriaextractor
- the function to sum; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the sum of the specified function
-
sum
CompletableFuture<Long> sum(com.tangosol.util.function.Remote.ToLongFunction<? super T> extractor)
Return the sum of the specified function.- Parameters:
extractor
- the function to sum; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the sum of the specified function
-
sum
CompletableFuture<Long> sum(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToLongFunction<? super T> extractor)
Return the sum of the specified function.- Parameters:
filter
- the entity selection criteriaextractor
- the function to sum; typically a method reference on the entity class, such asPerson::getAge
- Returns:
- a
CompletableFuture
that will resolve to the sum of the specified function
-
sum
CompletableFuture<Double> sum(com.tangosol.util.function.Remote.ToDoubleFunction<? super T> extractor)
Return the sum of the specified function.- Parameters:
extractor
- the function to sum; typically a method reference on the entity class, such asPerson::getWeight
- Returns:
- a
CompletableFuture
that will resolve to the sum of the specified function
-
sum
CompletableFuture<Double> sum(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToDoubleFunction<? super T> extractor)
Return the sum of the specified function.- Parameters:
filter
- the entity selection criteriaextractor
- the function to sum; typically a method reference on the entity class, such asPerson::getWeight
- Returns:
- a
CompletableFuture
that will resolve to the sum of the specified function
-
sum
CompletableFuture<BigDecimal> sum(com.tangosol.util.function.Remote.ToBigDecimalFunction<? super T> extractor)
Return the sum of the specified function.- Parameters:
extractor
- the function to sum; typically a method reference on the entity class, such asPerson::getSalary
- Returns:
- a
CompletableFuture
that will resolve to the sum of the specified function
-
sum
CompletableFuture<BigDecimal> sum(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.ToBigDecimalFunction<? super T> extractor)
Return the sum of the specified function.- Parameters:
filter
- the entity selection criteriaextractor
- the function to sum; typically a method reference on the entity class, such asPerson::getSalary
- Returns:
- a
CompletableFuture
that will resolve to the sum of the specified function
-
top
<R extends Comparable<? super R>> CompletableFuture<List<R>> top(com.tangosol.util.ValueExtractor<? super T,? extends R> extractor, int cResults)
Return the top N highest values for the specified extractor.- Type Parameters:
R
- the type of returned values- Parameters:
extractor
- the extractor to get the values to compare withcResults
- the number of highest values to return- Returns:
- a
CompletableFuture
that will resolve to the top N highest values for the specified extractor
-
top
<R extends Comparable<? super R>> CompletableFuture<List<R>> top(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor, int cResults)
Return the top N highest values for the specified extractor.- Type Parameters:
R
- the type of returned values- Parameters:
filter
- the entity selection criteriaextractor
- the extractor to get the values to compare withcResults
- the number of highest values to return- Returns:
- a
CompletableFuture
that will resolve to the top N highest values for the specified extractor
-
top
<R> CompletableFuture<List<R>> top(com.tangosol.util.ValueExtractor<? super T,? extends R> extractor, com.tangosol.util.function.Remote.Comparator<? super R> comparator, int cResults)
Return the top N highest values for the specified extractor.- Type Parameters:
R
- the type of returned values- Parameters:
extractor
- the extractor to get the values to compare withcomparator
- the comparator to use when comparing extracted valuescResults
- the number of highest values to return- Returns:
- a
CompletableFuture
that will resolve to the top N highest values for the specified extractor
-
top
<R> CompletableFuture<List<R>> top(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor, com.tangosol.util.function.Remote.Comparator<? super R> comparator, int cResults)
Return the top N highest values for the specified extractor.- Type Parameters:
R
- the type of returned values- Parameters:
filter
- the entity selection criteriaextractor
- the extractor to get the values to compare withcomparator
- the comparator to use when comparing extracted valuescResults
- the number of highest values to return- Returns:
- a
CompletableFuture
that will resolve to the top N highest values for the specified extractor
-
topBy
<R extends Comparable<? super R>> CompletableFuture<List<T>> topBy(com.tangosol.util.ValueExtractor<? super T,? extends R> extractor, int cResults)
Return the top N entities with the highest values for the specified extractor.- Type Parameters:
R
- the type of values used for comparison- Parameters:
extractor
- the extractor to get the values to compare withcResults
- the number of highest values to return- Returns:
- a
CompletableFuture
that will resolve to the top N entities with the highest values for the specified extractor
-
topBy
<R extends Comparable<? super R>> CompletableFuture<List<T>> topBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.ValueExtractor<? super T,? extends R> extractor, int cResults)
Return the top N entities with the highest values for the specified extractor.- Type Parameters:
R
- the type of values used for comparison- Parameters:
filter
- the entity selection criteriaextractor
- the extractor to get the values to compare withcResults
- the number of highest values to return- Returns:
- a
CompletableFuture
that will resolve to the top N entities with the highest values for the specified extractor
-
topBy
CompletableFuture<List<T>> topBy(com.tangosol.util.function.Remote.Comparator<? super T> comparator, int cResults)
Return the top N entities with the highest values for the specified extractor.- Parameters:
comparator
- the comparator to use when comparing extracted valuescResults
- the number of highest values to return- Returns:
- a
CompletableFuture
that will resolve to the top N entities with the highest value for the specified extractor
-
topBy
CompletableFuture<List<T>> topBy(com.tangosol.util.Filter<?> filter, com.tangosol.util.function.Remote.Comparator<? super T> comparator, int cResults)
Return the top N entities with the highest values for the specified extractor.- Parameters:
filter
- the entity selection criteriacomparator
- the comparator to use when comparing extracted valuescResults
- the number of highest values to return- Returns:
- a
CompletableFuture
that will resolve to the top N entities with the highest values for the specified extractor
-
addListener
void addListener(com.oracle.coherence.repository.AbstractRepositoryBase.Listener<? super T> listener)
Description copied from interface:ListenerSupport
Register a listener that will observe all repository events.- Specified by:
addListener
in interfaceListenerSupport<T,ID>
- Parameters:
listener
- the event listener to register
-
removeListener
void removeListener(com.oracle.coherence.repository.AbstractRepositoryBase.Listener<? super T> listener)
Description copied from interface:ListenerSupport
Unregister a listener that observes all repository events.- Specified by:
removeListener
in interfaceListenerSupport<T,ID>
- Parameters:
listener
- the event listener to unregister
-
addListener
void addListener(ID id, com.oracle.coherence.repository.AbstractRepositoryBase.Listener<? super T> listener)
Description copied from interface:ListenerSupport
Register a listener that will observe all events for a specific entity.- Specified by:
addListener
in interfaceListenerSupport<T,ID>
- Parameters:
id
- the identifier of the entity to observelistener
- the event listener to register
-
removeListener
void removeListener(ID id, com.oracle.coherence.repository.AbstractRepositoryBase.Listener<? super T> listener)
Description copied from interface:ListenerSupport
Unregister a listener that observes all events for a specific entity.- Specified by:
removeListener
in interfaceListenerSupport<T,ID>
- Parameters:
id
- the identifier of the entity to observelistener
- the event listener to unregister
-
addListener
void addListener(com.tangosol.util.Filter<?> filter, com.oracle.coherence.repository.AbstractRepositoryBase.Listener<? super T> listener)
Description copied from interface:ListenerSupport
Register a listener that will observe all events for entities that satisfy the specified criteria.- Specified by:
addListener
in interfaceListenerSupport<T,ID>
- Parameters:
filter
- the criteria to use to select entities to observelistener
- the event listener to register
-
removeListener
void removeListener(com.tangosol.util.Filter<?> filter, com.oracle.coherence.repository.AbstractRepositoryBase.Listener<? super T> listener)
Description copied from interface:ListenerSupport
Unregister a listener that observes all events for entities that satisfy the specified criteria.- Specified by:
removeListener
in interfaceListenerSupport<T,ID>
- Parameters:
filter
- the criteria to use to select entities to observelistener
- the event listener to unregister
-
listener
com.oracle.coherence.repository.AbstractRepositoryBase.Listener.Builder<T> listener()
Description copied from interface:ListenerSupport
Create newAbstractRepositoryBase.Listener.Builder
instance.- Specified by:
listener
in interfaceListenerSupport<T,ID>
- Returns:
- a new
AbstractRepositoryBase.Listener.Builder
instance
-
-