Uses of Interface
one.microstream.functional.Aggregator

Packages that use Aggregator

Package	Description
one.microstream.collections
one.microstream.collections.types
one.microstream.functional
one.microstream.persistence.internal
one.microstream.util.cql

Uses of Aggregator in one.microstream.collections

Methods in one.microstream.collections that return Aggregator

Modifier and Type	Method	Description
static <E> Aggregator<E,BulkList<E>>	BulkList.Builder()
static <E> Aggregator<E,BulkList<E>>	BulkList.Builder(long initialCapacity)
static <E> Aggregator<E,ConstList<E>>	ConstList.Builder()
static <E> Aggregator<E,ConstList<E>>	ConstList.Builder(int initialCapacity)
Aggregator<E,BulkList<E>>	BulkList.collector()
Aggregator<KeyValue<K,V>,? extends XCollection<KeyValue<K,V>>>	LockedMap.collector()
static <KI, VI, KO, VO> Aggregator<KeyValue<KI,VI>,ConstHashTable<KO,VO>>	ConstHashTable.projector(ConstHashTable<KO,VO> target, Function<KI,KO> keyProjector, Function<VI,VO> valueProjector)

Methods in one.microstream.collections with parameters of type Aggregator

Modifier and Type	Method	Description
static <E, R> R	AbstractArrayStorage.forwardAggregate(E[] data, int lowOffset, int highBound, Aggregator<? super E,R> aggregator)
static <E, R> R	AbstractArrayStorage.forwardConditionalAggregate(E[] data, int lowOffset, int highBound, Predicate<? super E> predicate, Aggregator<? super E,R> aggregator)
static <E, R> R	AbstractArrayStorage.rangedAggregate(E[] data, int size, int offset, int length, Aggregator<? super E,R> aggregator)
static <E, R> R	AbstractArrayStorage.rangedConditionalAggregate(E[] data, int size, int offset, int length, Predicate<? super E> predicate, Aggregator<? super E,R> aggregator)
static <E, R> R	AbstractArrayStorage.reverseAggregate(E[] data, int highOffset, int lowEnd, Aggregator<? super E,R> aggregator)
static <E, R> R	AbstractArrayStorage.reverseConditionalAggregate(E[] data, int highOffset, int lowEnd, Predicate<? super E> predicate, Aggregator<? super E,R> aggregator)
static <E, A extends AbstractSimpleArrayCollection<E> & XGettingSequence<E>, R> R	XUtilsArrayCollection.rngAggregate(A a, int offset, int length, Aggregator<? super E,R> aggregate)
static <E, R> R	XUtilsCollection.rngAggregate(XGettingSequence<E> sequence, long offset, long length, Aggregator<? super E,R> aggregate)

Uses of Aggregator in one.microstream.collections.types

Methods in one.microstream.collections.types that return Aggregator

Modifier and Type	Method	Description
static <E> Aggregator<E,XImmutableCollection<E>>	XImmutableCollection.Builder()
static <E> Aggregator<E,XImmutableCollection<E>>	XImmutableCollection.Builder(long initialCapacity)
default Aggregator<E,? extends XAddingCollection<E>>	XAddingCollection.collector()
default Aggregator<E,? extends XCollection<E>>	XCollection.collector()
default Aggregator<E,? extends XList<E>>	XList.collector()

Uses of Aggregator in one.microstream.functional

Subinterfaces of Aggregator in one.microstream.functional

Modifier and Type	Interface	Description
interface	SortingAggregator<E,R>

Classes in one.microstream.functional that implement Aggregator

Modifier and Type	Class	Description
class	Aggregate_doubleMin<E>
class	Aggregate_doubleSum<E>
class	AggregateApplies<E>
class	AggregateArrayAdder<E>
class	AggregateArrayBuilder<E>
class	AggregateContains<E>
class	AggregateCount<E>
class	AggregateCountingAdd<E>
class	AggregateCountingPut<E>
class	AggregateMax<E>
class	AggregateMin<E>
class	AggregateOffsetLength<E,R>
class	AggregateSearch<E>
class	AvgInteger
class	AvgIntegerNonNull
class	KamikazeArrayAdder<E>
class	PickAggregate<E>
class	SumByte
class	SumDouble
class	SumFloat
class	SumInteger
class	SumLong
class	SumShort
class	ToArrayAggregator<E>
static class	XFunc.MaxInteger

Methods in one.microstream.functional that return Aggregator

Modifier and Type	Method	Description
static <E, R> Aggregator<E,R>	XFunc.aggregator(BiConsumer<? super E,? super R> joiner, R aggregate)
static <E> Aggregator<E,Long>	XFunc.counter()
Aggregator<E,R>	Aggregator.Creator.createAggregator()
static Aggregator<Integer,Integer>	XFunc.max(int initialValue)
default Aggregator<E,R>	Aggregator.reset()

Constructors in one.microstream.functional with parameters of type Aggregator

Constructor	Description
AggregateOffsetLength(long offset, long length, Aggregator<? super E,R> aggregate)

Uses of Aggregator in one.microstream.persistence.internal

Classes in one.microstream.persistence.internal that implement Aggregator

Modifier and Type	Class	Description
class	TypeDictionaryAppenderBuilder

Uses of Aggregator in one.microstream.util.cql

Classes in one.microstream.util.cql that implement Aggregator

Modifier and Type	Class	Description
class	CqlWrapperCollectorLinkingFinalizing<O,R>
class	CqlWrapperCollectorLinkingSorting<O,R extends Sortable<O>>
class	CqlWrapperCollectorProcedure<O,T extends Consumer<O>>
class	CqlWrapperCollectorSequenceSorting<O,R extends Consumer<O> & XIterable<O>>

Methods in one.microstream.util.cql that return Aggregator

Modifier and Type	Method	Description
Aggregator<O,R>	CqlResultor.prepareCollector(XIterable<?> source)

Methods in one.microstream.util.cql with parameters of type Aggregator

Modifier and Type	Method	Description
static <I, O, R extends XIterable<O>> CqlQuery<I,O,R>	CqlIteration.New(XIterable<? extends I> source, Long skip, Long limit, Predicate<? super I> selector, Function<? super I,O> projector, Comparator<? super O> comparator, Aggregator<O,R> aggregator)
static <I, O> CqlProjection<I,O>	CqlProjection.New(XIterable<? extends I> source, Long skip, Long limit, Predicate<? super I> selector, Function<? super I,O> projector, Comparator<? super O> comparator, Aggregator<O,XSequence<O>> aggregator)
static <I, O, R> CqlQuery<I,O,R>	CqlQuery.New(XIterable<? extends I> source, Long skip, Long limit, Predicate<? super I> selector, Function<? super I,O> projector, Comparator<? super O> comparator, Aggregator<O,R> aggregator, R target)
static <O, R> CqlResultor<O,R>	CqlResultor.NewFromAggregator(Aggregator<O,R> collector)
default <R1> CqlAggregation<I,R1>	CqlAggregation.targeting(Aggregator<I,R1> collector)
default <R1> CqlQuery<I,O,R1>	CqlQuery.targeting(Aggregator<O,R1> collector)