Home
last modified time | relevance | path

Searched refs:dlTimes (Results 1 – 25 of 30) sorted by relevance

12

/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/
H A Dtupleconstantstep.cpp341 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 Dtuplehavingstep.cpp187 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 Dpdictionaryscan.cpp618 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 Dtupleannexstep.cpp377 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 Dlargehashjoin.cpp247 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 Dlargehashjoin.h164 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 Dcrossenginestep.cpp466 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 Dsubquerystep.cpp386 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 Dtupleunion.cpp192 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 Dtuple-bps.cpp2060 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 Dwindowfunctionstep.cpp901 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 Djoblist.cpp683 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 Dtupleaggregatestep.cpp595 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 Dtupleconstantstep.cpp341 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 Dtuplehavingstep.cpp187 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 Dpdictionaryscan.cpp618 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 Dtupleannexstep.cpp377 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 Dlargehashjoin.cpp247 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 Dlargehashjoin.h164 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 Dcrossenginestep.cpp466 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 Dsubquerystep.cpp386 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 Dtupleunion.cpp192 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 Dtuple-bps.cpp2060 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 Dwindowfunctionstep.cpp901 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 Djoblist.cpp683 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()

12