Method getStorageID

src/Interpreters/AsynchronousInsertQueue.cpp:222–232

}

StorageID AsynchronousInsertQueue::InsertQuery::getStorageID() const
{
    if (!query)
        throw Exception(ErrorCodes::LOGICAL_ERROR, "InsertQuery AST is null");

    auto * insert_query = query->as<ASTInsertQuery>();
    if (!insert_query)
        throw Exception(ErrorCodes::LOGICAL_ERROR, "AST is not type of ASTInsertQuery");

    return insert_query->table_id;
}

AsynchronousInsertQueue::InsertData::Entry::Entry(
    DataChunk && chunk_,