iceberg::FileScanTaskReader Class Reference

Opens a FileScanTask as an ArrowArrayStream. More...

#include <file_scan_task_reader.h>

Classes
class	Impl
struct	Options
	Options shared by all tasks opened by this reader. More...

Public Member Functions
Result< ArrowArrayStream >	Open (const FileScanTask &task)
	Open a task and return an Arrow C stream for its projected live rows.
	FileScanTaskReader (const FileScanTaskReader &)=delete
FileScanTaskReader &	operator= (const FileScanTaskReader &)=delete

Static Public Member Functions
static Result< std::unique_ptr< FileScanTaskReader > >	Make (Options options)
	Create a reusable task reader from shared read context.

Detailed Description

Opens a FileScanTask as an ArrowArrayStream.

FileScanTaskReader chooses the copy-on-write path for tasks without deletes and the merge-on-read path for tasks with v2 position or equality deletes. The returned stream always exposes projected_schema.

TODO(gangwu): Add a mode that emits a _deleted column instead of filtering rows. TODO(gangwu): Use evaluator to apply residual expression filters.

---

The documentation for this class was generated from the following files:

• iceberg/data/file_scan_task_reader.h
• iceberg/data/file_scan_task_reader.cc