| addProcessor(Processor p) | ca.uqac.lif.cep.GroupProcessor | |
| addProcessors(Processor ... procs) | ca.uqac.lif.cep.GroupProcessor | |
| allNotifiedEndOfTrace() | ca.uqac.lif.cep.Processor | protected |
| allNull(Object[] v) | ca.uqac.lif.cep.Processor | static |
| associateEndpoints(GroupProcessor group, Map< Integer, Processor > new_procs) | ca.uqac.lif.cep.GroupProcessor | protected |
| associateInput(int i, Processor p, int j) | ca.uqac.lif.cep.GroupProcessor | |
| associateOutput(int i, Processor p, int j) | ca.uqac.lif.cep.GroupProcessor | |
| associateTo(NodeFunction f, int out_stream_index, int out_stream_pos) | ca.uqac.lif.cep.Processor | |
| associateToInput(int in_stream_index, int in_stream_pos, int out_stream_index, int out_stream_pos) | ca.uqac.lif.cep.Processor | |
| associateToOutput(int in_stream_index, int in_stream_pos, int out_stream_index, int out_stream_pos) | ca.uqac.lif.cep.Processor | |
| cloneInto(GroupProcessor group, boolean with_state) | ca.uqac.lif.cep.GroupProcessor | |
| copyInputQueue(int index, Collection< Object > to) | ca.uqac.lif.cep.Processor | |
| copyOutputQueue(int index, Collection< Object > to) | ca.uqac.lif.cep.Processor | |
| copyProcessor(Processor p, boolean with_state) | ca.uqac.lif.cep.GroupProcessor | protectedstatic |
| duplicate(boolean with_state) | ca.uqac.lif.cep.GroupProcessor | |
| ca::uqac::lif::cep::Processor.duplicate() | ca.uqac.lif.cep.Processor | |
| duplicateInto(Processor p) | ca.uqac.lif.cep.Processor | |
| equals(Object o) | ca.uqac.lif.cep.Processor | |
| getAssociatedInput(int index) | ca.uqac.lif.cep.GroupProcessor | |
| getAssociatedInputIndex(int index) | ca.uqac.lif.cep.GroupProcessor | |
| getAssociatedOutput(int index) | ca.uqac.lif.cep.GroupProcessor | |
| getAssociatedOutputIndex(int index) | ca.uqac.lif.cep.GroupProcessor | |
| getAt(int index) | ca.uqac.lif.cep.Processor | |
| getContext(String key) | ca.uqac.lif.cep.Processor | |
| getContext() | ca.uqac.lif.cep.Processor | |
| getEmptyQueue() | ca.uqac.lif.cep.Processor | static |
| getEventTracker() | ca.uqac.lif.cep.Processor | |
| getGroupInputIndex(int id, int pipe_index) | ca.uqac.lif.cep.GroupProcessor | |
| getId() | ca.uqac.lif.cep.Processor | |
| getInnerTracker() | ca.uqac.lif.cep.GroupProcessor | |
| getInputArity() | ca.uqac.lif.cep.Processor | |
| getInputCount() | ca.uqac.lif.cep.Processor | |
| getInputType(int index) | ca.uqac.lif.cep.Processor | |
| getInputTypesFor(Set< Class<?>> classes, int index) | ca.uqac.lif.cep.Processor | |
| getLeaves(ProvenanceNode root) | ca.uqac.lif.cep.Processor | static |
| getLeaves(ProvenanceNode root, List< ProvenanceNode > leaves) | ca.uqac.lif.cep.Processor | protectedstatic |
| getOutputArity() | ca.uqac.lif.cep.Processor | |
| getOutputCount() | ca.uqac.lif.cep.Processor | |
| getOutputType(int index) | ca.uqac.lif.cep.Processor | |
| getPullableInput(int index) | ca.uqac.lif.cep.GroupProcessor | |
| getPullableOutput(int index) | ca.uqac.lif.cep.GroupProcessor | |
| ca::uqac::lif::cep::Processor.getPullableOutput() | ca.uqac.lif.cep.Processor | |
| getPushableInput(int index) | ca.uqac.lif.cep.GroupProcessor | |
| ca::uqac::lif::cep::Processor.getPushableInput() | ca.uqac.lif.cep.Processor | |
| getPushableOutput(int index) | ca.uqac.lif.cep.GroupProcessor | |
| getState() | ca.uqac.lif.cep.GroupProcessor | |
| GroupProcessor(int in_arity, int out_arity) | ca.uqac.lif.cep.GroupProcessor | |
| GroupProcessor() | ca.uqac.lif.cep.GroupProcessor | protected |
| hashCode() | ca.uqac.lif.cep.Processor | |
| m_context | ca.uqac.lif.cep.Processor | protected |
| m_eventTracker | ca.uqac.lif.cep.Processor | protected |
| m_hasBeenNotifiedOfEndOfTrace | ca.uqac.lif.cep.Processor | protected |
| m_innerTracker | ca.uqac.lif.cep.GroupProcessor | protected |
| m_inputArity | ca.uqac.lif.cep.Processor | protected |
| m_inputCount | ca.uqac.lif.cep.Processor | protected |
| m_inputPullables | ca.uqac.lif.cep.Processor | protected |
| m_inputQueues | ca.uqac.lif.cep.Processor | protected |
| m_outputArity | ca.uqac.lif.cep.Processor | protected |
| m_outputCount | ca.uqac.lif.cep.Processor | protected |
| m_outputPushables | ca.uqac.lif.cep.Processor | protected |
| m_outputQueues | ca.uqac.lif.cep.Processor | protected |
| MAX_PULL_RETRIES | ca.uqac.lif.cep.Processor | static |
| newContext() | ca.uqac.lif.cep.Processor | protected |
| notifySources(boolean b) | ca.uqac.lif.cep.GroupProcessor | |
| onEndOfTrace(Queue< Object[]> outputs) | ca.uqac.lif.cep.GroupProcessor | |
| or(Processor p) | ca.uqac.lif.cep.Processor | |
| or(Pushable p) | ca.uqac.lif.cep.Processor | |
| print(ObjectPrinter<?> printer) | ca.uqac.lif.cep.Processor | |
| printState() | ca.uqac.lif.cep.GroupProcessor | |
| Processor(int in_arity, int out_arity) | ca.uqac.lif.cep.Processor | |
| read(ObjectReader<?> reader, Object o) | ca.uqac.lif.cep.Processor | |
| readState(Object o) | ca.uqac.lif.cep.GroupProcessor | |
| reset() | ca.uqac.lif.cep.GroupProcessor | |
| s_versionString | ca.uqac.lif.cep.Processor | static |
| setContext(Context context) | ca.uqac.lif.cep.GroupProcessor | |
| setContext(String key, Object value) | ca.uqac.lif.cep.GroupProcessor | |
| setEventTracker(EventTracker tracker) | ca.uqac.lif.cep.GroupProcessor | |
| setPullableInput(int i, Pullable p) | ca.uqac.lif.cep.GroupProcessor | |
| setPullableInputAssociation(int i, Processor p, int j) | ca.uqac.lif.cep.GroupProcessor | |
| setPullableOutput(int i, Pullable p) | ca.uqac.lif.cep.GroupProcessor | |
| setPushableInput(int i, Pushable p) | ca.uqac.lif.cep.GroupProcessor | |
| setPushableOutput(int i, Pushable p) | ca.uqac.lif.cep.GroupProcessor | |
| setPushableOutputAssociation(int i, Processor p, int j) | ca.uqac.lif.cep.GroupProcessor | |
| start() | ca.uqac.lif.cep.GroupProcessor | |
| startAll(Processor ... procs) | ca.uqac.lif.cep.Processor | static |
| stop() | ca.uqac.lif.cep.GroupProcessor | |
| stopAll(Processor ... procs) | ca.uqac.lif.cep.Processor | static |
1.8.13