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

Method DoConsume

cpp/src/arrow/ipc/read_write_test.cc:1448–1453  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1446
1447struct StreamDecoderDataWriterHelper : public StreamDecoderWriterHelper {
1448 Status DoConsume(StreamDecoder* decoder) override {
1449 // This data is valid only in this function.
1450 ARROW_ASSIGN_OR_RAISE(auto temporary_buffer,
1451 Buffer::Copy(buffer_, arrow::default_cpu_memory_manager()));
1452 return decoder->Consume(temporary_buffer->data(), temporary_buffer->size());
1453 }
1454};
1455
1456struct StreamDecoderBufferWriterHelper : public StreamDecoderWriterHelper {

Callers

nothing calls this directly

Calls 3

ConsumeMethod · 0.45
dataMethod · 0.45
sizeMethod · 0.45

Tested by

no test coverage detected