Uses of Class
com.fluxtion.compiler.builder.stream.EventStreamBuilder

Packages that use EventStreamBuilder

Package	Description
com.fluxtion.compiler.builder.stream

Uses of EventStreamBuilder in com.fluxtion.compiler.builder.stream

Methods in com.fluxtion.compiler.builder.stream that return EventStreamBuilder

Modifier and Type	Method and Description
<S,R,F extends com.fluxtion.runtime.stream.aggregate.AggregateFunction<T,R,F>> EventStreamBuilder<R>	EventStreamBuilder.aggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction)
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>>	GroupByStreamBuilder.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>>	GroupByStreamBuilder.biMapStreams(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<V1,V2,R> mappingBiFunction, EventStreamBuilder<G> firstArgument, EventStreamBuilder<H> secondArgument, V2 defaultSecondArgument)
EventStreamBuilder<Double>	DoubleStreamBuilder.box()
EventStreamBuilder<Long>	LongStreamBuilder.box()
EventStreamBuilder<Integer>	IntStreamBuilder.box()
EventStreamBuilder<T>	EventStreamBuilder.console()
EventStreamBuilder<T>	EventStreamBuilder.console(String in)
<R> EventStreamBuilder<T>	EventStreamBuilder.console(String in, com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,R> transformFunction)
EventStreamBuilder<T>	EventStreamBuilder.defaultValue(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<T> defaultValue)
EventStreamBuilder<T>	EventStreamBuilder.defaultValue(T defaultValue)
<S> EventStreamBuilder<T>	EventStreamBuilder.filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,Double,Boolean> predicate, DoubleStreamBuilder secondArgument)
<S> EventStreamBuilder<T>	EventStreamBuilder.filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,Integer,Boolean> predicate, IntStreamBuilder secondArgument)
<S> EventStreamBuilder<T>	EventStreamBuilder.filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,Long,Boolean> predicate, LongStreamBuilder secondArgument)
<S> EventStreamBuilder<T>	EventStreamBuilder.filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,S,Boolean> predicate, EventStreamBuilder<S> secondArgument)
EventStreamBuilder<T>	EventStreamBuilder.filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,Boolean> filterFunction)
<P,S> EventStreamBuilder<T>	EventStreamBuilder.filterByProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<P,Double,Boolean> predicate, com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,P> accessor, DoubleStreamBuilder secondArgument)
<P,S> EventStreamBuilder<T>	EventStreamBuilder.filterByProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<P,Integer,Boolean> predicate, com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,P> accessor, IntStreamBuilder secondArgument)
<P,S> EventStreamBuilder<T>	EventStreamBuilder.filterByProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<P,Long,Boolean> predicate, com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,P> accessor, LongStreamBuilder secondArgument)
<P,S> EventStreamBuilder<T>	EventStreamBuilder.filterByProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<P,S,Boolean> predicate, com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,P> accessor, EventStreamBuilder<S> secondArgument)
<P> EventStreamBuilder<T>	EventStreamBuilder.filterByProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,P> accessor, com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<P,Boolean> filterFunction)
<S,R> EventStreamBuilder<R>	EventStreamBuilder.flatMap(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,Iterable<R>> iterableFunction)
<S,R> EventStreamBuilder<R>	EventStreamBuilder.flatMapFromArray(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,R[]> iterableFunction)
<V,K> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupByStreamed<K,T>>	EventStreamBuilder.groupBy(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction)
<V,K> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupByStreamed<K,V>>	EventStreamBuilder.groupBy(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction, com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,V> valueFunction)
<V,K,A,F extends com.fluxtion.runtime.stream.aggregate.AggregateFunction<V,A,F>> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupByStreamed<K,A>>	EventStreamBuilder.groupBy(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction, com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,V> valueFunction, com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunctionSupplier)
<V,K> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupByStreamed<K,List<T>>>	EventStreamBuilder.groupByAsList(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction)
<V,K> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupByStreamed<K,List<T>>>	EventStreamBuilder.groupByAsList(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction, int maxElementsInList)
<V,K> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K,V>>	EventStreamBuilder.groupBySliding(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction, com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,V> valueFunction, int bucketSizeMillis, int numberOfBuckets)
<V,K,A,F extends com.fluxtion.runtime.stream.aggregate.AggregateFunction<V,A,F>> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K,A>>	EventStreamBuilder.groupBySliding(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction, com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,V> valueFunction, com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunctionSupplier, int bucketSizeMillis, int numberOfBuckets)
<K,A,F extends com.fluxtion.runtime.stream.aggregate.AggregateFunction<T,A,F>> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K,A>>	EventStreamBuilder.groupBySliding(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction, com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunctionSupplier, int bucketSizeMillis, int numberOfBuckets)
<V,K> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K,V>>	EventStreamBuilder.groupByTumbling(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction, com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,V> valueFunction, int bucketSizeMillis)
<V,K,A,F extends com.fluxtion.runtime.stream.aggregate.AggregateFunction<V,A,F>> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K,A>>	EventStreamBuilder.groupByTumbling(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction, com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,V> valueFunction, com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunctionSupplier, int bucketSizeMillis)
EventStreamBuilder<T>	EventStreamBuilder.id(String nodeId)
static <K1,V1,K2 extends K1,V2> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K1,com.fluxtion.runtime.stream.groupby.Tuple<V1,V2>>>	GroupByStreamBuilder.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>>>	GroupByStreamBuilder.leftJoinStreams(EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>> leftGroupBy, EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K2,V2>> rightGroupBy)
<R,I,L> EventStreamBuilder<R>	EventStreamBuilder.lookup(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,I> lookupKeyFunction, com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<I,L> lookupFunction, com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,L,R> enrichFunction)
<R> EventStreamBuilder<R>	EventStreamBuilder.map(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,R> mapFunction)
<S,R> EventStreamBuilder<R>	EventStreamBuilder.mapBiFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,S,R> int2IntFunction, EventStreamBuilder<S> stream2Builder)
<R> EventStreamBuilder<R>	EventStreamBuilder.mapOnNotify(R target)
<T> EventStreamBuilder<T>	DoubleStreamBuilder.mapOnNotify(T target)
<T> EventStreamBuilder<T>	LongStreamBuilder.mapOnNotify(T target)
<T> EventStreamBuilder<T>	IntStreamBuilder.mapOnNotify(T target)
<R> EventStreamBuilder<R>	DoubleStreamBuilder.mapToObj(com.fluxtion.runtime.partition.LambdaReflection.SerializableDoubleFunction<R> int2IntFunction)
<R> EventStreamBuilder<R>	IntStreamBuilder.mapToObj(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntFunction<R> int2IntFunction)
<R> EventStreamBuilder<R>	LongStreamBuilder.mapToObj(com.fluxtion.runtime.partition.LambdaReflection.SerializableLongFunction<R> int2IntFunction)
EventStreamBuilder<T>	EventStreamBuilder.merge(EventStreamBuilder<? extends T> streamToMerge)
static <T> EventStreamBuilder<T>	EventFlow.mergeMap(MergeMapStreamBuilder<T> builder) Merges and maps several EventStream's into a single event stream of type T
EventStreamBuilder<T>	EventStreamBuilder.notify(Object target)
static <K1,V1,K2 extends K1,V2> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K1,com.fluxtion.runtime.stream.groupby.Tuple<V1,V2>>>	GroupByStreamBuilder.outerJoinStreams(EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>> leftGroupBy, EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K2,V2>> rightGroupBy)
EventStreamBuilder<T>	EventStreamBuilder.peek(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<T> peekFunction)
EventStreamBuilder<T>	EventStreamBuilder.processAsNewGraphEvent()
EventStreamBuilder<T>	EventStreamBuilder.publishTrigger(Object publishTrigger)
EventStreamBuilder<T>	EventStreamBuilder.publishTriggerOverride(Object publishTrigger)
EventStreamBuilder<T>	EventStreamBuilder.push(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<T> pushFunction)
EventStreamBuilder<T>	EventStreamBuilder.resetTrigger(Object resetTrigger)
static <K1,V1,K2 extends K1,V2> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K1,com.fluxtion.runtime.stream.groupby.Tuple<V1,V2>>>	GroupByStreamBuilder.rightJoinStreams(EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>> leftGroupBy, EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K2,V2>> rightGroupBy)
EventStreamBuilder<T>	EventStreamBuilder.sink(String sinkId)
<S,R,F extends com.fluxtion.runtime.stream.aggregate.AggregateFunction<T,R,F>> EventStreamBuilder<R>	EventStreamBuilder.slidingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction, int bucketSizeMillis, int bucketsPerWindow)
static <T> EventStreamBuilder<T>	EventFlow.subscribe(Class<T> classSubscription) Subscribes to events of type <T>.
static <T extends com.fluxtion.runtime.event.Event> EventStreamBuilder<T>	EventFlow.subscribe(Class<T> classSubscription, int filter) Subscribes to events of type <T> filtering by Event.filterId().
static <T extends com.fluxtion.runtime.event.Event> EventStreamBuilder<T>	EventFlow.subscribe(Class<T> classSubscription, String filter) Subscribes to events of type <T> filtering by Event.filterString().
static <T> EventStreamBuilder<T>	EventFlow.subscribeToNode(T source) Subscribes to an internal node within the processing graph and presents it as an EventStreamBuilder for constructing stream processing logic.
static <T,R> EventStreamBuilder<R>	EventFlow.subscribeToNodeProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,R> sourceProperty)
static <R> EventStreamBuilder<R>	EventFlow.subscribeToNodeProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<R> propertySupplier)
static EventStreamBuilder<Object>	EventFlow.subscribeToSignal(String filterId)
static <T> EventStreamBuilder<T>	EventFlow.subscribeToSignal(String filterId, Class<T> signalType)
static <T> EventStreamBuilder<T>	EventFlow.subscribeToSignal(String filterId, Class<T> signalType, T defaultValue)
<S,R,F extends com.fluxtion.runtime.stream.aggregate.AggregateFunction<T,R,F>> EventStreamBuilder<R>	EventStreamBuilder.tumblingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction, int bucketSizeMillis)
EventStreamBuilder<T>	EventStreamBuilder.updateTrigger(Object updateTrigger)

