MCPcopy Create free account
hub / github.com/apache/arrow / WriteWithMetadata

Method WriteWithMetadata

cpp/src/arrow/flight/client.cc:474–485  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

472 }
473
474 Status WriteWithMetadata(const RecordBatch& batch,
475 std::shared_ptr<Buffer> app_metadata) override {
476 RETURN_NOT_OK(CheckStarted());
477 app_metadata_ = app_metadata;
478 auto status = batch_writer_->WriteRecordBatch(batch);
479 if (!status.ok() &&
480 // Only want to Close() if server error, not for client error
481 ServerErrorTagStatusDetail::UnwrapStatus(status)) {
482 return Close();
483 }
484 return status;
485 }
486
487 Status DoneWriting() override {
488 // Do not CheckStarted - DoneWriting applies to data and metadata

Callers 12

TestDoExchangeEchoMethod · 0.45
CheckDoPutMethod · 0.45
TestSizeLimitMethod · 0.45
TestDoPutMethod · 0.45
TestDoPutDictionariesMethod · 0.45
TestDoPutReadMetadataMethod · 0.45
DoExchangeMethod · 0.45
RunExchangeEchoMethod · 0.45
UploadBatchesToFlightFunction · 0.45
RunEchoExchangeMethod · 0.45
RunClientMethod · 0.45

Calls 3

CloseFunction · 0.50
WriteRecordBatchMethod · 0.45
okMethod · 0.45

Tested by 11

TestDoExchangeEchoMethod · 0.36
CheckDoPutMethod · 0.36
TestSizeLimitMethod · 0.36
TestDoPutMethod · 0.36
TestDoPutDictionariesMethod · 0.36
TestDoPutReadMetadataMethod · 0.36
DoExchangeMethod · 0.36
RunExchangeEchoMethod · 0.36
UploadBatchesToFlightFunction · 0.36
RunEchoExchangeMethod · 0.36
RunClientMethod · 0.36