diff options
38 files changed, 31 insertions, 63 deletions
diff --git a/yt/cpp/mapreduce/client/abortable_registry.h b/yt/cpp/mapreduce/client/abortable_registry.h index b19c802f985..26a04236097 100644 --- a/yt/cpp/mapreduce/client/abortable_registry.h +++ b/yt/cpp/mapreduce/client/abortable_registry.h @@ -1,10 +1,10 @@ #pragma once -#include <yt/cpp/mapreduce/interface/common.h> +#include <yt/cpp/mapreduce/common/fwd.h> #include <yt/cpp/mapreduce/http/context.h> -#include <yt/cpp/mapreduce/raw_client/raw_requests.h> +#include <yt/cpp/mapreduce/interface/common.h> #include <util/str_stl.h> #include <util/system/mutex.h> diff --git a/yt/cpp/mapreduce/client/batch_request_impl.cpp b/yt/cpp/mapreduce/client/batch_request_impl.cpp index e7456b91873..64c7e50bafc 100644 --- a/yt/cpp/mapreduce/client/batch_request_impl.cpp +++ b/yt/cpp/mapreduce/client/batch_request_impl.cpp @@ -7,6 +7,7 @@ #include <yt/cpp/mapreduce/http/retry_request.h> +#include <yt/cpp/mapreduce/interface/raw_batch_request.h> #include <yt/cpp/mapreduce/interface/config.h> #include <yt/cpp/mapreduce/interface/logging/yt_log.h> @@ -14,20 +15,12 @@ #include <library/cpp/yson/node/node.h> #include <library/cpp/yson/node/serialize.h> -#include <yt/cpp/mapreduce/raw_client/raw_requests.h> -#include <yt/cpp/mapreduce/raw_client/raw_batch_request.h> -#include <yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.h> - #include <util/generic/guid.h> #include <util/string/builder.h> -#include <exception> - namespace NYT { namespace NDetail { -using namespace NRawClient; - using ::NThreading::TFuture; using ::NThreading::TPromise; using ::NThreading::NewPromise; diff --git a/yt/cpp/mapreduce/client/client.cpp b/yt/cpp/mapreduce/client/client.cpp index 8e3eed7bdc1..92a255696f8 100644 --- a/yt/cpp/mapreduce/client/client.cpp +++ b/yt/cpp/mapreduce/client/client.cpp @@ -41,9 +41,8 @@ #include <yt/cpp/mapreduce/library/table_schema/protobuf.h> -#include <yt/cpp/mapreduce/raw_client/raw_client.h> -#include <yt/cpp/mapreduce/raw_client/raw_requests.h> -#include <yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.h> +#include <yt/cpp/mapreduce/http_client/raw_client.h> +#include <yt/cpp/mapreduce/http_client/raw_requests.h> #include <yt/yt/core/ytree/fluent.h> diff --git a/yt/cpp/mapreduce/client/client_reader.cpp b/yt/cpp/mapreduce/client/client_reader.cpp index b144b70c023..ad21a309a34 100644 --- a/yt/cpp/mapreduce/client/client_reader.cpp +++ b/yt/cpp/mapreduce/client/client_reader.cpp @@ -13,6 +13,7 @@ #include <yt/cpp/mapreduce/http/retry_request.h> #include <yt/cpp/mapreduce/interface/config.h> +#include <yt/cpp/mapreduce/interface/raw_client.h> #include <yt/cpp/mapreduce/interface/tvm.h> #include <yt/cpp/mapreduce/interface/logging/yt_log.h> @@ -20,9 +21,6 @@ #include <yt/cpp/mapreduce/io/helpers.h> #include <yt/cpp/mapreduce/io/yamr_table_reader.h> -#include <yt/cpp/mapreduce/raw_client/raw_client.h> -#include <yt/cpp/mapreduce/raw_client/raw_requests.h> - #include <library/cpp/yson/node/serialize.h> #include <util/random/random.h> diff --git a/yt/cpp/mapreduce/client/client_writer.cpp b/yt/cpp/mapreduce/client/client_writer.cpp index 84e0802ee23..ef10acf85fe 100644 --- a/yt/cpp/mapreduce/client/client_writer.cpp +++ b/yt/cpp/mapreduce/client/client_writer.cpp @@ -9,8 +9,6 @@ #include <yt/cpp/mapreduce/interface/io.h> -#include <yt/cpp/mapreduce/raw_client/raw_client.h> - namespace NYT { //////////////////////////////////////////////////////////////////////////////// diff --git a/yt/cpp/mapreduce/client/file_reader.cpp b/yt/cpp/mapreduce/client/file_reader.cpp index 1682212f1df..eb591d83f88 100644 --- a/yt/cpp/mapreduce/client/file_reader.cpp +++ b/yt/cpp/mapreduce/client/file_reader.cpp @@ -8,6 +8,7 @@ #include <yt/cpp/mapreduce/common/wait_proxy.h> #include <yt/cpp/mapreduce/interface/config.h> +#include <yt/cpp/mapreduce/interface/raw_client.h> #include <yt/cpp/mapreduce/interface/tvm.h> #include <yt/cpp/mapreduce/interface/logging/yt_log.h> @@ -19,9 +20,6 @@ #include <yt/cpp/mapreduce/http/http_client.h> #include <yt/cpp/mapreduce/http/retry_request.h> -#include <yt/cpp/mapreduce/raw_client/raw_client.h> -#include <yt/cpp/mapreduce/raw_client/raw_requests.h> - namespace NYT { namespace NDetail { diff --git a/yt/cpp/mapreduce/client/file_writer.cpp b/yt/cpp/mapreduce/client/file_writer.cpp index fcbb02bec92..aa0d7f8e146 100644 --- a/yt/cpp/mapreduce/client/file_writer.cpp +++ b/yt/cpp/mapreduce/client/file_writer.cpp @@ -6,8 +6,6 @@ #include <yt/cpp/mapreduce/io/helpers.h> -#include <yt/cpp/mapreduce/raw_client/raw_client.h> - namespace NYT { //////////////////////////////////////////////////////////////////////////////// diff --git a/yt/cpp/mapreduce/client/lock.cpp b/yt/cpp/mapreduce/client/lock.cpp index 4eecfdb0d5b..234a4e16353 100644 --- a/yt/cpp/mapreduce/client/lock.cpp +++ b/yt/cpp/mapreduce/client/lock.cpp @@ -2,19 +2,17 @@ #include "yt_poller.h" -#include <yt/cpp/mapreduce/http/retry_request.h> - #include <yt/cpp/mapreduce/common/retry_lib.h> -#include <yt/cpp/mapreduce/raw_client/raw_batch_request.h> +#include <yt/cpp/mapreduce/http/retry_request.h> + +#include <yt/cpp/mapreduce/interface/raw_batch_request.h> #include <util/string/builder.h> namespace NYT { namespace NDetail { -using namespace NRawClient; - //////////////////////////////////////////////////////////////////////////////// class TLockPollerItem diff --git a/yt/cpp/mapreduce/client/operation.cpp b/yt/cpp/mapreduce/client/operation.cpp index ccad6c20654..3070427f98f 100644 --- a/yt/cpp/mapreduce/client/operation.cpp +++ b/yt/cpp/mapreduce/client/operation.cpp @@ -36,8 +36,7 @@ #include <yt/cpp/mapreduce/io/proto_helpers.h> #include <yt/cpp/mapreduce/io/skiff_table_reader.h> -#include <yt/cpp/mapreduce/raw_client/raw_batch_request.h> -#include <yt/cpp/mapreduce/raw_client/raw_requests.h> +#include <yt/cpp/mapreduce/http_client/raw_requests.h> #include <library/cpp/yson/node/serialize.h> diff --git a/yt/cpp/mapreduce/client/operation_helpers.cpp b/yt/cpp/mapreduce/client/operation_helpers.cpp index a15b56cf75c..7445011b407 100644 --- a/yt/cpp/mapreduce/client/operation_helpers.cpp +++ b/yt/cpp/mapreduce/client/operation_helpers.cpp @@ -11,8 +11,6 @@ #include <yt/cpp/mapreduce/interface/logging/yt_log.h> -#include <yt/cpp/mapreduce/raw_client/raw_requests.h> - #include <util/string/builder.h> #include <util/system/mutex.h> diff --git a/yt/cpp/mapreduce/client/operation_preparer.cpp b/yt/cpp/mapreduce/client/operation_preparer.cpp index c1907a70378..74e16f811dc 100644 --- a/yt/cpp/mapreduce/client/operation_preparer.cpp +++ b/yt/cpp/mapreduce/client/operation_preparer.cpp @@ -13,8 +13,7 @@ #include <yt/cpp/mapreduce/common/retry_lib.h> #include <yt/cpp/mapreduce/common/wait_proxy.h> -#include <yt/cpp/mapreduce/raw_client/raw_requests.h> -#include <yt/cpp/mapreduce/raw_client/raw_batch_request.h> +#include <yt/cpp/mapreduce/http_client/raw_requests.h> #include <yt/cpp/mapreduce/interface/error_codes.h> #include <yt/cpp/mapreduce/interface/raw_client.h> diff --git a/yt/cpp/mapreduce/client/prepare_operation.cpp b/yt/cpp/mapreduce/client/prepare_operation.cpp index 31574d7e0e4..271594ce644 100644 --- a/yt/cpp/mapreduce/client/prepare_operation.cpp +++ b/yt/cpp/mapreduce/client/prepare_operation.cpp @@ -4,12 +4,10 @@ #include <yt/cpp/mapreduce/http/retry_request.h> +#include <yt/cpp/mapreduce/interface/raw_batch_request.h> #include <yt/cpp/mapreduce/interface/raw_client.h> #include <yt/cpp/mapreduce/interface/serialize.h> -#include <yt/cpp/mapreduce/raw_client/raw_requests.h> -#include <yt/cpp/mapreduce/raw_client/raw_batch_request.h> - #include <library/cpp/iterator/functools.h> namespace NYT::NDetail { diff --git a/yt/cpp/mapreduce/client/py_helpers.cpp b/yt/cpp/mapreduce/client/py_helpers.cpp index 79c372daa96..02d88921b16 100644 --- a/yt/cpp/mapreduce/client/py_helpers.cpp +++ b/yt/cpp/mapreduce/client/py_helpers.cpp @@ -4,11 +4,13 @@ #include "operation.h" #include "transaction.h" +#include <yt/cpp/mapreduce/common/retry_lib.h> +#include <yt/cpp/mapreduce/common/helpers.h> + #include <yt/cpp/mapreduce/interface/client.h> #include <yt/cpp/mapreduce/interface/fluent.h> -#include <yt/cpp/mapreduce/common/retry_lib.h> -#include <yt/cpp/mapreduce/common/helpers.h> +#include <yt/cpp/mapreduce/http_client/raw_requests.h> #include <library/cpp/yson/node/node_io.h> diff --git a/yt/cpp/mapreduce/client/retry_heavy_write_request.cpp b/yt/cpp/mapreduce/client/retry_heavy_write_request.cpp index 80f54d2340d..952e11fd896 100644 --- a/yt/cpp/mapreduce/client/retry_heavy_write_request.cpp +++ b/yt/cpp/mapreduce/client/retry_heavy_write_request.cpp @@ -7,6 +7,7 @@ #include <yt/cpp/mapreduce/common/wait_proxy.h> #include <yt/cpp/mapreduce/interface/config.h> +#include <yt/cpp/mapreduce/interface/raw_client.h> #include <yt/cpp/mapreduce/interface/tvm.h> #include <yt/cpp/mapreduce/interface/logging/yt_log.h> diff --git a/yt/cpp/mapreduce/client/retry_heavy_write_request.h b/yt/cpp/mapreduce/client/retry_heavy_write_request.h index b65f4572392..27ebd593168 100644 --- a/yt/cpp/mapreduce/client/retry_heavy_write_request.h +++ b/yt/cpp/mapreduce/client/retry_heavy_write_request.h @@ -7,8 +7,6 @@ #include <yt/cpp/mapreduce/http/context.h> #include <yt/cpp/mapreduce/http/requests.h> -#include <yt/cpp/mapreduce/raw_client/raw_client.h> - namespace NYT { //////////////////////////////////////////////////////////////////////////////// diff --git a/yt/cpp/mapreduce/client/retryful_writer.cpp b/yt/cpp/mapreduce/client/retryful_writer.cpp index 666229d7a65..e94aaa9419e 100644 --- a/yt/cpp/mapreduce/client/retryful_writer.cpp +++ b/yt/cpp/mapreduce/client/retryful_writer.cpp @@ -9,7 +9,7 @@ #include <yt/cpp/mapreduce/interface/logging/yt_log.h> -#include <yt/cpp/mapreduce/raw_client/raw_client.h> +#include <yt/cpp/mapreduce/http_client/raw_client.h> #include <util/generic/size_literals.h> diff --git a/yt/cpp/mapreduce/client/retryful_writer.h b/yt/cpp/mapreduce/client/retryful_writer.h index a77b52a9869..345a1221fd0 100644 --- a/yt/cpp/mapreduce/client/retryful_writer.h +++ b/yt/cpp/mapreduce/client/retryful_writer.h @@ -14,8 +14,6 @@ #include <yt/cpp/mapreduce/io/helpers.h> -#include <yt/cpp/mapreduce/raw_client/raw_requests.h> - #include <library/cpp/threading/blocking_queue/blocking_queue.h> #include <util/generic/buffer.h> diff --git a/yt/cpp/mapreduce/client/retryful_writer_v2.cpp b/yt/cpp/mapreduce/client/retryful_writer_v2.cpp index c11f20ce3f4..4575a35cd11 100644 --- a/yt/cpp/mapreduce/client/retryful_writer_v2.cpp +++ b/yt/cpp/mapreduce/client/retryful_writer_v2.cpp @@ -12,6 +12,8 @@ #include <yt/cpp/mapreduce/http/helpers.h> #include <yt/cpp/mapreduce/http/http.h> +#include <yt/cpp/mapreduce/interface/raw_client.h> + #include <util/system/condvar.h> #include <queue> diff --git a/yt/cpp/mapreduce/client/retryless_writer.h b/yt/cpp/mapreduce/client/retryless_writer.h index 689c1c5f2fd..aa5ed529582 100644 --- a/yt/cpp/mapreduce/client/retryless_writer.h +++ b/yt/cpp/mapreduce/client/retryless_writer.h @@ -1,8 +1,10 @@ #pragma once +#include <yt/cpp/mapreduce/http/context.h> #include <yt/cpp/mapreduce/http/helpers.h> #include <yt/cpp/mapreduce/http/http.h> #include <yt/cpp/mapreduce/http/http_client.h> +#include <yt/cpp/mapreduce/http/requests.h> #include <yt/cpp/mapreduce/interface/config.h> #include <yt/cpp/mapreduce/interface/common.h> @@ -12,8 +14,6 @@ #include <yt/cpp/mapreduce/io/helpers.h> -#include <yt/cpp/mapreduce/raw_client/raw_requests.h> - #include <util/stream/buffered.h> namespace NYT { diff --git a/yt/cpp/mapreduce/client/skiff.cpp b/yt/cpp/mapreduce/client/skiff.cpp index 113dee0743a..537a28f0593 100644 --- a/yt/cpp/mapreduce/client/skiff.cpp +++ b/yt/cpp/mapreduce/client/skiff.cpp @@ -14,8 +14,7 @@ #include <library/cpp/yson/node/node_builder.h> #include <library/cpp/yson/node/node_io.h> -#include <yt/cpp/mapreduce/raw_client/raw_batch_request.h> -#include <yt/cpp/mapreduce/raw_client/raw_requests.h> +#include <yt/cpp/mapreduce/http_client/raw_requests.h> #include <yt/cpp/mapreduce/skiff/skiff_schema.h> diff --git a/yt/cpp/mapreduce/client/structured_table_formats.cpp b/yt/cpp/mapreduce/client/structured_table_formats.cpp index 9da31dcf14e..2d0bcee3db6 100644 --- a/yt/cpp/mapreduce/client/structured_table_formats.cpp +++ b/yt/cpp/mapreduce/client/structured_table_formats.cpp @@ -14,7 +14,7 @@ #include <yt/cpp/mapreduce/library/table_schema/protobuf.h> -#include <yt/cpp/mapreduce/raw_client/raw_requests.h> +#include <yt/cpp/mapreduce/http_client/raw_requests.h> #include <library/cpp/type_info/type_info.h> #include <library/cpp/yson/writer.h> diff --git a/yt/cpp/mapreduce/client/transaction.cpp b/yt/cpp/mapreduce/client/transaction.cpp index 80230b899dd..7ee13474b51 100644 --- a/yt/cpp/mapreduce/client/transaction.cpp +++ b/yt/cpp/mapreduce/client/transaction.cpp @@ -12,8 +12,6 @@ #include <yt/cpp/mapreduce/interface/error_codes.h> #include <yt/cpp/mapreduce/interface/raw_client.h> -#include <yt/cpp/mapreduce/raw_client/raw_requests.h> - #include <util/datetime/base.h> #include <util/generic/scope.h> diff --git a/yt/cpp/mapreduce/client/transaction_pinger.cpp b/yt/cpp/mapreduce/client/transaction_pinger.cpp index 074249efcef..4bbd9e2603f 100644 --- a/yt/cpp/mapreduce/client/transaction_pinger.cpp +++ b/yt/cpp/mapreduce/client/transaction_pinger.cpp @@ -13,8 +13,6 @@ #include <yt/cpp/mapreduce/http/requests.h> #include <yt/cpp/mapreduce/http/retry_request.h> -#include <yt/cpp/mapreduce/raw_client/raw_requests.h> - #include <yt/yt/core/concurrency/periodic_executor.h> #include <yt/yt/core/concurrency/poller.h> #include <yt/yt/core/concurrency/scheduler_api.h> diff --git a/yt/cpp/mapreduce/client/ya.make b/yt/cpp/mapreduce/client/ya.make index 753dfa0ea7d..6ac61f8f7ee 100644 --- a/yt/cpp/mapreduce/client/ya.make +++ b/yt/cpp/mapreduce/client/ya.make @@ -39,9 +39,9 @@ PEERDIR( library/cpp/yson yt/cpp/mapreduce/common yt/cpp/mapreduce/http + yt/cpp/mapreduce/http_client yt/cpp/mapreduce/interface yt/cpp/mapreduce/io - yt/cpp/mapreduce/raw_client ) PEERDIR( @@ -61,7 +61,7 @@ IF (BUILD_TYPE == "PROFILE") ELSE() SRCS( job_profiler.cpp - ) + ) ENDIF() ELSE() SRCS( diff --git a/yt/cpp/mapreduce/client/yt_poller.cpp b/yt/cpp/mapreduce/client/yt_poller.cpp index 4980d287faf..1b5b156aa58 100644 --- a/yt/cpp/mapreduce/client/yt_poller.cpp +++ b/yt/cpp/mapreduce/client/yt_poller.cpp @@ -1,7 +1,6 @@ #include "yt_poller.h" -#include <yt/cpp/mapreduce/raw_client/raw_batch_request.h> -#include <yt/cpp/mapreduce/raw_client/raw_requests.h> +#include <yt/cpp/mapreduce/http_client/raw_batch_request.h> #include <yt/cpp/mapreduce/common/debug_metrics.h> #include <yt/cpp/mapreduce/common/retry_lib.h> diff --git a/yt/cpp/mapreduce/raw_client/raw_batch_request.cpp b/yt/cpp/mapreduce/http_client/raw_batch_request.cpp index 08fee25b799..08fee25b799 100644 --- a/yt/cpp/mapreduce/raw_client/raw_batch_request.cpp +++ b/yt/cpp/mapreduce/http_client/raw_batch_request.cpp diff --git a/yt/cpp/mapreduce/raw_client/raw_batch_request.h b/yt/cpp/mapreduce/http_client/raw_batch_request.h index 2af0e31305f..2af0e31305f 100644 --- a/yt/cpp/mapreduce/raw_client/raw_batch_request.h +++ b/yt/cpp/mapreduce/http_client/raw_batch_request.h diff --git a/yt/cpp/mapreduce/raw_client/raw_client.cpp b/yt/cpp/mapreduce/http_client/raw_client.cpp index 3586751191e..3586751191e 100644 --- a/yt/cpp/mapreduce/raw_client/raw_client.cpp +++ b/yt/cpp/mapreduce/http_client/raw_client.cpp diff --git a/yt/cpp/mapreduce/raw_client/raw_client.h b/yt/cpp/mapreduce/http_client/raw_client.h index f0e8378db35..f0e8378db35 100644 --- a/yt/cpp/mapreduce/raw_client/raw_client.h +++ b/yt/cpp/mapreduce/http_client/raw_client.h diff --git a/yt/cpp/mapreduce/raw_client/raw_requests.cpp b/yt/cpp/mapreduce/http_client/raw_requests.cpp index 30b1619b710..30b1619b710 100644 --- a/yt/cpp/mapreduce/raw_client/raw_requests.cpp +++ b/yt/cpp/mapreduce/http_client/raw_requests.cpp diff --git a/yt/cpp/mapreduce/raw_client/raw_requests.h b/yt/cpp/mapreduce/http_client/raw_requests.h index 14876241714..14876241714 100644 --- a/yt/cpp/mapreduce/raw_client/raw_requests.h +++ b/yt/cpp/mapreduce/http_client/raw_requests.h diff --git a/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp b/yt/cpp/mapreduce/http_client/rpc_parameters_serialization.cpp index 1a3cee94898..1a3cee94898 100644 --- a/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp +++ b/yt/cpp/mapreduce/http_client/rpc_parameters_serialization.cpp diff --git a/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.h b/yt/cpp/mapreduce/http_client/rpc_parameters_serialization.h index 5dc2045bc5c..5dc2045bc5c 100644 --- a/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.h +++ b/yt/cpp/mapreduce/http_client/rpc_parameters_serialization.h diff --git a/yt/cpp/mapreduce/raw_client/ut/raw_batch_request_ut.cpp b/yt/cpp/mapreduce/http_client/ut/raw_batch_request_ut.cpp index 1871ee80fb4..f185b5a6067 100644 --- a/yt/cpp/mapreduce/raw_client/ut/raw_batch_request_ut.cpp +++ b/yt/cpp/mapreduce/http_client/ut/raw_batch_request_ut.cpp @@ -1,4 +1,4 @@ -#include <yt/cpp/mapreduce/raw_client/raw_batch_request.h> +#include <yt/cpp/mapreduce/http_client/raw_batch_request.h> #include <yt/cpp/mapreduce/http/context.h> #include <yt/cpp/mapreduce/interface/client_method_options.h> diff --git a/yt/cpp/mapreduce/raw_client/ut/raw_requests_ut.cpp b/yt/cpp/mapreduce/http_client/ut/raw_requests_ut.cpp index d2c7022f02e..59fee2be61f 100644 --- a/yt/cpp/mapreduce/raw_client/ut/raw_requests_ut.cpp +++ b/yt/cpp/mapreduce/http_client/ut/raw_requests_ut.cpp @@ -1,4 +1,4 @@ -#include <yt/cpp/mapreduce/raw_client/raw_requests.h> +#include <yt/cpp/mapreduce/http_client/raw_requests.h> #include <library/cpp/yson/node/node_io.h> diff --git a/yt/cpp/mapreduce/raw_client/ut/ya.make b/yt/cpp/mapreduce/http_client/ut/ya.make index 248471152cb..0247aac339a 100644 --- a/yt/cpp/mapreduce/raw_client/ut/ya.make +++ b/yt/cpp/mapreduce/http_client/ut/ya.make @@ -6,7 +6,7 @@ SRCS( ) PEERDIR( - yt/cpp/mapreduce/raw_client + yt/cpp/mapreduce/http_client ) END() diff --git a/yt/cpp/mapreduce/raw_client/ya.make b/yt/cpp/mapreduce/http_client/ya.make index a038b2931fe..a038b2931fe 100644 --- a/yt/cpp/mapreduce/raw_client/ya.make +++ b/yt/cpp/mapreduce/http_client/ya.make diff --git a/yt/cpp/mapreduce/io/yamr_table_reader.cpp b/yt/cpp/mapreduce/io/yamr_table_reader.cpp index cb987674495..3ae6b8a8aeb 100644 --- a/yt/cpp/mapreduce/io/yamr_table_reader.cpp +++ b/yt/cpp/mapreduce/io/yamr_table_reader.cpp @@ -2,7 +2,6 @@ #include <yt/cpp/mapreduce/common/helpers.h> #include <yt/cpp/mapreduce/common/retry_lib.h> -#include <yt/cpp/mapreduce/raw_client/raw_requests.h> //////////////////////////////////////////////////////////////////////////////// @@ -16,8 +15,6 @@ static void CheckedSkip(IInputStream* input, size_t byteCount) namespace NYT { -using namespace NYT::NDetail::NRawClient; - //////////////////////////////////////////////////////////////////////////////// TYaMRTableReader::TYaMRTableReader(::TIntrusivePtr<TRawTableReader> input) |