Move yql/udfs/common/ to /yql/essentials YQL-19206

Except the following directories:

* clickhouse/client
* datetime
* knn
* roaring
commit_hash:c7da95636144d28db109d6b17ddc762e9bacb59f

1 files changed, 66 insertions, 0 deletions

diff --git a/yql/essentials/udfs/common/json2/parse.h b/yql/essentials/udfs/common/json2/parse.h
new file mode 100644
index 00000000000..0020c164c2b
--- /dev/null
+++ b/yql/essentials/udfs/common/json2/parse.h
@@ -0,0 +1,66 @@
+#pragma once
+
+#include "resource.h"
+
+#include <yql/essentials/public/udf/udf_value.h>
+#include <yql/essentials/public/udf/udf_helpers.h>
+#include <yql/essentials/minikql/dom/json.h>
+
+#include <library/cpp/json/json_reader.h>
+
+namespace NJson2Udf {
+    using namespace NKikimr;
+    using namespace NUdf;
+    using namespace NYql;
+    using namespace NDom;
+
+    class TParse: public TBoxedValue {
+    public:
+        TParse(TSourcePosition pos)
+            : Pos_(pos)
+        {
+        }
+
+        static const TStringRef& Name() {
+            static auto name = TStringRef::Of("Parse");
+            return name;
+        }
+
+        static bool DeclareSignature(
+            const TStringRef& name,
+            TType* userType,
+            IFunctionTypeInfoBuilder& builder,
+            bool typesOnly) {
+            Y_UNUSED(userType);
+            if (name != Name()) {
+                return false;
+            }
+
+            builder.Args()
+                ->Add<TAutoMap<TJson>>()
+                .Done()
+                .Returns<TJsonNodeResource>();
+
+            if (!typesOnly) {
+                builder.Implementation(new TParse(builder.GetSourcePosition()));
+            }
+            return true;
+        }
+
+    private:
+        TUnboxedValue Run(
+            const IValueBuilder* valueBuilder,
+            const TUnboxedValuePod* args) const final {
+            Y_UNUSED(valueBuilder);
+            try {
+                const auto json = args[0].AsStringRef();
+                return TryParseJsonDom(json, valueBuilder);
+            } catch (const std::exception& e) {
+                UdfTerminate((TStringBuilder() << Pos_ << " " << e.what()).data());
+            }
+        }
+
+        TSourcePosition Pos_;
+    };
+}
+