[FSTORE-1285] Model Dependent Transformation Functions (logicalclocks#206)

* load test

* adding udf decorator to hopsworks repo

* reverting pyproject modeified for loadtest

* reverting pyproject modeified for loadtest

* adding api documentation for udf decorator

Author: manu-sj

auto_doc.py

@@ -27,6 +27,9 @@
         "mr_api": ["hopsworks.project.Project.get_model_registry"],
         "ms_api": ["hopsworks.project.Project.get_model_serving"],
     },
+    "api/udf.md": {
+        "udf": ["hopsworks.udf"],
+    },
     "api/connection.md": {
         "connection_create": ["hopsworks.connection.Connection.connection"],
         "connection_properties": keras_autodoc.get_properties(

docs/templates/api/udf.md

@@ -0,0 +1,3 @@
+# UDF API
+
+{{udf}}

mkdocs.yml

@@ -21,6 +21,7 @@ nav:
       - Login: generated/api/login.md
       - Connection: generated/api/connection.md
       - Projects: generated/api/projects.md
+      - UDF: generated/api/udf.md
       - Jobs: generated/api/jobs.md
       - Executions: generated/api/executions.md
       - FlinkCluster: generated/api/flink_cluster.md

python/hopsworks/__init__.py

@@ -47,14 +47,16 @@
 _secrets_api = None
 _project_api = None
 
+udf = hsfs.hopsworks_udf.udf
+
 
 def hw_formatwarning(message, category, filename, lineno, line=None):
     return "{}: {}\n".format(category.__name__, message)
 
 
 warnings.formatwarning = hw_formatwarning
 
-__all__ = ["connection"]
+__all__ = ["connection", "udf"]
 
 logging.basicConfig(
     level=logging.INFO,