/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/ |
H A D | tupleconstantstep.cpp | 341 dlTimes.setFirstReadTime(); in nextBand() 386 dlTimes.setLastReadTime(); in nextBand() 459 dlTimes.setLastReadTime(); in execute() 460 dlTimes.setEndOfInputTime(); in execute() 594 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) in printCalTrace() 614 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) << " " in formatMiniStats() 717 dlTimes.setLastReadTime(); in run() 771 dlTimes.setLastReadTime(); in nextBand() 868 dlTimes.setFirstReadTime(); in nextBand() 869 dlTimes.setLastReadTime(); in nextBand() [all …]
|
H A D | tuplehavingstep.cpp | 187 if (dlTimes.FirstReadTime().tv_sec == 0) in nextBand() 188 dlTimes.setFirstReadTime(); in nextBand() 251 dlTimes.setLastReadTime(); in nextBand() 252 dlTimes.setEndOfInputTime(); in nextBand() 274 dlTimes.setFirstReadTime(); in execute() 324 dlTimes.setLastReadTime(); in execute() 325 dlTimes.setEndOfInputTime(); in execute() 408 << "\t1st read " << dlTimes.FirstReadTimeString() in printCalTrace() 409 << "; EOI " << dlTimes.EndOfInputTimeString() << "; runtime-" in printCalTrace() 410 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) in printCalTrace() [all …]
|
H A D | pdictionaryscan.cpp | 618 if (fOid >= 3000 && traceOn() && dlTimes.FirstReadTime().tv_sec == 0) in receivePrimitiveMessages() 619 dlTimes.setFirstReadTime(); in receivePrimitiveMessages() 622 dlTimes.setLastReadTime(); in receivePrimitiveMessages() 657 dlTimes.setFirstInsertTime(); in receivePrimitiveMessages() 794 dlTimes.setEndOfInputTime(); in receivePrimitiveMessages() 804 "\t1st read " << dlTimes.FirstReadTimeString() << in receivePrimitiveMessages() 805 "; EOI " << dlTimes.EndOfInputTimeString() << "; runtime-" << in receivePrimitiveMessages() 806 … JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) << "s" << endl in receivePrimitiveMessages() 816 dlTimes.FirstReadTime(), // first datalist read in receivePrimitiveMessages() 817 dlTimes.LastReadTime(), // last datalist read in receivePrimitiveMessages() [all …]
|
H A D | tupleannexstep.cpp | 377 dlTimes.setFirstReadTime(); in execute() 379 dlTimes.setLastReadTime(); in execute() 380 dlTimes.setEndOfInputTime(); in execute() 907 dlTimes.setFirstReadTime(); in finalizeParallelOrderByDistinct() 909 dlTimes.setLastReadTime(); in finalizeParallelOrderByDistinct() 910 dlTimes.setEndOfInputTime(); in finalizeParallelOrderByDistinct() 1102 dlTimes.setFirstReadTime(); in finalizeParallelOrderBy() 1104 dlTimes.setLastReadTime(); in finalizeParallelOrderBy() 1105 dlTimes.setEndOfInputTime(); in finalizeParallelOrderBy() 1271 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) in printCalTrace() [all …]
|
H A D | largehashjoin.cpp | 247 params->dlTimes, params->die); in HashJoinByBucket_thr() 643 dlTimes.setFirstReadTime(); in doHashJoin() 644 dlTimes.setEndOfInputTime( dlTimes.FirstReadTime() ); in doHashJoin() 701 "; 1st read " << dlTimes.FirstReadTimeString() << in doHashJoin() 702 "; EOI " << dlTimes.EndOfInputTimeString() << endl in doHashJoin() 706 JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) in doHashJoin() 941 dlTimes.setFirstReadTime(); in doStringHashJoin() 942 dlTimes.setEndOfInputTime( dlTimes.FirstReadTime() ); in doStringHashJoin() 1070 if (fTableOID2 >= 3000) dlTimes.setEndOfInputTime(); in doStringHashJoin() 1098 "; 1st read " << dlTimes.FirstReadTimeString() << in doStringHashJoin() [all …]
|
H A D | largehashjoin.h | 164 JSTimeStamp dlTimes; 173 JSTimeStamp* dlTimes, 286 JSTimeStamp* dlTimes; 318 dlTimes = dlt; 480 dlTimes->setFirstReadTime( params[0].dlTimes.FirstReadTime() ); 482 dlTimes->setEndOfInputTime(); 489 if ( params[i].dlTimes.FirstReadTime().tv_sec < dlTimes->FirstReadTime().tv_sec ) 490 dlTimes->setFirstReadTime( params[i].dlTimes.FirstReadTime() );
|
H A D | crossenginestep.cpp | 466 dlTimes.setFirstReadTime(); in execute() 637 dlTimes.setLastReadTime(); in execute() 638 dlTimes.setEndOfInputTime(); in execute() 772 if (traceOn() && dlTimes.FirstReadTime().tv_sec == 0) in nextBand() 773 dlTimes.setFirstReadTime(); in nextBand() 812 dlTimes.setLastReadTime(); in nextBand() 813 dlTimes.setEndOfInputTime(); in nextBand() 855 << "\t1st read " << dlTimes.FirstReadTimeString() in printCalTrace() 856 << "; EOI " << dlTimes.EndOfInputTimeString() << "; runtime-" in printCalTrace() 857 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) in printCalTrace() [all …]
|
H A D | subquerystep.cpp | 386 if (traceOn()) dlTimes.setFirstReadTime(); in execute() 450 dlTimes.setLastReadTime(); in execute() 451 dlTimes.setEndOfInputTime(); in execute() 535 << "\t1st read " << dlTimes.FirstReadTimeString() in printCalTrace() 536 << "; EOI " << dlTimes.EndOfInputTimeString() << "; runtime-" in printCalTrace() 537 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) in printCalTrace()
|
H A D | tupleunion.cpp | 192 if (dlTimes.FirstReadTime().tv_sec == 0) in readInput() 193 dlTimes.setFirstReadTime(); in readInput() 319 dlTimes.setLastReadTime(); in readInput() 320 dlTimes.setEndOfInputTime(); in readInput() 329 << "\t1st read " << dlTimes.FirstReadTimeString() in readInput() 330 << "; EOI " << dlTimes.EndOfInputTimeString() << "; runtime-" in readInput() 331 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) in readInput() 1415 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) << " " in formatMiniStats()
|
H A D | tuple-bps.cpp | 2060 dlTimes.setFirstReadTime(); in receiveMultiPrimitiveMessages() 2336 dlTimes.setFirstInsertTime(); in receiveMultiPrimitiveMessages() 2472 if (dlTimes.FirstReadTime().tv_sec == 0) in receiveMultiPrimitiveMessages() 2474 dlTimes.setFirstReadTime(); in receiveMultiPrimitiveMessages() 2475 dlTimes.setLastReadTime(); in receiveMultiPrimitiveMessages() 2476 dlTimes.setFirstInsertTime(); in receiveMultiPrimitiveMessages() 2479 dlTimes.setEndOfInputTime(); in receiveMultiPrimitiveMessages() 2580 "\t1st read " << dlTimes.FirstReadTimeString() << in receiveMultiPrimitiveMessages() 2581 "; EOI " << dlTimes.EndOfInputTimeString() << "; runtime-" << in receiveMultiPrimitiveMessages() 2582 JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) << in receiveMultiPrimitiveMessages() [all …]
|
H A D | windowfunctionstep.cpp | 901 if (traceOn()) dlTimes.setFirstReadTime(); in execute() 959 dlTimes.setLastReadTime(); in execute() 976 dlTimes.setEndOfInputTime(); in execute() 1031 dlTimes.setEndOfInputTime(); in execute() 1636 << "\t1st read " << dlTimes.FirstReadTimeString() in printCalTrace() 1637 << "; EOI " << dlTimes.EndOfInputTimeString() << "; runtime-" in printCalTrace() 1638 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) in printCalTrace() 1658 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) << " " in formatMiniStats()
|
H A D | joblist.cpp | 683 dotFile << JSTimeStamp::tsdiffstr(qsi->get()->dlTimes.EndOfInputTime(), in graph() 684 qsi->get()->dlTimes.FirstReadTime()) << "s"; in graph() 995 …dotFile << JSTimeStamp::tsdiffstr(psi->get()->dlTimes.EndOfInputTime(), psi->get()->dlTimes.FirstR… in graph()
|
H A D | tupleaggregatestep.cpp | 595 dlTimes.setLastReadTime(); in doThreadedSecondPhaseAggregate() 596 dlTimes.setEndOfInputTime(); in doThreadedSecondPhaseAggregate() 5158 if (traceOn()) dlTimes.setFirstReadTime(); in aggregateRowGroups() 5209 dlTimes.setLastReadTime(); in aggregateRowGroups() 5210 dlTimes.setEndOfInputTime(); in aggregateRowGroups() 5289 dlTimes.setFirstReadTime(); in threadedAggregateRowGroups() 5525 dlTimes.setLastReadTime(); in threadedAggregateRowGroups() 5526 dlTimes.setEndOfInputTime(); in threadedAggregateRowGroups() 5856 << "\t1st read " << dlTimes.FirstReadTimeString() in printCalTrace() 5858 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) in printCalTrace() [all …]
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/ |
H A D | tupleconstantstep.cpp | 341 dlTimes.setFirstReadTime(); in nextBand() 386 dlTimes.setLastReadTime(); in nextBand() 459 dlTimes.setLastReadTime(); in execute() 460 dlTimes.setEndOfInputTime(); in execute() 594 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) in printCalTrace() 614 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) << " " in formatMiniStats() 717 dlTimes.setLastReadTime(); in run() 771 dlTimes.setLastReadTime(); in nextBand() 868 dlTimes.setFirstReadTime(); in nextBand() 869 dlTimes.setLastReadTime(); in nextBand() [all …]
|
H A D | tuplehavingstep.cpp | 187 if (dlTimes.FirstReadTime().tv_sec == 0) in nextBand() 188 dlTimes.setFirstReadTime(); in nextBand() 251 dlTimes.setLastReadTime(); in nextBand() 252 dlTimes.setEndOfInputTime(); in nextBand() 274 dlTimes.setFirstReadTime(); in execute() 324 dlTimes.setLastReadTime(); in execute() 325 dlTimes.setEndOfInputTime(); in execute() 408 << "\t1st read " << dlTimes.FirstReadTimeString() in printCalTrace() 409 << "; EOI " << dlTimes.EndOfInputTimeString() << "; runtime-" in printCalTrace() 410 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) in printCalTrace() [all …]
|
H A D | pdictionaryscan.cpp | 618 if (fOid >= 3000 && traceOn() && dlTimes.FirstReadTime().tv_sec == 0) in receivePrimitiveMessages() 619 dlTimes.setFirstReadTime(); in receivePrimitiveMessages() 622 dlTimes.setLastReadTime(); in receivePrimitiveMessages() 657 dlTimes.setFirstInsertTime(); in receivePrimitiveMessages() 794 dlTimes.setEndOfInputTime(); in receivePrimitiveMessages() 804 "\t1st read " << dlTimes.FirstReadTimeString() << in receivePrimitiveMessages() 805 "; EOI " << dlTimes.EndOfInputTimeString() << "; runtime-" << in receivePrimitiveMessages() 806 … JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) << "s" << endl in receivePrimitiveMessages() 816 dlTimes.FirstReadTime(), // first datalist read in receivePrimitiveMessages() 817 dlTimes.LastReadTime(), // last datalist read in receivePrimitiveMessages() [all …]
|
H A D | tupleannexstep.cpp | 377 dlTimes.setFirstReadTime(); in execute() 379 dlTimes.setLastReadTime(); in execute() 380 dlTimes.setEndOfInputTime(); in execute() 907 dlTimes.setFirstReadTime(); in finalizeParallelOrderByDistinct() 909 dlTimes.setLastReadTime(); in finalizeParallelOrderByDistinct() 910 dlTimes.setEndOfInputTime(); in finalizeParallelOrderByDistinct() 1102 dlTimes.setFirstReadTime(); in finalizeParallelOrderBy() 1104 dlTimes.setLastReadTime(); in finalizeParallelOrderBy() 1105 dlTimes.setEndOfInputTime(); in finalizeParallelOrderBy() 1271 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) in printCalTrace() [all …]
|
H A D | largehashjoin.cpp | 247 params->dlTimes, params->die); in HashJoinByBucket_thr() 643 dlTimes.setFirstReadTime(); in doHashJoin() 644 dlTimes.setEndOfInputTime( dlTimes.FirstReadTime() ); in doHashJoin() 701 "; 1st read " << dlTimes.FirstReadTimeString() << in doHashJoin() 702 "; EOI " << dlTimes.EndOfInputTimeString() << endl in doHashJoin() 706 JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) in doHashJoin() 941 dlTimes.setFirstReadTime(); in doStringHashJoin() 942 dlTimes.setEndOfInputTime( dlTimes.FirstReadTime() ); in doStringHashJoin() 1070 if (fTableOID2 >= 3000) dlTimes.setEndOfInputTime(); in doStringHashJoin() 1098 "; 1st read " << dlTimes.FirstReadTimeString() << in doStringHashJoin() [all …]
|
H A D | largehashjoin.h | 164 JSTimeStamp dlTimes; 173 JSTimeStamp* dlTimes, 286 JSTimeStamp* dlTimes; 318 dlTimes = dlt; 480 dlTimes->setFirstReadTime( params[0].dlTimes.FirstReadTime() ); 482 dlTimes->setEndOfInputTime(); 489 if ( params[i].dlTimes.FirstReadTime().tv_sec < dlTimes->FirstReadTime().tv_sec ) 490 dlTimes->setFirstReadTime( params[i].dlTimes.FirstReadTime() );
|
H A D | crossenginestep.cpp | 466 dlTimes.setFirstReadTime(); in execute() 637 dlTimes.setLastReadTime(); in execute() 638 dlTimes.setEndOfInputTime(); in execute() 772 if (traceOn() && dlTimes.FirstReadTime().tv_sec == 0) in nextBand() 773 dlTimes.setFirstReadTime(); in nextBand() 812 dlTimes.setLastReadTime(); in nextBand() 813 dlTimes.setEndOfInputTime(); in nextBand() 855 << "\t1st read " << dlTimes.FirstReadTimeString() in printCalTrace() 856 << "; EOI " << dlTimes.EndOfInputTimeString() << "; runtime-" in printCalTrace() 857 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) in printCalTrace() [all …]
|
H A D | subquerystep.cpp | 386 if (traceOn()) dlTimes.setFirstReadTime(); in execute() 450 dlTimes.setLastReadTime(); in execute() 451 dlTimes.setEndOfInputTime(); in execute() 535 << "\t1st read " << dlTimes.FirstReadTimeString() in printCalTrace() 536 << "; EOI " << dlTimes.EndOfInputTimeString() << "; runtime-" in printCalTrace() 537 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) in printCalTrace()
|
H A D | tupleunion.cpp | 192 if (dlTimes.FirstReadTime().tv_sec == 0) in readInput() 193 dlTimes.setFirstReadTime(); in readInput() 319 dlTimes.setLastReadTime(); in readInput() 320 dlTimes.setEndOfInputTime(); in readInput() 329 << "\t1st read " << dlTimes.FirstReadTimeString() in readInput() 330 << "; EOI " << dlTimes.EndOfInputTimeString() << "; runtime-" in readInput() 331 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) in readInput() 1415 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) << " " in formatMiniStats()
|
H A D | tuple-bps.cpp | 2060 dlTimes.setFirstReadTime(); in receiveMultiPrimitiveMessages() 2336 dlTimes.setFirstInsertTime(); in receiveMultiPrimitiveMessages() 2472 if (dlTimes.FirstReadTime().tv_sec == 0) in receiveMultiPrimitiveMessages() 2474 dlTimes.setFirstReadTime(); in receiveMultiPrimitiveMessages() 2475 dlTimes.setLastReadTime(); in receiveMultiPrimitiveMessages() 2476 dlTimes.setFirstInsertTime(); in receiveMultiPrimitiveMessages() 2479 dlTimes.setEndOfInputTime(); in receiveMultiPrimitiveMessages() 2580 "\t1st read " << dlTimes.FirstReadTimeString() << in receiveMultiPrimitiveMessages() 2581 "; EOI " << dlTimes.EndOfInputTimeString() << "; runtime-" << in receiveMultiPrimitiveMessages() 2582 JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) << in receiveMultiPrimitiveMessages() [all …]
|
H A D | windowfunctionstep.cpp | 901 if (traceOn()) dlTimes.setFirstReadTime(); in execute() 959 dlTimes.setLastReadTime(); in execute() 976 dlTimes.setEndOfInputTime(); in execute() 1031 dlTimes.setEndOfInputTime(); in execute() 1636 << "\t1st read " << dlTimes.FirstReadTimeString() in printCalTrace() 1637 << "; EOI " << dlTimes.EndOfInputTimeString() << "; runtime-" in printCalTrace() 1638 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) in printCalTrace() 1658 << JSTimeStamp::tsdiffstr(dlTimes.EndOfInputTime(), dlTimes.FirstReadTime()) << " " in formatMiniStats()
|
H A D | joblist.cpp | 683 dotFile << JSTimeStamp::tsdiffstr(qsi->get()->dlTimes.EndOfInputTime(), in graph() 684 qsi->get()->dlTimes.FirstReadTime()) << "s"; in graph() 995 …dotFile << JSTimeStamp::tsdiffstr(psi->get()->dlTimes.EndOfInputTime(), psi->get()->dlTimes.FirstR… in graph()
|