|
44 | 44 | #include <ydb/library/yql/providers/pq/async_io/dq_pq_read_actor.h>
|
45 | 45 | #include <ydb/library/yql/providers/pq/async_io/dq_pq_write_actor.h>
|
46 | 46 | #include <ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.h>
|
47 |
| -#include <ydb/library/yql/providers/ydb/actors/yql_ydb_source_factory.h> |
48 |
| -#include <ydb/library/yql/providers/ydb/comp_nodes/yql_ydb_factory.h> |
49 |
| -#include <ydb/library/yql/providers/ydb/comp_nodes/yql_ydb_dq_transform.h> |
50 |
| -#include <ydb/library/yql/providers/ydb/actors/yql_ydb_source_factory.h> |
51 | 47 | #include <ydb/library/yql/providers/common/http_gateway/yql_http_default_retry_policy.h>
|
52 | 48 |
|
53 | 49 |
|
@@ -157,16 +153,14 @@ void Init(
|
157 | 153 |
|
158 | 154 | TVector<NKikimr::NMiniKQL::TComputationNodeFactory> compNodeFactories = {
|
159 | 155 | NYql::GetCommonDqFactory(),
|
160 |
| - NYql::GetDqYdbFactory(yqSharedResources->UserSpaceYdbDriver), |
161 | 156 | NKikimr::NMiniKQL::GetYqlFactory()
|
162 | 157 | };
|
163 | 158 |
|
164 | 159 | compNodeFactories.insert(compNodeFactories.end(), additionalCompNodeFactories.begin(), additionalCompNodeFactories.end());
|
165 | 160 | NKikimr::NMiniKQL::TComputationNodeFactory dqCompFactory = NKikimr::NMiniKQL::GetCompositeWithBuiltinFactory(std::move(compNodeFactories));
|
166 | 161 |
|
167 | 162 | NYql::TTaskTransformFactory dqTaskTransformFactory = NYql::CreateCompositeTaskTransformFactory({
|
168 |
| - NYql::CreateCommonDqTaskTransformFactory(), |
169 |
| - NYql::CreateYdbDqTaskTransformFactory() |
| 163 | + NYql::CreateCommonDqTaskTransformFactory() |
170 | 164 | });
|
171 | 165 |
|
172 | 166 | auto asyncIoFactory = MakeIntrusive<NYql::NDq::TDqAsyncIoFactory>();
|
@@ -201,7 +195,6 @@ void Init(
|
201 | 195 |
|
202 | 196 | RegisterDqInputTransformLookupActorFactory(*asyncIoFactory);
|
203 | 197 | RegisterDqPqReadActorFactory(*asyncIoFactory, yqSharedResources->UserSpaceYdbDriver, credentialsFactory, yqCounters->GetSubgroup("subsystem", "DqSourceTracker"));
|
204 |
| - RegisterYdbReadActorFactory(*asyncIoFactory, yqSharedResources->UserSpaceYdbDriver, credentialsFactory); |
205 | 198 |
|
206 | 199 | s3ActorsFactory->RegisterS3ReadActorFactory(*asyncIoFactory, credentialsFactory, httpGateway, s3HttpRetryPolicy, readActorFactoryCfg,
|
207 | 200 | yqCounters->GetSubgroup("subsystem", "S3ReadActor"), protoConfig.GetGateways().GetS3().GetAllowLocalFiles());
|
|
0 commit comments