| 48 | : pool_(pool), raw_(raw), is_open_(false), compressed_pos_(0), total_pos_(0) {} |
| 49 | |
| 50 | Status Init(Codec* codec) { |
| 51 | ARROW_ASSIGN_OR_RAISE(compressor_, codec->MakeCompressor()); |
| 52 | ARROW_ASSIGN_OR_RAISE(compressed_, AllocateResizableBuffer(kChunkSize, pool_)); |
| 53 | compressed_pos_ = 0; |
| 54 | is_open_ = true; |
| 55 | return Status::OK(); |
| 56 | } |
| 57 | |
| 58 | Result<int64_t> Tell() const { |
| 59 | std::lock_guard<std::mutex> guard(lock_); |
nothing calls this directly
no test coverage detected