| 267 | static constexpr const char* kFactoryName = "backpressure_delay"; |
| 268 | |
| 269 | static void Register() { |
| 270 | auto exec_reg = default_exec_factory_registry(); |
| 271 | if (!exec_reg->GetFactory(kFactoryName).ok()) { |
| 272 | ASSERT_OK(exec_reg->AddFactory(kFactoryName, GatedNode::Make)); |
| 273 | } |
| 274 | } |
| 275 | |
| 276 | GatedNode(ExecPlan* plan, std::vector<ExecNode*> inputs, |
| 277 | std::shared_ptr<Schema> output_schema, const GatedNodeOptions& options) |
nothing calls this directly
no test coverage detected