public class IntStreamBuilder extends Object implements com.fluxtion.runtime.stream.EventStream.EventSupplierAccessor<com.fluxtion.runtime.stream.EventStream.IntEventSupplier>
| Modifier and Type | Method and Description |
|---|---|
<F extends com.fluxtion.runtime.stream.aggregate.IntAggregateFunction<F>> |
aggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction) |
EventStreamBuilder<Integer> |
box() |
IntStreamBuilder |
console() |
IntStreamBuilder |
console(String in) |
IntStreamBuilder |
defaultValue(int defaultValue) |
<S> IntStreamBuilder |
filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiIntPredicate predicate,
IntStreamBuilder secondArgument) |
IntStreamBuilder |
filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntFunction<Boolean> filterFunction) |
com.fluxtion.runtime.stream.EventStream.IntEventSupplier |
getEventSupplier() |
IntStreamBuilder |
id(String nodeId) |
IntStreamBuilder |
map(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntUnaryOperator int2IntFunction) |
IntStreamBuilder |
mapBiFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiIntFunction int2IntFunction,
IntStreamBuilder stream2Builder) |
<T> EventStreamBuilder<T> |
mapOnNotify(T target) |
DoubleStreamBuilder |
mapToDouble(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntToDoubleFunction int2IntFunction) |
LongStreamBuilder |
mapToLong(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntToLongFunction int2IntFunction) |
<R> EventStreamBuilder<R> |
mapToObj(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntFunction<R> int2IntFunction) |
IntStreamBuilder |
notify(Object target) |
IntStreamBuilder |
peek(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<Integer> peekFunction) |
IntStreamBuilder |
publishTrigger(Object publishTrigger) |
IntStreamBuilder |
publishTriggerOverride(Object publishTrigger) |
IntStreamBuilder |
push(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntConsumer pushFunction) |
IntStreamBuilder |
resetTrigger(Object resetTrigger) |
IntStreamBuilder |
sink(String sinkId) |
<F extends com.fluxtion.runtime.stream.aggregate.IntAggregateFunction<F>> |
slidingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction,
int bucketSizeMillis,
int numberOfBuckets) |
<F extends com.fluxtion.runtime.stream.aggregate.IntAggregateFunction<F>> |
tumblingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction,
int bucketSizeMillis) |
IntStreamBuilder |
updateTrigger(Object updateTrigger) |
public com.fluxtion.runtime.stream.EventStream.IntEventSupplier getEventSupplier()
getEventSupplier in interface com.fluxtion.runtime.stream.EventStream.EventSupplierAccessor<com.fluxtion.runtime.stream.EventStream.IntEventSupplier>public IntStreamBuilder updateTrigger(Object updateTrigger)
public IntStreamBuilder publishTrigger(Object publishTrigger)
public IntStreamBuilder publishTriggerOverride(Object publishTrigger)
public IntStreamBuilder resetTrigger(Object resetTrigger)
public IntStreamBuilder filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntFunction<Boolean> filterFunction)
public <S> IntStreamBuilder filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiIntPredicate predicate, IntStreamBuilder secondArgument)
public IntStreamBuilder defaultValue(int defaultValue)
public IntStreamBuilder map(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntUnaryOperator int2IntFunction)
public IntStreamBuilder mapBiFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiIntFunction int2IntFunction, IntStreamBuilder stream2Builder)
public <F extends com.fluxtion.runtime.stream.aggregate.IntAggregateFunction<F>> IntStreamBuilder aggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction)
public <F extends com.fluxtion.runtime.stream.aggregate.IntAggregateFunction<F>> IntStreamBuilder tumblingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction, int bucketSizeMillis)
public <F extends com.fluxtion.runtime.stream.aggregate.IntAggregateFunction<F>> IntStreamBuilder slidingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction, int bucketSizeMillis, int numberOfBuckets)
public <T> EventStreamBuilder<T> mapOnNotify(T target)
public EventStreamBuilder<Integer> box()
public <R> EventStreamBuilder<R> mapToObj(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntFunction<R> int2IntFunction)
public DoubleStreamBuilder mapToDouble(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntToDoubleFunction int2IntFunction)
public LongStreamBuilder mapToLong(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntToLongFunction int2IntFunction)
public IntStreamBuilder notify(Object target)
public IntStreamBuilder sink(String sinkId)
public IntStreamBuilder push(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntConsumer pushFunction)
public IntStreamBuilder peek(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<Integer> peekFunction)
public IntStreamBuilder console(String in)
public IntStreamBuilder console()
public IntStreamBuilder id(String nodeId)
Copyright © 2022. All rights reserved.