com.fluxtion.compiler.builder.stream

Class EventStreamBuilder<T>

java.lang.Object

com.fluxtion.compiler.builder.stream.EventStreamBuilder<T>

All Implemented Interfaces:

com.fluxtion.runtime.stream.EventStream.EventSupplierAccessor<com.fluxtion.runtime.stream.EventStream.EventSupplier<T>>

public class EventStreamBuilder<T>
extends Object
implements com.fluxtion.runtime.stream.EventStream.EventSupplierAccessor<com.fluxtion.runtime.stream.EventStream.EventSupplier<T>>

Method Summary

Modifier and Type	Method and Description
<S,R,F extends com.fluxtion.runtime.stream.aggregate.AggregateFunction<T,R,F>> EventStreamBuilder<R>	aggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction)
EventStreamBuilder<T>	console()
EventStreamBuilder<T>	console(String in)
<R> EventStreamBuilder<T>	console(String in, com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,R> transformFunction)
EventStreamBuilder<T>	defaultValue(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<T> defaultValue)
EventStreamBuilder<T>	defaultValue(T defaultValue)
<S> EventStreamBuilder<T>	filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,Double,Boolean> predicate, DoubleStreamBuilder secondArgument)
<S> EventStreamBuilder<T>	filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,Integer,Boolean> predicate, IntStreamBuilder secondArgument)
<S> EventStreamBuilder<T>	filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,Long,Boolean> predicate, LongStreamBuilder secondArgument)
<S> EventStreamBuilder<T>	filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,S,Boolean> predicate, EventStreamBuilder<S> secondArgument)
EventStreamBuilder<T>	filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,Boolean> filterFunction)
<P,S> EventStreamBuilder<T>	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>	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>	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>	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>	filterByProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,P> accessor, com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<P,Boolean> filterFunction)
<S,R> EventStreamBuilder<R>	flatMap(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,Iterable<R>> iterableFunction)
<S,R> EventStreamBuilder<R>	flatMapFromArray(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,R[]> iterableFunction)
com.fluxtion.runtime.stream.EventStream.EventSupplier<T>	getEventSupplier()
<V,K> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupByStreamed<K,T>>	groupBy(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction)
<V,K> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupByStreamed<K,V>>	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>>	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>>>	groupByAsList(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction)
<V,K> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupByStreamed<K,List<T>>>	groupByAsList(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction, int maxElementsInList)
<V,K> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K,V>>	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>>	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>>	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>>	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>>	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>	id(String nodeId)
<R,I,L> EventStreamBuilder<R>	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>	map(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,R> mapFunction)
<S,R> EventStreamBuilder<R>	mapBiFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,S,R> int2IntFunction, EventStreamBuilder<S> stream2Builder)
<R> EventStreamBuilder<R>	mapOnNotify(R target)
DoubleStreamBuilder	mapToDouble(com.fluxtion.runtime.partition.LambdaReflection.SerializableToDoubleFunction<T> mapFunction)
IntStreamBuilder	mapToInt(com.fluxtion.runtime.partition.LambdaReflection.SerializableToIntFunction<T> mapFunction)
LongStreamBuilder	mapToLong(com.fluxtion.runtime.partition.LambdaReflection.SerializableToLongFunction<T> mapFunction)
EventStreamBuilder<T>	merge(EventStreamBuilder<? extends T> streamToMerge)
EventStreamBuilder<T>	notify(Object target)
EventStreamBuilder<T>	peek(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<T> peekFunction)
EventStreamBuilder<T>	processAsNewGraphEvent()
EventStreamBuilder<T>	publishTrigger(Object publishTrigger)
EventStreamBuilder<T>	publishTriggerOverride(Object publishTrigger)
EventStreamBuilder<T>	push(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<T> pushFunction)
EventStreamBuilder<T>	resetTrigger(Object resetTrigger)
EventStreamBuilder<T>	sink(String sinkId)
<S,R,F extends com.fluxtion.runtime.stream.aggregate.AggregateFunction<T,R,F>> EventStreamBuilder<R>	slidingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction, int bucketSizeMillis, int bucketsPerWindow)
<S,R,F extends com.fluxtion.runtime.stream.aggregate.AggregateFunction<T,R,F>> EventStreamBuilder<R>	tumblingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction, int bucketSizeMillis)
EventStreamBuilder<T>	updateTrigger(Object updateTrigger)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getEventSupplier

public com.fluxtion.runtime.stream.EventStream.EventSupplier<T> getEventSupplier()

Specified by:

getEventSupplier in interface com.fluxtion.runtime.stream.EventStream.EventSupplierAccessor<com.fluxtion.runtime.stream.EventStream.EventSupplier<T>>

updateTrigger

public EventStreamBuilder<T> updateTrigger(Object updateTrigger)

publishTrigger

public EventStreamBuilder<T> publishTrigger(Object publishTrigger)

publishTriggerOverride

public EventStreamBuilder<T> publishTriggerOverride(Object publishTrigger)

resetTrigger

public EventStreamBuilder<T> resetTrigger(Object resetTrigger)

filter

public EventStreamBuilder<T> filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,Boolean> filterFunction)

filterByProperty

public <P> EventStreamBuilder<T> filterByProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,P> accessor,
                                                  com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<P,Boolean> filterFunction)

filter

public <S> EventStreamBuilder<T> filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,S,Boolean> predicate,
                                        EventStreamBuilder<S> secondArgument)

filter

public <S> EventStreamBuilder<T> filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,Integer,Boolean> predicate,
                                        IntStreamBuilder secondArgument)

filter

public <S> EventStreamBuilder<T> filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,Double,Boolean> predicate,
                                        DoubleStreamBuilder secondArgument)

filter

public <S> EventStreamBuilder<T> filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,Long,Boolean> predicate,
                                        LongStreamBuilder secondArgument)

filterByProperty

public <P,S> EventStreamBuilder<T> filterByProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<P,S,Boolean> predicate,
                                                    com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,P> accessor,
                                                    EventStreamBuilder<S> secondArgument)

filterByProperty

public <P,S> EventStreamBuilder<T> filterByProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<P,Integer,Boolean> predicate,
                                                    com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,P> accessor,
                                                    IntStreamBuilder secondArgument)

filterByProperty

public <P,S> EventStreamBuilder<T> filterByProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<P,Double,Boolean> predicate,
                                                    com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,P> accessor,
                                                    DoubleStreamBuilder secondArgument)

filterByProperty

public <P,S> EventStreamBuilder<T> filterByProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<P,Long,Boolean> predicate,
                                                    com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,P> accessor,
                                                    LongStreamBuilder secondArgument)

defaultValue

public EventStreamBuilder<T> defaultValue(T defaultValue)

defaultValue

public EventStreamBuilder<T> defaultValue(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<T> defaultValue)

lookup

public <R,I,L> EventStreamBuilder<R> 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)

map

public <R> EventStreamBuilder<R> map(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,R> mapFunction)

mapBiFunction

public <S,R> EventStreamBuilder<R> mapBiFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,S,R> int2IntFunction,
                                                 EventStreamBuilder<S> stream2Builder)

merge

public EventStreamBuilder<T> merge(EventStreamBuilder<? extends T> streamToMerge)

flatMap

public <S,R> EventStreamBuilder<R> flatMap(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,Iterable<R>> iterableFunction)

flatMapFromArray

public <S,R> EventStreamBuilder<R> flatMapFromArray(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,R[]> iterableFunction)

aggregate

public <S,R,F extends com.fluxtion.runtime.stream.aggregate.AggregateFunction<T,R,F>> EventStreamBuilder<R> aggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction)

tumblingAggregate

public <S,R,F extends com.fluxtion.runtime.stream.aggregate.AggregateFunction<T,R,F>> EventStreamBuilder<R> tumblingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction,
                                                                                                                              int bucketSizeMillis)

slidingAggregate

public <S,R,F extends com.fluxtion.runtime.stream.aggregate.AggregateFunction<T,R,F>> EventStreamBuilder<R> slidingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction,
                                                                                                                             int bucketSizeMillis,
                                                                                                                             int bucketsPerWindow)

groupBy

public <V,K,A,F extends com.fluxtion.runtime.stream.aggregate.AggregateFunction<V,A,F>> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupByStreamed<K,A>> 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)

groupBy

public <V,K> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupByStreamed<K,V>> groupBy(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction,
                                                                                                  com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,V> valueFunction)

groupBy

public <V,K> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupByStreamed<K,T>> groupBy(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction)

groupByAsList

public <V,K> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupByStreamed<K,List<T>>> groupByAsList(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction)

groupByAsList

public <V,K> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupByStreamed<K,List<T>>> groupByAsList(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction,
                                                                                                              int maxElementsInList)

groupByTumbling

public <V,K,A,F extends com.fluxtion.runtime.stream.aggregate.AggregateFunction<V,A,F>> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K,A>> 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)

groupByTumbling

public <V,K> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K,V>> groupByTumbling(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction,
                                                                                                  com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,V> valueFunction,
                                                                                                  int bucketSizeMillis)

groupBySliding

public <V,K,A,F extends com.fluxtion.runtime.stream.aggregate.AggregateFunction<V,A,F>> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K,A>> 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)

groupBySliding

public <V,K> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K,V>> groupBySliding(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction,
                                                                                                 com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,V> valueFunction,
                                                                                                 int bucketSizeMillis,
                                                                                                 int numberOfBuckets)

groupBySliding

public <K,A,F extends com.fluxtion.runtime.stream.aggregate.AggregateFunction<T,A,F>> EventStreamBuilder<com.fluxtion.runtime.stream.groupby.GroupBy<K,A>> groupBySliding(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,K> keyFunction,
                                                                                                                                                                          com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunctionSupplier,
                                                                                                                                                                          int bucketSizeMillis,
                                                                                                                                                                          int numberOfBuckets)

mapOnNotify

public <R> EventStreamBuilder<R> mapOnNotify(R target)

mapToInt

public IntStreamBuilder mapToInt(com.fluxtion.runtime.partition.LambdaReflection.SerializableToIntFunction<T> mapFunction)

mapToDouble

public DoubleStreamBuilder mapToDouble(com.fluxtion.runtime.partition.LambdaReflection.SerializableToDoubleFunction<T> mapFunction)

mapToLong

public LongStreamBuilder mapToLong(com.fluxtion.runtime.partition.LambdaReflection.SerializableToLongFunction<T> mapFunction)

push

public EventStreamBuilder<T> push(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<T> pushFunction)

sink

public EventStreamBuilder<T> sink(String sinkId)

notify

public EventStreamBuilder<T> notify(Object target)

processAsNewGraphEvent

public EventStreamBuilder<T> processAsNewGraphEvent()

peek

public EventStreamBuilder<T> peek(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<T> peekFunction)

console

public <R> EventStreamBuilder<T> console(String in,
                                         com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,R> transformFunction)

console

public EventStreamBuilder<T> console(String in)

console

public EventStreamBuilder<T> console()

id

public EventStreamBuilder<T> id(String nodeId)