Function fillPartModel

src/Protos/DataModelHelpers.cpp:248–377

}

void fillPartModel(const IStorage & storage, const IMergeTreeDataPart & part, Protos::DataModelPart & part_model, bool ignore_column_commit_time, UInt64 txn_id)
{
    /// fill part info
    Protos::DataModelPartInfo * model_info = part_model.mutable_part_info();
    fillPartInfoModel(part, *model_info);

    Protos::DataModelPartTTLInfo * model_ttl_info = part_model.mutable_part_ttl_info();
    fillPartTTLInfoModel(part, *model_ttl_info);

    part_model.set_size(part.bytes_on_disk);
    part_model.set_rows_count(part.rows_count);
    part_model.set_row_exists_count(part.row_exists_count.has_value() ? part.row_exists_count.value() : part.rows_count);
    ///TODO: if we need marks_count in ce?
    if (part.index_granularity_info.is_adaptive)
    {
        auto part_index_granularity = part.index_granularity.getIndexGranularities();
        part_model.mutable_index_granularities()->Add(part_index_granularity.begin(), part_index_granularity.end());
    }

    const auto cnch_part = std::dynamic_pointer_cast<const MergeTreeDataPartCNCH>(part.shared_from_this());
    if (cnch_part)
        part_model.set_marks_count(cnch_part->getMarksCount());

    /// Normally, the DataModelPart::txnID and DataModelPart::part_info::mutation are always the same.
    /// But in some special cases(like ATTACH PARTITION, see CnchAttachProcessor::prepareParts),
    /// the DataModelPart::txnID not equal to DataModelPart::part_info::mutation.
    /// To handle this case, we need to set txnID and part_info::mutation separately.
    /// And when getting txnID, use DataModelPart::txnID by default, and use mutation as fallback, see ServerDataPart::txnID() .
    if (part.secondary_txn_id != IMergeTreeDataPart::NOT_INITIALIZED_COMMIT_TIME)
    {
        /// If we in a interactive transaction, use primary txn's txnid for this part
        part_model.set_txnid(part.info.mutation);
    }
    else
    {
        part_model.set_txnid(txn_id ? txn_id : part.info.mutation);
    }
    part_model.set_bucket_number(part.bucket_number);
    part_model.set_table_definition_hash(part.table_definition_hash);
    part_model.set_commit_time(part.commit_time.toUInt64());
    // TODO support multiple namenode , mock 0 now.
    part_model.set_data_path_id(0);

    if (part.deleted)
        part_model.set_deleted(part.deleted);
    if (part.mutation_commit_time)
        part_model.set_mutation_commit_time(part.mutation_commit_time);
    if (part.delete_flag)
        part_model.set_delete_flag(part.delete_flag);
    if (part.low_priority)
        part_model.set_low_priority(part.low_priority);
    if (part.last_modification_time)
        part_model.set_last_modification_time(part.last_modification_time);

    if (!ignore_column_commit_time && part.columns_commit_time)
    {
        part_model.set_columns_commit_time(part.columns_commit_time);
    }