| 153 | TestConnector(const std::string& id) : connector::Connector(id) {} |
| 154 | |
| 155 | std::unique_ptr<connector::DataSource> createDataSource( |
| 156 | const RowTypePtr& /* outputType */, |
| 157 | const std::shared_ptr<ConnectorTableHandle>& /* tableHandle */, |
| 158 | const std::unordered_map< |
| 159 | std::string, |
| 160 | std::shared_ptr<connector::ColumnHandle>>& /* columnHandles */, |
| 161 | std::shared_ptr<ConnectorQueryCtx> connectorQueryCtx, |
| 162 | const core::QueryConfig& /* queryConfig */) override { |
| 163 | return std::make_unique<TestDataSource>(connectorQueryCtx->memoryPool()); |
| 164 | } |
| 165 | |
| 166 | std::unique_ptr<connector::DataSink> createDataSink( |
| 167 | RowTypePtr /*inputType*/, |
no test coverage detected