com.fluxtion.compiler.builder.stream

Interface GroupByFunction

public interface GroupByFunction

Method Summary

Modifier and Type	Method and Description
static <K,V,A,O,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K,V>,H extends com.fluxtion.runtime.stream.groupby.GroupBy<K,A>> com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<G,H,com.fluxtion.runtime.stream.groupby.GroupBy<K,O>>	biMapFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<V,A,O> mappingBiFunction)
static <K,V,A,O,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K,V>,H extends com.fluxtion.runtime.stream.groupby.GroupBy<K,A>> com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<G,H,com.fluxtion.runtime.stream.groupby.GroupBy<K,O>>	biMapFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<V,A,O> mappingBiFunction, A defaultValue)
static <K,V,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K,V>> com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<G,com.fluxtion.runtime.stream.groupby.GroupBy<K,V>>	filterValues(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<V,Boolean> mappingFunction)
static <K,V,K1,V1,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K,V>> com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<G,com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>>	mapEntry(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<Map.Entry<K,V>,Map.Entry<K1,V1>> mappingFunction)
static <K,V,O,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K,V>> com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<G,com.fluxtion.runtime.stream.groupby.GroupBy<O,V>>	mapKeys(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<K,O> mappingFunction)
static <K,F,S,R> com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<com.fluxtion.runtime.stream.groupby.GroupBy<K,com.fluxtion.runtime.stream.groupby.Tuple<F,S>>,com.fluxtion.runtime.stream.groupby.GroupBy<K,R>>	mapTuplesInGroupBy(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<F,S,R> tupleMapFunction)
static <K,V,A,O,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K,V>> com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<G,A,com.fluxtion.runtime.stream.groupby.GroupByStreamed<K,O>>	mapValueByKey(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<V,A,O> mappingBiFunction, com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<A,K> keyFunction)
static <K,V,O,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K,V>> com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<G,com.fluxtion.runtime.stream.groupby.GroupBy<K,O>>	mapValues(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<V,O> mappingFunction)
static <K,V,R,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K,V>,F extends com.fluxtion.runtime.stream.aggregate.AggregateFunction<V,R,F>> com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<G,R>	reduceValues(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFactory)
static <K,F,S,TIN extends com.fluxtion.runtime.stream.groupby.Tuple<? extends F,? extends S>> com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<com.fluxtion.runtime.stream.groupby.GroupBy<K,TIN>,com.fluxtion.runtime.stream.groupby.GroupBy<K,com.fluxtion.runtime.stream.groupby.Tuple<F,S>>>	replaceTupleNullInGroupBy(F first, S second)

Method Detail

replaceTupleNullInGroupBy

static <K,F,S,TIN extends com.fluxtion.runtime.stream.groupby.Tuple<? extends F,? extends S>> com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<com.fluxtion.runtime.stream.groupby.GroupBy<K,TIN>,com.fluxtion.runtime.stream.groupby.GroupBy<K,com.fluxtion.runtime.stream.groupby.Tuple<F,S>>> replaceTupleNullInGroupBy(F first,
                                                                                                                                                                                                                                                                                                                                               S second)

mapTuplesInGroupBy

static <K,F,S,R> com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<com.fluxtion.runtime.stream.groupby.GroupBy<K,com.fluxtion.runtime.stream.groupby.Tuple<F,S>>,com.fluxtion.runtime.stream.groupby.GroupBy<K,R>> mapTuplesInGroupBy(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<F,S,R> tupleMapFunction)

mapValues

static <K,V,O,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K,V>> com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<G,com.fluxtion.runtime.stream.groupby.GroupBy<K,O>> mapValues(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<V,O> mappingFunction)

mapValueByKey

static <K,V,A,O,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K,V>> com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<G,A,com.fluxtion.runtime.stream.groupby.GroupByStreamed<K,O>> mapValueByKey(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<V,A,O> mappingBiFunction,
                                                                                                                                                                                                                               com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<A,K> keyFunction)

reduceValues

static <K,V,R,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K,V>,F extends com.fluxtion.runtime.stream.aggregate.AggregateFunction<V,R,F>> com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<G,R> reduceValues(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFactory)

biMapFunction

static <K,V,A,O,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K,V>,H extends com.fluxtion.runtime.stream.groupby.GroupBy<K,A>> com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<G,H,com.fluxtion.runtime.stream.groupby.GroupBy<K,O>> biMapFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<V,A,O> mappingBiFunction)

biMapFunction

static <K,V,A,O,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K,V>,H extends com.fluxtion.runtime.stream.groupby.GroupBy<K,A>> com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<G,H,com.fluxtion.runtime.stream.groupby.GroupBy<K,O>> biMapFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<V,A,O> mappingBiFunction,
                                                                                                                                                                                                                                                                                  A defaultValue)

mapKeys

static <K,V,O,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K,V>> com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<G,com.fluxtion.runtime.stream.groupby.GroupBy<O,V>> mapKeys(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<K,O> mappingFunction)

mapEntry

static <K,V,K1,V1,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K,V>> com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<G,com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>> mapEntry(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<Map.Entry<K,V>,Map.Entry<K1,V1>> mappingFunction)

filterValues

static <K,V,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K,V>> com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<G,com.fluxtion.runtime.stream.groupby.GroupBy<K,V>> filterValues(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<V,Boolean> mappingFunction)