canEarlyClose() | ExecStream | [virtual] |
checkAbort() const | ExecStream | [virtual] |
ClosableObject() | ClosableObject | [explicit, protected] |
close() | ClosableObject | |
closeImpl() | BarrierExecStream | [virtual] |
compareTuple | BarrierExecStream | [private] |
copyInputData(PBuffer destBuffer, SharedExecStreamBufAccessor &pInAccessor) | BarrierExecStream | [private] |
curOutputPos | BarrierExecStream | [private] |
disableTarget() | ErrorSource | |
disableTracing() | TraceSource | |
dynParamVal | BarrierExecStream | [private] |
ErrorSource() | ErrorSource | [explicit, protected] |
ErrorSource(SharedErrorTarget pErrorTarget, const std::string &name) | ErrorSource | [explicit, protected] |
ExecStream() | ExecStream | [explicit, protected] |
execute(ExecStreamQuantum const &quantum) | BarrierExecStream | [virtual] |
getErrorSourceName() const | ErrorSource | [inline] |
getErrorTarget() const | ErrorSource | [inline] |
getGraph() const | ExecStream | [inline] |
getInputBufProvision() const | ConfluenceExecStream | [virtual] |
getMinimumTraceLevel() const | TraceSource | [inline] |
getName() const | ExecStream | [virtual] |
getOutputBufConversion() const | ExecStream | [virtual] |
getOutputBufProvision() const | BarrierExecStream | [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] |
iInput | BarrierExecStream | [private] |
inAccessors | ConfluenceExecStream | [protected] |
initErrorSource(SharedErrorTarget pErrorTarget, const std::string &name) | ErrorSource | [virtual] |
initTraceSource(SharedTraceTarget pTraceTarget, std::string name) | TraceSource | [virtual] |
inputTuple | BarrierExecStream | [private] |
isClosed() const | ClosableObject | [inline] |
isDone | BarrierExecStream | [private] |
isOpen | ExecStream | [protected] |
isTracing() const | TraceSource | [inline] |
isTracingLevel(TraceLevel level) const | TraceSource | [inline] |
mayBlock() const | ExecStream | [virtual] |
name | ExecStream | [protected] |
needsClose | ClosableObject | [protected] |
open(bool restart) | BarrierExecStream | [virtual] |
outputBufSize | BarrierExecStream | [private] |
outputTupleAccessor | BarrierExecStream | [private] |
outputTupleBuffer | BarrierExecStream | [private] |
parameterIds | BarrierExecStream | [private] |
pDynamicParamManager | ExecStream | [protected] |
pGraph | ExecStream | [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 | |
pOutAccessor | SingleOutputExecStream | [protected] |
pQuotaAccessor | ExecStream | [protected] |
prepare(BarrierExecStreamParams const ¶ms) | BarrierExecStream | [virtual] |
ConfluenceExecStream::prepare(ConfluenceExecStreamParams const ¶ms) | ConfluenceExecStream | [virtual] |
SingleOutputExecStream::prepare(SingleOutputExecStreamParams const ¶ms) | SingleOutputExecStream | [virtual] |
ExecStream::prepare(ExecStreamParams const ¶ms) | ExecStream | [virtual] |
processInputTuple() | BarrierExecStream | [private] |
pScratchQuotaAccessor | ExecStream | [protected] |
pTxn | ExecStream | [protected] |
resourceAllocation | ExecStream | [protected] |
returnAllInputs() | BarrierExecStream | [inline, private] |
returnAnyInput() | BarrierExecStream | [inline, private] |
returnFirstInput() | BarrierExecStream | [inline, private] |
returnMode | BarrierExecStream | [private] |
setErrorSourceName(std::string const &n) | ErrorSource | [inline] |
setInputBufAccessors(std::vector< SharedExecStreamBufAccessor > const &inAccessors) | ConfluenceExecStream | [virtual] |
setName(std::string const &) | ExecStream | [virtual] |
setOutputBufAccessors(std::vector< SharedExecStreamBufAccessor > const &outAccessors) | SingleOutputExecStream | [virtual] |
setResourceAllocation(ExecStreamResourceQuantity &quantity) | ExecStream | [virtual] |
setTraceSourceName(std::string const &n) | TraceSource | [inline] |
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] |