quarks.oplet.core

Class Split<T>

java.lang.Object

quarks.oplet.core.AbstractOplet<T,T>

quarks.oplet.core.Split<T>

Type Parameters:

T - Type of the tuple.

All Implemented Interfaces:

java.io.Serializable, java.lang.AutoCloseable, Consumer<T>, Oplet<T,T>

public class Split<T>
extends AbstractOplet<T,T>
implements Consumer<T>

Split a stream into multiple streams depending on the result of a splitter function.
For each tuple a function is called:

• If the return is negative the tuple is dropped.
• Otherwise the return value is modded by the number of output ports and the result is the output port index the tuple is submitted to.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Split(ToIntFunction<T> splitter)

Method Summary

Modifier and Type	Method and Description
void	accept(T tuple) Apply the function to value.
void	close()
java.util.List<Consumer<T>>	getInputs() Get the input stream data handlers for this oplet.
void	initialize(OpletContext<T,T> context) Initialize the oplet.
void	start() Start the oplet.

Methods inherited from class quarks.oplet.core.AbstractOplet

getOpletContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Split

public Split(ToIntFunction<T> splitter)

Method Detail

initialize

public void initialize(OpletContext<T,T> context)

Description copied from interface: Oplet

Initialize the oplet.

Specified by:

initialize in interface Oplet<T,T>

Overrides:

initialize in class AbstractOplet<T,T>

start

public void start()

Description copied from interface: Oplet

Start the oplet. Oplets must not submit any tuples not derived from input tuples until this method is called.

Specified by:

start in interface Oplet<T,T>

getInputs

public java.util.List<Consumer<T>> getInputs()

Description copied from interface: Oplet

Get the input stream data handlers for this oplet. The number of handlers must equal the number of configured input ports. Each tuple arriving on an input port will be sent to the stream handler for that input port.

Specified by:

getInputs in interface Oplet<T,T>

Returns:

list of consumers

accept

public void accept(T tuple)

Description copied from interface: Consumer

Apply the function to value.

Specified by:

accept in interface Consumer<T>

Parameters:

tuple - Value function is applied to.

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception