Method pushQueryWithBlock

src/Interpreters/AsynchronousInsertQueue.cpp:517–522

}

AsynchronousInsertQueue::PushResult AsynchronousInsertQueue::pushQueryWithBlock(ASTPtr query, Block && block, ContextPtr query_context)
{
    query = query->clone();
    preprocessInsertQuery(query, query_context);
    return pushDataChunk(std::move(query), std::move(block), std::move(query_context));
}

std::vector<std::string> AsynchronousInsertQueue::getInsertQueryIds(InsertData & data)
{