| canEarlyClose() | ExecStream | [virtual] |
| castOutput() | ReshapeExecStream | [private] |
| castRequired | ReshapeExecStream | [private] |
| checkAbort() const | ExecStream | [virtual] |
| checkCastTypes(const TupleProjection &compareProj, const TupleDescriptor &inputTupleDesc, const TupleDescriptor &outputTupleDesc) | ReshapeExecStream | [private] |
| ClosableObject() | ClosableObject | [explicit, protected] |
| close() | ClosableObject | |
| closeImpl() | ReshapeExecStream | [virtual] |
| compareInput() | ReshapeExecStream | [private] |
| compOp | ReshapeExecStream | [private] |
| compTupleBuffer | ReshapeExecStream | [private] |
| compTupleDesc | ReshapeExecStream | [private] |
| copyCompareTuple(TupleDescriptor const &tupleDesc, TupleData &tupleData, PBuffer tupleBuffer) | ReshapeExecStream | [private] |
| disableTarget() | ErrorSource | |
| disableTracing() | TraceSource | |
| dynamicParameters | ReshapeExecStream | [private] |
| ErrorSource() | ErrorSource | [explicit, protected] |
| ErrorSource(SharedErrorTarget pErrorTarget, const std::string &name) | ErrorSource | [explicit, protected] |
| ExecStream() | ExecStream | [explicit, protected] |
| execute(ExecStreamQuantum const &quantum) | ReshapeExecStream | [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] |
| SingleInputExecStream::getOutputBufProvision() const | ExecStream | [virtual] |
| SingleOutputExecStream::getOutputBufProvision() const | SingleOutputExecStream | [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] |
| initCompareData(ReshapeExecStreamParams const ¶ms, TupleDescriptor const &inputDesc, TupleAccessor const &inputAccessor) | ReshapeExecStream | [private] |
| initErrorSource(SharedErrorTarget pErrorTarget, const std::string &name) | ErrorSource | [virtual] |
| initTraceSource(SharedTraceTarget pTraceTarget, std::string name) | TraceSource | [virtual] |
| inputCompareData | ReshapeExecStream | [private] |
| inputCompareProjAccessor | ReshapeExecStream | [private] |
| inputOutputData | ReshapeExecStream | [private] |
| inputOutputDesc | ReshapeExecStream | [private] |
| isClosed() const | ClosableObject | [inline] |
| isOpen | ExecStream | [protected] |
| isTracing() const | TraceSource | [inline] |
| isTracingLevel(TraceLevel level) const | TraceSource | [inline] |
| lastKey | ReshapeExecStream | [private] |
| lastKeyDesc | ReshapeExecStream | [private] |
| mayBlock() const | ExecStream | [virtual] |
| name | ExecStream | [protected] |
| needsClose | ClosableObject | [protected] |
| nullFilter(const TupleProjection &compareProj, uint colno) | ReshapeExecStream | [private] |
| numCompDynParams | ReshapeExecStream | [private] |
| open(bool restart) | ReshapeExecStream | [virtual] |
| outputData | ReshapeExecStream | [private] |
| outputDesc | ReshapeExecStream | [private] |
| outputProjAccessor | ReshapeExecStream | [private] |
| paramCompareData | ReshapeExecStream | [private] |
| paramsRead | ReshapeExecStream | [private] |
| 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 | |
| pOutAccessor | SingleOutputExecStream | [protected] |
| pQuotaAccessor | ExecStream | [protected] |
| precheckConduitBuffers() | ConduitExecStream | [protected] |
| prepare(ReshapeExecStreamParams const ¶ms) | ReshapeExecStream | [virtual] |
| ConduitExecStream::prepare(ConduitExecStreamParams const ¶ms) | ConduitExecStream | [virtual] |
| ConduitExecStream::SingleInputExecStream::prepare(SingleInputExecStreamParams const ¶ms) | SingleInputExecStream | [virtual] |
| ConduitExecStream::ExecStream::prepare(ExecStreamParams const ¶ms) | ExecStream | [virtual] |
| SingleOutputExecStream::prepare(SingleOutputExecStreamParams const ¶ms) | SingleOutputExecStream | [virtual] |
| producePending | ReshapeExecStream | [private] |
| pScratchQuotaAccessor | ExecStream | [protected] |
| pTxn | ExecStream | [protected] |
| readDynamicParams() | ReshapeExecStream | [private] |
| resourceAllocation | ExecStream | [protected] |
| setErrorSourceName(std::string const &n) | ErrorSource | [inline] |
| setInputBufAccessors(std::vector< SharedExecStreamBufAccessor > const &inAccessors) | ConduitExecStream | [virtual] |
| setName(std::string const &) | ExecStream | [virtual] |
| setOutputBufAccessors(std::vector< SharedExecStreamBufAccessor > const &outAccessors) | ConduitExecStream | [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] |