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

Packages that use DoubleStreamBuilder

Package	Description
com.fluxtion.compiler.builder.stream

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

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

Modifier and Type	Method and Description
<F extends com.fluxtion.runtime.stream.aggregate.DoubleAggregateFunction<F>> DoubleStreamBuilder	DoubleStreamBuilder.aggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction)
DoubleStreamBuilder	DoubleStreamBuilder.console()
DoubleStreamBuilder	DoubleStreamBuilder.console(String in)
DoubleStreamBuilder	DoubleStreamBuilder.defaultValue(double defaultValue)
<S> DoubleStreamBuilder	DoubleStreamBuilder.filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiDoublePredicate predicate, DoubleStreamBuilder secondArgument)
DoubleStreamBuilder	DoubleStreamBuilder.filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableDoubleFunction<Boolean> filterFunction)
DoubleStreamBuilder	DoubleStreamBuilder.id(String nodeId)
DoubleStreamBuilder	DoubleStreamBuilder.map(com.fluxtion.runtime.partition.LambdaReflection.SerializableDoubleUnaryOperator int2IntFunction)
DoubleStreamBuilder	DoubleStreamBuilder.mapBiFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiDoubleFunction int2IntFunction, DoubleStreamBuilder stream2Builder)
DoubleStreamBuilder	IntStreamBuilder.mapToDouble(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntToDoubleFunction int2IntFunction)
DoubleStreamBuilder	LongStreamBuilder.mapToDouble(com.fluxtion.runtime.partition.LambdaReflection.SerializableLongToDoubleFunction int2IntFunction)
DoubleStreamBuilder	EventStreamBuilder.mapToDouble(com.fluxtion.runtime.partition.LambdaReflection.SerializableToDoubleFunction<T> mapFunction)
DoubleStreamBuilder	DoubleStreamBuilder.notify(Object target)
DoubleStreamBuilder	DoubleStreamBuilder.peek(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<Double> peekFunction)
DoubleStreamBuilder	DoubleStreamBuilder.publishTrigger(Object publishTrigger)
DoubleStreamBuilder	DoubleStreamBuilder.publishTriggerOverride(Object publishTrigger)
DoubleStreamBuilder	DoubleStreamBuilder.push(com.fluxtion.runtime.partition.LambdaReflection.SerializableDoubleConsumer pushFunction)
DoubleStreamBuilder	DoubleStreamBuilder.resetTrigger(Object resetTrigger)
DoubleStreamBuilder	DoubleStreamBuilder.sink(String sinkId)
<F extends com.fluxtion.runtime.stream.aggregate.DoubleAggregateFunction<F>> DoubleStreamBuilder	DoubleStreamBuilder.slidingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction, int bucketSizeMillis, int numberOfBuckets)
static DoubleStreamBuilder	EventFlow.subscribeToDoubleSignal(String filterId)
static DoubleStreamBuilder	EventFlow.subscribeToDoubleSignal(String filterId, double defaultValue)
<F extends com.fluxtion.runtime.stream.aggregate.DoubleAggregateFunction<F>> DoubleStreamBuilder	DoubleStreamBuilder.tumblingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction, int bucketSizeMillis)
DoubleStreamBuilder	DoubleStreamBuilder.updateTrigger(Object updateTrigger)

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

Modifier and Type	Method and Description
<S> DoubleStreamBuilder	DoubleStreamBuilder.filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiDoublePredicate predicate, DoubleStreamBuilder secondArgument)
<S> EventStreamBuilder<T>	EventStreamBuilder.filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,Double,Boolean> predicate, DoubleStreamBuilder secondArgument)
<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)
DoubleStreamBuilder	DoubleStreamBuilder.mapBiFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiDoubleFunction int2IntFunction, DoubleStreamBuilder stream2Builder)