mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-20 00:30:49 +00:00
fixed style
This commit is contained in:
parent
4305457883
commit
238741dafe
@ -1,4 +1,4 @@
|
||||
#pragma once
|
||||
#pragma once
|
||||
|
||||
#include <Parsers/IAST.h>
|
||||
|
||||
|
@ -6,7 +6,7 @@ namespace DB
|
||||
{
|
||||
|
||||
/// Concurrent primitive for dependency completeness registration
|
||||
/// When arrive methods return true, dependant task must be executed (or scheduled)
|
||||
/// When arrive methods return true, dependent task must be executed (or scheduled)
|
||||
class RefreshAllCombiner
|
||||
{
|
||||
public:
|
||||
|
@ -12,7 +12,7 @@ namespace DB
|
||||
|
||||
class RefreshTask;
|
||||
|
||||
/// Concurrent primitive for managing list of dependant task and notifying them
|
||||
/// Concurrent primitive for managing list of dependent task and notifying them
|
||||
class RefreshDependencies
|
||||
{
|
||||
using Container = std::list<RefreshTaskObserver>;
|
||||
|
@ -1,6 +1,11 @@
|
||||
#include <Storages/MaterializedView/RefreshSet.h>
|
||||
#include <Storages/MaterializedView/RefreshTask.h>
|
||||
|
||||
namespace CurrentMetrics
|
||||
{
|
||||
extern const Metric Refresh;
|
||||
}
|
||||
|
||||
namespace DB
|
||||
{
|
||||
|
||||
|
@ -6,15 +6,10 @@
|
||||
|
||||
#include <Common/CurrentMetrics.h>
|
||||
|
||||
namespace CurrentMetrics
|
||||
{
|
||||
extern const Metric Refresh;
|
||||
}
|
||||
|
||||
namespace DB
|
||||
namespace DB
|
||||
{
|
||||
|
||||
struct RefreshInfo
|
||||
struct RefreshInfo
|
||||
{
|
||||
String database;
|
||||
String view_name;
|
||||
|
@ -7,7 +7,7 @@
|
||||
#include <Parsers/ASTCreateQuery.h>
|
||||
#include <Processors/Executors/ManualPipelineExecutor.h>
|
||||
|
||||
namespace DB
|
||||
namespace DB
|
||||
{
|
||||
|
||||
namespace ErrorCodes
|
||||
|
@ -66,7 +66,7 @@ public:
|
||||
/// Resume task execution
|
||||
void resume();
|
||||
|
||||
/// Notify dependant task
|
||||
/// Notify dependent task
|
||||
void notify(const StorageID & parent_id);
|
||||
|
||||
private:
|
||||
|
@ -38,7 +38,7 @@ void StorageSystemViewRefreshes::fillData(
|
||||
auto valid_access = AccessType::SHOW_TABLES;
|
||||
bool check_access_for_tables = !access->isGranted(valid_access);
|
||||
|
||||
|
||||
|
||||
for (const auto & refresh : context->getRefreshSet().getInfo())
|
||||
{
|
||||
if (check_access_for_tables && !access->isGranted(valid_access, refresh.database, refresh.view_name))
|
||||
|
Loading…
Reference in New Issue
Block a user