com.fluxtion.compiler.builder.stream

Class LongStreamBuilder

java.lang.Object

com.fluxtion.compiler.builder.stream.LongStreamBuilder

All Implemented Interfaces:

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

public class LongStreamBuilder
extends Object
implements com.fluxtion.runtime.stream.EventStream.EventSupplierAccessor<com.fluxtion.runtime.stream.EventStream.LongEventSupplier>

Method Summary

Modifier and Type	Method and Description
<F extends com.fluxtion.runtime.stream.aggregate.LongAggregateFunction<F>> LongStreamBuilder	aggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction)
EventStreamBuilder<Long>	box()
LongStreamBuilder	console()
LongStreamBuilder	console(String in)
LongStreamBuilder	defaultValue(long defaultValue)
<S> LongStreamBuilder	filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiLongPredicate predicate, LongStreamBuilder secondArgument)
LongStreamBuilder	filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableLongFunction<Boolean> filterFunction)
com.fluxtion.runtime.stream.EventStream.LongEventSupplier	getEventSupplier()
LongStreamBuilder	id(String nodeId)
LongStreamBuilder	map(com.fluxtion.runtime.partition.LambdaReflection.SerializableLongUnaryOperator int2IntFunction)
LongStreamBuilder	mapBiFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiLongFunction int2IntFunction, LongStreamBuilder stream2Builder)
<T> EventStreamBuilder<T>	mapOnNotify(T target)
DoubleStreamBuilder	mapToDouble(com.fluxtion.runtime.partition.LambdaReflection.SerializableLongToDoubleFunction int2IntFunction)
IntStreamBuilder	mapToInt(com.fluxtion.runtime.partition.LambdaReflection.SerializableLongToIntFunction int2IntFunction)
<R> EventStreamBuilder<R>	mapToObj(com.fluxtion.runtime.partition.LambdaReflection.SerializableLongFunction<R> int2IntFunction)
LongStreamBuilder	notify(Object target)
LongStreamBuilder	peek(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<Long> peekFunction)
LongStreamBuilder	publishTrigger(Object publishTrigger)
LongStreamBuilder	publishTriggerOverride(Object publishTrigger)
LongStreamBuilder	push(com.fluxtion.runtime.partition.LambdaReflection.SerializableLongConsumer pushFunction)
LongStreamBuilder	resetTrigger(Object resetTrigger)
LongStreamBuilder	sink(String sinkId)
<F extends com.fluxtion.runtime.stream.aggregate.LongAggregateFunction<F>> LongStreamBuilder	slidingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction, int bucketSizeMillis, int numberOfBuckets)
<F extends com.fluxtion.runtime.stream.aggregate.LongAggregateFunction<F>> LongStreamBuilder	tumblingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction, int bucketSizeMillis)
LongStreamBuilder	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.LongEventSupplier getEventSupplier()

Specified by:

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

updateTrigger

public LongStreamBuilder updateTrigger(Object updateTrigger)

publishTrigger

public LongStreamBuilder publishTrigger(Object publishTrigger)

publishTriggerOverride

public LongStreamBuilder publishTriggerOverride(Object publishTrigger)

resetTrigger

public LongStreamBuilder resetTrigger(Object resetTrigger)

filter

public LongStreamBuilder filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableLongFunction<Boolean> filterFunction)

filter

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

defaultValue

public LongStreamBuilder defaultValue(long defaultValue)

map

public LongStreamBuilder map(com.fluxtion.runtime.partition.LambdaReflection.SerializableLongUnaryOperator int2IntFunction)

mapBiFunction

public LongStreamBuilder mapBiFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiLongFunction int2IntFunction,
                                       LongStreamBuilder stream2Builder)

aggregate

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

tumblingAggregate

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

slidingAggregate

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

mapOnNotify

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

box

public EventStreamBuilder<Long> box()

mapToObj

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

mapToInt

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

mapToDouble

public DoubleStreamBuilder mapToDouble(com.fluxtion.runtime.partition.LambdaReflection.SerializableLongToDoubleFunction int2IntFunction)

notify

public LongStreamBuilder notify(Object target)

sink

public LongStreamBuilder sink(String sinkId)

push

public LongStreamBuilder push(com.fluxtion.runtime.partition.LambdaReflection.SerializableLongConsumer pushFunction)

peek

public LongStreamBuilder peek(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<Long> peekFunction)

console

public LongStreamBuilder console(String in)

console

public LongStreamBuilder console()

id

public LongStreamBuilder id(String nodeId)