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

Method DoConsume

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

Source from the content-addressed store, hash-verified

1442
1443struct StreamDecoderDataWriterHelper : public StreamDecoderWriterHelper {
1444 Status DoConsume(StreamDecoder* decoder) override {
1445 // This data is valid only in this function.
1446 ARROW_ASSIGN_OR_RAISE(auto temporary_buffer,
1447 Buffer::Copy(buffer_, arrow::default_cpu_memory_manager()));
1448 return decoder->Consume(temporary_buffer->data(), temporary_buffer->size());
1449 }
1450};
1451
1452struct 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