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

Method TableBatchReader

cpp/src/arrow/table.cc:655–667  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

653// Convert a table to a sequence of record batches
654
655TableBatchReader::TableBatchReader(const Table& table)
656 : owned_table_(nullptr),
657 table_(table),
658 column_data_(table.num_columns()),
659 chunk_numbers_(table.num_columns(), 0),
660 chunk_offsets_(table.num_columns(), 0),
661 absolute_row_position_(0),
662 max_chunksize_(std::numeric_limits<int64_t>::max()) {
663 for (int i = 0; i < table.num_columns(); ++i) {
664 column_data_[i] = table.column(i).get();
665 }
666 DCHECK(table_.Validate().ok());
667}
668
669TableBatchReader::TableBatchReader(std::shared_ptr<Table> table)
670 : 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