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

Method getWriteBuffer

src/IO/tests/gtest_writebuffer_s3.cpp:558–576  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

556 }
557
558 std::unique_ptr<WriteBufferFromS3> getWriteBuffer(String file_name = "file")
559 {
560 S3::S3RequestSettings request_settings;
561 request_settings.updateFromSettings(settings, /* if_changed */true, /* validate_settings */false);
562
563 client->resetCounters();
564
565 getAsyncPolicy().setAutoExecute(false);
566
567 return std::make_unique<WriteBufferFromS3>(
568 client,
569 bucket,
570 file_name,
571 DBMS_DEFAULT_BUFFER_SIZE,
572 request_settings,
573 nullptr,
574 std::nullopt,
575 getAsyncPolicy().getScheduler());
576 }
577
578 void setInjectionModel(std::shared_ptr<MockS3::InjectionModel> injections_)
579 {

Callers 7

finalizeMethod · 0.80
cancelMethod · 0.80
executeFormatImplMethod · 0.80
executeImplMethod · 0.80
createObjectWrapperMethod · 0.80
executeImplMethod · 0.80

Calls 4

updateFromSettingsMethod · 0.45
resetCountersMethod · 0.45
setAutoExecuteMethod · 0.45
getSchedulerMethod · 0.45

Tested by

no test coverage detected