diff options
author | Vasily Gerasimov <UgnineSirdis@gmail.com> | 2022-04-19 18:02:11 +0300 |
---|---|---|
committer | Vasily Gerasimov <UgnineSirdis@gmail.com> | 2022-04-19 18:02:11 +0300 |
commit | d78d1be41abdec0fa017a17bbe3a0459493e09d6 (patch) | |
tree | b2a05ebc4b2b25f1f4921bab90891dbe654d834a | |
parent | fa75a76410a21f6e10a7e8abe12226b14040fe4e (diff) | |
download | ydb-d78d1be41abdec0fa017a17bbe3a0459493e09d6.tar.gz |
YQ-1052 Rename files
Rename files
ref:f6ffd89095c85781fe12eed127c181a513d372b7
23 files changed, 25 insertions, 26 deletions
diff --git a/ydb/core/yq/libs/init/init.cpp b/ydb/core/yq/libs/init/init.cpp index 4e65e14ecc0..a434c086911 100644 --- a/ydb/core/yq/libs/init/init.cpp +++ b/ydb/core/yq/libs/init/init.cpp @@ -18,7 +18,7 @@ #include <library/cpp/protobuf/json/proto2json.h> #include <ydb/library/yql/dq/actors/compute/dq_checkpoints.h> -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_io_actors_factory.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io_factory.h> #include <ydb/library/yql/dq/comp_nodes/yql_common_dq_factory.h> #include <ydb/library/yql/dq/comp_nodes/yql_common_dq_transform.h> #include <ydb/library/yql/utils/actor_log/log.h> diff --git a/ydb/library/yql/dq/actors/compute/CMakeLists.txt b/ydb/library/yql/dq/actors/compute/CMakeLists.txt index 259d3ff8b04..43d32f8394d 100644 --- a/ydb/library/yql/dq/actors/compute/CMakeLists.txt +++ b/ydb/library/yql/dq/actors/compute/CMakeLists.txt @@ -32,7 +32,7 @@ target_sources(dq-actors-compute PRIVATE ${CMAKE_SOURCE_DIR}/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp ${CMAKE_SOURCE_DIR}/ydb/library/yql/dq/actors/compute/dq_compute_actor_channels.cpp ${CMAKE_SOURCE_DIR}/ydb/library/yql/dq/actors/compute/dq_compute_actor_checkpoints.cpp - ${CMAKE_SOURCE_DIR}/ydb/library/yql/dq/actors/compute/dq_compute_actor_io_actors_factory.cpp + ${CMAKE_SOURCE_DIR}/ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io_factory.cpp ${CMAKE_SOURCE_DIR}/ydb/library/yql/dq/actors/compute/dq_compute_actor_stats.cpp ${CMAKE_SOURCE_DIR}/ydb/library/yql/dq/actors/compute/dq_compute_issues_buffer.cpp ${CMAKE_SOURCE_DIR}/ydb/library/yql/dq/actors/compute/retry_queue.cpp diff --git a/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.h b/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.h index 6812598834d..209570081c7 100644 --- a/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.h +++ b/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.h @@ -1,7 +1,7 @@ #pragma once #include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sources.h> -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sinks.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_output.h> #include <ydb/library/yql/dq/actors/compute/dq_compute_actor.h> #include <ydb/library/yql/dq/actors/dq_events_ids.h> #include <ydb/library/yql/dq/actors/protos/dq_events.pb.h> diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor.h b/ydb/library/yql/dq/actors/compute/dq_compute_actor.h index 4dfc41f03a3..90a06438417 100644 --- a/ydb/library/yql/dq/actors/compute/dq_compute_actor.h +++ b/ydb/library/yql/dq/actors/compute/dq_compute_actor.h @@ -1,7 +1,7 @@ #pragma once #include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sources.h> -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sinks.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_output.h> #include <ydb/library/yql/dq/actors/dq_events_ids.h> #include <ydb/library/yql/dq/actors/protos/dq_events.pb.h> #include <ydb/library/yql/dq/common/dq_common.h> diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor_io_actors_factory.cpp b/ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io_factory.cpp index c8f51e185c6..f73750ce676 100644 --- a/ydb/library/yql/dq/actors/compute/dq_compute_actor_io_actors_factory.cpp +++ b/ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io_factory.cpp @@ -1,6 +1,6 @@ -#include "dq_compute_actor_io_actors_factory.h" +#include "dq_compute_actor_async_io_factory.h" -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sinks.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_output.h> #include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sources.h> #include <ydb/library/yql/dq/common/dq_common.h> diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor_io_actors_factory.h b/ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io_factory.h index 45b4ac13cf6..196e6952df8 100644 --- a/ydb/library/yql/dq/actors/compute/dq_compute_actor_io_actors_factory.h +++ b/ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io_factory.h @@ -1,6 +1,6 @@ #pragma once #include "dq_compute_actor_sources.h" -#include "dq_compute_actor_sinks.h" +#include "dq_compute_actor_async_output.h" #include <ydb/library/yql/dq/actors/protos/dq_events.pb.h> #include <ydb/library/yql/dq/common/dq_common.h> diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor_sinks.h b/ydb/library/yql/dq/actors/compute/dq_compute_actor_async_output.h index 74b4793e5a0..74b4793e5a0 100644 --- a/ydb/library/yql/dq/actors/compute/dq_compute_actor_sinks.h +++ b/ydb/library/yql/dq/actors/compute/dq_compute_actor_async_output.h diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor_checkpoints.h b/ydb/library/yql/dq/actors/compute/dq_compute_actor_checkpoints.h index ba7cd1dddc5..f7e5ef62266 100644 --- a/ydb/library/yql/dq/actors/compute/dq_compute_actor_checkpoints.h +++ b/ydb/library/yql/dq/actors/compute/dq_compute_actor_checkpoints.h @@ -1,7 +1,7 @@ #pragma once #include "dq_compute_actor.h" -#include "dq_compute_actor_sinks.h" +#include "dq_compute_actor_async_output.h" #include "retry_queue.h" #include <ydb/library/yql/dq/common/dq_common.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 51559b03dad..75b4086fd99 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 @@ -3,7 +3,7 @@ #include "dq_compute_actor.h" #include "dq_compute_actor_channels.h" #include "dq_compute_actor_checkpoints.h" -#include "dq_compute_actor_sinks.h" +#include "dq_compute_actor_async_output.h" #include "dq_compute_actor_sources.h" #include "dq_compute_issues_buffer.h" #include "dq_compute_memory_quota.h" diff --git a/ydb/library/yql/providers/clickhouse/actors/yql_ch_source_factory.h b/ydb/library/yql/providers/clickhouse/actors/yql_ch_source_factory.h index 2813cba4d35..faf868216e5 100644 --- a/ydb/library/yql/providers/clickhouse/actors/yql_ch_source_factory.h +++ b/ydb/library/yql/providers/clickhouse/actors/yql_ch_source_factory.h @@ -1,6 +1,6 @@ #pragma once -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_io_actors_factory.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io_factory.h> #include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sources.h> #include <ydb/library/yql/providers/common/http_gateway/yql_http_gateway.h> @@ -12,4 +12,3 @@ namespace NYql::NDq { void RegisterClickHouseReadActorFactory(TDqSourceFactory& factory, ISecuredServiceAccountCredentialsFactory::TPtr credentialsFactory, IHTTPGateway::TPtr gateway = IHTTPGateway::Make()); } - diff --git a/ydb/library/yql/providers/common/ut_helpers/dq_fake_ca.h b/ydb/library/yql/providers/common/ut_helpers/dq_fake_ca.h index 7a3de5b51e5..1d24d3ad1e0 100644 --- a/ydb/library/yql/providers/common/ut_helpers/dq_fake_ca.h +++ b/ydb/library/yql/providers/common/ut_helpers/dq_fake_ca.h @@ -2,7 +2,7 @@ #include <ydb/library/yql/minikql/computation/mkql_computation_node_holders.h> #include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sources.h> -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sinks.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_output.h> #include <ydb/library/yql/dq/actors/protos/dq_events.pb.h> #include <ydb/library/yql/dq/proto/dq_checkpoint.pb.h> #include <ydb/library/yql/minikql/mkql_alloc.h> diff --git a/ydb/library/yql/providers/dq/local_gateway/yql_dq_gateway_local.cpp b/ydb/library/yql/providers/dq/local_gateway/yql_dq_gateway_local.cpp index 93243a29525..99885567993 100644 --- a/ydb/library/yql/providers/dq/local_gateway/yql_dq_gateway_local.cpp +++ b/ydb/library/yql/providers/dq/local_gateway/yql_dq_gateway_local.cpp @@ -13,7 +13,7 @@ #include <ydb/library/yql/providers/s3/actors/yql_s3_source_factory.h> #include <ydb/library/yql/providers/ydb/actors/yql_ydb_source_factory.h> -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_io_actors_factory.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io_factory.h> #include <ydb/library/yql/utils/range_walker.h> #include <ydb/library/yql/utils/bind_in_range.h> diff --git a/ydb/library/yql/providers/dq/worker_manager/local_worker_manager.h b/ydb/library/yql/providers/dq/worker_manager/local_worker_manager.h index 26f8a6a43ff..929f5af4ced 100644 --- a/ydb/library/yql/providers/dq/worker_manager/local_worker_manager.h +++ b/ydb/library/yql/providers/dq/worker_manager/local_worker_manager.h @@ -1,7 +1,7 @@ #pragma once #include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sources.h> -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sinks.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_output.h> #include <ydb/library/yql/providers/dq/worker_manager/interface/events.h> #include <ydb/library/yql/providers/dq/worker_manager/interface/counters.h> diff --git a/ydb/library/yql/providers/pq/async_io/dq_pq_read_actor.cpp b/ydb/library/yql/providers/pq/async_io/dq_pq_read_actor.cpp index c7caff8eccb..14a2b8ecd13 100644 --- a/ydb/library/yql/providers/pq/async_io/dq_pq_read_actor.cpp +++ b/ydb/library/yql/providers/pq/async_io/dq_pq_read_actor.cpp @@ -1,7 +1,7 @@ #include "dq_pq_read_actor.h" #include "probes.h" -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_io_actors_factory.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io_factory.h> #include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sources.h> #include <ydb/library/yql/dq/actors/protos/dq_events.pb.h> #include <ydb/library/yql/dq/common/dq_common.h> diff --git a/ydb/library/yql/providers/pq/async_io/dq_pq_read_actor.h b/ydb/library/yql/providers/pq/async_io/dq_pq_read_actor.h index 19b67f27b20..74058ee4621 100644 --- a/ydb/library/yql/providers/pq/async_io/dq_pq_read_actor.h +++ b/ydb/library/yql/providers/pq/async_io/dq_pq_read_actor.h @@ -1,6 +1,6 @@ #pragma once -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_io_actors_factory.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io_factory.h> #include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sources.h> #include <ydb/library/yql/providers/common/token_accessor/client/factory.h> diff --git a/ydb/library/yql/providers/pq/async_io/dq_pq_write_actor.cpp b/ydb/library/yql/providers/pq/async_io/dq_pq_write_actor.cpp index bfd7ad6dea9..0aae5a7558e 100644 --- a/ydb/library/yql/providers/pq/async_io/dq_pq_write_actor.cpp +++ b/ydb/library/yql/providers/pq/async_io/dq_pq_write_actor.cpp @@ -1,7 +1,7 @@ #include "dq_pq_write_actor.h" #include "probes.h" -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sinks.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_output.h> #include <ydb/library/yql/dq/actors/protos/dq_events.pb.h> #include <ydb/library/yql/dq/common/dq_common.h> #include <ydb/library/yql/dq/proto/dq_checkpoint.pb.h> diff --git a/ydb/library/yql/providers/pq/async_io/dq_pq_write_actor.h b/ydb/library/yql/providers/pq/async_io/dq_pq_write_actor.h index 2cc0b0ee183..651abc94a71 100644 --- a/ydb/library/yql/providers/pq/async_io/dq_pq_write_actor.h +++ b/ydb/library/yql/providers/pq/async_io/dq_pq_write_actor.h @@ -1,7 +1,7 @@ #pragma once -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_io_actors_factory.h> -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sinks.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io_factory.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_output.h> #include <ydb/library/yql/providers/common/token_accessor/client/factory.h> #include <ydb/library/yql/minikql/computation/mkql_computation_node_holders.h> diff --git a/ydb/library/yql/providers/pq/async_io/ut/ut_helpers.h b/ydb/library/yql/providers/pq/async_io/ut/ut_helpers.h index 5d9f3d11424..76c66c299ba 100644 --- a/ydb/library/yql/providers/pq/async_io/ut/ut_helpers.h +++ b/ydb/library/yql/providers/pq/async_io/ut/ut_helpers.h @@ -5,7 +5,7 @@ #include <ydb/library/yql/providers/pq/async_io/dq_pq_write_actor.h> #include <ydb/library/yql/minikql/computation/mkql_computation_node_holders.h> #include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sources.h> -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sinks.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_output.h> #include <ydb/library/yql/dq/actors/protos/dq_events.pb.h> #include <ydb/library/yql/minikql/mkql_alloc.h> diff --git a/ydb/library/yql/providers/s3/actors/yql_s3_source_factory.h b/ydb/library/yql/providers/s3/actors/yql_s3_source_factory.h index 2df0a312b1f..c47f923b93e 100644 --- a/ydb/library/yql/providers/s3/actors/yql_s3_source_factory.h +++ b/ydb/library/yql/providers/s3/actors/yql_s3_source_factory.h @@ -2,7 +2,7 @@ #include <ydb/library/yql/providers/common/token_accessor/client/factory.h> -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_io_actors_factory.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io_factory.h> #include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sources.h> #include <ydb/library/yql/providers/common/http_gateway/yql_http_gateway.h> #include <ydb/library/yql/providers/s3/proto/retry_config.pb.h> diff --git a/ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.cpp b/ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.cpp index d5bc0ab0ddc..293bba1a427 100644 --- a/ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.cpp +++ b/ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.cpp @@ -1,7 +1,7 @@ #include "dq_solomon_write_actor.h" #include "metrics_encoder.h" -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sinks.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_output.h> #include <ydb/library/yql/dq/actors/protos/dq_events.pb.h> #include <ydb/library/yql/dq/proto/dq_checkpoint.pb.h> diff --git a/ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.h b/ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.h index 12c7dfc2cd9..de6df237568 100644 --- a/ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.h +++ b/ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.h @@ -1,8 +1,8 @@ #pragma once #include <ydb/library/yql/utils/actors/http_sender.h> -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_io_actors_factory.h> -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sinks.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io_factory.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_output.h> #include <ydb/library/yql/providers/common/token_accessor/client/factory.h> #include <ydb/library/yql/minikql/computation/mkql_computation_node_holders.h> #include <ydb/library/yql/providers/solomon/proto/dq_solomon_shard.pb.h> diff --git a/ydb/library/yql/providers/solomon/async_io/ut/ut_helpers.h b/ydb/library/yql/providers/solomon/async_io/ut/ut_helpers.h index 5ba4931e60e..e557c45bf37 100644 --- a/ydb/library/yql/providers/solomon/async_io/ut/ut_helpers.h +++ b/ydb/library/yql/providers/solomon/async_io/ut/ut_helpers.h @@ -4,7 +4,7 @@ #include <ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.h> #include <ydb/library/yql/minikql/computation/mkql_computation_node_holders.h> #include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sources.h> -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sinks.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_output.h> #include <ydb/library/yql/dq/actors/protos/dq_events.pb.h> #include <ydb/library/yql/minikql/mkql_alloc.h> diff --git a/ydb/library/yql/providers/ydb/actors/yql_ydb_source_factory.h b/ydb/library/yql/providers/ydb/actors/yql_ydb_source_factory.h index 6bf59880dd4..d7f3a29931a 100644 --- a/ydb/library/yql/providers/ydb/actors/yql_ydb_source_factory.h +++ b/ydb/library/yql/providers/ydb/actors/yql_ydb_source_factory.h @@ -2,7 +2,7 @@ #include <ydb/public/sdk/cpp/client/ydb_driver/driver.h> -#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_io_actors_factory.h> +#include <ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io_factory.h> #include <ydb/library/yql/dq/actors/compute/dq_compute_actor_sources.h> #include <ydb/library/yql/providers/common/token_accessor/client/factory.h> |