Merge GH PR #9404

commit_hash:d780798556aedbe2be898d69185380f2ecb95f9c

1 files changed, 1 insertions, 46 deletions

diff --git a/yql/essentials/udfs/common/file/file_udf.cpp b/yql/essentials/udfs/common/file/file_udf.cpp
index 57db826591c..fa5f84a2c57 100644
--- a/yql/essentials/udfs/common/file/file_udf.cpp
+++ b/yql/essentials/udfs/common/file/file_udf.cpp
@@ -1,4 +1,5 @@
 #include <yql/essentials/public/udf/udf_helpers.h>
+#include <yql/essentials/utils/line_split.h>
 
 #include <util/generic/yexception.h>
 #include <util/stream/buffered.h>
@@ -236,52 +237,6 @@ namespace {
         const TTerminateFunc TerminateFunc;
     };
 
-    class TLineSplitter {
-    public:
-        TLineSplitter(IInputStream& stream)
-            : Stream_(stream)
-        {
-        }
-
-        size_t Next(TString& st) {
-            st.clear();
-            char c;
-            size_t ret = 0;
-            if (HasPendingLineChar_) {
-                st.push_back(PendingLineChar_);
-                HasPendingLineChar_ = false;
-                ++ret;
-            }
-
-            while (Stream_.ReadChar(c)) {
-                ++ret;
-                if (c == '\n') {
-                    break;
-                } else if (c == '\r') {
-                    if (Stream_.ReadChar(c)) {
-                        ++ret;
-                        if (c != '\n') {
-                            --ret;
-                            PendingLineChar_ = c;
-                            HasPendingLineChar_ = true;
-                        }
-                    }
-
-                    break;
-                } else {
-                    st.push_back(c);
-                }
-            }
-
-            return ret;
-        }
-
-    private:
-        IInputStream& Stream_;
-        bool HasPendingLineChar_ = false;
-        char PendingLineChar_ = 0;
-    };
-
     template <class TUserType>
     class TLineByLineBoxedValueIterator: public TBoxedValue {
     public: