From 3e1899838408bbad47622007aa382bc8a2b01f87 Mon Sep 17 00:00:00 2001
From: max42 <max42@yandex-team.com>
Date: Fri, 30 Jun 2023 11:13:34 +0300
Subject: Revert "YT-19324: move YT provider to ydb/library/yql"

This reverts commit ca272f12fdd0e8d5c3e957fc87939148f1caaf72, reversing
changes made to 49f8acfc8b0b5c0071b804423bcf53fda26c7c12.
---
 yt/cpp/mapreduce/io/node_table_writer.cpp | 72 -------------------------------
 1 file changed, 72 deletions(-)
 delete mode 100644 yt/cpp/mapreduce/io/node_table_writer.cpp

(limited to 'yt/cpp/mapreduce/io/node_table_writer.cpp')

diff --git a/yt/cpp/mapreduce/io/node_table_writer.cpp b/yt/cpp/mapreduce/io/node_table_writer.cpp
deleted file mode 100644
index dcb5a0f5b5e..00000000000
--- a/yt/cpp/mapreduce/io/node_table_writer.cpp
+++ /dev/null
@@ -1,72 +0,0 @@
-#include "node_table_writer.h"
-
-#include <yt/cpp/mapreduce/common/node_visitor.h>
-
-#include <yt/cpp/mapreduce/interface/io.h>
-
-#include <yt/cpp/mapreduce/interface/logging/yt_log.h>
-
-#include <library/cpp/yson/writer.h>
-
-namespace NYT {
-
-////////////////////////////////////////////////////////////////////////////////
-
-TNodeTableWriter::TNodeTableWriter(THolder<IProxyOutput> output, NYson::EYsonFormat format)
-    : Output_(std::move(output))
-{
-    for (size_t i = 0; i < Output_->GetStreamCount(); ++i) {
-        Writers_.push_back(
-            MakeHolder<::NYson::TYsonWriter>(Output_->GetStream(i), format, NYT::NYson::EYsonType::ListFragment));
-    }
-}
-
-TNodeTableWriter::~TNodeTableWriter()
-{ }
-
-size_t TNodeTableWriter::GetTableCount() const
-{
-    return Output_->GetStreamCount();
-}
-
-void TNodeTableWriter::FinishTable(size_t tableIndex) {
-    Output_->GetStream(tableIndex)->Finish();
-}
-
-void TNodeTableWriter::AddRow(const TNode& row, size_t tableIndex)
-{
-    if (row.HasAttributes()) {
-        ythrow TIOException() << "Row cannot have attributes";
-    }
-
-    static const TNode emptyMap = TNode::CreateMap();
-    const TNode* outRow = &emptyMap;
-    if (row.GetType() != TNode::Undefined) {
-        if (!row.IsMap()) {
-            ythrow TIOException() << "Row should be a map node";
-        } else {
-            outRow = &row;
-        }
-    }
-
-    auto* writer = Writers_[tableIndex].Get();
-    writer->OnListItem();
-
-    TNodeVisitor visitor(writer);
-    visitor.Visit(*outRow);
-
-    Output_->OnRowFinished(tableIndex);
-}
-
-void TNodeTableWriter::AddRow(TNode&& row, size_t tableIndex) {
-    AddRow(row, tableIndex);
-}
-
-void TNodeTableWriter::Abort()
-{
-    Output_->Abort();
-}
-
-////////////////////////////////////////////////////////////////////////////////
-
-} // namespace NYT
-- 
cgit v1.3