| addCrlf(boolean b) | ca.uqac.lif.cep.io.ReadLines | |
| 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 | |
| compute(Object[] inputs, Queue< Object[]> outputs) | ca.uqac.lif.cep.io.ReadLines | protected |
| copyInputQueue(int index, Collection< Object > to) | ca.uqac.lif.cep.Processor | |
| copyOutputQueue(int index, Collection< Object > to) | ca.uqac.lif.cep.Processor | |
| CRLF | ca.uqac.lif.cep.io.ReadLines | static |
| duplicate(boolean with_state) | ca.uqac.lif.cep.io.ReadInputStream | |
| ca::uqac::lif::cep::tmf::Source.duplicate() | ca.uqac.lif.cep.Processor | |
| duplicateInto(Processor p) | ca.uqac.lif.cep.Processor | |
| END_CHARACTER | ca.uqac.lif.cep.io.ReadInputStream | static |
| 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.SynchronousProcessor | |
| ca::uqac::lif::cep::Processor.getPullableOutput() | ca.uqac.lif.cep.Processor | |
| getPushableInput(int index) | ca.uqac.lif.cep.SynchronousProcessor | |
| 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_addCrlf | ca.uqac.lif.cep.io.ReadLines | protected |
| m_bufferedInputStream | ca.uqac.lif.cep.io.ReadLines | protected |
| m_chunkSize | ca.uqac.lif.cep.io.ReadInputStream | protected |
| 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_hasReadEot | ca.uqac.lif.cep.io.ReadInputStream | 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_inputPushables | ca.uqac.lif.cep.SynchronousProcessor | protected |
| m_inputQueues | ca.uqac.lif.cep.Processor | protected |
| m_inputStream | ca.uqac.lif.cep.io.ReadInputStream | protected |
| m_isFile | ca.uqac.lif.cep.io.ReadInputStream | protected |
| m_outputArity | ca.uqac.lif.cep.Processor | protected |
| m_outputCount | ca.uqac.lif.cep.Processor | protected |
| m_outputPullables | ca.uqac.lif.cep.SynchronousProcessor | protected |
| m_outputPushables | ca.uqac.lif.cep.Processor | protected |
| m_outputQueues | ca.uqac.lif.cep.Processor | protected |
| m_scanner | ca.uqac.lif.cep.io.ReadLines | protected |
| m_tempQueue | ca.uqac.lif.cep.SynchronousProcessor | protected |
| m_trim | ca.uqac.lif.cep.io.ReadLines | 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 | |
| push() | ca.uqac.lif.cep.tmf.Source | |
| read(ObjectReader<?> reader, Object o) | ca.uqac.lif.cep.Processor | |
| ReadInputStream(InputStream is) | ca.uqac.lif.cep.io.ReadInputStream | |
| ReadLines(InputStream is) | ca.uqac.lif.cep.io.ReadLines | |
| readState(Object o) | ca.uqac.lif.cep.Processor | protected |
| reset() | ca.uqac.lif.cep.Processor | |
| s_versionString | ca.uqac.lif.cep.Processor | static |
| setChunkSize(int size) | ca.uqac.lif.cep.io.ReadInputStream | |
| 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.SynchronousProcessor | |
| setIsFile(boolean b) | ca.uqac.lif.cep.io.ReadInputStream | |
| setPullableInput(int i, Pullable p) | ca.uqac.lif.cep.Processor | |
| setPushableOutput(int i, Pushable p) | ca.uqac.lif.cep.Processor | |
| Source(int out_arity) | ca.uqac.lif.cep.tmf.Source | |
| 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 |
| SynchronousProcessor(int in_arity, int out_arity) | ca.uqac.lif.cep.SynchronousProcessor | |
| trim(boolean b) | ca.uqac.lif.cep.io.ReadLines | |
1.8.13