Fennel: Member List (original) (raw)

canEarlyClose() ExecStream [virtual]
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 &params) JavaSinkExecStream [virtual]
SingleInputExecStream::prepare(SingleInputExecStreamParams const &params) SingleInputExecStream [virtual]
ExecStream::prepare(ExecStreamParams const &params) 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]