allNotifiedEndOfTrace() | ca.uqac.lif.cep.Processor | protected |
allNull(Object[] v) | ca.uqac.lif.cep.Processor | static |
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 | |
copyInputQueue(int index, Collection< Object > to) | ca.uqac.lif.cep.Processor | |
copyOutputQueue(int index, Collection< Object > to) | ca.uqac.lif.cep.Processor | |
duplicate(boolean with_state) | ca.uqac.lif.cep.tmf.Tank | |
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 | |
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 | |
getId() | ca.uqac.lif.cep.Processor | |
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 i) | ca.uqac.lif.cep.Processor | |
getPullableOutput(int index) | ca.uqac.lif.cep.tmf.Tank | |
ca::uqac::lif::cep::Processor.getPullableOutput() | ca.uqac.lif.cep.Processor | |
getPushableInput(int index) | ca.uqac.lif.cep.tmf.Tank | |
ca::uqac::lif::cep::Processor.getPushableInput() | ca.uqac.lif.cep.Processor | |
getPushableOutput(int i) | ca.uqac.lif.cep.Processor | |
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_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 |
m_pullable | ca.uqac.lif.cep.tmf.Tank | protected |
m_pushable | ca.uqac.lif.cep.tmf.Tank | protected |
MAX_PULL_RETRIES | ca.uqac.lif.cep.Processor | static |
newContext() | ca.uqac.lif.cep.Processor | protected |
onEndOfTrace(Queue< Object[]> outputs) | ca.uqac.lif.cep.Processor | protected |
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.Processor | protected |
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.Processor | protected |
reset() | ca.uqac.lif.cep.tmf.Tank | |
s_versionString | ca.uqac.lif.cep.Processor | static |
setContext(String key, Object value) | ca.uqac.lif.cep.Processor | |
setContext(Context context) | ca.uqac.lif.cep.Processor | |
setEventTracker(EventTracker tracker) | ca.uqac.lif.cep.Processor | |
setPullableInput(int i, Pullable p) | ca.uqac.lif.cep.Processor | |
setPushableOutput(int i, Pushable p) | ca.uqac.lif.cep.Processor | |
start() | ca.uqac.lif.cep.Processor | |
startAll(Processor ... procs) | ca.uqac.lif.cep.Processor | static |
stop() | ca.uqac.lif.cep.Processor | |
stopAll(Processor ... procs) | ca.uqac.lif.cep.Processor | static |
Tank() | ca.uqac.lif.cep.tmf.Tank | |