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

Except the following directories:

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

1 files changed, 70 insertions, 0 deletions

diff --git a/yql/essentials/udfs/common/json2/compile_path.h b/yql/essentials/udfs/common/json2/compile_path.h
new file mode 100644
index 0000000000..8239cfc1ee
--- /dev/null
+++ b/yql/essentials/udfs/common/json2/compile_path.h
@@ -0,0 +1,70 @@
+#pragma once
+
+#include "resource.h"
+
+#include <yql/essentials/public/udf/udf_value.h>
+#include <yql/essentials/public/udf/udf_helpers.h>
+
+namespace NJson2Udf {
+    using namespace NKikimr;
+    using namespace NUdf;
+    using namespace NYql;
+
+    class TCompilePath: public TBoxedValue {
+    public:
+        TCompilePath(TSourcePosition pos)
+            : Pos_(pos)
+        {
+        }
+
+        static const TStringRef& Name() {
+            static auto name = TStringRef::Of("CompilePath");
+            return name;
+        }
+
+        static bool DeclareSignature(
+            const TStringRef& name,
+            TType* userType,
+            IFunctionTypeInfoBuilder& builder,
+            bool typesOnly) {
+            Y_UNUSED(userType);
+            if (name != Name()) {
+                return false;
+            }
+
+            auto resourceType = builder.Resource(JSONPATH_RESOURCE_NAME);
+            builder.Args()
+                ->Add<NUdf::TUtf8>()
+                .Done()
+                .Returns(resourceType);
+
+            if (!typesOnly) {
+                builder.Implementation(new TCompilePath(builder.GetSourcePosition()));
+            }
+            return true;
+        }
+
+    private:
+        const size_t MaxParseErrors = 10;
+
+        TUnboxedValue Run(
+            const IValueBuilder* valueBuilder,
+            const TUnboxedValuePod* args) const final {
+            Y_UNUSED(valueBuilder);
+            try {
+                TIssues issues;
+                const auto jsonPath = NJsonPath::ParseJsonPath(args[0].AsStringRef(), issues, MaxParseErrors);
+                if (!issues.Empty()) {
+                    ythrow yexception() << "Error parsing jsonpath:" << Endl << issues.ToString();
+                }
+
+                return TUnboxedValuePod(new TJsonPathResource(jsonPath));
+            } catch (const std::exception& e) {
+                UdfTerminate((TStringBuilder() << Pos_ << " " << e.what()).data());
+            }
+        }
+
+        TSourcePosition Pos_;
+    };
+}
+