MCPcopy Create free account
hub / github.com/ClickHouse/ClickHouse / tryGetAsynchronousInsertQueue

Method tryGetAsynchronousInsertQueue

src/Interpreters/Context.cpp:7669–7673  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

7667}
7668
7669AsynchronousInsertQueue * Context::tryGetAsynchronousInsertQueue() const
7670{
7671 SharedLockGuard lock(shared->mutex);
7672 return shared->async_insert_queue.get();
7673}
7674
7675void Context::setAsynchronousInsertQueue(const std::shared_ptr<AsynchronousInsertQueue> & ptr)
7676{

Callers 4

fillDataMethod · 0.80
processInsertQueryMethod · 0.80
executeQueryImplFunction · 0.80
executeMethod · 0.80

Calls 1

getMethod · 0.45

Tested by

no test coverage detected