Home
last modified time | relevance | path

Searched refs:hasNewData (Results 1 – 5 of 5) sorted by relevance

/dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/
H A DProgressReporter.scala129 protected def finishTrigger(hasNewData: Boolean): Unit = {
132 val executionStats = extractExecutionStats(hasNewData)
168 if (hasNewData) {
184 private def extractStateOperatorMetrics(hasNewData: Boolean): Seq[StateOperatorProgress] = {
192 val numRowsUpdated = if (hasNewData) {
204 private def extractExecutionStats(hasNewData: Boolean): ExecutionStats = {
211 val stateOperators = extractStateOperatorMetrics(hasNewData)
213 if (!hasNewData) {
H A DStreamExecution.scala412 val hasNewData = { constant
433 if (hasNewData) {
/dports/converters/wkhtmltopdf/qt-5db36ec/src/sql/models/
H A Dqsqlquerymodel.cpp323 bool hasNewData = (newRec != QSqlRecord()) || !query.lastError().isValid(); in setQuery() local
344 if (columnsChanged && hasNewData) in setQuery()
/dports/math/vtk9/VTK-9.1.0/IO/Legacy/
H A DvtkDataReader.cxx2070 bool hasNewData = false; in ReadArray() local
2073 hasNewData = false; in ReadArray()
2090 hasNewData = true; in ReadArray()
2110 while (!readyToCheckMetaData && (peekSize == 256 || hasNewData)); in ReadArray()
/dports/math/vtk8/VTK-8.2.0/IO/Legacy/
H A DvtkDataReader.cxx2044 bool hasNewData = false; in ReadArray() local
2047 hasNewData = false; in ReadArray()
2064 hasNewData = true; in ReadArray()
2084 while (!readyToCheckMetaData && (peekSize == 256 || hasNewData)); in ReadArray()