com.fluxtion.compiler.builder.stream

Interface GroupByStreamBuilder

public interface GroupByStreamBuilder

Method Summary

Modifier and Type	Method and Description
static <K1,K2 extends K1,V1,V2,R,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>,H extends com.fluxtion.runtime.stream.groupby.GroupBy<K2,V2>> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K1,R>>	biMapStreams(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<V1,V2,R> mappingBiFunction, EventStreamBuilder<G> firstArgument, EventStreamBuilder<H> secondArgument)
static <K1,K2 extends K1,V1,V2,R,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>,H extends com.fluxtion.runtime.stream.groupby.GroupBy<K2,V2>> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K1,R>>	biMapStreams(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<V1,V2,R> mappingBiFunction, EventStreamBuilder<G> firstArgument, EventStreamBuilder<H> secondArgument, V2 defaultSecondArgument)
static <K1,V1,K2 extends K1,V2> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K1,com.fluxtion.runtime.stream.groupby.Tuple<V1,V2>>>	innerJoinStreams(EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>> leftGroupBy, EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K2,V2>> rightGroupBy)
static <K1,V1,K2 extends K1,V2> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K1,com.fluxtion.runtime.stream.groupby.Tuple<V1,V2>>>	leftJoinStreams(EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>> leftGroupBy, EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K2,V2>> rightGroupBy)
static <K1,V1,K2 extends K1,V2> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K1,com.fluxtion.runtime.stream.groupby.Tuple<V1,V2>>>	outerJoinStreams(EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>> leftGroupBy, EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K2,V2>> rightGroupBy)
static <K1,V1,K2 extends K1,V2> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K1,com.fluxtion.runtime.stream.groupby.Tuple<V1,V2>>>	rightJoinStreams(EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>> leftGroupBy, EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K2,V2>> rightGroupBy)

Method Detail

biMapStreams

static <K1,K2 extends K1,V1,V2,R,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>,H extends com.fluxtion.runtime.stream.groupby.GroupBy<K2,V2>> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K1,R>> biMapStreams(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<V1,V2,R> mappingBiFunction,
                                                                                                                                                                                                                                               EventStreamBuilder<G> firstArgument,
                                                                                                                                                                                                                                               EventStreamBuilder<H> secondArgument)

biMapStreams

static <K1,K2 extends K1,V1,V2,R,G extends com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>,H extends com.fluxtion.runtime.stream.groupby.GroupBy<K2,V2>> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K1,R>> biMapStreams(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<V1,V2,R> mappingBiFunction,
                                                                                                                                                                                                                                               EventStreamBuilder<G> firstArgument,
                                                                                                                                                                                                                                               EventStreamBuilder<H> secondArgument,
                                                                                                                                                                                                                                               V2 defaultSecondArgument)

innerJoinStreams

static <K1,V1,K2 extends K1,V2> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K1,com.fluxtion.runtime.stream.groupby.Tuple<V1,V2>>> innerJoinStreams(EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>> leftGroupBy,
                                                                                                                                                                      EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K2,V2>> rightGroupBy)

outerJoinStreams

static <K1,V1,K2 extends K1,V2> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K1,com.fluxtion.runtime.stream.groupby.Tuple<V1,V2>>> outerJoinStreams(EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>> leftGroupBy,
                                                                                                                                                                      EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K2,V2>> rightGroupBy)

leftJoinStreams

static <K1,V1,K2 extends K1,V2> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K1,com.fluxtion.runtime.stream.groupby.Tuple<V1,V2>>> leftJoinStreams(EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>> leftGroupBy,
                                                                                                                                                                     EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K2,V2>> rightGroupBy)

rightJoinStreams

static <K1,V1,K2 extends K1,V2> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K1,com.fluxtion.runtime.stream.groupby.Tuple<V1,V2>>> rightJoinStreams(EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>> leftGroupBy,
                                                                                                                                                                      EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K2,V2>> rightGroupBy)