Package one.microstream.functional

Interface Summary

Interface	Description
_bytePredicate
_byteProcedure
_charPredicate
_charProcedure
_charRangeProcedure
_intFunction
_intIndexedSupplier<T>
_intIndexProcedure
_intPredicate
_intProcedure
_longIndexProcedure
_longIterable
_longPredicate
_longProcedure
Action
Aggregator<E,R>
Aggregator.Creator<E,R>
BinaryFunction<I1,I2,O>
BooleanTerm
DefaultInstantiator
IndexedAcceptor<T>
IndexedAggregator<E,R>
IndexedAggregator.Creator<E,R>
IndexedFunction<I,O>
InstanceDispatcherLogic
Instantiator<T>
ParallelProcedure<E>
ParallelProcedure.LogicProvider<S,P extends Consumer<? super S>>	Type providing the actual logic Consumer to be applied to the elements enountered by aParallelProcedure.
ParallelProcedure.ThreadCountProvider
ParallelProcedure.ThreadTimeoutProvider
Procedure<E>
Processable<E>
QuadConsumer<T1,T2,T3,T4>
QuadFunction<I1,I2,I3,I4,O>
SortingAggregator<E,R>
ThrowingProcedure<E,T extends Throwable>
To_double<E>
TriConsumer<T1,T2,T3>
TriFunction<I1,I2,I3,O>

Class Summary

Class	Description
_intSum
AbstractProcedureLimit<I>
AbstractProcedureSkip<I>
AbstractProcedureSkipLimit<I>
Aggregate_doubleMin<E>
Aggregate_doubleSum<E>
AggregateApplies<E>
AggregateArrayAdder<E>
AggregateArrayBuilder<E>
AggregateContains<E>
AggregateCount<E>
AggregateCountingAdd<E>
AggregateCountingPut<E>
AggregateMax<E>
AggregateMin<E>
AggregateOffsetLength<E,R>
AggregateSearch<E>
AvgInteger
AvgIntegerNonNull
ComparatorReversed<T>
ComparatorSequence<T>	Helper class to chain multiple Comparator functions together as a super Comparator. Useful for implementing SQL-like "ORDER BY" for querying / processing collections.
DefaultInstantiator.Default
Instantiator.WrappingDefaultConstructor<T>
IsCustomEqual<E>
IsEqual<E>
IsGreater<E>
IsNull<E>
IsSame<E>
IsSmaller<E>
KamikazeArrayAdder<E>
LimitedOperationWithPredicate<E>
LimitedPredicate<E>
LimitedProcedure<E>
LimitedRange<E>
MainTestFunc
ParallelProcedure.Default<E>	Sample implementation with a user defined number of maximum worker threads and a user defined timeout (in ms) after which one worker thread will be abolished.
ParallelProcedure.LogicProvider.SingletonLogic<S,P extends Consumer<? super S>>
ParallelProcedure.ThreadCountProvider.Constant
ParallelProcedure.ThreadTimeoutProvider.Constant
PickAggregate<E>
RangedPredicate<E>
SumByte
SumDouble
SumFloat
SumInteger
SumLong
SumShort
ToArrayAggregator<E>
XFunc	Normally, writing "Func" instead of "Functional" is a capital sin of writing clean code.
XFunc.MaxInteger