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

Packages that use LongStreamBuilder

Package	Description
com.fluxtion.compiler.builder.stream

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

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

Modifier and Type	Method and Description
<F extends com.fluxtion.runtime.stream.aggregate.LongAggregateFunction<F>> LongStreamBuilder	LongStreamBuilder.aggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction)
LongStreamBuilder	LongStreamBuilder.console()
LongStreamBuilder	LongStreamBuilder.console(String in)
LongStreamBuilder	LongStreamBuilder.defaultValue(long defaultValue)
<S> LongStreamBuilder	LongStreamBuilder.filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiLongPredicate predicate, LongStreamBuilder secondArgument)
LongStreamBuilder	LongStreamBuilder.filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableLongFunction<Boolean> filterFunction)
LongStreamBuilder	LongStreamBuilder.id(String nodeId)
LongStreamBuilder	LongStreamBuilder.map(com.fluxtion.runtime.partition.LambdaReflection.SerializableLongUnaryOperator int2IntFunction)
LongStreamBuilder	LongStreamBuilder.mapBiFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiLongFunction int2IntFunction, LongStreamBuilder stream2Builder)
LongStreamBuilder	DoubleStreamBuilder.mapToLong(com.fluxtion.runtime.partition.LambdaReflection.SerializableDoubleToLongFunction int2IntFunction)
LongStreamBuilder	IntStreamBuilder.mapToLong(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntToLongFunction int2IntFunction)
LongStreamBuilder	EventStreamBuilder.mapToLong(com.fluxtion.runtime.partition.LambdaReflection.SerializableToLongFunction<T> mapFunction)
LongStreamBuilder	LongStreamBuilder.notify(Object target)
LongStreamBuilder	LongStreamBuilder.peek(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<Long> peekFunction)
LongStreamBuilder	LongStreamBuilder.publishTrigger(Object publishTrigger)
LongStreamBuilder	LongStreamBuilder.publishTriggerOverride(Object publishTrigger)
LongStreamBuilder	LongStreamBuilder.push(com.fluxtion.runtime.partition.LambdaReflection.SerializableLongConsumer pushFunction)
LongStreamBuilder	LongStreamBuilder.resetTrigger(Object resetTrigger)
LongStreamBuilder	LongStreamBuilder.sink(String sinkId)
<F extends com.fluxtion.runtime.stream.aggregate.LongAggregateFunction<F>> LongStreamBuilder	LongStreamBuilder.slidingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction, int bucketSizeMillis, int numberOfBuckets)
static LongStreamBuilder	EventFlow.subscribeToLongSignal(String filterId)
static LongStreamBuilder	EventFlow.subscribeToLongSignal(String filterId, long defaultValue)
<F extends com.fluxtion.runtime.stream.aggregate.LongAggregateFunction<F>> LongStreamBuilder	LongStreamBuilder.tumblingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction, int bucketSizeMillis)
LongStreamBuilder	LongStreamBuilder.updateTrigger(Object updateTrigger)

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

Modifier and Type	Method and Description
<S> EventStreamBuilder<T>	EventStreamBuilder.filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,Long,Boolean> predicate, LongStreamBuilder secondArgument)
<S> LongStreamBuilder	LongStreamBuilder.filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiLongPredicate predicate, LongStreamBuilder secondArgument)
<P,S> EventStreamBuilder<T>	EventStreamBuilder.filterByProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<P,Long,Boolean> predicate, com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,P> accessor, LongStreamBuilder secondArgument)
LongStreamBuilder	LongStreamBuilder.mapBiFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiLongFunction int2IntFunction, LongStreamBuilder stream2Builder)