Rename dq_sink files

Rename dq_sink files

ref:ed7a69425dcb2e426ddcda172e466a62d546e208

5 files changed, 5 insertions, 5 deletions

diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor_async_output.h b/ydb/library/yql/dq/actors/compute/dq_compute_actor_async_output.h
index 7af1d9a4103..082450196cb 100644
--- a/ydb/library/yql/dq/actors/compute/dq_compute_actor_async_output.h
+++ b/ydb/library/yql/dq/actors/compute/dq_compute_actor_async_output.h
@@ -1,7 +1,7 @@
 #pragma once
 #include <ydb/library/yql/dq/common/dq_common.h>
 #include <ydb/library/yql/dq/runtime/dq_output_consumer.h>
-#include <ydb/library/yql/dq/runtime/dq_sink.h>
+#include <ydb/library/yql/dq/runtime/dq_async_output.h>
 #include <ydb/library/yql/minikql/computation/mkql_computation_node_holders.h>
 #include <ydb/library/yql/public/issue/yql_issue.h>
 
@@ -34,7 +34,7 @@ namespace NYql::NDq {
 // 2. CA runs program and gets results.
 // 3. CA calls IDqComputeActorAsyncOutput::SendData().
 // 4. If SendData() returns value less than 0, loop stops running until free space appears.
-// 5. When free space appears, sink calls ICallbacks::ResumeExecution() to start processing again.
+// 5. When free space appears, sink/transform calls ICallbacks::ResumeExecution() to start processing again.
 //
 // Checkpointing:
 // 1. InjectCheckpoint event arrives to CA.
diff --git a/ydb/library/yql/dq/runtime/CMakeLists.txt b/ydb/library/yql/dq/runtime/CMakeLists.txt
index 73d906dbf6b..bfdbbb4b164 100644
--- a/ydb/library/yql/dq/runtime/CMakeLists.txt
+++ b/ydb/library/yql/dq/runtime/CMakeLists.txt
@@ -36,7 +36,7 @@ target_sources(yql-dq-runtime PRIVATE
   ${CMAKE_SOURCE_DIR}/ydb/library/yql/dq/runtime/dq_output_channel.cpp
   ${CMAKE_SOURCE_DIR}/ydb/library/yql/dq/runtime/dq_output_consumer.cpp
   ${CMAKE_SOURCE_DIR}/ydb/library/yql/dq/runtime/dq_source.cpp
-  ${CMAKE_SOURCE_DIR}/ydb/library/yql/dq/runtime/dq_sink.cpp
+  ${CMAKE_SOURCE_DIR}/ydb/library/yql/dq/runtime/dq_async_output.cpp
   ${CMAKE_SOURCE_DIR}/ydb/library/yql/dq/runtime/dq_tasks_runner.cpp
   ${CMAKE_SOURCE_DIR}/ydb/library/yql/dq/runtime/dq_transport.cpp
 )
diff --git a/ydb/library/yql/dq/runtime/dq_sink.cpp b/ydb/library/yql/dq/runtime/dq_async_output.cpp
index 99e04ba3f08..38bd1999baa 100644
--- a/ydb/library/yql/dq/runtime/dq_sink.cpp
+++ b/ydb/library/yql/dq/runtime/dq_async_output.cpp
@@ -1,4 +1,4 @@
-#include "dq_sink.h"
+#include "dq_async_output.h"
 #include "dq_transport.h"
 
 #include <ydb/library/yql/utils/yql_panic.h>
diff --git a/ydb/library/yql/dq/runtime/dq_sink.h b/ydb/library/yql/dq/runtime/dq_async_output.h
index 931957a7208..931957a7208 100644
--- a/ydb/library/yql/dq/runtime/dq_sink.h
+++ b/ydb/library/yql/dq/runtime/dq_async_output.h
diff --git a/ydb/library/yql/dq/runtime/dq_tasks_runner.h b/ydb/library/yql/dq/runtime/dq_tasks_runner.h
index aa9e9b8a96e..5dbefd9f2f5 100644
--- a/ydb/library/yql/dq/runtime/dq_tasks_runner.h
+++ b/ydb/library/yql/dq/runtime/dq_tasks_runner.h
@@ -2,12 +2,12 @@
 
 #include <ydb/library/yql/dq/common/dq_common.h>
 #include <ydb/library/yql/dq/proto/dq_tasks.pb.h>
+#include <ydb/library/yql/dq/runtime/dq_async_output.h>
 #include <ydb/library/yql/dq/runtime/dq_compute.h>
 #include <ydb/library/yql/dq/runtime/dq_input_channel.h>
 #include <ydb/library/yql/dq/runtime/dq_output_channel.h>
 #include <ydb/library/yql/dq/runtime/dq_output_consumer.h>
 #include <ydb/library/yql/dq/runtime/dq_source.h>
-#include <ydb/library/yql/dq/runtime/dq_sink.h>
 
 #include <ydb/library/yql/minikql/mkql_alloc.h>
 #include <ydb/library/yql/minikql/mkql_function_registry.h>