| 1389 | static constexpr const char* kFactoryName = "backpressure_count"; |
| 1390 | |
| 1391 | static void Register() { |
| 1392 | auto exec_reg = default_exec_factory_registry(); |
| 1393 | if (!exec_reg->GetFactory(kFactoryName).ok()) { |
| 1394 | ASSERT_OK(exec_reg->AddFactory(kFactoryName, BackpressureCountingNode::Make)); |
| 1395 | } |
| 1396 | } |
| 1397 | |
| 1398 | BackpressureCountingNode(ExecPlan* plan, std::vector<ExecNode*> inputs, |
| 1399 | std::shared_ptr<Schema> output_schema, |
nothing calls this directly
no test coverage detected