com.fluxtion.compiler.builder.stream

Class DoubleStreamBuilder

java.lang.Object

com.fluxtion.compiler.builder.stream.DoubleStreamBuilder

All Implemented Interfaces:

com.fluxtion.runtime.stream.EventStream.EventSupplierAccessor<com.fluxtion.runtime.stream.EventStream.DoubleEventSupplier>

public class DoubleStreamBuilder
extends Object
implements com.fluxtion.runtime.stream.EventStream.EventSupplierAccessor<com.fluxtion.runtime.stream.EventStream.DoubleEventSupplier>

Method Summary

Modifier and Type	Method and Description
<F extends com.fluxtion.runtime.stream.aggregate.DoubleAggregateFunction<F>> DoubleStreamBuilder	aggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction)
EventStreamBuilder<Double>	box()
DoubleStreamBuilder	console()
DoubleStreamBuilder	console(String in)
DoubleStreamBuilder	defaultValue(double defaultValue)
<S> DoubleStreamBuilder	filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiDoublePredicate predicate, DoubleStreamBuilder secondArgument)
DoubleStreamBuilder	filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableDoubleFunction<Boolean> filterFunction)
com.fluxtion.runtime.stream.EventStream.DoubleEventSupplier	getEventSupplier()
DoubleStreamBuilder	id(String nodeId)
DoubleStreamBuilder	map(com.fluxtion.runtime.partition.LambdaReflection.SerializableDoubleUnaryOperator int2IntFunction)
DoubleStreamBuilder	mapBiFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiDoubleFunction int2IntFunction, DoubleStreamBuilder stream2Builder)
<T> EventStreamBuilder<T>	mapOnNotify(T target)
IntStreamBuilder	mapToInt(com.fluxtion.runtime.partition.LambdaReflection.SerializableDoubleToIntFunction int2IntFunction)
LongStreamBuilder	mapToLong(com.fluxtion.runtime.partition.LambdaReflection.SerializableDoubleToLongFunction int2IntFunction)
<R> EventStreamBuilder<R>	mapToObj(com.fluxtion.runtime.partition.LambdaReflection.SerializableDoubleFunction<R> int2IntFunction)
DoubleStreamBuilder	notify(Object target)
DoubleStreamBuilder	peek(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<Double> peekFunction)
DoubleStreamBuilder	publishTrigger(Object publishTrigger)
DoubleStreamBuilder	publishTriggerOverride(Object publishTrigger)
DoubleStreamBuilder	push(com.fluxtion.runtime.partition.LambdaReflection.SerializableDoubleConsumer pushFunction)
DoubleStreamBuilder	resetTrigger(Object resetTrigger)
DoubleStreamBuilder	sink(String sinkId)
<F extends com.fluxtion.runtime.stream.aggregate.DoubleAggregateFunction<F>> DoubleStreamBuilder	slidingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction, int bucketSizeMillis, int numberOfBuckets)
<F extends com.fluxtion.runtime.stream.aggregate.DoubleAggregateFunction<F>> DoubleStreamBuilder	tumblingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction, int bucketSizeMillis)
DoubleStreamBuilder	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.DoubleEventSupplier getEventSupplier()

Specified by:

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

updateTrigger

public DoubleStreamBuilder updateTrigger(Object updateTrigger)

publishTrigger

public DoubleStreamBuilder publishTrigger(Object publishTrigger)

publishTriggerOverride

public DoubleStreamBuilder publishTriggerOverride(Object publishTrigger)

resetTrigger

public DoubleStreamBuilder resetTrigger(Object resetTrigger)

filter

public DoubleStreamBuilder filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableDoubleFunction<Boolean> filterFunction)

filter

public <S> DoubleStreamBuilder filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiDoublePredicate predicate,
                                      DoubleStreamBuilder secondArgument)

defaultValue

public DoubleStreamBuilder defaultValue(double defaultValue)

map

public DoubleStreamBuilder map(com.fluxtion.runtime.partition.LambdaReflection.SerializableDoubleUnaryOperator int2IntFunction)

mapBiFunction

public DoubleStreamBuilder mapBiFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiDoubleFunction int2IntFunction,
                                         DoubleStreamBuilder stream2Builder)

aggregate

public <F extends com.fluxtion.runtime.stream.aggregate.DoubleAggregateFunction<F>> DoubleStreamBuilder aggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction)

tumblingAggregate

public <F extends com.fluxtion.runtime.stream.aggregate.DoubleAggregateFunction<F>> DoubleStreamBuilder tumblingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction,
                                                                                                                          int bucketSizeMillis)

slidingAggregate

public <F extends com.fluxtion.runtime.stream.aggregate.DoubleAggregateFunction<F>> DoubleStreamBuilder slidingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction,
                                                                                                                         int bucketSizeMillis,
                                                                                                                         int numberOfBuckets)

mapOnNotify

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

box

public EventStreamBuilder<Double> box()

mapToObj

public <R> EventStreamBuilder<R> mapToObj(com.fluxtion.runtime.partition.LambdaReflection.SerializableDoubleFunction<R> int2IntFunction)

mapToInt

public IntStreamBuilder mapToInt(com.fluxtion.runtime.partition.LambdaReflection.SerializableDoubleToIntFunction int2IntFunction)

mapToLong

public LongStreamBuilder mapToLong(com.fluxtion.runtime.partition.LambdaReflection.SerializableDoubleToLongFunction int2IntFunction)

notify

public DoubleStreamBuilder notify(Object target)

sink

public DoubleStreamBuilder sink(String sinkId)

push

public DoubleStreamBuilder push(com.fluxtion.runtime.partition.LambdaReflection.SerializableDoubleConsumer pushFunction)

peek

public DoubleStreamBuilder peek(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<Double> peekFunction)

console

public DoubleStreamBuilder console(String in)

console

public DoubleStreamBuilder console()

id

public DoubleStreamBuilder id(String nodeId)