executor: make SLOW_QUERY support query slow log at any time (#14840)

pingcap · Feb 20, 2020 · b06e3e8 · b06e3e8
1 parent b98c88c
commit b06e3e8
Show file tree

Hide file tree

Showing 5 changed files with 488 additions and 84 deletions.
diff --git a/executor/builder.go b/executor/builder.go
@@ -1354,12 +1354,16 @@ func (b *executorBuilder) buildMemTable(v *plannercore.PhysicalMemTable) Executo
 				},
 			}
 		case strings.ToLower(infoschema.TableSlowQuery), strings.ToLower(infoschema.ClusterTableSlowLog):
+			retriever := &slowQueryRetriever{
+				table:      v.Table,
+				outputCols: v.Columns,
+			}
+			if v.Extractor != nil {
+				retriever.extractor = v.Extractor.(*plannercore.SlowQueryExtractor)
+			}
 			return &MemTableReaderExec{
 				baseExecutor: newBaseExecutor(b.ctx, v.Schema(), v.ExplainID()),
-				retriever: &SlowQueryRetriever{
-					table:      v.Table,
-					outputCols: v.Columns,
-				},
+				retriever:    retriever,
 			}
 		}
 	}