Detailed Description

Encapsulates a chain of processors as if it were a single one.

Author: Sylvain Hallé

Since: 0.1

Definition at line 42 of file GroupProcessor.java.

Classes
class	InputOutputAssociation
class	ProcessorAssociation
	Tuple made of a number and a processor. More...
class	CopyCrawler
	Crawler that creates copies (clones) of whatever it encounters on its way and re-pipes processors as in the original group. More...
class	CollectCrawler
	A crawler that adds to the group any processor it encounters. More...
class	ProxyPullable
class	ProxyPushable
class	OutputCallAfterConnect
	A `CallAfterConnect` object that can be used to connect the underlying processor of a `GroupProcessor`, and then to collect all processors that are part of the group. More...

Public Member Functions
	GroupProcessor (int in_arity, int out_arity)
	Creates a group processor.
	GroupProcessor ()
	No-args constructor assuming an input and output arity of 1.
GroupProcessor	notifySources (boolean b)
	Sets the processor to notify the QueueSource objects in the group to push an event when a call to push is made on the group.
EventTracker	getInnerTracker ()
	Gets the tracker instance for the processors contained in this group.
void	putAt (int index, SelectedInputPipe p)
void	putAt (int index, SelectedOutputPipe p)
GroupProcessor	addProcessor (Processor p)
	Adds a processor to the group.
GroupProcessor	addProcessors (Processor ... procs)
	Adds multiple processors to the group.
GroupProcessor	associateInput (int i, Processor p, int j)
	Declares that the i-th input of the group is linked to the j-th input of processor `p`.
