Method getBySerializedKeys

src/Storages/StorageKeeperMap.cpp:1470–1548

}

Chunk StorageKeeperMap::getBySerializedKeys(
    const std::span<const std::string> keys, PaddedPODArray<UInt8> * null_map, bool with_version, const ContextPtr & local_context) const
{
    auto metadata_snapshot = getInMemoryMetadataPtr(local_context, false);
    Block sample_block = metadata_snapshot->getSampleBlock();
    MutableColumns columns = sample_block.cloneEmptyColumns();
    MutableColumnPtr version_column = nullptr;

    if (with_version)
        version_column = ColumnVector<Int32>::create();

    size_t primary_key_pos = getPrimaryKeyPos(sample_block, getPrimaryKey());

    if (null_map)
    {
        null_map->clear();
        null_map->resize_fill(keys.size(), 1);
    }

    Strings full_key_paths;
    full_key_paths.reserve(keys.size());

    for (const auto & key : keys)
        full_key_paths.emplace_back(fullPathForKey(key));

    const auto & settings = local_context->getSettingsRef();
    ZooKeeperRetriesControl zk_retry{
        getName(),
        getLogger(getName()),
        ZooKeeperRetriesInfo{
            settings[Setting::keeper_max_retries],
            settings[Setting::keeper_retry_initial_backoff_ms],
            settings[Setting::keeper_retry_max_backoff_ms],
            local_context->getProcessListElement()}};

    zkutil::ZooKeeper::MultiTryGetResponse values;
    zk_retry.retryLoop([&]{
        auto client = getClient();
        values = client->tryGet(full_key_paths);
    });

    for (size_t i = 0; i < keys.size(); ++i)
    {
        auto response = values[i];

        Coordination::Error code = response.error;

        if (code == Coordination::Error::ZOK)
        {
            fillColumns(base64Decode(keys[i], true), response.data, primary_key_pos, sample_block, columns);

            if (version_column)
                version_column->insert(response.stat.version);
        }
        else if (code == Coordination::Error::ZNONODE)
        {
            if (null_map)
            {