use context->getWriteSettings()

This commit is contained in:
Sergei Trifonov 2022-07-13 19:48:57 +02:00
parent af4a5a5f3a
commit 15ab3bc99f
3 changed files with 4 additions and 2 deletions

View File

@ -3476,6 +3476,8 @@ WriteSettings Context::getWriteSettings() const
res.enable_filesystem_cache_on_write_operations = settings.enable_filesystem_cache_on_write_operations;
res.throttler = getRemoteWriteThrottler();
return res;
}

View File

@ -418,7 +418,7 @@ public:
uri,
context->getGlobalContext()->getConfigRef(),
context->getSettingsRef().hdfs_replication,
WriteSettings{.throttler = context->getRemoteWriteThrottler()}),
context->getWriteSettings()),
compression_method, 3);
writer = FormatFactory::instance().getOutputFormatParallelIfPossible(format, *write_buf, sample_block, context);
}

View File

@ -588,7 +588,7 @@ public:
std::nullopt,
DBMS_DEFAULT_BUFFER_SIZE,
threadPoolCallbackRunner(IOThreadPool::get()),
WriteSettings{.throttler = context->getRemoteWriteThrottler()}),
context->getWriteSettings()),
compression_method,
3);
writer