GroupProcessor	associateInput (Processor p)
	Declares that the first (i.e.
GroupProcessor	associateOutput (int i, Processor p, int j)
	Declares that the i-th output of the group is linked to the j-th output of processor p.
GroupProcessor	associateOutput (Processor p)
	Declares that the first (i.e.
ProxyPushable	getPushableInput (int index)
	Returns the `Pushable` corresponding to the processor's i-th input trace.
Pullable	getPullableOutput (int index)
	Returns the `Pullable` corresponding to the processor's i-th output trace.
final void	setPullableInput (int i, Pullable p)
	Assigns a `Pullable` to the processor's i-th input.
final void	setPushableOutputAssociation (int i, Processor p, int j)
final void	setPushableOutput (int i, Pushable p)
	Assigns a `Pushable` to the processor's i-th output.
final void	setPullableInputAssociation (int i, Processor p, int j)
final void	setPushableInput (int i, Pushable p)
	Sets an input pushable for this processor.
final void	setPullableOutput (int i, Pullable p)
	Sets an output pullable for this processor.
final Pushable	getPushableOutput (int index)
	Retrieves the `Pushable` associated to the processor's i-th output.
final Pullable	getPullableInput (int index)
	Returns the `Pullable` corresponding to the processor's i-th input.
Map< Integer, Processor >	cloneInto (GroupProcessor group, boolean with_state)
	Clones the contents of the current `GroupProcessor` into a new group.
Processor	in (Processor p)
	Sets a processor as the input 0 of the group.
CallAfterConnect	out (Processor p)
	Sets a processor as the output 0 of the group, and crawls the pipeline backwards from that processor to add all other processors encountered along the way.
GroupProcessor	duplicate (boolean with_state)
	Duplicates an object.
void	setContext (Context context)
	Adds a complete context to this object.
void	setContext (String key, Object value)
	Adds an object to the object's context.
void	start ()
	Starts the processor.
void	stop ()
	Stops the processor.
Processor	getAssociatedInput (int index)
	Gets the processor associated to the i-th input of the group.
int	getGroupInputIndex (int id, int pipe_index)
	Gets the index of the group's input pipe associated to the inner processor with given ID and pipe index.
int	getAssociatedInputIndex (int index)
	Gets the input stream index of the processor associated to the i-th input of the group.
Processor	getAssociatedOutput (int index)
	Gets the processor associated to the i-th output of the group.
int	getAssociatedOutputIndex (int index)
	Gets the output stream index of the processor associated to the i-th output of the group.
boolean	onEndOfTrace (Queue< Object[]> outputs)
	Allows to describe a specific behavior when the trace of input fronts has reached its end.
Object	printState ()
GroupProcessor	readState (Object o) throws ProcessorException
void	reset ()
	Resets the processor.
final Processor	setEventTracker (EventTracker tracker)
	Associates an event tracker to this processor.
Object	getState ()
	Gets the token corresponding to the processor's internal state.
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.
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.
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	getInputTypesFor (Set< Class<?> > classes, int index)
	Populates the set of classes accepted by the processor for its i-th input.
Class<?>	getOutputType (int index)
	Returns the type of the events produced by the processor for its i-th output.
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
void	associateEndpoints (GroupProcessor group, Map< Integer, Processor > new_procs)
	Associates the endpoints of a new `GroupProcessor` like the ones in the current group.
void	collectProcessors (Processor start)
	Crawls the network of processors and adds to `m_processors` any processor that is not already present in the list.
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.

Static Protected Member Functions
static Processor	copyProcessor (Processor p, boolean with_state)
	Creates a copy of a processor.
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
EventTracker	m_innerTracker
	An inner event tracker for the group.
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 `Pullable`s, one for each input trace this processor receives.
transient Pushable[]	m_outputPushables
	An array of `Pushable`s, 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.

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.

Constructor & Destructor Documentation

◆ GroupProcessor() [1/2]

ca.uqac.lif.cep.GroupProcessor.GroupProcessor	(	int	in_arity,
		int	out_arity )

Creates a group processor.

Parameters

in_arity	The input arity
out_arity	The output arity

Definition at line 97 of file GroupProcessor.java.

◆ GroupProcessor() [2/2]

ca.uqac.lif.cep.GroupProcessor.GroupProcessor ( )

No-args constructor assuming an input and output arity of 1.

Definition at line 112 of file GroupProcessor.java.

Member Function Documentation

◆ addProcessor()

GroupProcessor ca.uqac.lif.cep.GroupProcessor.addProcessor ( Processor p )

Adds a processor to the group.

Parameters

p	The processor to add

Returns: A reference to the current group processor

Definition at line 228 of file GroupProcessor.java.

◆ addProcessors()

GroupProcessor ca.uqac.lif.cep.GroupProcessor.addProcessors ( Processor ... procs )

Adds multiple processors to the group.

Parameters

procs The processors to add

Returns: A reference to the current group processor

Definition at line 249 of file GroupProcessor.java.

◆ associateEndpoints()

void ca.uqac.lif.cep.GroupProcessor.associateEndpoints	(	GroupProcessor	group,
		Map< Integer, Processor >	new_procs )

protected

Associates the endpoints of a new GroupProcessor like the ones in the current group.

Parameters

group	The new group
new_procs	An association between processor IDs and processors

Definition at line 483 of file GroupProcessor.java.

◆ associateInput() [1/2]

GroupProcessor ca.uqac.lif.cep.GroupProcessor.associateInput	(	int	i,
		Processor	p,
		int	j )

Declares that the i-th input of the group is linked to the j-th input of processor p.

Parameters

i	The number of the input of the group
p	The processor to connect to
j	The number of the input of processor `p`

Returns: A reference to the current group processor

Definition at line 278 of file GroupProcessor.java.

◆ associateInput() [2/2]

GroupProcessor ca.uqac.lif.cep.GroupProcessor.associateInput ( Processor p )

Declares that the first (i.e.

0-th) input of the group is linked to the first (i.e. 0-th) input of processor p.

Parameters

p	The processor to connect to

Returns: A reference to the current group processor

Definition at line 291 of file GroupProcessor.java.

◆ associateOutput() [1/2]

GroupProcessor ca.uqac.lif.cep.GroupProcessor.associateOutput	(	int	i,
		Processor	p,
		int	j )

Declares that the i-th output of the group is linked to the j-th output of processor p.

Parameters

i	The number of the output of the group
p	The processor to connect to
j	The number of the output of processor `p`

Returns: A reference to the current group processor

Definition at line 308 of file GroupProcessor.java.

◆ associateOutput() [2/2]

GroupProcessor ca.uqac.lif.cep.GroupProcessor.associateOutput ( Processor p )

Declares that the first (i.e.

0-th) output of the group is linked to the first (i.e. 0-th) output of processor p.

Parameters

p	The processor to connect to

Returns: A reference to the current group processor

Definition at line 321 of file GroupProcessor.java.

◆ cloneInto()

Map< Integer, Processor > ca.uqac.lif.cep.GroupProcessor.cloneInto	(	GroupProcessor	group,
		boolean	with_state )

Clones the contents of the current GroupProcessor into a new group.

Parameters

group	The `GroupProcessor` to clone into. When the method is called, it is expected to be empty.
with_state	It set to `true`, each processor in the new group has the same events in its input/output buffers as in the original. Otherwise, the queues are empty.

Returns: An association between IDs and the new processors that have been put into the group

Definition at line 439 of file GroupProcessor.java.

◆ collectProcessors()

void ca.uqac.lif.cep.GroupProcessor.collectProcessors ( Processor start )

protected

Crawls the network of processors and adds to m_processors any processor that is not already present in the list.

Parameters

start The starting point of the collection

Definition at line 588 of file GroupProcessor.java.

◆ copyProcessor()

Processor ca.uqac.lif.cep.GroupProcessor.copyProcessor	(	Processor	p,
		boolean	with_state )

staticprotected

Creates a copy of a processor.

Parameters

p	The processor to copy. Nothing is changed on this processor.
with_state	If set to `true`, the new copy has the same events in its input/output buffers as the original. Otherwise, the queues are empty.

Returns: The new processor

Definition at line 604 of file GroupProcessor.java.

◆ duplicate()

GroupProcessor ca.uqac.lif.cep.GroupProcessor.duplicate ( boolean with_state )

Duplicates an object.

Optionally, set the object into the same state as the source object.

Parameters

with_state Set to true to replicate the object's state, false to create a new copy in the initial state.

Returns: Another object

Reimplemented from ca.uqac.lif.cep.Processor.

Definition at line 624 of file GroupProcessor.java.

◆ getAssociatedInput()

Processor ca.uqac.lif.cep.GroupProcessor.getAssociatedInput ( int index )

Gets the processor associated to the i-th input of the group.

Parameters

index The index

Returns: The processor, or null if no processor is associated to this index

Definition at line 977 of file GroupProcessor.java.

◆ getAssociatedInputIndex()

int ca.uqac.lif.cep.GroupProcessor.getAssociatedInputIndex ( int index )

Gets the input stream index of the processor associated to the i-th input of the group.

Parameters

index The index

Returns: The index, or -1 if no processor is associated to this index

Definition at line 1016 of file GroupProcessor.java.

◆ getAssociatedOutput()

Processor ca.uqac.lif.cep.GroupProcessor.getAssociatedOutput ( int index )

Gets the processor associated to the i-th output of the group.

Parameters

index The index

Returns: The processor, or null if no processor is associated to this index

Definition at line 1033 of file GroupProcessor.java.

◆ getAssociatedOutputIndex()

int ca.uqac.lif.cep.GroupProcessor.getAssociatedOutputIndex ( int index )

Gets the output stream index of the processor associated to the i-th output of the group.

Parameters

index The index

Returns: The index, or -1 if no processor is associated to this index

Definition at line 1051 of file GroupProcessor.java.

◆ getGroupInputIndex()

int ca.uqac.lif.cep.GroupProcessor.getGroupInputIndex	(	int	id,
		int	pipe_index )

Gets the index of the group's input pipe associated to the inner processor with given ID and pipe index.

Parameters

id	The ID of the inner processor
pipe_index	The input pipe index of the inner processor

Returns: The index of the group's input pipe, or -1 if no such association exists

Definition at line 994 of file GroupProcessor.java.

◆ getInnerTracker()

EventTracker ca.uqac.lif.cep.GroupProcessor.getInnerTracker ( )

Gets the tracker instance for the processors contained in this group.

Returns: The tracker instance, or null if no inner tracker is set.

Since: 0.11

Definition at line 136 of file GroupProcessor.java.

◆ getPullableInput()

final Pullable ca.uqac.lif.cep.GroupProcessor.getPullableInput ( int i )

Returns the Pullable corresponding to the processor's i-th input.

Parameters

i	The index of the input. Should be greater than 0 and less than the processor's output arity. Outside these bounds, an ArrayIndexOutOfBounds will be thrown.

Returns: The pullable

Reimplemented from ca.uqac.lif.cep.Processor.

Definition at line 416 of file GroupProcessor.java.

◆ getPullableOutput()

Pullable ca.uqac.lif.cep.GroupProcessor.getPullableOutput ( int index )

Returns the Pullable corresponding to the processor's i-th output trace.

Parameters

index The index. Should be between 0 and the processor's output arity - 1 (since indices start at 0).

Returns: The pullable if the index is within the appropriate range, null otherwise.

Reimplemented from ca.uqac.lif.cep.Processor.

Definition at line 333 of file GroupProcessor.java.

◆ getPushableInput()

ProxyPushable ca.uqac.lif.cep.GroupProcessor.getPushableInput ( int index )

Returns the Pushable corresponding to the processor's i-th input trace.

Parameters

index The index. Should be between 0 and the processor's input arity - 1 (since indices start at 0).

Returns: The pushable if the index is within the appropriate range. Outside of the range,

Reimplemented from ca.uqac.lif.cep.Processor.

Definition at line 327 of file GroupProcessor.java.

◆ getPushableOutput()

final Pushable ca.uqac.lif.cep.GroupProcessor.getPushableOutput ( int i )

Retrieves the Pushable associated to the processor's i-th output.

Parameters

i	The index of the output. Should be greater than 0 (not checked) and less than the processor's output arity. Outside these bounds, an ArrayIndexOutOfBounds will be thrown.

Returns: The pushable

Reimplemented from ca.uqac.lif.cep.Processor.

Definition at line 405 of file GroupProcessor.java.

◆ getState()

Object ca.uqac.lif.cep.GroupProcessor.getState ( )

Gets the token corresponding to the processor's internal state.

Returns: The token

Exceptions

UnsupportedOperationException Thrown if the internal state cannot be provided for some reason

Implements ca.uqac.lif.cep.Stateful.

Definition at line 1211 of file GroupProcessor.java.

◆ in()

Processor ca.uqac.lif.cep.GroupProcessor.in ( Processor p )

Sets a processor as the input 0 of the group.

This method is similar to associateInput(Processor), except that it also automatically adds the argument to the group (something that the other method does not do).

This method has little interest when using BeepBeep from Java. However, in Groovy, it makes it possible to create a pipeline in a group by sparing the user from calling addProcessor() and associateInput() separately. For instance, one could write (assuming that P1, P2 and P3 are processor instances):

g = new GroupProcessor() {{
  in(P1) | P2 | out(P3)
}}

The single line creates the pipeline, associates P1 as the input of the group, P3 as its output, and automatically adds P1, P2 and P3 to the group (that later task is taken care of by out(Processor).

Parameters

p	The processor to set as the input of the group

Returns: That processor

Since: 0.11.3

Definition at line 529 of file GroupProcessor.java.

◆ notifySources()

GroupProcessor ca.uqac.lif.cep.GroupProcessor.notifySources ( boolean b )

Sets the processor to notify the QueueSource objects in the group to push an event when a call to push is made on the group.

Parameters

b	Set to `true` to notify the sources

Returns: This group processor

Definition at line 125 of file GroupProcessor.java.

◆ onEndOfTrace()

boolean ca.uqac.lif.cep.GroupProcessor.onEndOfTrace ( Queue< Object[]> outputs )

Allows to describe a specific behavior when the trace of input fronts has reached its end.

Called in "push mode" only. In "pull mode", implementing such a behavior can be done by using Pullable#hasNext() or Pullable#hasNextSoft().

Parameters

outputs A queue of arrays of objects. The processor should push arrays into this queue for every output front it produces. The size of each array should be equal to the processor's output arity, although this is not enforced.

Returns: true if the processor should output one or several output fronts, false otherwise and by default.

Exceptions

ProcessorException An exception thrown when a problem occurs with the operation

Reimplemented from ca.uqac.lif.cep.Processor.

Definition at line 1061 of file GroupProcessor.java.

◆ out()

CallAfterConnect ca.uqac.lif.cep.GroupProcessor.out ( Processor p )

Sets a processor as the output 0 of the group, and crawls the pipeline backwards from that processor to add all other processors encountered along the way.

This method has little interest when using BeepBeep from Java. However, in Groovy, it makes it possible to create a pipeline in a group by sparing the user from calling addProcessor() and associateOutput() separately. For instance, one could write (assuming that P1, P2 and P3 are processor instances):

g = new GroupProcessor() {{
  in(P1) | P2 | out(P3)
}}

The single line creates the pipeline, associates P1 as the input of the group, P3 as its output, and automatically adds P1, P2 and P3 to the group.

The reason why this method returns a CallAfterConnect object, instead of just a processor, comes from the fact that in the context of a Groovy script, method out is called before the processor is connected upstream to the rest of the chain (hence in the previous example, before P3 is connected to P2). Therefore, trying to harvest other processors in the group by working up the chain from p, in the context of this method, would not return anything.

The workaround is therefore to pass this object, which will allow the processor to be connected, and then for upstream processors to be harvested by collectProcessors(Processor) through the call to CallAfterConnect#call().

Parameters

p	The processor to set as the output of the group

Returns: A CallAfterConnect object, which allows the underlying processor to be connected, and then for upstream processors to be harvested by collectProcessors(Processor).

Since: 0.11.3

Definition at line 576 of file GroupProcessor.java.

◆ printState()

Object ca.uqac.lif.cep.GroupProcessor.printState ( )

Since: 0.10.2

Reimplemented from ca.uqac.lif.cep.Processor.

Definition at line 1070 of file GroupProcessor.java.

◆ putAt() [1/2]

void ca.uqac.lif.cep.GroupProcessor.putAt	(	int	index,
		SelectedInputPipe	p )

Definition at line 141 of file GroupProcessor.java.

◆ putAt() [2/2]

void ca.uqac.lif.cep.GroupProcessor.putAt	(	int	index,
		SelectedOutputPipe	p )

Definition at line 146 of file GroupProcessor.java.

◆ readState()

GroupProcessor ca.uqac.lif.cep.GroupProcessor.readState ( Object o ) throws ProcessorException

Since: 0.10.2

Reimplemented from ca.uqac.lif.cep.Processor.

Definition at line 1114 of file GroupProcessor.java.

◆ reset()

void ca.uqac.lif.cep.GroupProcessor.reset ( )

Resets the processor.

This has for effect of flushing the contents of all input and output event queues. If the processor has an internal state, this should also reset this state to its "initial" settings (whatever that means in your context).

Reimplemented from ca.uqac.lif.cep.Processor.

Definition at line 1178 of file GroupProcessor.java.

◆ setContext() [1/2]

void ca.uqac.lif.cep.GroupProcessor.setContext ( Context context )

Adds a complete context to this object.

Parameters

context The context to add

Reimplemented from ca.uqac.lif.cep.Processor.

Definition at line 708 of file GroupProcessor.java.

◆ setContext() [2/2]

void ca.uqac.lif.cep.GroupProcessor.setContext	(	String	key,
		Object	value )

Adds an object to the object's context.

Parameters

key	The key associated to that object
value	The object

Reimplemented from ca.uqac.lif.cep.Processor.

Definition at line 718 of file GroupProcessor.java.

◆ setEventTracker()

final Processor ca.uqac.lif.cep.GroupProcessor.setEventTracker ( EventTracker tracker )

Associates an event tracker to this processor.

Parameters

tracker The event tracker, or null to remove the association to an existing tracker

Returns: This processor

Reimplemented from ca.uqac.lif.cep.Processor.

Definition at line 1192 of file GroupProcessor.java.

◆ setPullableInput()

final void ca.uqac.lif.cep.GroupProcessor.setPullableInput	(	int	i,
		Pullable	p )

Assigns a Pullable to the processor's i-th input.

Parameters

i	The index of the input. An ArrayIndexOutOfBounds will be thrown if it is out of range.
p	The pullable to assign it to

Reimplemented from ca.uqac.lif.cep.Processor.

Definition at line 339 of file GroupProcessor.java.

◆ setPullableInputAssociation()

final void ca.uqac.lif.cep.GroupProcessor.setPullableInputAssociation	(	int	i,
		Processor	p,
		int	j )

Definition at line 365 of file GroupProcessor.java.

◆ setPullableOutput()

final void ca.uqac.lif.cep.GroupProcessor.setPullableOutput	(	int	i,
		Pullable	p )

Sets an output pullable for this processor.

Parameters

i	The index of the pullable
p	The pullable

Definition at line 392 of file GroupProcessor.java.

◆ setPushableInput()

final void ca.uqac.lif.cep.GroupProcessor.setPushableInput	(	int	i,
		Pushable	p )

Sets an input pushable for this processor.

Parameters

i	The position
p	The pushable

Definition at line 375 of file GroupProcessor.java.

◆ setPushableOutput()

final void ca.uqac.lif.cep.GroupProcessor.setPushableOutput	(	int	i,
		Pushable	p )

Assigns a Pushable to the processor's i-th output.

Parameters

i	The index of the output. Should be greater than 0 and less than the processor's output arity. Outside these bounds, an ArrayIndexOutOfBounds will be thrown.
p	The pushable to assign it to

Reimplemented from ca.uqac.lif.cep.Processor.

Definition at line 355 of file GroupProcessor.java.

◆ setPushableOutputAssociation()

final void ca.uqac.lif.cep.GroupProcessor.setPushableOutputAssociation	(	int	i,
		Processor	p,
		int	j )

Definition at line 349 of file GroupProcessor.java.

◆ start()

void ca.uqac.lif.cep.GroupProcessor.start ( )

Starts the processor.

This has no effect, except for processors that use threads; in such a case, calling this method should start the thread.

Reimplemented from ca.uqac.lif.cep.Processor.

Definition at line 950 of file GroupProcessor.java.

◆ stop()

void ca.uqac.lif.cep.GroupProcessor.stop ( )

Stops the processor.

This has no effect, except for processors that use threads; in such a case, calling this method should stop the thread.

Reimplemented from ca.uqac.lif.cep.Processor.

Definition at line 960 of file GroupProcessor.java.

Member Data Documentation

◆ m_innerTracker

EventTracker ca.uqac.lif.cep.GroupProcessor.m_innerTracker

protected

An inner event tracker for the group.

Definition at line 87 of file GroupProcessor.java.

The documentation for this class was generated from the following file:

/home/sylvain/Workspaces/beepbeep/core/src/ca/uqac/lif/cep/GroupProcessor.java

Detailed Description

Classes

Public Member Functions

Protected Member Functions

Static Protected Member Functions

Protected Attributes

Additional Inherited Members

Constructor & Destructor Documentation

◆ GroupProcessor() [1/2]

◆ GroupProcessor() [2/2]

Member Function Documentation

◆ addProcessor()

◆ addProcessors()

◆ associateEndpoints()

◆ associateInput() [1/2]

◆ associateInput() [2/2]

◆ associateOutput() [1/2]

◆ associateOutput() [2/2]

◆ cloneInto()

◆ collectProcessors()

◆ copyProcessor()

◆ duplicate()

◆ getAssociatedInput()

◆ getAssociatedInputIndex()

◆ getAssociatedOutput()

◆ getAssociatedOutputIndex()

◆ getGroupInputIndex()

◆ getInnerTracker()

◆ getPullableInput()

◆ getPullableOutput()

◆ getPushableInput()

◆ getPushableOutput()

◆ getState()

◆ in()

◆ notifySources()

◆ onEndOfTrace()

◆ out()

◆ printState()

◆ putAt() [1/2]

◆ putAt() [2/2]

◆ readState()

◆ reset()

◆ setContext() [1/2]

◆ setContext() [2/2]

◆ setEventTracker()

◆ setPullableInput()

◆ setPullableInputAssociation()

◆ setPullableOutput()

◆ setPushableInput()

◆ setPushableOutput()

◆ setPushableOutputAssociation()

◆ start()

◆ stop()

Member Data Documentation

◆ m_innerTracker