 |
0.11.4
|
|
0.11.4
|
Creates a cumulative processor out of a cumulative function.
This is simply a ApplyFunction whose function is of a specific type (a CumulativeFunction).
It is represented graphically as:
In earlier versions of the library, this class was called CumulativeProcessor.
Definition at line 37 of file Cumulate.java.
Classes | |
| class | StartValue |
| Node function representing the start value defined for a particular function. More... | |
Public Member Functions | |
| Cumulate (CumulativeFunction<?> f) | |
| Creates a new instance of the processor from a cumulative function. | |
| Cumulate (BinaryFunction<?,?,?> f) | |
| Creates a new instance of the processor from a binary function. | |
| void | cloneInto (Cumulate c, boolean with_state) |
| Cumulate | duplicate (boolean with_state) |
| Duplicates an object. | |
| Object | printState () |
| Cumulate | readState (Object o) |
| Object | getState () |
| Public Member Functions inherited from ca.uqac.lif.cep.functions.ApplyFunction | |
| ApplyFunction (Function comp) | |
| Instantiates a new function processor. | |
| void | reset () |
| Resets the processor. | |
| final void | getInputTypesFor (Set< Class<?> > classes, int index) |
| Populates the set of classes accepted by the processor for its i-th input. | |
| final synchronized Class<?> | getOutputType (int index) |
| Returns the type of the events produced by the processor for its i-th output. | |
| String | toString () |
| Function | getFunction () |
| Gets the function associated to that processor. | |
| void | cloneInto (ApplyFunction af, boolean with_state) |
| Public Member Functions inherited from ca.uqac.lif.cep.UniformProcessor | |
| UniformProcessor (int in_arity, int out_arity, Context c) | |
| Creates a new uniform processor. | |
| UniformProcessor (int in_arity, int out_arity) | |
| Initializes a processor. | |
| Pullable | getPullableOutput (int index) |
Returns the Pullable corresponding to the processor's i-th output trace. | |
| Pushable | getPushableInput (int index) |
Returns the Pushable corresponding to the processor's i-th input trace. | |
| Public Member Functions inherited from ca.uqac.lif.cep.SynchronousProcessor | |
| SynchronousProcessor (int in_arity, int out_arity) | |
| Initializes a processor. | |
| final SynchronousProcessor | setEventTracker (EventTracker tracker) |
| Associates an event tracker to this processor. | |
| Public Member Functions inherited from ca.uqac.lif.cep.Processor | |
| Processor (int in_arity, int out_arity) | |
| Initializes a processor. | |
| final Object | getContext (String key) |
| Retrieves an object from the processor's context. | |
| Context | getContext () |
| Gets the context associated to this object. | |
| void | setContext (String key, Object value) |
| Adds an object to the object's context. | |
| void | setContext (Context context) |
| Adds a complete context to this object. | |
| final int | hashCode () |
Implementation of hashCode() specific to processors. | |
| final boolean | equals (Object o) |
Implementation of equals() specific to processors. | |
| final int | getId () |
| Fetches the processor instance's unique ID. | |
| final Pushable | getPushableInput () |
Returns the Pushable corresponding to the processor's first input trace. | |
| final Pullable | getPullableOutput () |
Returns the Pullable corresponding to the processor's first output trace. | |
| void | setPullableInput (int i, Pullable p) |
Assigns a Pullable to the processor's i-th input. | |
| Pullable | getPullableInput (int i) |
Returns the Pullable corresponding to the processor's i-th input. | |
| void | setPushableOutput (int i, Pushable p) |
Assigns a Pushable to the processor's i-th output. | |
| Pushable | getPushableOutput (int i) |
Retrieves the Pushable associated to the processor's i-th output. | |
| final int | getInputArity () |
| Returns the processor's input arity. | |
| final int | getOutputArity () |
| Returns the processor's output arity. | |
| void | duplicateInto (Processor p) |
| Copies the contents and state of the current processor into another. | |
| final Set< Class<?> > | getInputType (int index) |
| Gets the type of events the processor accepts for its i-th input trace. | |
| void | start () |
| Starts the processor. | |
| void | stop () |
| Stops the processor. | |
| final EventTracker | getEventTracker () |
| Gets the instance of event tracker associated to this processor. | |
| void | associateToInput (int in_stream_index, int in_stream_pos, int out_stream_index, int out_stream_pos) |
| Associates an input event to an output event. | |
| void | associateTo (NodeFunction f, int out_stream_index, int out_stream_pos) |
| Associates a node function to a particular event of processor's output stream. | |
| void | associateToOutput (int in_stream_index, int in_stream_pos, int out_stream_index, int out_stream_pos) |
| Associates an input event to an output event. | |
| final int | getInputCount () |
| Gets the number of event fronts received so far by this processor. | |
| final int | getOutputCount () |
| Gets the number of event fronts produced so far by this processor. | |
| final Object | print (ObjectPrinter<?> printer) throws ProcessorException |
| Prints the contents of this processor into an object printer. | |
| final Processor | read (ObjectReader<?> reader, Object o) throws ProcessorException |
| Reads the content of a processor from a serialized object. | |
| final Processor | duplicate () |
| Duplicates an object and sets it to its initial state. | |
| void | copyInputQueue (int index, Collection< Object > to) |
| Copies the content of one of the processor's input queue to a collection. | |
| void | copyOutputQueue (int index, Collection< Object > to) |
| Copies the content of one of the processor's output queue to a collection. | |
| Processor | or (Processor p) |
| Connects the first output pipe of this processor to the first input pipe of another processor. | |
| Processor | or (CallAfterConnect c) |
Operates similar to or(Processor), but also calls a method after the connection has been established. | |
| Processor | or (SelectedInputPipe p) |
| Connects the output at index 0 of the current processor to the input of another processor. | |
| PipeSelector | getAt (int index) |
Gets the PipeSelector object corresponding to the processor's input or output pipe for a given index. | |
| Pushable | rightShift (int index) |
| Pullable | leftShift (int index) |
| Queue< Object > | getInputQueue (int index) |
| Gets the content of the processor's input queue at a given index. | |
| Queue< Object > | getOutputQueue (int index) |
| Gets the content of the processor's output queue at a given index. | |
Protected Member Functions | |
| boolean | compute (Object[] inputs, Object[] outputs) |
| Computes one output events from its input events. | |
| Protected Member Functions inherited from ca.uqac.lif.cep.UniformProcessor | |
| final boolean | compute (Object[] inputs, Queue< Object[]> outputs) |
| Computes one or more output events from its input events. | |
| final boolean | onEndOfTrace (Queue< Object[]> outputs) |
| Allows to describe a specific behavior when the trace of input fronts has reached its end. | |
| boolean | onEndOfTrace (Object[] outputs) |
| Allows to describe a specific behavior when the trace of input fronts has reached its end. | |
| Protected Member Functions inherited from ca.uqac.lif.cep.Processor | |
| boolean | allNotifiedEndOfTrace () |
| Determines if all the upstream pushables have sent the end of trace notification. | |
| final Context | newContext () |
| Creates a new empty context map. | |
Additional Inherited Members | |
| Static Public Member Functions inherited from ca.uqac.lif.cep.Processor | |
| static boolean | allNull (Object[] v) |
| Checks if all objects in the array are null. | |
| static Queue< Object[]> | getEmptyQueue () |
| Gets an instance of an empty event queue. | |
| static void | startAll (Processor ... procs) |
| Starts all processors given as an argument. | |
| static void | stopAll (Processor ... procs) |
| Stops all processors given as an argument. | |
| static List< ProvenanceNode > | getLeaves (ProvenanceNode root) |
| Gets the leaves of a provenance tree. | |
| Static Public Attributes inherited from ca.uqac.lif.cep.Processor | |
| static final transient String | s_versionString = "0.11.2" |
| A string used to identify the program's version. | |
| static final transient int | MAX_PULL_RETRIES = 10000000 |
Number of times the Pullable#hasNext() method tries to produce an output from the input before giving up. | |
| Static Protected Member Functions inherited from ca.uqac.lif.cep.Processor | |
| static void | getLeaves (ProvenanceNode root, List< ProvenanceNode > leaves) |
| Accumulates the leaves of a provenance tree in a list. | |
| Protected Attributes inherited from ca.uqac.lif.cep.functions.ApplyFunction | |
| Function | m_function |
| The object responsible for the computation. | |
| ShiftTracker | m_shiftTracker |
| A shift tracker. | |
| Protected Attributes inherited from ca.uqac.lif.cep.UniformProcessor | |
| transient Object[] | m_outputArray |
| An array that will be used by the processor to compute its output. | |
| Protected Attributes inherited from ca.uqac.lif.cep.SynchronousProcessor | |
| final transient Queue< Object[]> | m_tempQueue |
A queue object that will be passed to the compute(Object[], Queue) method. | |
| final transient Pushable[] | m_inputPushables |
| An array of input pushables. | |
| transient Pullable[] | m_outputPullables |
| An array of output pullables. | |
| Protected Attributes inherited from ca.uqac.lif.cep.Processor | |
| int | m_inputArity |
| The processor's input arity, i.e. | |
| int | m_outputArity |
| The processor's output arity, i.e. | |
| transient Queue< Object >[] | m_inputQueues |
| An array of input event queues. | |
| transient EventTracker | m_eventTracker = null |
| An object that keeps track of the relationship between input and output events. | |
| transient Queue< Object >[] | m_outputQueues |
| An array of output event queues. | |
| transient Pullable[] | m_inputPullables |
An array of Pullables, one for each input trace this processor receives. | |
| transient Pushable[] | m_outputPushables |
An array of Pushables, one for each output trace this processor produces. | |
| int | m_inputCount = 0 |
| A counter incremented upon each input front processed. | |
| int | m_outputCount = 0 |
| A counter incremented upon each output front processed. | |
| Context | m_context = null |
| The context in which the processor is instantiated. | |
| boolean[] | m_hasBeenNotifiedOfEndOfTrace |
| Indicates whether the processor has been notified of the end of trace or not. | |
| boolean | m_notifiedEndOfTraceDownstream |
| Indicates whether the processor has notified the end of the trace to the downstream processors it is connected to. | |
| ca.uqac.lif.cep.functions.Cumulate.Cumulate | ( | CumulativeFunction<?> | f | ) |
Creates a new instance of the processor from a cumulative function.
| f | The cumulative function |
Definition at line 50 of file Cumulate.java.
| ca.uqac.lif.cep.functions.Cumulate.Cumulate | ( | BinaryFunction<?,?,?> | f | ) |
Creates a new instance of the processor from a binary function.
| f | The binary function |
Definition at line 61 of file Cumulate.java.
| void ca.uqac.lif.cep.functions.Cumulate.cloneInto | ( | Cumulate | c, |
| boolean | with_state ) |
Definition at line 182 of file Cumulate.java.
|
protected |
Computes one output events from its input events.
| inputs | An array of input events; its length corresponds to the processor's input arity |
| outputs | An array where the outputs are produced |
Reimplemented from ca.uqac.lif.cep.functions.ApplyFunction.
Definition at line 67 of file Cumulate.java.
| Cumulate ca.uqac.lif.cep.functions.Cumulate.duplicate | ( | boolean | with_state | ) |
Duplicates an object.
Optionally, set the object into the same state as the source object.
| with_state | Set to true to replicate the object's state, false to create a new copy in the initial state. |
Reimplemented from ca.uqac.lif.cep.functions.ApplyFunction.
Definition at line 188 of file Cumulate.java.
| Object ca.uqac.lif.cep.functions.Cumulate.getState | ( | ) |
Reimplemented from ca.uqac.lif.cep.functions.ApplyFunction.
Definition at line 218 of file Cumulate.java.
| Object ca.uqac.lif.cep.functions.Cumulate.printState | ( | ) |
Reimplemented from ca.uqac.lif.cep.functions.ApplyFunction.
Definition at line 199 of file Cumulate.java.
| Cumulate ca.uqac.lif.cep.functions.Cumulate.readState | ( | Object | o | ) |
Reimplemented from ca.uqac.lif.cep.functions.ApplyFunction.
Definition at line 208 of file Cumulate.java.
1.15.0