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