aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorvvvv <vvvv@yandex-team.ru>2022-04-01 15:58:29 +0300
committervvvv <vvvv@yandex-team.ru>2022-04-01 15:58:29 +0300
commit8018b6403b0a541ceb735336fecb7d98c02c0120 (patch)
tree73ec3208987f85e10f73bbe59630c51e8ae6e9e3
parentc0a08d1a2e831489b2b61fba05f5489822f06388 (diff)
downloadydb-8018b6403b0a541ceb735336fecb7d98c02c0120.tar.gz
DQ-8 no KQP in common code
ref:944cdf749c23a8764fffe744752d432a78e4509d
-rw-r--r--CMakeLists.darwin.txt84
-rw-r--r--CMakeLists.linux.txt84
-rw-r--r--ydb/library/yql/dq/actors/compute/CMakeLists.txt2
-rw-r--r--ydb/library/yql/dq/actors/compute/dq_compute_actor_channels.cpp2
-rw-r--r--ydb/library/yql/dq/actors/compute/dq_compute_actor_channels.h3
-rw-r--r--ydb/library/yql/dq/actors/compute/dq_compute_actor_checkpoints.cpp1
-rw-r--r--ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h2
-rw-r--r--ydb/library/yql/providers/dq/actors/CMakeLists.txt1
-rw-r--r--ydb/library/yql/providers/dq/worker_manager/CMakeLists.txt1
9 files changed, 91 insertions, 89 deletions
diff --git a/CMakeLists.darwin.txt b/CMakeLists.darwin.txt
index db48450b479..c37321ca8ee 100644
--- a/CMakeLists.darwin.txt
+++ b/CMakeLists.darwin.txt
@@ -645,49 +645,13 @@ add_subdirectory(ydb/library/yql/providers/common/token_accessor/client)
add_subdirectory(ydb/library/yql/providers/common/structured_token)
add_subdirectory(ydb/library/yql/providers/common/token_accessor/grpc)
add_subdirectory(ydb/library/yql/providers/solomon/proto)
+add_subdirectory(ydb/library/yql/utils/actor_log)
add_subdirectory(ydb/library/yql/utils/failure_injector)
add_subdirectory(ydb/library/yql/providers/dq/counters)
add_subdirectory(ydb/library/yql/providers/dq/task_runner)
add_subdirectory(ydb/library/yql/providers/dq/task_runner_actor)
add_subdirectory(ydb/library/yql/dq/actors/task_runner)
add_subdirectory(ydb/library/yql/providers/dq/worker_manager)
-add_subdirectory(ydb/core/kqp)
-add_subdirectory(ydb/core/kqp/compute_actor)
-add_subdirectory(ydb/core/tx/scheme_cache)
-add_subdirectory(ydb/core/kqp/counters)
-add_subdirectory(ydb/core/kqp/executer)
-add_subdirectory(ydb/core/kqp/compile)
-add_subdirectory(ydb/core/kqp/rm)
-add_subdirectory(ydb/core/cms/console)
-add_subdirectory(library/cpp/actors/http)
-add_subdirectory(library/cpp/dns)
-add_subdirectory(ydb/core/cms/console/validators)
-add_subdirectory(ydb/core/mind)
-add_subdirectory(ydb/core/blobstorage/dsproxy/mock)
-add_subdirectory(ydb/core/mind/bscontroller)
-add_subdirectory(ydb/core/sys_view/processor)
-add_subdirectory(ydb/core/test_tablet)
-add_subdirectory(ydb/core/tx/replication/controller)
-add_subdirectory(ydb/core/tx/replication/ydb_proxy)
-add_subdirectory(ydb/public/sdk/cpp/client/ydb_scheme)
-add_subdirectory(ydb/public/sdk/cpp/client/ydb_common_client/impl)
-add_subdirectory(ydb/core/tx/scheme_board)
-add_subdirectory(ydb/core/tx/schemeshard)
-add_subdirectory(ydb/core/blockstore/core)
-add_subdirectory(ydb/core/filestore/core)
-add_subdirectory(ydb/core/tx/tx_allocator_client)
-add_subdirectory(ydb/core/tx/tx_allocator)
-add_subdirectory(ydb/core/kqp/host)
-add_subdirectory(ydb/core/kqp/opt)
-add_subdirectory(ydb/core/kqp/opt/logical)
-add_subdirectory(ydb/core/kqp/opt/peephole)
-add_subdirectory(ydb/library/naming_conventions)
-add_subdirectory(ydb/core/kqp/opt/physical)
-add_subdirectory(ydb/core/kqp/opt/physical/effects)
-add_subdirectory(ydb/core/kqp/prepare)
-add_subdirectory(ydb/core/kqp/node)
-add_subdirectory(ydb/core/kqp/proxy)
-add_subdirectory(ydb/library/yql/utils/actor_log)
add_subdirectory(ydb/library/yql/providers/dq/runtime)
add_subdirectory(ydb/library/yql/providers/dq/worker_manager/interface)
add_subdirectory(ydb/core/yq/libs/common)
@@ -701,6 +665,8 @@ add_subdirectory(ydb/core/yq/libs/ydb)
add_subdirectory(library/cpp/retry)
add_subdirectory(library/cpp/retry/protos)
add_subdirectory(ydb/library/security)
+add_subdirectory(ydb/public/sdk/cpp/client/ydb_scheme)
+add_subdirectory(ydb/public/sdk/cpp/client/ydb_common_client/impl)
add_subdirectory(ydb/core/yq/libs/db_schema)
add_subdirectory(ydb/core/yq/libs/shared_resources)
add_subdirectory(ydb/core/yq/libs/shared_resources/interface)
@@ -739,6 +705,25 @@ add_subdirectory(ydb/library/persqueue/counter_time_keeper)
add_subdirectory(ydb/core/ymq/actor)
add_subdirectory(library/cpp/scheme)
add_subdirectory(ydb/core/mind/address_classification)
+add_subdirectory(ydb/core/cms/console)
+add_subdirectory(library/cpp/actors/http)
+add_subdirectory(library/cpp/dns)
+add_subdirectory(ydb/core/cms/console/validators)
+add_subdirectory(ydb/core/mind)
+add_subdirectory(ydb/core/blobstorage/dsproxy/mock)
+add_subdirectory(ydb/core/mind/bscontroller)
+add_subdirectory(ydb/core/sys_view/processor)
+add_subdirectory(ydb/core/kqp/counters)
+add_subdirectory(ydb/core/tx/scheme_cache)
+add_subdirectory(ydb/core/test_tablet)
+add_subdirectory(ydb/core/tx/replication/controller)
+add_subdirectory(ydb/core/tx/replication/ydb_proxy)
+add_subdirectory(ydb/core/tx/scheme_board)
+add_subdirectory(ydb/core/tx/schemeshard)
+add_subdirectory(ydb/core/blockstore/core)
+add_subdirectory(ydb/core/filestore/core)
+add_subdirectory(ydb/core/tx/tx_allocator_client)
+add_subdirectory(ydb/core/tx/tx_allocator)
add_subdirectory(ydb/core/tx/tx_proxy)
add_subdirectory(ydb/core/tx/balance_coverage)
add_subdirectory(ydb/core/ymq/base)
@@ -750,6 +735,21 @@ add_subdirectory(ydb/core/ymq/queues/common)
add_subdirectory(ydb/core/ymq/queues/fifo)
add_subdirectory(ydb/core/ymq/queues/std)
add_subdirectory(ydb/services/persqueue_v1)
+add_subdirectory(ydb/core/kqp)
+add_subdirectory(ydb/core/kqp/compute_actor)
+add_subdirectory(ydb/core/kqp/executer)
+add_subdirectory(ydb/core/kqp/compile)
+add_subdirectory(ydb/core/kqp/rm)
+add_subdirectory(ydb/core/kqp/host)
+add_subdirectory(ydb/core/kqp/opt)
+add_subdirectory(ydb/core/kqp/opt/logical)
+add_subdirectory(ydb/core/kqp/opt/peephole)
+add_subdirectory(ydb/library/naming_conventions)
+add_subdirectory(ydb/core/kqp/opt/physical)
+add_subdirectory(ydb/core/kqp/opt/physical/effects)
+add_subdirectory(ydb/core/kqp/prepare)
+add_subdirectory(ydb/core/kqp/node)
+add_subdirectory(ydb/core/kqp/proxy)
add_subdirectory(ydb/library/persqueue/tests)
add_subdirectory(ydb/services/lib/actors)
add_subdirectory(ydb/public/lib/jwt)
@@ -1127,6 +1127,11 @@ add_subdirectory(ydb/core/blobstorage/vdisk/hulldb/generic/ut)
add_subdirectory(ydb/core/sys_view/partition_stats/ut)
add_subdirectory(ydb/core/sys_view/query_stats/ut)
add_subdirectory(ydb/core/sys_view/service/ut)
+add_subdirectory(ydb/core/mind/address_classification/ut)
+add_subdirectory(ydb/core/mind/bscontroller/ut)
+add_subdirectory(ydb/core/mind/bscontroller/ut_bscontroller)
+add_subdirectory(ydb/core/mind/bscontroller/ut_selfheal)
+add_subdirectory(ydb/core/mind/hive/ut)
add_subdirectory(ydb/core/kqp/ut/fat)
add_subdirectory(ydb/core/kqp/rm/ut)
add_subdirectory(ydb/core/kqp/proxy/ut)
@@ -1134,11 +1139,6 @@ add_subdirectory(ydb/core/kqp/runtime/ut)
add_subdirectory(ydb/core/kqp/executer/ut)
add_subdirectory(ydb/core/kqp/node/ut)
add_subdirectory(ydb/core/kqp/provider/ut)
-add_subdirectory(ydb/core/mind/address_classification/ut)
-add_subdirectory(ydb/core/mind/bscontroller/ut)
-add_subdirectory(ydb/core/mind/bscontroller/ut_bscontroller)
-add_subdirectory(ydb/core/mind/bscontroller/ut_selfheal)
-add_subdirectory(ydb/core/mind/hive/ut)
add_subdirectory(ydb/core/cms/console/ut)
add_subdirectory(ydb/core/cms/console/validators/ut)
add_subdirectory(ydb/core/tx/columnshard/engines/ut)
diff --git a/CMakeLists.linux.txt b/CMakeLists.linux.txt
index b74a5ddf126..c6a8efbb3e5 100644
--- a/CMakeLists.linux.txt
+++ b/CMakeLists.linux.txt
@@ -725,49 +725,13 @@ add_subdirectory(ydb/library/yql/providers/common/token_accessor/client)
add_subdirectory(ydb/library/yql/providers/common/structured_token)
add_subdirectory(ydb/library/yql/providers/common/token_accessor/grpc)
add_subdirectory(ydb/library/yql/providers/solomon/proto)
+add_subdirectory(ydb/library/yql/utils/actor_log)
add_subdirectory(ydb/library/yql/utils/failure_injector)
add_subdirectory(ydb/library/yql/providers/dq/counters)
add_subdirectory(ydb/library/yql/providers/dq/task_runner)
add_subdirectory(ydb/library/yql/providers/dq/task_runner_actor)
add_subdirectory(ydb/library/yql/dq/actors/task_runner)
add_subdirectory(ydb/library/yql/providers/dq/worker_manager)
-add_subdirectory(ydb/core/kqp)
-add_subdirectory(ydb/core/kqp/compute_actor)
-add_subdirectory(ydb/core/tx/scheme_cache)
-add_subdirectory(ydb/core/kqp/counters)
-add_subdirectory(ydb/core/kqp/executer)
-add_subdirectory(ydb/core/kqp/compile)
-add_subdirectory(ydb/core/kqp/rm)
-add_subdirectory(ydb/core/cms/console)
-add_subdirectory(library/cpp/actors/http)
-add_subdirectory(library/cpp/dns)
-add_subdirectory(ydb/core/cms/console/validators)
-add_subdirectory(ydb/core/mind)
-add_subdirectory(ydb/core/blobstorage/dsproxy/mock)
-add_subdirectory(ydb/core/mind/bscontroller)
-add_subdirectory(ydb/core/sys_view/processor)
-add_subdirectory(ydb/core/test_tablet)
-add_subdirectory(ydb/core/tx/replication/controller)
-add_subdirectory(ydb/core/tx/replication/ydb_proxy)
-add_subdirectory(ydb/public/sdk/cpp/client/ydb_scheme)
-add_subdirectory(ydb/public/sdk/cpp/client/ydb_common_client/impl)
-add_subdirectory(ydb/core/tx/scheme_board)
-add_subdirectory(ydb/core/tx/schemeshard)
-add_subdirectory(ydb/core/blockstore/core)
-add_subdirectory(ydb/core/filestore/core)
-add_subdirectory(ydb/core/tx/tx_allocator_client)
-add_subdirectory(ydb/core/tx/tx_allocator)
-add_subdirectory(ydb/core/kqp/host)
-add_subdirectory(ydb/core/kqp/opt)
-add_subdirectory(ydb/core/kqp/opt/logical)
-add_subdirectory(ydb/core/kqp/opt/peephole)
-add_subdirectory(ydb/library/naming_conventions)
-add_subdirectory(ydb/core/kqp/opt/physical)
-add_subdirectory(ydb/core/kqp/opt/physical/effects)
-add_subdirectory(ydb/core/kqp/prepare)
-add_subdirectory(ydb/core/kqp/node)
-add_subdirectory(ydb/core/kqp/proxy)
-add_subdirectory(ydb/library/yql/utils/actor_log)
add_subdirectory(ydb/library/yql/providers/dq/runtime)
add_subdirectory(ydb/library/yql/providers/dq/worker_manager/interface)
add_subdirectory(ydb/core/yq/libs/common)
@@ -781,6 +745,8 @@ add_subdirectory(ydb/core/yq/libs/ydb)
add_subdirectory(library/cpp/retry)
add_subdirectory(library/cpp/retry/protos)
add_subdirectory(ydb/library/security)
+add_subdirectory(ydb/public/sdk/cpp/client/ydb_scheme)
+add_subdirectory(ydb/public/sdk/cpp/client/ydb_common_client/impl)
add_subdirectory(ydb/core/yq/libs/db_schema)
add_subdirectory(ydb/core/yq/libs/shared_resources)
add_subdirectory(ydb/core/yq/libs/shared_resources/interface)
@@ -819,6 +785,25 @@ add_subdirectory(ydb/library/persqueue/counter_time_keeper)
add_subdirectory(ydb/core/ymq/actor)
add_subdirectory(library/cpp/scheme)
add_subdirectory(ydb/core/mind/address_classification)
+add_subdirectory(ydb/core/cms/console)
+add_subdirectory(library/cpp/actors/http)
+add_subdirectory(library/cpp/dns)
+add_subdirectory(ydb/core/cms/console/validators)
+add_subdirectory(ydb/core/mind)
+add_subdirectory(ydb/core/blobstorage/dsproxy/mock)
+add_subdirectory(ydb/core/mind/bscontroller)
+add_subdirectory(ydb/core/sys_view/processor)
+add_subdirectory(ydb/core/kqp/counters)
+add_subdirectory(ydb/core/tx/scheme_cache)
+add_subdirectory(ydb/core/test_tablet)
+add_subdirectory(ydb/core/tx/replication/controller)
+add_subdirectory(ydb/core/tx/replication/ydb_proxy)
+add_subdirectory(ydb/core/tx/scheme_board)
+add_subdirectory(ydb/core/tx/schemeshard)
+add_subdirectory(ydb/core/blockstore/core)
+add_subdirectory(ydb/core/filestore/core)
+add_subdirectory(ydb/core/tx/tx_allocator_client)
+add_subdirectory(ydb/core/tx/tx_allocator)
add_subdirectory(ydb/core/tx/tx_proxy)
add_subdirectory(ydb/core/tx/balance_coverage)
add_subdirectory(ydb/core/ymq/base)
@@ -830,6 +815,21 @@ add_subdirectory(ydb/core/ymq/queues/common)
add_subdirectory(ydb/core/ymq/queues/fifo)
add_subdirectory(ydb/core/ymq/queues/std)
add_subdirectory(ydb/services/persqueue_v1)
+add_subdirectory(ydb/core/kqp)
+add_subdirectory(ydb/core/kqp/compute_actor)
+add_subdirectory(ydb/core/kqp/executer)
+add_subdirectory(ydb/core/kqp/compile)
+add_subdirectory(ydb/core/kqp/rm)
+add_subdirectory(ydb/core/kqp/host)
+add_subdirectory(ydb/core/kqp/opt)
+add_subdirectory(ydb/core/kqp/opt/logical)
+add_subdirectory(ydb/core/kqp/opt/peephole)
+add_subdirectory(ydb/library/naming_conventions)
+add_subdirectory(ydb/core/kqp/opt/physical)
+add_subdirectory(ydb/core/kqp/opt/physical/effects)
+add_subdirectory(ydb/core/kqp/prepare)
+add_subdirectory(ydb/core/kqp/node)
+add_subdirectory(ydb/core/kqp/proxy)
add_subdirectory(ydb/library/persqueue/tests)
add_subdirectory(ydb/services/lib/actors)
add_subdirectory(ydb/public/lib/jwt)
@@ -1222,6 +1222,11 @@ add_subdirectory(ydb/core/blobstorage/vdisk/hulldb/generic/ut)
add_subdirectory(ydb/core/sys_view/partition_stats/ut)
add_subdirectory(ydb/core/sys_view/query_stats/ut)
add_subdirectory(ydb/core/sys_view/service/ut)
+add_subdirectory(ydb/core/mind/address_classification/ut)
+add_subdirectory(ydb/core/mind/bscontroller/ut)
+add_subdirectory(ydb/core/mind/bscontroller/ut_bscontroller)
+add_subdirectory(ydb/core/mind/bscontroller/ut_selfheal)
+add_subdirectory(ydb/core/mind/hive/ut)
add_subdirectory(ydb/core/kqp/ut/fat)
add_subdirectory(ydb/core/kqp/rm/ut)
add_subdirectory(ydb/core/kqp/proxy/ut)
@@ -1229,11 +1234,6 @@ add_subdirectory(ydb/core/kqp/runtime/ut)
add_subdirectory(ydb/core/kqp/executer/ut)
add_subdirectory(ydb/core/kqp/node/ut)
add_subdirectory(ydb/core/kqp/provider/ut)
-add_subdirectory(ydb/core/mind/address_classification/ut)
-add_subdirectory(ydb/core/mind/bscontroller/ut)
-add_subdirectory(ydb/core/mind/bscontroller/ut_bscontroller)
-add_subdirectory(ydb/core/mind/bscontroller/ut_selfheal)
-add_subdirectory(ydb/core/mind/hive/ut)
add_subdirectory(ydb/core/cms/console/ut)
add_subdirectory(ydb/core/cms/console/validators/ut)
add_subdirectory(ydb/core/tx/columnshard/engines/ut)
diff --git a/ydb/library/yql/dq/actors/compute/CMakeLists.txt b/ydb/library/yql/dq/actors/compute/CMakeLists.txt
index eb9fcc28f19..259d3ff8b04 100644
--- a/ydb/library/yql/dq/actors/compute/CMakeLists.txt
+++ b/ydb/library/yql/dq/actors/compute/CMakeLists.txt
@@ -16,8 +16,6 @@ target_link_libraries(dq-actors-compute PUBLIC
yutil
cpp-actors-core
ydb-core-base
- core-kqp-common
- core-kqp-runtime
ydb-core-protos
ydb-core-scheme
ydb-core-tablet_flat
diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor_channels.cpp b/ydb/library/yql/dq/actors/compute/dq_compute_actor_channels.cpp
index 1a1611ec81e..920c1a7d197 100644
--- a/ydb/library/yql/dq/actors/compute/dq_compute_actor_channels.cpp
+++ b/ydb/library/yql/dq/actors/compute/dq_compute_actor_channels.cpp
@@ -1,6 +1,8 @@
#include "dq_compute_actor_channels.h"
#include <util/string/join.h>
+#include <ydb/core/protos/services.pb.h>
+#include <ydb/library/yql/dq/actors/dq.h>
#define LOG_D(s) \
diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor_channels.h b/ydb/library/yql/dq/actors/compute/dq_compute_actor_channels.h
index 648b1d8b563..6660b6f688e 100644
--- a/ydb/library/yql/dq/actors/compute/dq_compute_actor_channels.h
+++ b/ydb/library/yql/dq/actors/compute/dq_compute_actor_channels.h
@@ -2,10 +2,9 @@
#include "dq_compute_actor.h"
-#include <ydb/core/kqp/kqp.h>
-
#include <library/cpp/actors/core/actor.h>
#include <library/cpp/actors/interconnect/interconnect.h>
+#include <ydb/core/base/events.h>
namespace NYql::NDq {
diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor_checkpoints.cpp b/ydb/library/yql/dq/actors/compute/dq_compute_actor_checkpoints.cpp
index 4afc81a844d..84355c8734d 100644
--- a/ydb/library/yql/dq/actors/compute/dq_compute_actor_checkpoints.cpp
+++ b/ydb/library/yql/dq/actors/compute/dq_compute_actor_checkpoints.cpp
@@ -1,6 +1,7 @@
#include "dq_compute_actor_checkpoints.h"
#include "dq_checkpoints.h"
#include "dq_compute_actor_impl.h"
+#include <ydb/core/protos/services.pb.h>
#include <ydb/library/yql/minikql/comp_nodes/mkql_saveload.h>
diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h b/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h
index 03dc572ac8a..f831bda122e 100644
--- a/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h
+++ b/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h
@@ -10,6 +10,7 @@
#include <ydb/core/scheme/scheme_tabledefs.h> // TODO: TTableId
#include <ydb/core/base/kikimr_issue.h>
#include <ydb/core/tablet_flat/util_basics.h> // TODO: IDestructable
+#include <ydb/core/protos/services.pb.h>
#include <ydb/library/yql/dq/actors/protos/dq_events.pb.h>
#include <ydb/library/yql/dq/common/dq_common.h>
@@ -17,6 +18,7 @@
#include <ydb/library/yql/core/issue/yql_issue.h>
#include <ydb/library/yql/minikql/comp_nodes/mkql_saveload.h>
#include <ydb/library/yql/public/issue/yql_issue_message.h>
+#include <ydb/library/yql/dq/actors/dq.h>
#include <library/cpp/actors/core/interconnect.h>
diff --git a/ydb/library/yql/providers/dq/actors/CMakeLists.txt b/ydb/library/yql/providers/dq/actors/CMakeLists.txt
index 549efc42597..a607fb65d89 100644
--- a/ydb/library/yql/providers/dq/actors/CMakeLists.txt
+++ b/ydb/library/yql/providers/dq/actors/CMakeLists.txt
@@ -22,6 +22,7 @@ target_link_libraries(providers-dq-actors PUBLIC
core-services-mounts
yql-core-user_data
yql-utils-actors
+ yql-utils-actor_log
yql-utils-backtrace
yql-utils-log
api-protos
diff --git a/ydb/library/yql/providers/dq/worker_manager/CMakeLists.txt b/ydb/library/yql/providers/dq/worker_manager/CMakeLists.txt
index b115520ba0c..f20c6f88255 100644
--- a/ydb/library/yql/providers/dq/worker_manager/CMakeLists.txt
+++ b/ydb/library/yql/providers/dq/worker_manager/CMakeLists.txt
@@ -14,7 +14,6 @@ target_compile_options(providers-dq-worker_manager PRIVATE
target_link_libraries(providers-dq-worker_manager PUBLIC
contrib-libs-cxxsupp
yutil
- ydb-core-kqp
yql-utils-failure_injector
providers-common-config
providers-common-gateway