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

Method TableBatchReader

cpp/src/arrow/table.cc:646–658  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

644// Convert a table to a sequence of record batches
645
646TableBatchReader::TableBatchReader(const Table& table)
647 : owned_table_(nullptr),
648 table_(table),
649 column_data_(table.num_columns()),
650 chunk_numbers_(table.num_columns(), 0),
651 chunk_offsets_(table.num_columns(), 0),
652 absolute_row_position_(0),
653 max_chunksize_(std::numeric_limits<int64_t>::max()) {
654 for (int i = 0; i < table.num_columns(); ++i) {
655 column_data_[i] = table.column(i).get();
656 }
657 DCHECK(table_.Validate().ok());
658}
659
660TableBatchReader::TableBatchReader(std::shared_ptr<Table> table)
661 : owned_table_(std::move(table)),

Callers

nothing calls this directly

Calls 5

num_columnsMethod · 0.45
getMethod · 0.45
columnMethod · 0.45
okMethod · 0.45
ValidateMethod · 0.45

Tested by

no test coverage detected