Methods in com.fluxtion.compiler.builder.stream with parameters of type EventStreamBuilder

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>>	GroupByStreamBuilder.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>>	GroupByStreamBuilder.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>>	GroupByStreamBuilder.biMapStreams(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<V1,V2,R> mappingBiFunction, EventStreamBuilder<G> firstArgument, EventStreamBuilder<H> secondArgument, V2 defaultSecondArgument)
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>>	GroupByStreamBuilder.biMapStreams(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<V1,V2,R> mappingBiFunction, EventStreamBuilder<G> firstArgument, EventStreamBuilder<H> secondArgument, V2 defaultSecondArgument)
<S> EventStreamBuilder<T>	EventStreamBuilder.filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,S,Boolean> predicate, EventStreamBuilder<S> secondArgument)
<P,S> EventStreamBuilder<T>	EventStreamBuilder.filterByProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<P,S,Boolean> predicate, com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,P> accessor, EventStreamBuilder<S> secondArgument)
static <K1,V1,K2 extends K1,V2> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K1,com.fluxtion.runtime.stream.groupby.Tuple<V1,V2>>>	GroupByStreamBuilder.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>>>	GroupByStreamBuilder.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>>>	GroupByStreamBuilder.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>>>	GroupByStreamBuilder.leftJoinStreams(EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>> leftGroupBy, EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K2,V2>> rightGroupBy)
<S,R> EventStreamBuilder<R>	EventStreamBuilder.mapBiFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,S,R> int2IntFunction, EventStreamBuilder<S> stream2Builder)
EventStreamBuilder<T>	EventStreamBuilder.merge(EventStreamBuilder<? extends T> streamToMerge)
static <K1,V1,K2 extends K1,V2> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K1,com.fluxtion.runtime.stream.groupby.Tuple<V1,V2>>>	GroupByStreamBuilder.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>>>	GroupByStreamBuilder.outerJoinStreams(EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>> leftGroupBy, EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K2,V2>> rightGroupBy)
<R> MergeMapStreamBuilder<T>	MergeMapStreamBuilder.required(EventStreamBuilder<R> trigger, com.fluxtion.runtime.partition.LambdaReflection.SerializableBiConsumer<T,R> setValue)
<R> MergeMapStreamBuilder<T>	MergeMapStreamBuilder.requiredNoTrigger(EventStreamBuilder<R> trigger, com.fluxtion.runtime.partition.LambdaReflection.SerializableBiConsumer<T,R> setValue)
static <K1,V1,K2 extends K1,V2> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K1,com.fluxtion.runtime.stream.groupby.Tuple<V1,V2>>>	GroupByStreamBuilder.rightJoinStreams(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>>>	GroupByStreamBuilder.rightJoinStreams(EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K1,V1>> leftGroupBy, EventStreamBuilder<? extends com.fluxtion.runtime.stream.groupby.GroupBy<K2,V2>> rightGroupBy)