| checkAbort() const |
ExecStream |
[virtual] |
| ClosableObject() |
ClosableObject |
[explicit, protected] |
| close() |
ClosableObject |
|
| closeImpl() |
JavaSinkExecStream |
[virtual] |
| disableTarget() |
ErrorSource |
|
| disableTracing() |
TraceSource |
|
| ErrorSource() |
ErrorSource |
[explicit, protected] |
| ErrorSource(SharedErrorTarget pErrorTarget, const std::string &name) |
ErrorSource |
[explicit, protected] |
| ExecStream() |
ExecStream |
[explicit, protected] |
| execute(ExecStreamQuantum const &quantum) |
JavaSinkExecStream |
[virtual] |
| getErrorSourceName() const |
ErrorSource |
[inline] |
| getErrorTarget() const |
ErrorSource |
[inline] |
| getGraph() const |
ExecStream |
[inline] |
| getInputBufProvision() const |
SingleInputExecStream |
[virtual] |
| getMinimumTraceLevel() const |
TraceSource |
[inline] |
| getName() const |
ExecStream |
[virtual] |
| getOutputBufConversion() const |
ExecStream |
[virtual] |
| getOutputBufProvision() const |
ExecStream |
[virtual] |
| getResourceRequirements(ExecStreamResourceQuantity &minQuantity, ExecStreamResourceQuantity &optQuantity, ExecStreamResourceSettingType &optType) |
ExecStream |
[virtual] |
| getResourceRequirements(ExecStreamResourceQuantity &minQuantity, ExecStreamResourceQuantity &optQuantity) |
ExecStream |
[virtual] |
| getSharedErrorTarget() const |
ErrorSource |
[inline] |
| getSharedTraceTarget() const |
TraceSource |
[inline] |
| getStreamId() const |
ExecStream |
[inline] |
| getTraceSourceName() const |
TraceSource |
[inline] |
| getTraceTarget() const |
TraceSource |
[inline] |
| hasTarget() const |
ErrorSource |
[inline] |
| id |
ExecStream |
[protected] |
| initErrorSource(SharedErrorTarget pErrorTarget, const std::string &name) |
ErrorSource |
[virtual] |
| initTraceSource(SharedTraceTarget pTraceTarget, std::string name) |
TraceSource |
[virtual] |
| isClosed() const |
ClosableObject |
[inline] |
| isOpen |
ExecStream |
[protected] |
| isTracing() const |
TraceSource |
[inline] |
| isTracingLevel(TraceLevel level) const |
TraceSource |
[inline] |
| javaFennelPipeTupleIter |
JavaSinkExecStream |
[private] |
| javaFennelPipeTupleIterId |
JavaSinkExecStream |
[private] |
| JavaSinkExecStream() |
JavaSinkExecStream |
[explicit] |
| lastResult |
JavaSinkExecStream |
[private] |
| mayBlock() const |
ExecStream |
[virtual] |
| methByteBuffer_array |
JavaSinkExecStream |
[private] |
| methFennelPipeTupleIter_getByteBuffer |
JavaSinkExecStream |
[private] |
| methFennelPipeTupleIter_write |
JavaSinkExecStream |
[private] |
| name |
ExecStream |
[protected] |
| needsClose |
ClosableObject |
[protected] |
| open(bool restart) |
JavaSinkExecStream |
[virtual] |
| pDynamicParamManager |
ExecStream |
[protected] |
| pGraph |
ExecStream |
[protected] |
| pInAccessor |
SingleInputExecStream |
[protected] |
| postError(ErrorLevel level, const std::string &message, void *address, long capacity, int index) |
ErrorSource |
|
| postError(ErrorLevel level, const std::string &message, const TupleDescriptor &errorDesc, const TupleData &errorTuple, int index) |
ErrorSource |
|
| pQuotaAccessor |
ExecStream |
[protected] |
| prepare(JavaSinkExecStreamParams const ¶ms) |
JavaSinkExecStream |
[virtual] |
| SingleInputExecStream::prepare(SingleInputExecStreamParams const ¶ms) |
SingleInputExecStream |
[virtual] |
| ExecStream::prepare(ExecStreamParams const ¶ms) |
ExecStream |
[virtual] |
| pScratchQuotaAccessor |
ExecStream |
[protected] |
| pStreamGraphHandle |
JavaSinkExecStream |
[private] |
| pTxn |
ExecStream |
[protected] |
| resourceAllocation |
ExecStream |
[protected] |
| sendData(PConstBuffer src, uint size) |
JavaSinkExecStream |
[private] |
| setErrorSourceName(std::string const &n) |
ErrorSource |
[inline] |
| setInputBufAccessors(std::vector< SharedExecStreamBufAccessor > const &inAccessors) |
SingleInputExecStream |
[virtual] |
| setName(std::string const &) |
ExecStream |
[virtual] |
| setOutputBufAccessors(std::vector< SharedExecStreamBufAccessor > const &outAccessors) |
SingleInputExecStream |
[virtual] |
| setResourceAllocation(ExecStreamResourceQuantity &quantity) |
ExecStream |
[virtual] |
| setTraceSourceName(std::string const &n) |
TraceSource |
[inline] |
| stuffByteBuffer(jobject byteBuffer, PConstBuffer src, uint size) |
JavaSinkExecStream |
[private] |
| trace(TraceLevel level, std::string message) const |
TraceSource |
|
| TraceSource() |
TraceSource |
[explicit, protected] |
| TraceSource(SharedTraceTarget pTraceTarget, std::string name) |
TraceSource |
[explicit, protected] |
| ~ClosableObject() |
ClosableObject |
[virtual] |
| ~ErrorSource() |
ErrorSource |
[virtual] |
| ~TraceSource() |
TraceSource |
[virtual] |