本小节仅使用OmniOperator算子加速 UDF功能才需要进行操作。当前的OmniOperator算子加速 UDF插件仅支持Simple UDF,若OmniOperator算子加速 UDF不支持,会回退到原生Spark。
执行步骤参照执行Spark引擎业务,只需在SparkExtension的Spark-SQL命令行窗口启动命令基础上补充如下命令参数即可。
--conf spark.driver.extraClassPath=/opt/omni-operator/lib/boostkit-omniop-spark-3.1.1-1.1.0-aarch64.jar:/opt/omni-operator/lib/boostkit-omniop-bindings-1.1.0-aarch64.jar:/opt/omni-operator/lib/boostkit-omniop-udf-1.1.0-aarch64.jar:/opt/omni-operator/lib/dependencies/*
--conf spark.executor.extraClassPath=/opt/omni-operator/lib/boostkit-omniop-spark-3.1.1-1.1.0-aarch64.jar:/opt/omni-operator/lib/boostkit-omniop-bindings-1.1.0-aarch64.jar:/opt/omni-operator/lib/boostkit-omniop-udf-1.1.0-aarch64.jar:/opt/omni-operator/lib/dependencies/*
--jars /opt/omni-operator/lib/boostkit-omniop-udf-1.1.0-aarch64.jar