Method loadKeys

src/Dictionaries/HTTPDictionarySource.cpp:172–201

}

BlockIO HTTPDictionarySource::loadKeys(const Columns & key_columns, const VectorWithMemoryTracking<size_t> & requested_rows)
{
    LOG_TRACE(log, "loadKeys {} size = {}", toString(), requested_rows.size());

    auto block = blockForKeys(dict_struct, key_columns, requested_rows);

    ReadWriteBufferFromHTTP::OutStreamCallback out_stream_callback = [block, this](std::ostream & ostr)
    {
        WriteBufferFromOStream out_buffer(ostr);
        auto output_format = context->getOutputFormatParallelIfPossible(configuration.format, out_buffer, block.cloneEmpty());
        formatBlock(output_format, block);
        out_buffer.finalize();
    };

    Poco::URI uri(configuration.url);

    auto buf = BuilderRWBufferFromHTTP(uri)
                   .withConnectionGroup(HTTPConnectionGroupType::STORAGE)
                   .withMethod(Poco::Net::HTTPRequest::HTTP_POST)
                   .withSettings(context->getReadSettings())
                   .withTimeouts(timeouts)
                   .withHeaders(configuration.header_entries)
                   .withOutCallback(std::move(out_stream_callback))
                   .withDelayInit(false)
                   .create(credentials);

    BlockIO io;
    io.pipeline = createWrappedBuffer(std::move(buf));
    return io;
}

bool HTTPDictionarySource::isModified() const
{