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

Method TestDoExchangeWriteOnlySchema

cpp/src/arrow/flight/test_definitions.cc:389–403  ·  view source on GitHub ↗

Test sending a schema without any data, as this hits an edge case in the client-side writer.

Source from the content-addressed store, hash-verified

387// Test sending a schema without any data, as this hits an edge case
388// in the client-side writer.
389void DataTest::TestDoExchangeWriteOnlySchema() {
390 auto descr = FlightDescriptor::Command("counter");
391 ASSERT_OK_AND_ASSIGN(auto exchange, client_->DoExchange(descr));
392 std::unique_ptr<FlightStreamReader> reader = std::move(exchange.reader);
393 std::unique_ptr<FlightStreamWriter> writer = std::move(exchange.writer);
394 auto schema = arrow::schema({field("f1", arrow::int32())});
395 ASSERT_OK(writer->Begin(schema));
396 ASSERT_OK(writer->WriteMetadata(Buffer::FromString("foo")));
397 ASSERT_OK(writer->DoneWriting());
398 ASSERT_OK_AND_ASSIGN(auto chunk, reader->Next());
399 ASSERT_EQ(nullptr, chunk.data);
400 ASSERT_NE(nullptr, chunk.app_metadata);
401 ASSERT_EQ("0", chunk.app_metadata->ToString());
402 ASSERT_OK(writer->Close());
403}
404// Emulate DoGet
405void DataTest::TestDoExchangeGet() {
406 auto descr = FlightDescriptor::Command("get");

Callers

nothing calls this directly

Calls 9

FromStringFunction · 0.85
DoneWritingMethod · 0.80
CommandFunction · 0.70
schemaFunction · 0.50
fieldFunction · 0.50
BeginMethod · 0.45
WriteMetadataMethod · 0.45
ToStringMethod · 0.45
CloseMethod · 0.45

Tested by

no test coverage detected