aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorgvit <gvit@ydb.tech>2023-07-13 17:17:00 +0300
committergvit <gvit@ydb.tech>2023-07-13 17:17:00 +0300
commit28c078dba8c4e79f2c2218c0b31e5795434915e4 (patch)
tree6d41ebb928b4ab724d239e153cb44b5fe3cd6377
parent07b559d039679d1da7e7f2a6e10dd6b4156554f5 (diff)
downloadydb-28c078dba8c4e79f2c2218c0b31e5795434915e4.tar.gz
refactor ydb/core/scheme dependencies
-rw-r--r--ydb/core/base/CMakeLists.darwin-x86_64.txt2
-rw-r--r--ydb/core/base/CMakeLists.linux-aarch64.txt2
-rw-r--r--ydb/core/base/CMakeLists.linux-x86_64.txt2
-rw-r--r--ydb/core/base/CMakeLists.windows-x86_64.txt2
-rw-r--r--ydb/core/base/blobstorage.h2
-rw-r--r--ydb/core/base/board_subscriber_ut.cpp2
-rw-r--r--ydb/core/base/statestorage_impl.h2
-rw-r--r--ydb/core/base/ya.make2
-rw-r--r--ydb/core/cms/console/console_tenants_manager.h2
-rw-r--r--ydb/core/formats/arrow/converter.cpp1
-rw-r--r--ydb/core/protos/CMakeLists.darwin-x86_64.txt14
-rw-r--r--ydb/core/protos/CMakeLists.linux-aarch64.txt14
-rw-r--r--ydb/core/protos/CMakeLists.linux-x86_64.txt14
-rw-r--r--ydb/core/protos/CMakeLists.windows-x86_64.txt14
-rw-r--r--ydb/core/protos/base.proto5
-rw-r--r--ydb/core/protos/flat_scheme_op.proto4
-rw-r--r--ydb/core/protos/flat_tx_scheme.proto3
-rw-r--r--ydb/core/protos/kqp.proto2
-rw-r--r--ydb/core/protos/pqconfig.proto2
-rw-r--r--ydb/core/protos/replication.proto2
-rw-r--r--ydb/core/protos/scheme_log.proto2
-rw-r--r--ydb/core/protos/tx.proto8
-rw-r--r--ydb/core/protos/tx_datashard.proto4
-rw-r--r--ydb/core/protos/tx_sequenceshard.proto1
-rw-r--r--ydb/core/protos/ya.make2
-rw-r--r--ydb/core/scheme/CMakeLists.darwin-x86_64.txt7
-rw-r--r--ydb/core/scheme/CMakeLists.linux-aarch64.txt7
-rw-r--r--ydb/core/scheme/CMakeLists.linux-x86_64.txt7
-rw-r--r--ydb/core/scheme/CMakeLists.windows-x86_64.txt7
-rw-r--r--ydb/core/scheme/defs.h3
-rw-r--r--ydb/core/scheme/protos/CMakeLists.darwin-x86_64.txt83
-rw-r--r--ydb/core/scheme/protos/CMakeLists.linux-aarch64.txt84
-rw-r--r--ydb/core/scheme/protos/CMakeLists.linux-x86_64.txt84
-rw-r--r--ydb/core/scheme/protos/CMakeLists.txt17
-rw-r--r--ydb/core/scheme/protos/CMakeLists.windows-x86_64.txt83
-rw-r--r--ydb/core/scheme/protos/key_range.proto9
-rw-r--r--ydb/core/scheme/protos/pathid.proto7
-rw-r--r--ydb/core/scheme/protos/type_info.proto (renamed from ydb/core/protos/type_info.proto)0
-rw-r--r--ydb/core/scheme/protos/ya.make17
-rw-r--r--ydb/core/scheme/scheme_pathid.cpp (renamed from ydb/core/base/pathid.cpp)18
-rw-r--r--ydb/core/scheme/scheme_pathid.h (renamed from ydb/core/base/pathid.h)4
-rw-r--r--ydb/core/scheme/scheme_tablecell.cpp3
-rw-r--r--ydb/core/scheme/scheme_tabledefs.h4
-rw-r--r--ydb/core/scheme/scheme_types_proto.h2
-rw-r--r--ydb/core/scheme/ya.make7
-rw-r--r--ydb/core/sys_view/common/events.h2
-rw-r--r--ydb/core/sys_view/common/processor_scan.h2
-rw-r--r--ydb/core/sys_view/common/scan_actor_base_impl.h4
-rw-r--r--ydb/core/sys_view/nodes/nodes.cpp6
-rw-r--r--ydb/core/sys_view/nodes/nodes.h5
-rw-r--r--ydb/core/sys_view/partition_stats/partition_stats.cpp6
-rw-r--r--ydb/core/sys_view/partition_stats/partition_stats.h7
-rw-r--r--ydb/core/sys_view/partition_stats/top_partitions.cpp2
-rw-r--r--ydb/core/sys_view/partition_stats/top_partitions.h5
-rw-r--r--ydb/core/sys_view/processor/processor.cpp4
-rw-r--r--ydb/core/sys_view/processor/processor.h4
-rw-r--r--ydb/core/sys_view/processor/processor_impl.cpp4
-rw-r--r--ydb/core/sys_view/processor/processor_impl.h4
-rw-r--r--ydb/core/sys_view/processor/tx_configure.cpp2
-rw-r--r--ydb/core/sys_view/query_stats/query_metrics.cpp2
-rw-r--r--ydb/core/sys_view/query_stats/query_metrics.h5
-rw-r--r--ydb/core/sys_view/query_stats/query_stats.cpp4
-rw-r--r--ydb/core/sys_view/query_stats/query_stats.h5
-rw-r--r--ydb/core/sys_view/scan.cpp6
-rw-r--r--ydb/core/sys_view/scan.h6
-rw-r--r--ydb/core/sys_view/service/db_counters.cpp2
-rw-r--r--ydb/core/sys_view/service/db_counters.h4
-rw-r--r--ydb/core/sys_view/service/sysview_service.cpp4
-rw-r--r--ydb/core/sys_view/service/sysview_service.h4
-rw-r--r--ydb/core/sys_view/storage/groups.cpp2
-rw-r--r--ydb/core/sys_view/storage/groups.h5
-rw-r--r--ydb/core/sys_view/storage/pdisks.cpp2
-rw-r--r--ydb/core/sys_view/storage/pdisks.h5
-rw-r--r--ydb/core/sys_view/storage/storage_pools.cpp2
-rw-r--r--ydb/core/sys_view/storage/storage_pools.h5
-rw-r--r--ydb/core/sys_view/storage/storage_stats.cpp2
-rw-r--r--ydb/core/sys_view/storage/storage_stats.h5
-rw-r--r--ydb/core/sys_view/storage/vslots.cpp2
-rw-r--r--ydb/core/sys_view/storage/vslots.h5
-rw-r--r--ydb/core/sys_view/tablets/tablets.cpp4
-rw-r--r--ydb/core/sys_view/tablets/tablets.h4
-rw-r--r--ydb/core/tablet_flat/protos/CMakeLists.darwin-x86_64.txt1
-rw-r--r--ydb/core/tablet_flat/protos/CMakeLists.linux-aarch64.txt1
-rw-r--r--ydb/core/tablet_flat/protos/CMakeLists.linux-x86_64.txt1
-rw-r--r--ydb/core/tablet_flat/protos/CMakeLists.windows-x86_64.txt1
-rw-r--r--ydb/core/tablet_flat/protos/flat_table_part.proto2
-rw-r--r--ydb/core/tablet_flat/protos/ya.make1
-rw-r--r--ydb/core/tx/datashard/cdc_stream_scan.h2
-rw-r--r--ydb/core/tx/datashard/change_record.h2
-rw-r--r--ydb/core/tx/datashard/change_sender_monitoring.cpp1
-rw-r--r--ydb/core/tx/datashard/change_sender_monitoring.h4
-rw-r--r--ydb/core/tx/datashard/snapshot_key.h2
-rw-r--r--ydb/core/tx/replication/controller/private_events.h2
-rw-r--r--ydb/core/tx/replication/controller/replication.h2
-rw-r--r--ydb/core/tx/scheme_board/events.h2
-rw-r--r--ydb/core/tx/scheme_board/helpers.h2
-rw-r--r--ydb/core/tx/scheme_board/mon_events.h2
-rw-r--r--ydb/core/tx/scheme_board/monitoring.cpp2
-rw-r--r--ydb/core/tx/scheme_board/populator.h2
-rw-r--r--ydb/core/tx/scheme_board/populator_ut.cpp2
-rw-r--r--ydb/core/tx/scheme_board/replica_ut.cpp2
-rw-r--r--ydb/core/tx/scheme_board/subscriber.h2
-rw-r--r--ydb/core/tx/scheme_board/subscriber_ut.cpp2
-rw-r--r--ydb/core/tx/scheme_cache/scheme_cache.h2
-rw-r--r--ydb/core/tx/schemeshard/schemeshard_identificators.h2
-rw-r--r--ydb/core/tx/schemeshard/schemeshard_schema.h2
-rw-r--r--ydb/core/tx/schemeshard/schemeshard_tables_storage.h2
-rw-r--r--ydb/core/tx/schemeshard/ut_helpers/ls_checks.h2
-rw-r--r--ydb/core/tx/sequenceproxy/public/events.h2
-rw-r--r--ydb/core/tx/sequenceshard/public/events.h2
110 files changed, 579 insertions, 180 deletions
diff --git a/ydb/core/base/CMakeLists.darwin-x86_64.txt b/ydb/core/base/CMakeLists.darwin-x86_64.txt
index b26c3a19a1..2a6628b32e 100644
--- a/ydb/core/base/CMakeLists.darwin-x86_64.txt
+++ b/ydb/core/base/CMakeLists.darwin-x86_64.txt
@@ -36,6 +36,7 @@ target_link_libraries(ydb-core-base PUBLIC
ydb-core-erasure
ydb-core-protos
core-protos-out
+ ydb-core-scheme
ydb-library-aclib
ydb-library-login
ydb-library-pdisk_io
@@ -60,7 +61,6 @@ target_sources(ydb-core-base PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/base/localdb.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/logoblob.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/path.cpp
- ${CMAKE_SOURCE_DIR}/ydb/core/base/pathid.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/pool_stats_collector.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/quoter.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/row_version.cpp
diff --git a/ydb/core/base/CMakeLists.linux-aarch64.txt b/ydb/core/base/CMakeLists.linux-aarch64.txt
index 247b95949a..bd7865b0b0 100644
--- a/ydb/core/base/CMakeLists.linux-aarch64.txt
+++ b/ydb/core/base/CMakeLists.linux-aarch64.txt
@@ -37,6 +37,7 @@ target_link_libraries(ydb-core-base PUBLIC
ydb-core-erasure
ydb-core-protos
core-protos-out
+ ydb-core-scheme
ydb-library-aclib
ydb-library-login
ydb-library-pdisk_io
@@ -61,7 +62,6 @@ target_sources(ydb-core-base PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/base/localdb.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/logoblob.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/path.cpp
- ${CMAKE_SOURCE_DIR}/ydb/core/base/pathid.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/pool_stats_collector.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/quoter.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/row_version.cpp
diff --git a/ydb/core/base/CMakeLists.linux-x86_64.txt b/ydb/core/base/CMakeLists.linux-x86_64.txt
index 247b95949a..bd7865b0b0 100644
--- a/ydb/core/base/CMakeLists.linux-x86_64.txt
+++ b/ydb/core/base/CMakeLists.linux-x86_64.txt
@@ -37,6 +37,7 @@ target_link_libraries(ydb-core-base PUBLIC
ydb-core-erasure
ydb-core-protos
core-protos-out
+ ydb-core-scheme
ydb-library-aclib
ydb-library-login
ydb-library-pdisk_io
@@ -61,7 +62,6 @@ target_sources(ydb-core-base PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/base/localdb.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/logoblob.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/path.cpp
- ${CMAKE_SOURCE_DIR}/ydb/core/base/pathid.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/pool_stats_collector.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/quoter.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/row_version.cpp
diff --git a/ydb/core/base/CMakeLists.windows-x86_64.txt b/ydb/core/base/CMakeLists.windows-x86_64.txt
index b26c3a19a1..2a6628b32e 100644
--- a/ydb/core/base/CMakeLists.windows-x86_64.txt
+++ b/ydb/core/base/CMakeLists.windows-x86_64.txt
@@ -36,6 +36,7 @@ target_link_libraries(ydb-core-base PUBLIC
ydb-core-erasure
ydb-core-protos
core-protos-out
+ ydb-core-scheme
ydb-library-aclib
ydb-library-login
ydb-library-pdisk_io
@@ -60,7 +61,6 @@ target_sources(ydb-core-base PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/base/localdb.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/logoblob.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/path.cpp
- ${CMAKE_SOURCE_DIR}/ydb/core/base/pathid.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/pool_stats_collector.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/quoter.cpp
${CMAKE_SOURCE_DIR}/ydb/core/base/row_version.cpp
diff --git a/ydb/core/base/blobstorage.h b/ydb/core/base/blobstorage.h
index b8ff78474b..d087de7720 100644
--- a/ydb/core/base/blobstorage.h
+++ b/ydb/core/base/blobstorage.h
@@ -5,8 +5,8 @@
#include "events.h"
#include "tablet_types.h"
#include "logoblob.h"
-#include "pathid.h"
+#include <ydb/core/scheme/scheme_pathid.h>
#include <ydb/core/base/services/blobstorage_service_id.h>
#include <ydb/core/base/blobstorage_grouptype.h>
#include <ydb/core/protos/base.pb.h>
diff --git a/ydb/core/base/board_subscriber_ut.cpp b/ydb/core/base/board_subscriber_ut.cpp
index 404432b979..b86aef4672 100644
--- a/ydb/core/base/board_subscriber_ut.cpp
+++ b/ydb/core/base/board_subscriber_ut.cpp
@@ -1,7 +1,7 @@
#include <ydb/core/base/statestorage.h>
#include <ydb/core/base/statestorage_impl.h>
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <ydb/core/testlib/basics/appdata.h>
#include <ydb/core/testlib/basics/helpers.h>
diff --git a/ydb/core/base/statestorage_impl.h b/ydb/core/base/statestorage_impl.h
index 2fd78b0757..ed154b9d2d 100644
--- a/ydb/core/base/statestorage_impl.h
+++ b/ydb/core/base/statestorage_impl.h
@@ -1,5 +1,5 @@
#pragma once
-#include "pathid.h"
+#include "ydb/core/scheme/scheme_pathid.h"
#include "statestorage.h"
namespace NKikimr {
diff --git a/ydb/core/base/ya.make b/ydb/core/base/ya.make
index 016b772782..3af57c78ff 100644
--- a/ydb/core/base/ya.make
+++ b/ydb/core/base/ya.make
@@ -37,7 +37,6 @@ SRCS(
memobserver.h
nameservice.h
path.cpp
- pathid.cpp
pool_stats_collector.cpp
pool_stats_collector.h
quoter.cpp
@@ -99,6 +98,7 @@ PEERDIR(
ydb/core/erasure
ydb/core/protos
ydb/core/protos/out
+ ydb/core/scheme
ydb/library/aclib
ydb/library/login
ydb/library/pdisk_io
diff --git a/ydb/core/cms/console/console_tenants_manager.h b/ydb/core/cms/console/console_tenants_manager.h
index 0932dd273e..bf5ad34cdf 100644
--- a/ydb/core/cms/console/console_tenants_manager.h
+++ b/ydb/core/cms/console/console_tenants_manager.h
@@ -8,7 +8,7 @@
#include <ydb/core/base/blobstorage.h>
#include <ydb/core/base/location.h>
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <ydb/core/base/tablet_pipe.h>
#include <ydb/core/engine/minikql/flat_local_tx_factory.h>
#include <ydb/core/mind/tenant_slot_broker.h>
diff --git a/ydb/core/formats/arrow/converter.cpp b/ydb/core/formats/arrow/converter.cpp
index df99fbc05a..7c3caa905a 100644
--- a/ydb/core/formats/arrow/converter.cpp
+++ b/ydb/core/formats/arrow/converter.cpp
@@ -5,6 +5,7 @@
#include <ydb/library/dynumber/dynumber.h>
#include <util/memory/pool.h>
+#include <library/cpp/containers/stack_vector/stack_vec.h>
#include <contrib/libs/apache/arrow/cpp/src/arrow/builder.h>
#include <contrib/libs/apache/arrow/cpp/src/arrow/record_batch.h>
diff --git a/ydb/core/protos/CMakeLists.darwin-x86_64.txt b/ydb/core/protos/CMakeLists.darwin-x86_64.txt
index 21afc82480..df64832294 100644
--- a/ydb/core/protos/CMakeLists.darwin-x86_64.txt
+++ b/ydb/core/protos/CMakeLists.darwin-x86_64.txt
@@ -1490,18 +1490,6 @@ get_built_tool_path(
cpp_styleguide
)
get_built_tool_path(
- TOOL_protoc_bin
- TOOL_protoc_dependency
- contrib/tools/protoc/bin
- protoc
-)
-get_built_tool_path(
- TOOL_cpp_styleguide_bin
- TOOL_cpp_styleguide_dependency
- contrib/tools/protoc/plugins/cpp_styleguide
- cpp_styleguide
-)
-get_built_tool_path(
TOOL_enum_parser_bin
TOOL_enum_parser_dependency
tools/enum_parser/enum_parser
@@ -1525,6 +1513,7 @@ target_link_libraries(ydb-core-protos PUBLIC
tools-enum_parser-enum_serialization_runtime
cpp-actors-protos
libs-config-protos
+ core-scheme-protos
library-login-protos
library-mkql_proto-protos
api-protos
@@ -1649,7 +1638,6 @@ target_proto_messages(ydb-core-protos PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/protos/tx_proxy.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/tx_scheme.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/tx_sequenceshard.proto
- ${CMAKE_SOURCE_DIR}/ydb/core/protos/type_info.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/pdiskfit.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/pqconfig.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/auth.proto
diff --git a/ydb/core/protos/CMakeLists.linux-aarch64.txt b/ydb/core/protos/CMakeLists.linux-aarch64.txt
index dd7c1ba870..c7f97d4885 100644
--- a/ydb/core/protos/CMakeLists.linux-aarch64.txt
+++ b/ydb/core/protos/CMakeLists.linux-aarch64.txt
@@ -1490,18 +1490,6 @@ get_built_tool_path(
cpp_styleguide
)
get_built_tool_path(
- TOOL_protoc_bin
- TOOL_protoc_dependency
- contrib/tools/protoc/bin
- protoc
-)
-get_built_tool_path(
- TOOL_cpp_styleguide_bin
- TOOL_cpp_styleguide_dependency
- contrib/tools/protoc/plugins/cpp_styleguide
- cpp_styleguide
-)
-get_built_tool_path(
TOOL_enum_parser_bin
TOOL_enum_parser_dependency
tools/enum_parser/enum_parser
@@ -1526,6 +1514,7 @@ target_link_libraries(ydb-core-protos PUBLIC
tools-enum_parser-enum_serialization_runtime
cpp-actors-protos
libs-config-protos
+ core-scheme-protos
library-login-protos
library-mkql_proto-protos
api-protos
@@ -1650,7 +1639,6 @@ target_proto_messages(ydb-core-protos PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/protos/tx_proxy.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/tx_scheme.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/tx_sequenceshard.proto
- ${CMAKE_SOURCE_DIR}/ydb/core/protos/type_info.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/pdiskfit.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/pqconfig.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/auth.proto
diff --git a/ydb/core/protos/CMakeLists.linux-x86_64.txt b/ydb/core/protos/CMakeLists.linux-x86_64.txt
index dd7c1ba870..c7f97d4885 100644
--- a/ydb/core/protos/CMakeLists.linux-x86_64.txt
+++ b/ydb/core/protos/CMakeLists.linux-x86_64.txt
@@ -1490,18 +1490,6 @@ get_built_tool_path(
cpp_styleguide
)
get_built_tool_path(
- TOOL_protoc_bin
- TOOL_protoc_dependency
- contrib/tools/protoc/bin
- protoc
-)
-get_built_tool_path(
- TOOL_cpp_styleguide_bin
- TOOL_cpp_styleguide_dependency
- contrib/tools/protoc/plugins/cpp_styleguide
- cpp_styleguide
-)
-get_built_tool_path(
TOOL_enum_parser_bin
TOOL_enum_parser_dependency
tools/enum_parser/enum_parser
@@ -1526,6 +1514,7 @@ target_link_libraries(ydb-core-protos PUBLIC
tools-enum_parser-enum_serialization_runtime
cpp-actors-protos
libs-config-protos
+ core-scheme-protos
library-login-protos
library-mkql_proto-protos
api-protos
@@ -1650,7 +1639,6 @@ target_proto_messages(ydb-core-protos PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/protos/tx_proxy.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/tx_scheme.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/tx_sequenceshard.proto
- ${CMAKE_SOURCE_DIR}/ydb/core/protos/type_info.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/pdiskfit.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/pqconfig.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/auth.proto
diff --git a/ydb/core/protos/CMakeLists.windows-x86_64.txt b/ydb/core/protos/CMakeLists.windows-x86_64.txt
index 21afc82480..df64832294 100644
--- a/ydb/core/protos/CMakeLists.windows-x86_64.txt
+++ b/ydb/core/protos/CMakeLists.windows-x86_64.txt
@@ -1490,18 +1490,6 @@ get_built_tool_path(
cpp_styleguide
)
get_built_tool_path(
- TOOL_protoc_bin
- TOOL_protoc_dependency
- contrib/tools/protoc/bin
- protoc
-)
-get_built_tool_path(
- TOOL_cpp_styleguide_bin
- TOOL_cpp_styleguide_dependency
- contrib/tools/protoc/plugins/cpp_styleguide
- cpp_styleguide
-)
-get_built_tool_path(
TOOL_enum_parser_bin
TOOL_enum_parser_dependency
tools/enum_parser/enum_parser
@@ -1525,6 +1513,7 @@ target_link_libraries(ydb-core-protos PUBLIC
tools-enum_parser-enum_serialization_runtime
cpp-actors-protos
libs-config-protos
+ core-scheme-protos
library-login-protos
library-mkql_proto-protos
api-protos
@@ -1649,7 +1638,6 @@ target_proto_messages(ydb-core-protos PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/protos/tx_proxy.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/tx_scheme.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/tx_sequenceshard.proto
- ${CMAKE_SOURCE_DIR}/ydb/core/protos/type_info.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/pdiskfit.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/pqconfig.proto
${CMAKE_SOURCE_DIR}/ydb/core/protos/auth.proto
diff --git a/ydb/core/protos/base.proto b/ydb/core/protos/base.proto
index 1f7e855e09..574cc48275 100644
--- a/ydb/core/protos/base.proto
+++ b/ydb/core/protos/base.proto
@@ -37,8 +37,3 @@ message TRowVersion {
optional uint64 Step = 1;
optional uint64 TxId = 2;
}
-
-message TPathID {
- optional fixed64 OwnerId = 1;
- optional uint64 LocalId = 2;
-}
diff --git a/ydb/core/protos/flat_scheme_op.proto b/ydb/core/protos/flat_scheme_op.proto
index eec4c42fbb..629e577868 100644
--- a/ydb/core/protos/flat_scheme_op.proto
+++ b/ydb/core/protos/flat_scheme_op.proto
@@ -1,5 +1,5 @@
-import "ydb/core/protos/base.proto";
-import "ydb/core/protos/type_info.proto";
+import "ydb/core/scheme/protos/type_info.proto";
+import "ydb/core/scheme/protos/pathid.proto";
import "ydb/core/protos/bind_channel_storage_pool.proto";
import "ydb/core/protos/pqconfig.proto";
import "ydb/core/protos/replication.proto";
diff --git a/ydb/core/protos/flat_tx_scheme.proto b/ydb/core/protos/flat_tx_scheme.proto
index ed2d300245..bb4bcde645 100644
--- a/ydb/core/protos/flat_tx_scheme.proto
+++ b/ydb/core/protos/flat_tx_scheme.proto
@@ -1,6 +1,7 @@
import "library/cpp/actors/protos/actors.proto";
import "ydb/core/protos/base.proto";
-import "ydb/core/protos/type_info.proto";
+import "ydb/core/scheme/protos/pathid.proto";
+import "ydb/core/scheme/protos/type_info.proto";
import "ydb/core/protos/subdomains.proto";
import "ydb/core/protos/bind_channel_storage_pool.proto";
import "ydb/core/protos/flat_scheme_op.proto";
diff --git a/ydb/core/protos/kqp.proto b/ydb/core/protos/kqp.proto
index 5742f70258..14cca0f988 100644
--- a/ydb/core/protos/kqp.proto
+++ b/ydb/core/protos/kqp.proto
@@ -4,7 +4,7 @@ option cc_enable_arenas = true;
import "google/protobuf/duration.proto";
import "library/cpp/actors/protos/actors.proto";
-import "ydb/core/protos/type_info.proto";
+import "ydb/core/scheme/protos/type_info.proto";
import "ydb/core/protos/kqp_physical.proto";
import "ydb/core/protos/kqp_stats.proto";
import "ydb/core/protos/query_stats.proto";
diff --git a/ydb/core/protos/pqconfig.proto b/ydb/core/protos/pqconfig.proto
index e709a35314..1e3b26f44e 100644
--- a/ydb/core/protos/pqconfig.proto
+++ b/ydb/core/protos/pqconfig.proto
@@ -6,7 +6,7 @@ import "ydb/core/protos/msgbus_kv.proto";
import "ydb/core/protos/node_limits.proto";
import "ydb/core/protos/netclassifier.proto";
import "ydb/library/services/services.proto";
-import "ydb/core/protos/type_info.proto";
+import "ydb/core/scheme/protos/type_info.proto";
import "library/cpp/actors/protos/actors.proto";
diff --git a/ydb/core/protos/replication.proto b/ydb/core/protos/replication.proto
index 51fc908752..4a7f21c008 100644
--- a/ydb/core/protos/replication.proto
+++ b/ydb/core/protos/replication.proto
@@ -1,4 +1,4 @@
-import "ydb/core/protos/base.proto";
+import "ydb/core/scheme/protos/pathid.proto";
package NKikimrReplication;
option java_package = "ru.yandex.kikimr.proto";
diff --git a/ydb/core/protos/scheme_log.proto b/ydb/core/protos/scheme_log.proto
index 1507ed3cd0..70d313e2f7 100644
--- a/ydb/core/protos/scheme_log.proto
+++ b/ydb/core/protos/scheme_log.proto
@@ -1,5 +1,5 @@
import "ydb/core/protos/flat_scheme_op.proto";
-import "ydb/core/protos/type_info.proto";
+import "ydb/core/scheme/protos/type_info.proto";
package NTabletFlatScheme;
option java_package = "ru.yandex.kikimr.proto";
diff --git a/ydb/core/protos/tx.proto b/ydb/core/protos/tx.proto
index eaafd0ef31..de069bda69 100644
--- a/ydb/core/protos/tx.proto
+++ b/ydb/core/protos/tx.proto
@@ -1,4 +1,5 @@
import "library/cpp/actors/protos/actors.proto";
+import "ydb/core/scheme/protos/key_range.proto";
import "ydb/core/protos/base.proto";
import "google/protobuf/any.proto";
@@ -356,13 +357,6 @@ message TEvReadSetAck {
optional uint64 Seqno = 7; // Should be equal to TEvReadSet.Seqno which we are ACKing
}
-message TKeyRange {
- optional bytes From = 1;
- optional bytes To = 2;
- optional bool FromInclusive = 3;
- optional bool ToInclusive = 4;
-};
-
message TEvStreamClearanceRequest {
optional uint64 TxId = 1;
optional uint64 ShardId = 2;
diff --git a/ydb/core/protos/tx_datashard.proto b/ydb/core/protos/tx_datashard.proto
index 82b31b4de4..6b1a4fffb1 100644
--- a/ydb/core/protos/tx_datashard.proto
+++ b/ydb/core/protos/tx_datashard.proto
@@ -2,7 +2,9 @@ option cc_enable_arenas = true;
import "library/cpp/actors/protos/actors.proto";
import "ydb/core/protos/base.proto";
-import "ydb/core/protos/type_info.proto";
+import "ydb/core/scheme/protos/type_info.proto";
+import "ydb/core/scheme/protos/key_range.proto";
+import "ydb/core/scheme/protos/pathid.proto";
import "ydb/core/protos/kqp.proto";
import "ydb/core/protos/ssa.proto";
import "ydb/core/protos/tablet.proto";
diff --git a/ydb/core/protos/tx_sequenceshard.proto b/ydb/core/protos/tx_sequenceshard.proto
index dd3d203250..4b2a5967a3 100644
--- a/ydb/core/protos/tx_sequenceshard.proto
+++ b/ydb/core/protos/tx_sequenceshard.proto
@@ -1,5 +1,6 @@
syntax = "proto3";
import "ydb/core/protos/base.proto";
+import "ydb/core/scheme/protos/pathid.proto";
package NKikimrTxSequenceShard;
option java_package = "ru.yandex.kikimr.proto";
diff --git a/ydb/core/protos/ya.make b/ydb/core/protos/ya.make
index b2eddfbb88..b5982bcc5e 100644
--- a/ydb/core/protos/ya.make
+++ b/ydb/core/protos/ya.make
@@ -118,7 +118,6 @@ SRCS(
tx_proxy.proto
tx_scheme.proto
tx_sequenceshard.proto
- type_info.proto
pdiskfit.proto
pqconfig.proto
auth.proto
@@ -139,6 +138,7 @@ GENERATE_ENUM_SERIALIZATION(datashard_load.pb.h)
PEERDIR(
library/cpp/actors/protos
ydb/core/fq/libs/config/protos
+ ydb/core/scheme/protos
ydb/library/login/protos
ydb/library/mkql_proto/protos
ydb/public/api/protos
diff --git a/ydb/core/scheme/CMakeLists.darwin-x86_64.txt b/ydb/core/scheme/CMakeLists.darwin-x86_64.txt
index 82ba1fccb1..beb2abe3f8 100644
--- a/ydb/core/scheme/CMakeLists.darwin-x86_64.txt
+++ b/ydb/core/scheme/CMakeLists.darwin-x86_64.txt
@@ -6,6 +6,7 @@
# original buildsystem will not be accepted.
+add_subdirectory(protos)
add_subdirectory(ut)
add_library(ydb-core-scheme)
@@ -17,12 +18,13 @@ target_link_libraries(ydb-core-scheme PUBLIC
cpp-containers-bitseq
cpp-deprecated-enum_codegen
library-cpp-yson
- ydb-core-base
+ core-scheme-protos
ydb-core-scheme_types
- ydb-core-util
ydb-library-aclib
parser-pg_wrapper-interface
public-lib-scheme_types
+ library-pretty_types_print-protobuf
+ cpp-lwtrace-mon
)
target_sources(ydb-core-scheme PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_borders.cpp
@@ -31,4 +33,5 @@ target_sources(ydb-core-scheme PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_types_defs.cpp
${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_type_info.cpp
${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_types_proto.cpp
+ ${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_pathid.cpp
)
diff --git a/ydb/core/scheme/CMakeLists.linux-aarch64.txt b/ydb/core/scheme/CMakeLists.linux-aarch64.txt
index 98cdbeea4a..20a86e6a3a 100644
--- a/ydb/core/scheme/CMakeLists.linux-aarch64.txt
+++ b/ydb/core/scheme/CMakeLists.linux-aarch64.txt
@@ -6,6 +6,7 @@
# original buildsystem will not be accepted.
+add_subdirectory(protos)
add_subdirectory(ut)
add_library(ydb-core-scheme)
@@ -18,12 +19,13 @@ target_link_libraries(ydb-core-scheme PUBLIC
cpp-containers-bitseq
cpp-deprecated-enum_codegen
library-cpp-yson
- ydb-core-base
+ core-scheme-protos
ydb-core-scheme_types
- ydb-core-util
ydb-library-aclib
parser-pg_wrapper-interface
public-lib-scheme_types
+ library-pretty_types_print-protobuf
+ cpp-lwtrace-mon
)
target_sources(ydb-core-scheme PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_borders.cpp
@@ -32,4 +34,5 @@ target_sources(ydb-core-scheme PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_types_defs.cpp
${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_type_info.cpp
${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_types_proto.cpp
+ ${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_pathid.cpp
)
diff --git a/ydb/core/scheme/CMakeLists.linux-x86_64.txt b/ydb/core/scheme/CMakeLists.linux-x86_64.txt
index 98cdbeea4a..20a86e6a3a 100644
--- a/ydb/core/scheme/CMakeLists.linux-x86_64.txt
+++ b/ydb/core/scheme/CMakeLists.linux-x86_64.txt
@@ -6,6 +6,7 @@
# original buildsystem will not be accepted.
+add_subdirectory(protos)
add_subdirectory(ut)
add_library(ydb-core-scheme)
@@ -18,12 +19,13 @@ target_link_libraries(ydb-core-scheme PUBLIC
cpp-containers-bitseq
cpp-deprecated-enum_codegen
library-cpp-yson
- ydb-core-base
+ core-scheme-protos
ydb-core-scheme_types
- ydb-core-util
ydb-library-aclib
parser-pg_wrapper-interface
public-lib-scheme_types
+ library-pretty_types_print-protobuf
+ cpp-lwtrace-mon
)
target_sources(ydb-core-scheme PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_borders.cpp
@@ -32,4 +34,5 @@ target_sources(ydb-core-scheme PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_types_defs.cpp
${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_type_info.cpp
${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_types_proto.cpp
+ ${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_pathid.cpp
)
diff --git a/ydb/core/scheme/CMakeLists.windows-x86_64.txt b/ydb/core/scheme/CMakeLists.windows-x86_64.txt
index 82ba1fccb1..beb2abe3f8 100644
--- a/ydb/core/scheme/CMakeLists.windows-x86_64.txt
+++ b/ydb/core/scheme/CMakeLists.windows-x86_64.txt
@@ -6,6 +6,7 @@
# original buildsystem will not be accepted.
+add_subdirectory(protos)
add_subdirectory(ut)
add_library(ydb-core-scheme)
@@ -17,12 +18,13 @@ target_link_libraries(ydb-core-scheme PUBLIC
cpp-containers-bitseq
cpp-deprecated-enum_codegen
library-cpp-yson
- ydb-core-base
+ core-scheme-protos
ydb-core-scheme_types
- ydb-core-util
ydb-library-aclib
parser-pg_wrapper-interface
public-lib-scheme_types
+ library-pretty_types_print-protobuf
+ cpp-lwtrace-mon
)
target_sources(ydb-core-scheme PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_borders.cpp
@@ -31,4 +33,5 @@ target_sources(ydb-core-scheme PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_types_defs.cpp
${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_type_info.cpp
${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_types_proto.cpp
+ ${CMAKE_SOURCE_DIR}/ydb/core/scheme/scheme_pathid.cpp
)
diff --git a/ydb/core/scheme/defs.h b/ydb/core/scheme/defs.h
index c42f4b9f60..efe35fddda 100644
--- a/ydb/core/scheme/defs.h
+++ b/ydb/core/scheme/defs.h
@@ -1,8 +1,5 @@
#pragma once
-#include <ydb/core/base/defs.h>
-
-
namespace NKikimr {
namespace NScheme {
diff --git a/ydb/core/scheme/protos/CMakeLists.darwin-x86_64.txt b/ydb/core/scheme/protos/CMakeLists.darwin-x86_64.txt
new file mode 100644
index 0000000000..0191fcd833
--- /dev/null
+++ b/ydb/core/scheme/protos/CMakeLists.darwin-x86_64.txt
@@ -0,0 +1,83 @@
+
+# This file was generated by the build system used internally in the Yandex monorepo.
+# Only simple modifications are allowed (adding source-files to targets, adding simple properties
+# like target_include_directories). These modifications will be ported to original
+# ya.make files by maintainers. Any complex modifications which can't be ported back to the
+# original buildsystem will not be accepted.
+
+
+get_built_tool_path(
+ TOOL_grpc_cpp_bin
+ TOOL_grpc_cpp_dependency
+ contrib/tools/protoc/plugins/grpc_cpp
+ grpc_cpp
+)
+get_built_tool_path(
+ TOOL_protoc_bin
+ TOOL_protoc_dependency
+ contrib/tools/protoc/bin
+ protoc
+)
+get_built_tool_path(
+ TOOL_cpp_styleguide_bin
+ TOOL_cpp_styleguide_dependency
+ contrib/tools/protoc/plugins/cpp_styleguide
+ cpp_styleguide
+)
+get_built_tool_path(
+ TOOL_protoc_bin
+ TOOL_protoc_dependency
+ contrib/tools/protoc/bin
+ protoc
+)
+get_built_tool_path(
+ TOOL_cpp_styleguide_bin
+ TOOL_cpp_styleguide_dependency
+ contrib/tools/protoc/plugins/cpp_styleguide
+ cpp_styleguide
+)
+get_built_tool_path(
+ TOOL_protoc_bin
+ TOOL_protoc_dependency
+ contrib/tools/protoc/bin
+ protoc
+)
+get_built_tool_path(
+ TOOL_cpp_styleguide_bin
+ TOOL_cpp_styleguide_dependency
+ contrib/tools/protoc/plugins/cpp_styleguide
+ cpp_styleguide
+)
+
+add_library(core-scheme-protos)
+set_property(TARGET core-scheme-protos PROPERTY
+ PROTOC_EXTRA_OUTS .grpc.pb.cc .grpc.pb.h
+)
+target_link_libraries(core-scheme-protos PUBLIC
+ contrib-libs-cxxsupp
+ yutil
+ contrib-libs-grpc
+ contrib-libs-protobuf
+)
+target_proto_messages(core-scheme-protos PRIVATE
+ ${CMAKE_SOURCE_DIR}/ydb/core/scheme/protos/type_info.proto
+ ${CMAKE_SOURCE_DIR}/ydb/core/scheme/protos/key_range.proto
+ ${CMAKE_SOURCE_DIR}/ydb/core/scheme/protos/pathid.proto
+)
+target_proto_addincls(core-scheme-protos
+ ./
+ ${CMAKE_SOURCE_DIR}/
+ ${CMAKE_BINARY_DIR}
+ ${CMAKE_SOURCE_DIR}
+ ${CMAKE_SOURCE_DIR}/contrib/libs/protobuf/src
+ ${CMAKE_BINARY_DIR}
+ ${CMAKE_SOURCE_DIR}/contrib/libs/protobuf/src
+)
+target_proto_outs(core-scheme-protos
+ --cpp_out=${CMAKE_BINARY_DIR}/
+ --cpp_styleguide_out=${CMAKE_BINARY_DIR}/
+)
+target_proto_plugin(core-scheme-protos
+ grpc_cpp
+ grpc_cpp
+)
diff --git a/ydb/core/scheme/protos/CMakeLists.linux-aarch64.txt b/ydb/core/scheme/protos/CMakeLists.linux-aarch64.txt
new file mode 100644
index 0000000000..c8f537f77c
--- /dev/null
+++ b/ydb/core/scheme/protos/CMakeLists.linux-aarch64.txt
@@ -0,0 +1,84 @@
+
+# This file was generated by the build system used internally in the Yandex monorepo.
+# Only simple modifications are allowed (adding source-files to targets, adding simple properties
+# like target_include_directories). These modifications will be ported to original
+# ya.make files by maintainers. Any complex modifications which can't be ported back to the
+# original buildsystem will not be accepted.
+
+
+get_built_tool_path(
+ TOOL_grpc_cpp_bin
+ TOOL_grpc_cpp_dependency
+ contrib/tools/protoc/plugins/grpc_cpp
+ grpc_cpp
+)
+get_built_tool_path(
+ TOOL_protoc_bin
+ TOOL_protoc_dependency
+ contrib/tools/protoc/bin
+ protoc
+)
+get_built_tool_path(
+ TOOL_cpp_styleguide_bin
+ TOOL_cpp_styleguide_dependency
+ contrib/tools/protoc/plugins/cpp_styleguide
+ cpp_styleguide
+)
+get_built_tool_path(
+ TOOL_protoc_bin
+ TOOL_protoc_dependency
+ contrib/tools/protoc/bin
+ protoc
+)
+get_built_tool_path(
+ TOOL_cpp_styleguide_bin
+ TOOL_cpp_styleguide_dependency
+ contrib/tools/protoc/plugins/cpp_styleguide
+ cpp_styleguide
+)
+get_built_tool_path(
+ TOOL_protoc_bin
+ TOOL_protoc_dependency
+ contrib/tools/protoc/bin
+ protoc
+)
+get_built_tool_path(
+ TOOL_cpp_styleguide_bin
+ TOOL_cpp_styleguide_dependency
+ contrib/tools/protoc/plugins/cpp_styleguide
+ cpp_styleguide
+)
+
+add_library(core-scheme-protos)
+set_property(TARGET core-scheme-protos PROPERTY
+ PROTOC_EXTRA_OUTS .grpc.pb.cc .grpc.pb.h
+)
+target_link_libraries(core-scheme-protos PUBLIC
+ contrib-libs-linux-headers
+ contrib-libs-cxxsupp
+ yutil
+ contrib-libs-grpc
+ contrib-libs-protobuf
+)
+target_proto_messages(core-scheme-protos PRIVATE
+ ${CMAKE_SOURCE_DIR}/ydb/core/scheme/protos/type_info.proto
+ ${CMAKE_SOURCE_DIR}/ydb/core/scheme/protos/key_range.proto
+ ${CMAKE_SOURCE_DIR}/ydb/core/scheme/protos/pathid.proto
+)
+target_proto_addincls(core-scheme-protos
+ ./
+ ${CMAKE_SOURCE_DIR}/
+ ${CMAKE_BINARY_DIR}
+ ${CMAKE_SOURCE_DIR}
+ ${CMAKE_SOURCE_DIR}/contrib/libs/protobuf/src
+ ${CMAKE_BINARY_DIR}
+ ${CMAKE_SOURCE_DIR}/contrib/libs/protobuf/src
+)
+target_proto_outs(core-scheme-protos
+ --cpp_out=${CMAKE_BINARY_DIR}/
+ --cpp_styleguide_out=${CMAKE_BINARY_DIR}/
+)
+target_proto_plugin(core-scheme-protos
+ grpc_cpp
+ grpc_cpp
+)
diff --git a/ydb/core/scheme/protos/CMakeLists.linux-x86_64.txt b/ydb/core/scheme/protos/CMakeLists.linux-x86_64.txt
new file mode 100644
index 0000000000..c8f537f77c
--- /dev/null
+++ b/ydb/core/scheme/protos/CMakeLists.linux-x86_64.txt
@@ -0,0 +1,84 @@
+
+# This file was generated by the build system used internally in the Yandex monorepo.
+# Only simple modifications are allowed (adding source-files to targets, adding simple properties
+# like target_include_directories). These modifications will be ported to original
+# ya.make files by maintainers. Any complex modifications which can't be ported back to the
+# original buildsystem will not be accepted.
+
+
+get_built_tool_path(
+ TOOL_grpc_cpp_bin
+ TOOL_grpc_cpp_dependency
+ contrib/tools/protoc/plugins/grpc_cpp
+ grpc_cpp
+)
+get_built_tool_path(
+ TOOL_protoc_bin
+ TOOL_protoc_dependency
+ contrib/tools/protoc/bin
+ protoc
+)
+get_built_tool_path(
+ TOOL_cpp_styleguide_bin
+ TOOL_cpp_styleguide_dependency
+ contrib/tools/protoc/plugins/cpp_styleguide
+ cpp_styleguide
+)
+get_built_tool_path(
+ TOOL_protoc_bin
+ TOOL_protoc_dependency
+ contrib/tools/protoc/bin
+ protoc
+)
+get_built_tool_path(
+ TOOL_cpp_styleguide_bin
+ TOOL_cpp_styleguide_dependency
+ contrib/tools/protoc/plugins/cpp_styleguide
+ cpp_styleguide
+)
+get_built_tool_path(
+ TOOL_protoc_bin
+ TOOL_protoc_dependency
+ contrib/tools/protoc/bin
+ protoc
+)
+get_built_tool_path(
+ TOOL_cpp_styleguide_bin
+ TOOL_cpp_styleguide_dependency
+ contrib/tools/protoc/plugins/cpp_styleguide
+ cpp_styleguide
+)
+
+add_library(core-scheme-protos)
+set_property(TARGET core-scheme-protos PROPERTY
+ PROTOC_EXTRA_OUTS .grpc.pb.cc .grpc.pb.h
+)
+target_link_libraries(core-scheme-protos PUBLIC
+ contrib-libs-linux-headers
+ contrib-libs-cxxsupp
+ yutil
+ contrib-libs-grpc
+ contrib-libs-protobuf
+)
+target_proto_messages(core-scheme-protos PRIVATE
+ ${CMAKE_SOURCE_DIR}/ydb/core/scheme/protos/type_info.proto
+ ${CMAKE_SOURCE_DIR}/ydb/core/scheme/protos/key_range.proto
+ ${CMAKE_SOURCE_DIR}/ydb/core/scheme/protos/pathid.proto
+)
+target_proto_addincls(core-scheme-protos
+ ./
+ ${CMAKE_SOURCE_DIR}/
+ ${CMAKE_BINARY_DIR}
+ ${CMAKE_SOURCE_DIR}
+ ${CMAKE_SOURCE_DIR}/contrib/libs/protobuf/src
+ ${CMAKE_BINARY_DIR}
+ ${CMAKE_SOURCE_DIR}/contrib/libs/protobuf/src
+)
+target_proto_outs(core-scheme-protos
+ --cpp_out=${CMAKE_BINARY_DIR}/
+ --cpp_styleguide_out=${CMAKE_BINARY_DIR}/
+)
+target_proto_plugin(core-scheme-protos
+ grpc_cpp
+ grpc_cpp
+)
diff --git a/ydb/core/scheme/protos/CMakeLists.txt b/ydb/core/scheme/protos/CMakeLists.txt
new file mode 100644
index 0000000000..f8b31df0c1
--- /dev/null
+++ b/ydb/core/scheme/protos/CMakeLists.txt
@@ -0,0 +1,17 @@
+
+# This file was generated by the build system used internally in the Yandex monorepo.
+# Only simple modifications are allowed (adding source-files to targets, adding simple properties
+# like target_include_directories). These modifications will be ported to original
+# ya.make files by maintainers. Any complex modifications which can't be ported back to the
+# original buildsystem will not be accepted.
+
+
+if (CMAKE_SYSTEM_NAME STREQUAL "Linux" AND CMAKE_SYSTEM_PROCESSOR STREQUAL "aarch64" AND NOT HAVE_CUDA)
+ include(CMakeLists.linux-aarch64.txt)
+elseif (CMAKE_SYSTEM_NAME STREQUAL "Darwin" AND CMAKE_SYSTEM_PROCESSOR STREQUAL "x86_64")
+ include(CMakeLists.darwin-x86_64.txt)
+elseif (WIN32 AND CMAKE_SYSTEM_PROCESSOR STREQUAL "AMD64" AND NOT HAVE_CUDA)
+ include(CMakeLists.windows-x86_64.txt)
+elseif (CMAKE_SYSTEM_NAME STREQUAL "Linux" AND CMAKE_SYSTEM_PROCESSOR STREQUAL "x86_64" AND NOT HAVE_CUDA)
+ include(CMakeLists.linux-x86_64.txt)
+endif()
diff --git a/ydb/core/scheme/protos/CMakeLists.windows-x86_64.txt b/ydb/core/scheme/protos/CMakeLists.windows-x86_64.txt
new file mode 100644
index 0000000000..0191fcd833
--- /dev/null
+++ b/ydb/core/scheme/protos/CMakeLists.windows-x86_64.txt
@@ -0,0 +1,83 @@
+
+# This file was generated by the build system used internally in the Yandex monorepo.
+# Only simple modifications are allowed (adding source-files to targets, adding simple properties
+# like target_include_directories). These modifications will be ported to original
+# ya.make files by maintainers. Any complex modifications which can't be ported back to the
+# original buildsystem will not be accepted.
+
+
+get_built_tool_path(
+ TOOL_grpc_cpp_bin
+ TOOL_grpc_cpp_dependency
+ contrib/tools/protoc/plugins/grpc_cpp
+ grpc_cpp
+)
+get_built_tool_path(
+ TOOL_protoc_bin
+ TOOL_protoc_dependency
+ contrib/tools/protoc/bin
+ protoc
+)
+get_built_tool_path(
+ TOOL_cpp_styleguide_bin
+ TOOL_cpp_styleguide_dependency
+ contrib/tools/protoc/plugins/cpp_styleguide
+ cpp_styleguide
+)
+get_built_tool_path(
+ TOOL_protoc_bin
+ TOOL_protoc_dependency
+ contrib/tools/protoc/bin
+ protoc
+)
+get_built_tool_path(
+ TOOL_cpp_styleguide_bin
+ TOOL_cpp_styleguide_dependency
+ contrib/tools/protoc/plugins/cpp_styleguide
+ cpp_styleguide
+)
+get_built_tool_path(
+ TOOL_protoc_bin
+ TOOL_protoc_dependency
+ contrib/tools/protoc/bin
+ protoc
+)
+get_built_tool_path(
+ TOOL_cpp_styleguide_bin
+ TOOL_cpp_styleguide_dependency
+ contrib/tools/protoc/plugins/cpp_styleguide
+ cpp_styleguide
+)
+
+add_library(core-scheme-protos)
+set_property(TARGET core-scheme-protos PROPERTY
+ PROTOC_EXTRA_OUTS .grpc.pb.cc .grpc.pb.h
+)
+target_link_libraries(core-scheme-protos PUBLIC
+ contrib-libs-cxxsupp
+ yutil
+ contrib-libs-grpc
+ contrib-libs-protobuf
+)
+target_proto_messages(core-scheme-protos PRIVATE
+ ${CMAKE_SOURCE_DIR}/ydb/core/scheme/protos/type_info.proto
+ ${CMAKE_SOURCE_DIR}/ydb/core/scheme/protos/key_range.proto
+ ${CMAKE_SOURCE_DIR}/ydb/core/scheme/protos/pathid.proto
+)
+target_proto_addincls(core-scheme-protos
+ ./
+ ${CMAKE_SOURCE_DIR}/
+ ${CMAKE_BINARY_DIR}
+ ${CMAKE_SOURCE_DIR}
+ ${CMAKE_SOURCE_DIR}/contrib/libs/protobuf/src
+ ${CMAKE_BINARY_DIR}
+ ${CMAKE_SOURCE_DIR}/contrib/libs/protobuf/src
+)
+target_proto_outs(core-scheme-protos
+ --cpp_out=${CMAKE_BINARY_DIR}/
+ --cpp_styleguide_out=${CMAKE_BINARY_DIR}/
+)
+target_proto_plugin(core-scheme-protos
+ grpc_cpp
+ grpc_cpp
+)
diff --git a/ydb/core/scheme/protos/key_range.proto b/ydb/core/scheme/protos/key_range.proto
new file mode 100644
index 0000000000..f48dbc11d2
--- /dev/null
+++ b/ydb/core/scheme/protos/key_range.proto
@@ -0,0 +1,9 @@
+package NKikimrTx;
+option java_package = "ru.yandex.kikimr.proto";
+
+message TKeyRange {
+ optional bytes From = 1;
+ optional bytes To = 2;
+ optional bool FromInclusive = 3;
+ optional bool ToInclusive = 4;
+};
diff --git a/ydb/core/scheme/protos/pathid.proto b/ydb/core/scheme/protos/pathid.proto
new file mode 100644
index 0000000000..7f51f121cf
--- /dev/null
+++ b/ydb/core/scheme/protos/pathid.proto
@@ -0,0 +1,7 @@
+package NKikimrProto;
+option java_package = "ru.yandex.kikimr.proto";
+
+message TPathID {
+ optional fixed64 OwnerId = 1;
+ optional uint64 LocalId = 2;
+}
diff --git a/ydb/core/protos/type_info.proto b/ydb/core/scheme/protos/type_info.proto
index 3ce4b6ed83..3ce4b6ed83 100644
--- a/ydb/core/protos/type_info.proto
+++ b/ydb/core/scheme/protos/type_info.proto
diff --git a/ydb/core/scheme/protos/ya.make b/ydb/core/scheme/protos/ya.make
new file mode 100644
index 0000000000..526fc2bf5b
--- /dev/null
+++ b/ydb/core/scheme/protos/ya.make
@@ -0,0 +1,17 @@
+PROTO_LIBRARY()
+
+GRPC()
+
+IF (OS_WINDOWS)
+ NO_OPTIMIZE_PY_PROTOS()
+ENDIF()
+
+SRCS(
+ type_info.proto
+ key_range.proto
+ pathid.proto
+)
+
+EXCLUDE_TAGS(GO_PROTO)
+
+END()
diff --git a/ydb/core/base/pathid.cpp b/ydb/core/scheme/scheme_pathid.cpp
index 0ad8a2d93c..6093a41842 100644
--- a/ydb/core/base/pathid.cpp
+++ b/ydb/core/scheme/scheme_pathid.cpp
@@ -1,11 +1,25 @@
-#include "pathid.h"
+#include "scheme_pathid.h"
#include <util/stream/str.h>
namespace NKikimr {
+namespace {
+inline ui64 PathIdHash(ui64 a, ui64 b) noexcept {
+ const ui64 x1 = 0x001DFF3D8DC48F5Dull * (a & 0xFFFFFFFFull);
+ const ui64 x2 = 0x179CA10C9242235Dull * (a >> 32);
+ const ui64 x3 = 0x0F530CAD458B0FB1ull * (b & 0xFFFFFFFFull);
+ const ui64 x4 = 0xB5026F5AA96619E9ull * (b >> 32);
+
+ const ui64 sum = 0x06C9C021156EAA1Full + x1 + x2 + x3 + x4;
+
+ return (sum >> 32);
+}
+
+}
+
ui64 TPathId::Hash() const {
- return Hash128to32(OwnerId, LocalPathId);
+ return PathIdHash(OwnerId, LocalPathId);
}
TString TPathId::ToString() const {
diff --git a/ydb/core/base/pathid.h b/ydb/core/scheme/scheme_pathid.h
index 711c01593f..c62e80cca8 100644
--- a/ydb/core/base/pathid.h
+++ b/ydb/core/scheme/scheme_pathid.h
@@ -1,8 +1,6 @@
#pragma once
-#include "defs.h"
-
-#include <ydb/core/protos/base.pb.h>
+#include <ydb/core/scheme/protos/pathid.pb.h>
namespace NKikimr {
diff --git a/ydb/core/scheme/scheme_tablecell.cpp b/ydb/core/scheme/scheme_tablecell.cpp
index 80ef260d73..04f168be3a 100644
--- a/ydb/core/scheme/scheme_tablecell.cpp
+++ b/ydb/core/scheme/scheme_tablecell.cpp
@@ -1,6 +1,7 @@
#include <ydb/core/scheme/scheme_tablecell.h>
#include <ydb/core/scheme/scheme_type_registry.h>
+#include <library/cpp/actors/core/actorid.h>
#include <util/string/escape.h>
namespace NKikimr {
@@ -296,7 +297,7 @@ void DbgPrintValue(TString &res, const TCell &r, NScheme::TTypeInfo typeInfo) {
res += ToString(r.AsValue<double>());
break;
case NScheme::NTypeIds::ActorId:
- res += ToString(r.AsValue<TActorId>());
+ res += ToString(r.AsValue<NActors::TActorId>());
break;
case NScheme::NTypeIds::Pg:
// TODO: support pg types
diff --git a/ydb/core/scheme/scheme_tabledefs.h b/ydb/core/scheme/scheme_tabledefs.h
index 4615e5388d..b380d0f288 100644
--- a/ydb/core/scheme/scheme_tabledefs.h
+++ b/ydb/core/scheme/scheme_tabledefs.h
@@ -3,8 +3,8 @@
#include "defs.h"
#include "scheme_tablecell.h"
-#include <ydb/core/base/pathid.h>
-#include <ydb/core/protos/tx.pb.h>
+#include <ydb/core/scheme/scheme_pathid.h>
+#include <ydb/core/scheme/protos/key_range.pb.h>
#include <ydb/core/scheme_types/scheme_types.h>
#include <ydb/library/aclib/aclib.h>
diff --git a/ydb/core/scheme/scheme_types_proto.h b/ydb/core/scheme/scheme_types_proto.h
index ce46ccad11..6eabef1d63 100644
--- a/ydb/core/scheme/scheme_types_proto.h
+++ b/ydb/core/scheme/scheme_types_proto.h
@@ -1,7 +1,7 @@
#pragma once
#include <ydb/core/scheme_types/scheme_type_info.h>
-#include <ydb/core/protos/type_info.pb.h>
+#include <ydb/core/scheme/protos/type_info.pb.h>
namespace NKikimr::NScheme {
diff --git a/ydb/core/scheme/ya.make b/ydb/core/scheme/ya.make
index d20674f123..7c3479aba7 100644
--- a/ydb/core/scheme/ya.make
+++ b/ydb/core/scheme/ya.make
@@ -7,6 +7,7 @@ SRCS(
scheme_types_defs.cpp
scheme_type_info.cpp
scheme_types_proto.cpp
+ scheme_pathid.cpp
)
PEERDIR(
@@ -15,12 +16,14 @@ PEERDIR(
library/cpp/containers/bitseq
library/cpp/deprecated/enum_codegen
library/cpp/yson
- ydb/core/base
+ ydb/core/scheme/protos
ydb/core/scheme_types
- ydb/core/util
ydb/library/aclib
ydb/library/yql/parser/pg_wrapper/interface
ydb/public/lib/scheme_types
+ # temporary.
+ ydb/library/pretty_types_print/protobuf
+ library/cpp/lwtrace/mon
)
END()
diff --git a/ydb/core/sys_view/common/events.h b/ydb/core/sys_view/common/events.h
index b170395a54..c489c1f400 100644
--- a/ydb/core/sys_view/common/events.h
+++ b/ydb/core/sys_view/common/events.h
@@ -4,7 +4,7 @@
#include "db_counters.h"
#include <ydb/core/base/events.h>
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <library/cpp/actors/core/events.h>
#include <ydb/core/protos/sys_view.pb.h>
diff --git a/ydb/core/sys_view/common/processor_scan.h b/ydb/core/sys_view/common/processor_scan.h
index 56aeb70a0a..0ac998e278 100644
--- a/ydb/core/sys_view/common/processor_scan.h
+++ b/ydb/core/sys_view/common/processor_scan.h
@@ -26,7 +26,7 @@ public:
}
TProcessorScan(
- const TActorId& ownerId,
+ const NActors::TActorId& ownerId,
ui32 scanId,
const TTableId& tableId,
const TTableRange& tableRange,
diff --git a/ydb/core/sys_view/common/scan_actor_base_impl.h b/ydb/core/sys_view/common/scan_actor_base_impl.h
index 06a149457a..842362d9a2 100644
--- a/ydb/core/sys_view/common/scan_actor_base_impl.h
+++ b/ydb/core/sys_view/common/scan_actor_base_impl.h
@@ -27,7 +27,7 @@ class TScanActorBase : public TActorBootstrapped<TDerived> {
public:
using TBase = TActorBootstrapped<TDerived>;
- TScanActorBase(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+ TScanActorBase(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns)
: OwnerActorId(ownerId)
, ScanId(scanId)
@@ -319,7 +319,7 @@ private:
protected:
static constexpr TDuration Timeout = TDuration::Seconds(60);
- const TActorId OwnerActorId;
+ const NActors::TActorId OwnerActorId;
const ui32 ScanId;
const TTableId TableId;
TSerializedTableRange TableRange;
diff --git a/ydb/core/sys_view/nodes/nodes.cpp b/ydb/core/sys_view/nodes/nodes.cpp
index 6404789425..9c23429ed6 100644
--- a/ydb/core/sys_view/nodes/nodes.cpp
+++ b/ydb/core/sys_view/nodes/nodes.cpp
@@ -25,7 +25,7 @@ public:
return NKikimrServices::TActivity::KQP_SYSTEM_VIEW_SCAN;
}
- TNodesScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+ TNodesScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns)
: TBase(ownerId, scanId, tableId, tableRange, columns)
{
@@ -85,7 +85,7 @@ private:
return;
}
- const TActorId nameserviceId = GetNameserviceActorId();
+ const NActors::TActorId nameserviceId = GetNameserviceActorId();
Send(nameserviceId, new TEvInterconnect::TEvListNodes());
}
@@ -233,7 +233,7 @@ private:
THashMap<TNodeId, THolder<TEvWhiteboard::TEvSystemStateResponse>> WBSystemInfo;
};
-THolder<IActor> CreateNodesScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateNodesScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns)
{
return MakeHolder<TNodesScan>(ownerId, scanId, tableId, tableRange, columns);
diff --git a/ydb/core/sys_view/nodes/nodes.h b/ydb/core/sys_view/nodes/nodes.h
index 8f1192250b..d22c913929 100644
--- a/ydb/core/sys_view/nodes/nodes.h
+++ b/ydb/core/sys_view/nodes/nodes.h
@@ -2,10 +2,13 @@
#include <ydb/core/kqp/runtime/kqp_compute.h>
+#include <library/cpp/actors/core/actor.h>
+#include <library/cpp/actors/core/actorid.h>
+
namespace NKikimr {
namespace NSysView {
-THolder<IActor> CreateNodesScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateNodesScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns);
} // NSysView
diff --git a/ydb/core/sys_view/partition_stats/partition_stats.cpp b/ydb/core/sys_view/partition_stats/partition_stats.cpp
index 625e4d75b8..34c04abc4e 100644
--- a/ydb/core/sys_view/partition_stats/partition_stats.cpp
+++ b/ydb/core/sys_view/partition_stats/partition_stats.cpp
@@ -447,7 +447,7 @@ private:
bool ProcessInFly = false;
};
-THolder<IActor> CreatePartitionStatsCollector(size_t batchSize, size_t pendingRequestsLimit)
+THolder<NActors::IActor> CreatePartitionStatsCollector(size_t batchSize, size_t pendingRequestsLimit)
{
return MakeHolder<TPartitionStatsCollector>(batchSize, pendingRequestsLimit);
}
@@ -461,7 +461,7 @@ public:
return NKikimrServices::TActivity::KQP_SYSTEM_VIEW_SCAN;
}
- TPartitionStatsScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+ TPartitionStatsScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns)
: TBase(ownerId, scanId, tableId, tableRange, columns)
{
@@ -689,7 +689,7 @@ private:
bool IncludePathColumn = false;
};
-THolder<IActor> CreatePartitionStatsScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreatePartitionStatsScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns)
{
return MakeHolder<TPartitionStatsScan>(ownerId, scanId, tableId, tableRange, columns);
diff --git a/ydb/core/sys_view/partition_stats/partition_stats.h b/ydb/core/sys_view/partition_stats/partition_stats.h
index dedf62906f..cfe6f90ccb 100644
--- a/ydb/core/sys_view/partition_stats/partition_stats.h
+++ b/ydb/core/sys_view/partition_stats/partition_stats.h
@@ -2,17 +2,20 @@
#include <ydb/core/kqp/runtime/kqp_compute.h>
+#include <library/cpp/actors/core/actor.h>
+#include <library/cpp/actors/core/actorid.h>
+
namespace NKikimr {
namespace NSysView {
constexpr size_t STATS_COLLECTOR_BATCH_SIZE = 5000;
constexpr size_t STATS_COLLECTOR_QUEUE_SIZE_LIMIT = 10;
-THolder<IActor> CreatePartitionStatsCollector(
+THolder<NActors::IActor> CreatePartitionStatsCollector(
size_t batchSize = STATS_COLLECTOR_BATCH_SIZE,
size_t pendingRequestsCount = STATS_COLLECTOR_QUEUE_SIZE_LIMIT);
-THolder<IActor> CreatePartitionStatsScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreatePartitionStatsScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns);
} // NSysView
diff --git a/ydb/core/sys_view/partition_stats/top_partitions.cpp b/ydb/core/sys_view/partition_stats/top_partitions.cpp
index 57a719da46..ca80d79231 100644
--- a/ydb/core/sys_view/partition_stats/top_partitions.cpp
+++ b/ydb/core/sys_view/partition_stats/top_partitions.cpp
@@ -61,7 +61,7 @@ struct TTopPartitionsExtractorMap :
}
};
-THolder<IActor> CreateTopPartitionsScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateTopPartitionsScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns)
{
using TTopPartitionsScan = TProcessorScan<
diff --git a/ydb/core/sys_view/partition_stats/top_partitions.h b/ydb/core/sys_view/partition_stats/top_partitions.h
index dcf49a89a5..b3cf1b343f 100644
--- a/ydb/core/sys_view/partition_stats/top_partitions.h
+++ b/ydb/core/sys_view/partition_stats/top_partitions.h
@@ -2,9 +2,12 @@
#include <ydb/core/kqp/runtime/kqp_compute.h>
+#include <library/cpp/actors/core/actor.h>
+#include <library/cpp/actors/core/actorid.h>
+
namespace NKikimr::NSysView {
-THolder<IActor> CreateTopPartitionsScan(const TActorId& ownerId, ui32 scanId,
+THolder<NActors::IActor> CreateTopPartitionsScan(const NActors::TActorId& ownerId, ui32 scanId,
const TTableId& tableId, const TTableRange& tableRange,
const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns);
diff --git a/ydb/core/sys_view/processor/processor.cpp b/ydb/core/sys_view/processor/processor.cpp
index d0c09f8e7b..da6ec4a373 100644
--- a/ydb/core/sys_view/processor/processor.cpp
+++ b/ydb/core/sys_view/processor/processor.cpp
@@ -5,11 +5,11 @@
namespace NKikimr {
namespace NSysView {
-IActor* CreateSysViewProcessor(const TActorId& tablet, TTabletStorageInfo* info) {
+IActor* CreateSysViewProcessor(const NActors::TActorId& tablet, TTabletStorageInfo* info) {
return new TSysViewProcessor(tablet, info, EProcessorMode::MINUTE);
}
-IActor* CreateSysViewProcessorForTests(const TActorId& tablet, TTabletStorageInfo* info) {
+IActor* CreateSysViewProcessorForTests(const NActors::TActorId& tablet, TTabletStorageInfo* info) {
return new TSysViewProcessor(tablet, info, EProcessorMode::FAST);
}
diff --git a/ydb/core/sys_view/processor/processor.h b/ydb/core/sys_view/processor/processor.h
index ad08696597..1d01c2a88e 100644
--- a/ydb/core/sys_view/processor/processor.h
+++ b/ydb/core/sys_view/processor/processor.h
@@ -6,8 +6,8 @@
namespace NKikimr {
namespace NSysView {
-IActor* CreateSysViewProcessor(const TActorId& tablet, TTabletStorageInfo* info);
-IActor* CreateSysViewProcessorForTests(const TActorId& tablet, TTabletStorageInfo* info);
+IActor* CreateSysViewProcessor(const NActors::TActorId& tablet, TTabletStorageInfo* info);
+IActor* CreateSysViewProcessorForTests(const NActors::TActorId& tablet, TTabletStorageInfo* info);
} // NSysView
} // NKikimr
diff --git a/ydb/core/sys_view/processor/processor_impl.cpp b/ydb/core/sys_view/processor/processor_impl.cpp
index 1bd8bb5b05..4c624cdea7 100644
--- a/ydb/core/sys_view/processor/processor_impl.cpp
+++ b/ydb/core/sys_view/processor/processor_impl.cpp
@@ -8,7 +8,7 @@
namespace NKikimr {
namespace NSysView {
-TSysViewProcessor::TSysViewProcessor(const TActorId& tablet, TTabletStorageInfo* info, EProcessorMode processorMode)
+TSysViewProcessor::TSysViewProcessor(const NActors::TActorId& tablet, TTabletStorageInfo* info, EProcessorMode processorMode)
: TActor(&TThis::StateInit)
, TTabletExecutedFlat(info, tablet, new NMiniKQL::TMiniKQLFactory)
, TotalInterval(TDuration::Seconds(processorMode == EProcessorMode::FAST ? 1 : 60))
@@ -490,7 +490,7 @@ void TSysViewProcessor::EntryToProto(NKikimrSysView::TTopPartitionsEntry& dst, c
}
template <typename TResponse>
-void TSysViewProcessor::ReplyOverloaded(const TActorId& sender) {
+void TSysViewProcessor::ReplyOverloaded(const NActors::TActorId& sender) {
auto response = MakeHolder<TResponse>();
response->Record.SetOverloaded(true);
Send(sender, std::move(response));
diff --git a/ydb/core/sys_view/processor/processor_impl.h b/ydb/core/sys_view/processor/processor_impl.h
index 1b9a2a7a13..feb42c70e9 100644
--- a/ydb/core/sys_view/processor/processor_impl.h
+++ b/ydb/core/sys_view/processor/processor_impl.h
@@ -28,7 +28,7 @@ public:
return NKikimrServices::TActivity::SYSTEM_VIEW_PROCESSOR;
}
- TSysViewProcessor(const TActorId& tablet, TTabletStorageInfo* info, EProcessorMode processorMode);
+ TSysViewProcessor(const NActors::TActorId& tablet, TTabletStorageInfo* info, EProcessorMode processorMode);
private:
using Schema = TProcessorSchema;
@@ -173,7 +173,7 @@ private:
static void EntryToProto(NKikimrSysView::TTopPartitionsEntry& dst, const NKikimrSysView::TTopPartitionsInfo& src);
template <typename TResponse>
- void ReplyOverloaded(const TActorId& sender);
+ void ReplyOverloaded(const NActors::TActorId& sender);
template <typename TMap, typename TRequest, typename TResponse>
void Reply(typename TRequest::TPtr& ev);
diff --git a/ydb/core/sys_view/processor/tx_configure.cpp b/ydb/core/sys_view/processor/tx_configure.cpp
index 68a2a133e5..0cb063da7d 100644
--- a/ydb/core/sys_view/processor/tx_configure.cpp
+++ b/ydb/core/sys_view/processor/tx_configure.cpp
@@ -7,7 +7,7 @@ struct TSysViewProcessor::TTxConfigure : public TTxBase {
NKikimrSysView::TEvConfigureProcessor Record;
TActorId Sender;
- TTxConfigure(TSelf* self, NKikimrSysView::TEvConfigureProcessor&& record, const TActorId& sender)
+ TTxConfigure(TSelf* self, NKikimrSysView::TEvConfigureProcessor&& record, const NActors::TActorId& sender)
: TTxBase(self)
, Record(std::move(record))
, Sender(sender)
diff --git a/ydb/core/sys_view/query_stats/query_metrics.cpp b/ydb/core/sys_view/query_stats/query_metrics.cpp
index d303ea3978..de7f29ebc2 100644
--- a/ydb/core/sys_view/query_stats/query_metrics.cpp
+++ b/ydb/core/sys_view/query_stats/query_metrics.cpp
@@ -61,7 +61,7 @@ struct TQueryMetricsExtractorsMap :
}
};
-THolder<IActor> CreateQueryMetricsScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateQueryMetricsScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns)
{
using TQueryMetricsScan = TProcessorScan<
diff --git a/ydb/core/sys_view/query_stats/query_metrics.h b/ydb/core/sys_view/query_stats/query_metrics.h
index e374081126..09aa817b61 100644
--- a/ydb/core/sys_view/query_stats/query_metrics.h
+++ b/ydb/core/sys_view/query_stats/query_metrics.h
@@ -2,10 +2,13 @@
#include <ydb/core/kqp/runtime/kqp_compute.h>
+#include <library/cpp/actors/core/actor.h>
+#include <library/cpp/actors/core/actorid.h>
+
namespace NKikimr {
namespace NSysView {
-THolder<IActor> CreateQueryMetricsScan(const TActorId& ownerId, ui32 scanId,
+THolder<NActors::IActor> CreateQueryMetricsScan(const NActors::TActorId& ownerId, ui32 scanId,
const TTableId& tableId, const TTableRange& tableRange,
const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns);
diff --git a/ydb/core/sys_view/query_stats/query_stats.cpp b/ydb/core/sys_view/query_stats/query_stats.cpp
index 4f9e89a3b9..64bf42eae5 100644
--- a/ydb/core/sys_view/query_stats/query_stats.cpp
+++ b/ydb/core/sys_view/query_stats/query_stats.cpp
@@ -95,7 +95,7 @@ public:
return NKikimrServices::TActivity::KQP_SYSTEM_VIEW_SCAN;
}
- TQueryStatsScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+ TQueryStatsScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns,
NKikimrSysView::EStatsType statsType,
ui64 bucketCount, const TDuration& bucketSize)
@@ -506,7 +506,7 @@ private:
NKikimrSysView::TEvGetQueryMetricsRequest Request;
};
-THolder<IActor> CreateQueryStatsScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateQueryStatsScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns)
{
auto viewName = tableId.SysViewInfo;
diff --git a/ydb/core/sys_view/query_stats/query_stats.h b/ydb/core/sys_view/query_stats/query_stats.h
index a7a76b9b57..6473f95665 100644
--- a/ydb/core/sys_view/query_stats/query_stats.h
+++ b/ydb/core/sys_view/query_stats/query_stats.h
@@ -2,6 +2,9 @@
#include <ydb/core/kqp/runtime/kqp_compute.h>
+#include <library/cpp/actors/core/actor.h>
+#include <library/cpp/actors/core/actorid.h>
+
namespace NKikimr {
namespace NSysView {
@@ -17,7 +20,7 @@ struct TQueryStatsBucketRange {
explicit TQueryStatsBucketRange(const TSerializedTableRange& range, const TDuration& bucketSize);
};
-THolder<IActor> CreateQueryStatsScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateQueryStatsScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns);
} // NSysView
diff --git a/ydb/core/sys_view/scan.cpp b/ydb/core/sys_view/scan.cpp
index 577393cfbb..8d06e227e2 100644
--- a/ydb/core/sys_view/scan.cpp
+++ b/ydb/core/sys_view/scan.cpp
@@ -28,7 +28,7 @@ public:
using TBase = TActor<TSysViewRangesReader>;
TSysViewRangesReader(
- const TActorId& ownerId,
+ const NActors::TActorId& ownerId,
ui32 scanId,
const TTableId& tableId,
TVector<TSerializedTableRange> ranges,
@@ -140,7 +140,7 @@ private:
TMaybe<TActorId> ScanActorId;
};
-THolder<IActor> CreateSystemViewScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateSystemViewScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
TVector<TSerializedTableRange> ranges, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns)
{
if (ranges.size() == 1) {
@@ -150,7 +150,7 @@ THolder<IActor> CreateSystemViewScan(const TActorId& ownerId, ui32 scanId, const
}
}
-THolder<IActor> CreateSystemViewScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateSystemViewScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns)
{
if (tableId.SysViewInfo == PartitionStatsName) {
diff --git a/ydb/core/sys_view/scan.h b/ydb/core/sys_view/scan.h
index d85e7640ef..83f1ddd5b3 100644
--- a/ydb/core/sys_view/scan.h
+++ b/ydb/core/sys_view/scan.h
@@ -2,13 +2,15 @@
#include <ydb/core/kqp/runtime/kqp_compute.h>
+#include <library/cpp/actors/core/actor.h>
+
namespace NKikimr {
namespace NSysView {
-THolder<IActor> CreateSystemViewScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateSystemViewScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
TVector<TSerializedTableRange> ranges, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns);
-THolder<IActor> CreateSystemViewScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateSystemViewScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns);
} // NSysView
diff --git a/ydb/core/sys_view/service/db_counters.cpp b/ydb/core/sys_view/service/db_counters.cpp
index cc3a16d16a..dad00cebd4 100644
--- a/ydb/core/sys_view/service/db_counters.cpp
+++ b/ydb/core/sys_view/service/db_counters.cpp
@@ -108,7 +108,7 @@ private:
})
};
-IActor* CreateDbWatcherActor(TIntrusivePtr<TDbWatcherCallback> callback) {
+NActors::IActor* CreateDbWatcherActor(TIntrusivePtr<TDbWatcherCallback> callback) {
return new TDbWatcherActor(callback);
}
diff --git a/ydb/core/sys_view/service/db_counters.h b/ydb/core/sys_view/service/db_counters.h
index 92e15e51e2..99e4b2e81e 100644
--- a/ydb/core/sys_view/service/db_counters.h
+++ b/ydb/core/sys_view/service/db_counters.h
@@ -2,6 +2,8 @@
#include <ydb/core/scheme/scheme_tabledefs.h>
+#include <library/cpp/actors/core/actor.h>
+
namespace NKikimr {
namespace NSysView {
@@ -9,7 +11,7 @@ struct TDbWatcherCallback : public TThrRefBase {
virtual void OnDatabaseRemoved(const TString& database, TPathId pathId) = 0;
};
-IActor* CreateDbWatcherActor(TIntrusivePtr<TDbWatcherCallback> callback);
+NActors::IActor* CreateDbWatcherActor(TIntrusivePtr<TDbWatcherCallback> callback);
}
}
diff --git a/ydb/core/sys_view/service/sysview_service.cpp b/ydb/core/sys_view/service/sysview_service.cpp
index dfa98efdd2..873a335b10 100644
--- a/ydb/core/sys_view/service/sysview_service.cpp
+++ b/ydb/core/sys_view/service/sysview_service.cpp
@@ -1211,14 +1211,14 @@ private:
static constexpr TDuration ProcessCountersInterval = TDuration::Seconds(5);
};
-THolder<IActor> CreateSysViewService(
+THolder<NActors::IActor> CreateSysViewService(
TExtCountersConfig&& config, bool hasExternalCounters)
{
return MakeHolder<TSysViewService>(
std::move(config), hasExternalCounters, EProcessorMode::MINUTE);
}
-THolder<IActor> CreateSysViewServiceForTests() {
+THolder<NActors::IActor> CreateSysViewServiceForTests() {
return MakeHolder<TSysViewService>(
TExtCountersConfig(), true, EProcessorMode::FAST);
}
diff --git a/ydb/core/sys_view/service/sysview_service.h b/ydb/core/sys_view/service/sysview_service.h
index 430dfb0261..557d78b8c9 100644
--- a/ydb/core/sys_view/service/sysview_service.h
+++ b/ydb/core/sys_view/service/sysview_service.h
@@ -19,10 +19,10 @@ void CollectQueryStats(const TActorContext& ctx, const NKqpProto::TKqpStatsQuery
const TString& userSID, ui64 parametersSize, const TString& database,
const NKikimrKqp::EQueryType type, ui64 requestUnits);
-THolder<IActor> CreateSysViewService(
+THolder<NActors::IActor> CreateSysViewService(
TExtCountersConfig&& config, bool hasExternalCounters);
-THolder<IActor> CreateSysViewServiceForTests();
+THolder<NActors::IActor> CreateSysViewServiceForTests();
} // NSysView
} // NKikimr
diff --git a/ydb/core/sys_view/storage/groups.cpp b/ydb/core/sys_view/storage/groups.cpp
index dabd46f9dc..cca51da225 100644
--- a/ydb/core/sys_view/storage/groups.cpp
+++ b/ydb/core/sys_view/storage/groups.cpp
@@ -41,7 +41,7 @@ public:
}
};
-THolder<IActor> CreateGroupsScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateGroupsScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns)
{
return MakeHolder<TGroupsScan>(ownerId, scanId, tableId, tableRange, columns);
diff --git a/ydb/core/sys_view/storage/groups.h b/ydb/core/sys_view/storage/groups.h
index ab861d94a8..42755bf879 100644
--- a/ydb/core/sys_view/storage/groups.h
+++ b/ydb/core/sys_view/storage/groups.h
@@ -2,10 +2,13 @@
#include <ydb/core/kqp/runtime/kqp_compute.h>
+#include <library/cpp/actors/core/actor.h>
+#include <library/cpp/actors/core/actorid.h>
+
namespace NKikimr {
namespace NSysView {
-THolder<IActor> CreateGroupsScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateGroupsScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns);
} // NSysView
diff --git a/ydb/core/sys_view/storage/pdisks.cpp b/ydb/core/sys_view/storage/pdisks.cpp
index 7b99991c52..f870dc1ffa 100644
--- a/ydb/core/sys_view/storage/pdisks.cpp
+++ b/ydb/core/sys_view/storage/pdisks.cpp
@@ -45,7 +45,7 @@ public:
}
};
-THolder<IActor> CreatePDisksScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreatePDisksScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns)
{
return MakeHolder<TPDisksScan>(ownerId, scanId, tableId, tableRange, columns);
diff --git a/ydb/core/sys_view/storage/pdisks.h b/ydb/core/sys_view/storage/pdisks.h
index 4172cb333f..2ddc5d6b00 100644
--- a/ydb/core/sys_view/storage/pdisks.h
+++ b/ydb/core/sys_view/storage/pdisks.h
@@ -2,10 +2,13 @@
#include <ydb/core/kqp/runtime/kqp_compute.h>
+#include <library/cpp/actors/core/actor.h>
+#include <library/cpp/actors/core/actorid.h>
+
namespace NKikimr {
namespace NSysView {
-THolder<IActor> CreatePDisksScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreatePDisksScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns);
} // NSysView
diff --git a/ydb/core/sys_view/storage/storage_pools.cpp b/ydb/core/sys_view/storage/storage_pools.cpp
index 66896a6999..20c331f7da 100644
--- a/ydb/core/sys_view/storage/storage_pools.cpp
+++ b/ydb/core/sys_view/storage/storage_pools.cpp
@@ -40,7 +40,7 @@ public:
}
};
-THolder<IActor> CreateStoragePoolsScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateStoragePoolsScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns)
{
return MakeHolder<TStoragePoolsScan>(ownerId, scanId, tableId, tableRange, columns);
diff --git a/ydb/core/sys_view/storage/storage_pools.h b/ydb/core/sys_view/storage/storage_pools.h
index 7ced359d00..9ac4fd6ab2 100644
--- a/ydb/core/sys_view/storage/storage_pools.h
+++ b/ydb/core/sys_view/storage/storage_pools.h
@@ -2,10 +2,13 @@
#include <ydb/core/kqp/runtime/kqp_compute.h>
+#include <library/cpp/actors/core/actor.h>
+#include <library/cpp/actors/core/actorid.h>
+
namespace NKikimr {
namespace NSysView {
-THolder<IActor> CreateStoragePoolsScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateStoragePoolsScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns);
} // NSysView
diff --git a/ydb/core/sys_view/storage/storage_stats.cpp b/ydb/core/sys_view/storage/storage_stats.cpp
index 3668e79798..23876218c2 100644
--- a/ydb/core/sys_view/storage/storage_stats.cpp
+++ b/ydb/core/sys_view/storage/storage_stats.cpp
@@ -29,7 +29,7 @@ public:
}
};
-THolder<IActor> CreateStorageStatsScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateStorageStatsScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns)
{
return MakeHolder<TStorageStatsScan>(ownerId, scanId, tableId, tableRange, columns);
diff --git a/ydb/core/sys_view/storage/storage_stats.h b/ydb/core/sys_view/storage/storage_stats.h
index 5ffe026e29..cacfadbb7d 100644
--- a/ydb/core/sys_view/storage/storage_stats.h
+++ b/ydb/core/sys_view/storage/storage_stats.h
@@ -2,9 +2,12 @@
#include <ydb/core/kqp/runtime/kqp_compute.h>
+#include <library/cpp/actors/core/actor.h>
+#include <library/cpp/actors/core/actorid.h>
+
namespace NKikimr::NSysView {
-THolder<IActor> CreateStorageStatsScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateStorageStatsScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns);
} // NKikimr::NSysView
diff --git a/ydb/core/sys_view/storage/vslots.cpp b/ydb/core/sys_view/storage/vslots.cpp
index 987eb2750d..6a2bbabfec 100644
--- a/ydb/core/sys_view/storage/vslots.cpp
+++ b/ydb/core/sys_view/storage/vslots.cpp
@@ -42,7 +42,7 @@ public:
}
};
-THolder<IActor> CreateVSlotsScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateVSlotsScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns)
{
return MakeHolder<TVSlotsScan>(ownerId, scanId, tableId, tableRange, columns);
diff --git a/ydb/core/sys_view/storage/vslots.h b/ydb/core/sys_view/storage/vslots.h
index 34f38f9e0f..d9076e30a6 100644
--- a/ydb/core/sys_view/storage/vslots.h
+++ b/ydb/core/sys_view/storage/vslots.h
@@ -2,10 +2,13 @@
#include <ydb/core/kqp/runtime/kqp_compute.h>
+#include <library/cpp/actors/core/actor.h>
+#include <library/cpp/actors/core/actorid.h>
+
namespace NKikimr {
namespace NSysView {
-THolder<IActor> CreateVSlotsScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateVSlotsScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns);
} // NSysView
diff --git a/ydb/core/sys_view/tablets/tablets.cpp b/ydb/core/sys_view/tablets/tablets.cpp
index b79cbb1c13..cebb38ebd9 100644
--- a/ydb/core/sys_view/tablets/tablets.cpp
+++ b/ydb/core/sys_view/tablets/tablets.cpp
@@ -23,7 +23,7 @@ public:
return NKikimrServices::TActivity::KQP_SYSTEM_VIEW_SCAN;
}
- TTabletsScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+ TTabletsScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns)
: TBase(ownerId, scanId, tableId, tableRange, columns)
{
@@ -357,7 +357,7 @@ private:
bool BatchRequested = false;
};
-THolder<IActor> CreateTabletsScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateTabletsScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns)
{
return MakeHolder<TTabletsScan>(ownerId, scanId, tableId, tableRange, columns);
diff --git a/ydb/core/sys_view/tablets/tablets.h b/ydb/core/sys_view/tablets/tablets.h
index ca54b08d3e..9936737df9 100644
--- a/ydb/core/sys_view/tablets/tablets.h
+++ b/ydb/core/sys_view/tablets/tablets.h
@@ -2,10 +2,12 @@
#include <ydb/core/kqp/runtime/kqp_compute.h>
+#include <library/cpp/actors/core/actor.h>
+
namespace NKikimr {
namespace NSysView {
-THolder<IActor> CreateTabletsScan(const TActorId& ownerId, ui32 scanId, const TTableId& tableId,
+THolder<NActors::IActor> CreateTabletsScan(const NActors::TActorId& ownerId, ui32 scanId, const TTableId& tableId,
const TTableRange& tableRange, const TArrayRef<NMiniKQL::TKqpComputeContextBase::TColumn>& columns);
} // NSysView
diff --git a/ydb/core/tablet_flat/protos/CMakeLists.darwin-x86_64.txt b/ydb/core/tablet_flat/protos/CMakeLists.darwin-x86_64.txt
index f018a876e4..a04498fa62 100644
--- a/ydb/core/tablet_flat/protos/CMakeLists.darwin-x86_64.txt
+++ b/ydb/core/tablet_flat/protos/CMakeLists.darwin-x86_64.txt
@@ -37,6 +37,7 @@ target_link_libraries(core-tablet_flat-protos PUBLIC
yutil
contrib-libs-protobuf
ydb-core-protos
+ core-scheme-protos
)
target_proto_messages(core-tablet_flat-protos PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/tablet_flat/protos/flat_table_part.proto
diff --git a/ydb/core/tablet_flat/protos/CMakeLists.linux-aarch64.txt b/ydb/core/tablet_flat/protos/CMakeLists.linux-aarch64.txt
index ad30547f6b..d9797a00bb 100644
--- a/ydb/core/tablet_flat/protos/CMakeLists.linux-aarch64.txt
+++ b/ydb/core/tablet_flat/protos/CMakeLists.linux-aarch64.txt
@@ -38,6 +38,7 @@ target_link_libraries(core-tablet_flat-protos PUBLIC
yutil
contrib-libs-protobuf
ydb-core-protos
+ core-scheme-protos
)
target_proto_messages(core-tablet_flat-protos PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/tablet_flat/protos/flat_table_part.proto
diff --git a/ydb/core/tablet_flat/protos/CMakeLists.linux-x86_64.txt b/ydb/core/tablet_flat/protos/CMakeLists.linux-x86_64.txt
index ad30547f6b..d9797a00bb 100644
--- a/ydb/core/tablet_flat/protos/CMakeLists.linux-x86_64.txt
+++ b/ydb/core/tablet_flat/protos/CMakeLists.linux-x86_64.txt
@@ -38,6 +38,7 @@ target_link_libraries(core-tablet_flat-protos PUBLIC
yutil
contrib-libs-protobuf
ydb-core-protos
+ core-scheme-protos
)
target_proto_messages(core-tablet_flat-protos PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/tablet_flat/protos/flat_table_part.proto
diff --git a/ydb/core/tablet_flat/protos/CMakeLists.windows-x86_64.txt b/ydb/core/tablet_flat/protos/CMakeLists.windows-x86_64.txt
index f018a876e4..a04498fa62 100644
--- a/ydb/core/tablet_flat/protos/CMakeLists.windows-x86_64.txt
+++ b/ydb/core/tablet_flat/protos/CMakeLists.windows-x86_64.txt
@@ -37,6 +37,7 @@ target_link_libraries(core-tablet_flat-protos PUBLIC
yutil
contrib-libs-protobuf
ydb-core-protos
+ core-scheme-protos
)
target_proto_messages(core-tablet_flat-protos PRIVATE
${CMAKE_SOURCE_DIR}/ydb/core/tablet_flat/protos/flat_table_part.proto
diff --git a/ydb/core/tablet_flat/protos/flat_table_part.proto b/ydb/core/tablet_flat/protos/flat_table_part.proto
index 53892fabfe..77acb9a6d1 100644
--- a/ydb/core/tablet_flat/protos/flat_table_part.proto
+++ b/ydb/core/tablet_flat/protos/flat_table_part.proto
@@ -1,5 +1,5 @@
import "ydb/core/protos/base.proto";
-import "ydb/core/protos/type_info.proto";
+import "ydb/core/scheme/protos/type_info.proto";
package NKikimr.NTable.NProto;
option java_package = "ru.yandex.kikimr.proto";
diff --git a/ydb/core/tablet_flat/protos/ya.make b/ydb/core/tablet_flat/protos/ya.make
index 940c1e1fc9..72fdd74eae 100644
--- a/ydb/core/tablet_flat/protos/ya.make
+++ b/ydb/core/tablet_flat/protos/ya.make
@@ -8,6 +8,7 @@ SRCS(
PEERDIR(
contrib/libs/protobuf
ydb/core/protos
+ ydb/core/scheme/protos
)
END()
diff --git a/ydb/core/tx/datashard/cdc_stream_scan.h b/ydb/core/tx/datashard/cdc_stream_scan.h
index c8be61ded2..3abee90ccb 100644
--- a/ydb/core/tx/datashard/cdc_stream_scan.h
+++ b/ydb/core/tx/datashard/cdc_stream_scan.h
@@ -2,7 +2,7 @@
#include <library/cpp/actors/core/actor.h>
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <ydb/core/scheme/scheme_tablecell.h>
#include <ydb/core/tablet_flat/flat_cxx_database.h>
diff --git a/ydb/core/tx/datashard/change_record.h b/ydb/core/tx/datashard/change_record.h
index ae3ea88663..c1e7920df3 100644
--- a/ydb/core/tx/datashard/change_record.h
+++ b/ydb/core/tx/datashard/change_record.h
@@ -4,7 +4,7 @@
#include <library/cpp/json/json_value.h>
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <ydb/core/scheme/scheme_tablecell.h>
#include <util/generic/maybe.h>
diff --git a/ydb/core/tx/datashard/change_sender_monitoring.cpp b/ydb/core/tx/datashard/change_sender_monitoring.cpp
index 3ee4bcd5c1..9cc4ba1b6b 100644
--- a/ydb/core/tx/datashard/change_sender_monitoring.cpp
+++ b/ydb/core/tx/datashard/change_sender_monitoring.cpp
@@ -1,5 +1,6 @@
#include "change_sender_monitoring.h"
+#include <util/string/builder.h>
#include <util/string/cast.h>
#include <util/string/printf.h>
#include <util/string/split.h>
diff --git a/ydb/core/tx/datashard/change_sender_monitoring.h b/ydb/core/tx/datashard/change_sender_monitoring.h
index c650848b8d..fe9bf40b9a 100644
--- a/ydb/core/tx/datashard/change_sender_monitoring.h
+++ b/ydb/core/tx/datashard/change_sender_monitoring.h
@@ -1,9 +1,11 @@
#pragma once
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <library/cpp/monlib/service/pages/templates.h>
+#include <util/generic/maybe.h>
+
namespace NKikimr::NDataShard {
template <typename T>
diff --git a/ydb/core/tx/datashard/snapshot_key.h b/ydb/core/tx/datashard/snapshot_key.h
index 3efaf46fd5..f16e4438e6 100644
--- a/ydb/core/tx/datashard/snapshot_key.h
+++ b/ydb/core/tx/datashard/snapshot_key.h
@@ -1,6 +1,6 @@
#pragma once
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <util/generic/fwd.h>
diff --git a/ydb/core/tx/replication/controller/private_events.h b/ydb/core/tx/replication/controller/private_events.h
index 7048467930..8438e9f27c 100644
--- a/ydb/core/tx/replication/controller/private_events.h
+++ b/ydb/core/tx/replication/controller/private_events.h
@@ -4,7 +4,7 @@
#include <ydb/core/base/defs.h>
#include <ydb/core/base/events.h>
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <ydb/core/protos/flat_tx_scheme.pb.h>
namespace NKikimr::NReplication::NController {
diff --git a/ydb/core/tx/replication/controller/replication.h b/ydb/core/tx/replication/controller/replication.h
index 5ab51fd34d..df69d5227e 100644
--- a/ydb/core/tx/replication/controller/replication.h
+++ b/ydb/core/tx/replication/controller/replication.h
@@ -3,7 +3,7 @@
#include "sys_params.h"
#include <ydb/core/base/defs.h>
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <util/generic/ptr.h>
diff --git a/ydb/core/tx/scheme_board/events.h b/ydb/core/tx/scheme_board/events.h
index 506fb5beca..8e686e8b92 100644
--- a/ydb/core/tx/scheme_board/events.h
+++ b/ydb/core/tx/scheme_board/events.h
@@ -4,7 +4,7 @@
#include "helpers.h"
#include "two_part_description.h"
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <ydb/core/base/statestorage.h>
#include <ydb/core/protos/flat_tx_scheme.pb.h>
#include <ydb/core/protos/scheme_board.pb.h>
diff --git a/ydb/core/tx/scheme_board/helpers.h b/ydb/core/tx/scheme_board/helpers.h
index 3b07df3e06..c613ee48a6 100644
--- a/ydb/core/tx/scheme_board/helpers.h
+++ b/ydb/core/tx/scheme_board/helpers.h
@@ -1,7 +1,7 @@
#pragma once
#include "defs.h"
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <ydb/core/protos/flat_tx_scheme.pb.h>
diff --git a/ydb/core/tx/scheme_board/mon_events.h b/ydb/core/tx/scheme_board/mon_events.h
index 7e02c2d58f..9a12be47f6 100644
--- a/ydb/core/tx/scheme_board/mon_events.h
+++ b/ydb/core/tx/scheme_board/mon_events.h
@@ -2,7 +2,7 @@
#include "defs.h"
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <ydb/core/protos/scheme_board_mon.pb.h>
#include <ydb/library/services/services.pb.h>
diff --git a/ydb/core/tx/scheme_board/monitoring.cpp b/ydb/core/tx/scheme_board/monitoring.cpp
index 923cf75f90..8b0d2281ec 100644
--- a/ydb/core/tx/scheme_board/monitoring.cpp
+++ b/ydb/core/tx/scheme_board/monitoring.cpp
@@ -2,7 +2,7 @@
#include "monitoring.h"
#include <ydb/core/base/appdata.h>
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <ydb/core/base/statestorage_impl.h>
#include <ydb/core/mon/mon.h>
#include <ydb/library/services/services.pb.h>
diff --git a/ydb/core/tx/scheme_board/populator.h b/ydb/core/tx/scheme_board/populator.h
index 8105c56ba4..ff0b4cead4 100644
--- a/ydb/core/tx/scheme_board/populator.h
+++ b/ydb/core/tx/scheme_board/populator.h
@@ -3,7 +3,7 @@
#include "defs.h"
#include "two_part_description.h"
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <util/generic/map.h>
diff --git a/ydb/core/tx/scheme_board/populator_ut.cpp b/ydb/core/tx/scheme_board/populator_ut.cpp
index 50394d74c7..e2af80d747 100644
--- a/ydb/core/tx/scheme_board/populator_ut.cpp
+++ b/ydb/core/tx/scheme_board/populator_ut.cpp
@@ -1,7 +1,7 @@
#include "events.h"
#include "ut_helpers.h"
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <ydb/core/base/tablet_types.h>
#include <ydb/library/services/services.pb.h>
#include <ydb/core/tx/schemeshard/ut_helpers/helpers.h>
diff --git a/ydb/core/tx/scheme_board/replica_ut.cpp b/ydb/core/tx/scheme_board/replica_ut.cpp
index 90799649a5..2f79b5bfc1 100644
--- a/ydb/core/tx/scheme_board/replica_ut.cpp
+++ b/ydb/core/tx/scheme_board/replica_ut.cpp
@@ -2,7 +2,7 @@
#include "replica.h"
#include "ut_helpers.h"
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <ydb/library/services/services.pb.h>
#include <ydb/core/testlib/basics/appdata.h>
diff --git a/ydb/core/tx/scheme_board/subscriber.h b/ydb/core/tx/scheme_board/subscriber.h
index f415e4e9d5..8e6cd2ffa4 100644
--- a/ydb/core/tx/scheme_board/subscriber.h
+++ b/ydb/core/tx/scheme_board/subscriber.h
@@ -2,7 +2,7 @@
#include "defs.h"
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <util/generic/string.h>
diff --git a/ydb/core/tx/scheme_board/subscriber_ut.cpp b/ydb/core/tx/scheme_board/subscriber_ut.cpp
index 9db9833d22..3eec1e58c1 100644
--- a/ydb/core/tx/scheme_board/subscriber_ut.cpp
+++ b/ydb/core/tx/scheme_board/subscriber_ut.cpp
@@ -2,7 +2,7 @@
#include "subscriber.h"
#include "ut_helpers.h"
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <ydb/core/base/statestorage_impl.h>
#include <ydb/library/services/services.pb.h>
#include <ydb/core/testlib/basics/appdata.h>
diff --git a/ydb/core/tx/scheme_cache/scheme_cache.h b/ydb/core/tx/scheme_cache/scheme_cache.h
index e799a91e29..c3e8a9df21 100644
--- a/ydb/core/tx/scheme_cache/scheme_cache.h
+++ b/ydb/core/tx/scheme_cache/scheme_cache.h
@@ -2,7 +2,7 @@
#include <ydb/core/base/appdata.h>
#include <ydb/core/base/events.h>
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <ydb/core/base/tx_processing.h>
#include <ydb/core/protos/flat_scheme_op.pb.h>
#include <ydb/core/protos/flat_tx_scheme.pb.h>
diff --git a/ydb/core/tx/schemeshard/schemeshard_identificators.h b/ydb/core/tx/schemeshard/schemeshard_identificators.h
index a6f0ff5aa0..e774da9d35 100644
--- a/ydb/core/tx/schemeshard/schemeshard_identificators.h
+++ b/ydb/core/tx/schemeshard/schemeshard_identificators.h
@@ -1,6 +1,6 @@
#pragma once
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <ydb/core/util/ui64id.h>
#include <util/generic/utility.h>
diff --git a/ydb/core/tx/schemeshard/schemeshard_schema.h b/ydb/core/tx/schemeshard/schemeshard_schema.h
index c9d88ec9dc..0fd9a999f1 100644
--- a/ydb/core/tx/schemeshard/schemeshard_schema.h
+++ b/ydb/core/tx/schemeshard/schemeshard_schema.h
@@ -2,7 +2,7 @@
#include "schemeshard_types.h"
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <ydb/core/protos/tx_datashard.pb.h>
#include <ydb/core/protos/tx.pb.h>
#include <ydb/core/tablet_flat/flat_cxx_database.h>
diff --git a/ydb/core/tx/schemeshard/schemeshard_tables_storage.h b/ydb/core/tx/schemeshard/schemeshard_tables_storage.h
index 0f57d81ab4..c006967336 100644
--- a/ydb/core/tx/schemeshard/schemeshard_tables_storage.h
+++ b/ydb/core/tx/schemeshard/schemeshard_tables_storage.h
@@ -1,7 +1,7 @@
#pragma once
#include "schemeshard_info_types.h"
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <ydb/library/accessor/accessor.h>
#include <util/digest/numeric.h>
diff --git a/ydb/core/tx/schemeshard/ut_helpers/ls_checks.h b/ydb/core/tx/schemeshard/ut_helpers/ls_checks.h
index 0168972abf..edd085969c 100644
--- a/ydb/core/tx/schemeshard/ut_helpers/ls_checks.h
+++ b/ydb/core/tx/schemeshard/ut_helpers/ls_checks.h
@@ -3,7 +3,7 @@
#include <ydb/core/protos/flat_tx_scheme.pb.h>
#include <ydb/core/testlib/actors/test_runtime.h>
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <functional>
diff --git a/ydb/core/tx/sequenceproxy/public/events.h b/ydb/core/tx/sequenceproxy/public/events.h
index db786242e3..2fdaae7c8c 100644
--- a/ydb/core/tx/sequenceproxy/public/events.h
+++ b/ydb/core/tx/sequenceproxy/public/events.h
@@ -1,7 +1,7 @@
#pragma once
#include <ydb/core/base/events.h>
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <ydb/library/aclib/aclib.h>
#include <ydb/public/api/protos/ydb_status_codes.pb.h>
#include <ydb/library/yql/public/issue/yql_issue.h>
diff --git a/ydb/core/tx/sequenceshard/public/events.h b/ydb/core/tx/sequenceshard/public/events.h
index 3175b90641..599bd718c1 100644
--- a/ydb/core/tx/sequenceshard/public/events.h
+++ b/ydb/core/tx/sequenceshard/public/events.h
@@ -1,7 +1,7 @@
#pragma once
#include <ydb/core/base/events.h>
-#include <ydb/core/base/pathid.h>
+#include <ydb/core/scheme/scheme_pathid.h>
#include <ydb/core/protos/tx_sequenceshard.pb.h>
namespace NKikimr {