| 1258 | } |
| 1259 | |
| 1260 | Status Start() { |
| 1261 | started_ = true; |
| 1262 | RETURN_NOT_OK(payload_writer_->Start()); |
| 1263 | |
| 1264 | IpcPayload payload; |
| 1265 | RETURN_NOT_OK(GetSchemaPayload(schema_, options_, mapper_, &payload)); |
| 1266 | return WritePayload(payload); |
| 1267 | } |
| 1268 | |
| 1269 | WriteStats stats() const override { return stats_; } |
| 1270 |
no test coverage detected