diff options
| author | a-romanov <Anton.Romanov@ydb.tech> | 2022-07-18 12:41:15 +0300 |
|---|---|---|
| committer | a-romanov <Anton.Romanov@ydb.tech> | 2022-07-18 12:41:15 +0300 |
| commit | 14c177383c8fba3709cfc2f6114d1788184f1159 (patch) | |
| tree | 9ec229ee4484d861d276e6f98412265b48a56184 | |
| parent | 3a2de33038c3f2fa14d94a45c2d793315a4060a3 (diff) | |
| download | ydb-14c177383c8fba3709cfc2f6114d1788184f1159.tar.gz | |
Register S3 sink actor factory.
| -rw-r--r-- | ydb/core/yq/libs/init/init.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/ydb/core/yq/libs/init/init.cpp b/ydb/core/yq/libs/init/init.cpp index 871dec3d94..ff24490d58 100644 --- a/ydb/core/yq/libs/init/init.cpp +++ b/ydb/core/yq/libs/init/init.cpp @@ -29,6 +29,7 @@ #include <ydb/library/yql/providers/common/comp_nodes/yql_factory.h> #include <ydb/library/yql/providers/dq/task_runner/tasks_runner_local.h> #include <ydb/library/yql/providers/dq/worker_manager/local_worker_manager.h> +#include <ydb/library/yql/providers/s3/actors/yql_s3_sink_factory.h> #include <ydb/library/yql/providers/s3/actors/yql_s3_source_factory.h> #include <ydb/library/yql/providers/s3/proto/retry_config.pb.h> #include <ydb/library/yql/providers/clickhouse/actors/yql_ch_source_factory.h> @@ -148,6 +149,8 @@ void Init( RegisterYdbReadActorFactory(*asyncIoFactory, yqSharedResources->UserSpaceYdbDriver, credentialsFactory); RegisterS3ReadActorFactory(*asyncIoFactory, credentialsFactory, httpGateway, std::make_shared<NYql::NS3::TRetryConfig>(protoConfig.GetReadActorsFactoryConfig().GetS3ReadActorFactoryConfig().GetRetryConfig())); + RegisterS3WriteActorFactory(*asyncIoFactory, credentialsFactory, + httpGateway, std::make_shared<NYql::NS3::TRetryConfig>(protoConfig.GetReadActorsFactoryConfig().GetS3ReadActorFactoryConfig().GetRetryConfig())); RegisterClickHouseReadActorFactory(*asyncIoFactory, credentialsFactory, httpGateway); RegisterDqPqWriteActorFactory(*asyncIoFactory, yqSharedResources->UserSpaceYdbDriver, credentialsFactory); |