| 245 | } |
| 246 | |
| 247 | std::string TableWriter::createTableCommitContext(bool lastOutput) { |
| 248 | // clang-format off |
| 249 | return folly::toJson( |
| 250 | folly::dynamic::object |
| 251 | (TableWriteTraits::kLifeSpanContextKey, "TaskWide") |
| 252 | (TableWriteTraits::kTaskIdContextKey, connectorQueryCtx_->taskId()) |
| 253 | (TableWriteTraits::kCommitStrategyContextKey, commitStrategyToString(commitStrategy_)) |
| 254 | (TableWriteTraits::klastPageContextKey, lastOutput)); |
| 255 | // clang-format on |
| 256 | } |
| 257 | |
| 258 | void TableWriter::updateStats(const connector::DataSink::Stats& stats) { |
| 259 | { |
nothing calls this directly
no test coverage detected