com.fluxtion.compiler.builder.stream

Class IntStreamBuilder

java.lang.Object

com.fluxtion.compiler.builder.stream.IntStreamBuilder

All Implemented Interfaces:

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

public class IntStreamBuilder
extends Object
implements com.fluxtion.runtime.stream.EventStream.EventSupplierAccessor<com.fluxtion.runtime.stream.EventStream.IntEventSupplier>

Method Summary

Modifier and Type	Method and Description
<F extends com.fluxtion.runtime.stream.aggregate.IntAggregateFunction<F>> IntStreamBuilder	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>> IntStreamBuilder	slidingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction, int bucketSizeMillis, int numberOfBuckets)
<F extends com.fluxtion.runtime.stream.aggregate.IntAggregateFunction<F>> IntStreamBuilder	tumblingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction, int bucketSizeMillis)
IntStreamBuilder	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.IntEventSupplier getEventSupplier()

Specified by:

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

updateTrigger

public IntStreamBuilder updateTrigger(Object updateTrigger)

publishTrigger

public IntStreamBuilder publishTrigger(Object publishTrigger)

publishTriggerOverride

public IntStreamBuilder publishTriggerOverride(Object publishTrigger)

resetTrigger

public IntStreamBuilder resetTrigger(Object resetTrigger)

filter

public IntStreamBuilder filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntFunction<Boolean> filterFunction)

filter

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

defaultValue

public IntStreamBuilder defaultValue(int defaultValue)

map

public IntStreamBuilder map(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntUnaryOperator int2IntFunction)

mapBiFunction

public IntStreamBuilder mapBiFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiIntFunction int2IntFunction,
                                      IntStreamBuilder stream2Builder)

aggregate

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

tumblingAggregate

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

slidingAggregate

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

mapOnNotify

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

box

public EventStreamBuilder<Integer> box()

mapToObj

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

mapToDouble

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

mapToLong

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

notify

public IntStreamBuilder notify(Object target)

sink

public IntStreamBuilder sink(String sinkId)

push

public IntStreamBuilder push(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntConsumer pushFunction)

peek

public IntStreamBuilder peek(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<Integer> peekFunction)

console

public IntStreamBuilder console(String in)

console

public IntStreamBuilder console()

id

public IntStreamBuilder id(String nodeId)