Apache Calcite - 自定义标量函数

前言

上一篇文章中我们介绍了calcite中内置函数的使用。实际需求中会遇到一些场景标准内置函数无法满足需求,这时候就需要用到自定义函数。在 Apache Calcite 中添加自定义函数,以便在 SQL 查询中使用自定义的逻辑。这对于执行特定的数据处理或分析任务非常有用。

相关依赖

通过前面的学习,我们知道表、函数等信息维护在schema中,因此我们要做的事情就是在schema中新增自定义的函数。

以下演示基于1.36版包实现。

    <dependency><groupId>org.apache.calcite</groupId><artifactId>calcite-core</artifactId><version>1.36.0</version></dependency>

为了新增函数我们需要重写AbstractSchema中的 getFunctionMultimap方法,方法定义如下:

  protected Multimap<String, Function> getFunctionMultimap() {return ImmutableMultimap.of();}

Function有多种实现,由于我们要扩展的是标量函数,所以关注ScalarFunction即可。
在这里插入图片描述
这里我们用到ScalarFunctionImpl.create方法来创建标量函数,方法中的参数1是所建函数所在的类,第二个是对应的方法名。

  /*** Creates {@link org.apache.calcite.schema.ScalarFunction} from given class.** <p>If a method of the given name is not found, or it does not suit,* returns {@code null}.** @param clazz class that is used to implement the function* @param methodName Method name (typically "eval")* @return created {@link ScalarFunction} or null*/public static @Nullable ScalarFunction create(Class<?> clazz, String methodName) {final Method method = findMethod(clazz, methodName);if (method == null) {return null;}return create(method);}

实现自定义标量函数

为了方便演示,我们实现一个无用的简单方法,对整数减1

public class CustomFunctions {public static Integer minus1(int num1) {return num1 - 1;}
}

接着扩展前文中用到的schema,实现getFunctionMultimap方法,并增加添加函数的方法

public class ListSchema extends AbstractSchema {Map<String, Table> tableMap = new HashMap<>();Multimap<String, Function> functionMap = LinkedListMultimap.create();public void addTable(String name, Table table) {tableMap.put(name, table);}public void addFunction(String name,Function function) { functionMap.put(name, function);}public ListSchema() {}@Overrideprotected Map<String, Table> getTableMap() {return tableMap;}@Overrideprotected Multimap<String, Function> getFunctionMultimap() {return functionMap;}
}

最后我们在schema中注册函数

ListSchema listSchema = new ListSchema();
listSchema.addFunction("minus1", ScalarFunctionImpl.create(CustomFunctions.class,"minus1"));

完成上述工作后,在sql中使用自定义的函数

ResultSet countResult = statement.executeQuery("select age,listSchema.minus1(age) from listSchema.MyTable");

打印结果,可以看到自定义方法的计算结果

95 94 
21 20 
47 46 

异常处理

在完成上述工作时也遇到了几个异常,分别如下:

No match found for function signature minus1(< NUMERIC>)

  • 详细的异常提示为:java.sql.SQLException: Error while executing SQL “select age,minus1(age) from listSchema.MyTable”: From line 1, column 12 to line 1, column 22: No match found for function signature minus1()
  • 异常原因
    1.注册的方法名与使用方法名不一致。最开始注册时,将方法名首字母写成了大写。但实际使用时却使用的小写名 Minus1 - > minus1 listSchema.addFunction(“Minus1”, ScalarFunctionImpl.create(CustomFunctions.class,“minus1”));
    2.另外使用方法名时没指定schema名,导致了错误
    上述两个问题修改完毕程序正常运行

总结

实现自定义标量函数,注册到schema最后使用,schema是核心,维护了各类元信息,并提供了扩展接口来实现自定义的能力

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/web/20790.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【蓝牙BR/EDR 操作概述】

基本速率/增强数据速率 (BR/EDR) 无线电&#xff08;物理层或 PHY&#xff09;在 2.4 GHz 的免许可 ISM 频段中运行。该系统采用跳频收发器来对抗干扰和衰落&#xff0c;并提供许多 FHSS 载波。基本速率无线电操作使用成形的二进制频率调制来最大限度地减少收发器的复杂性。符号…

1.1 OpenCV随手简记(一)

OpenCV学习篇 OpenCV (Open Source Computer Vision Library) 是一个开源的计算机视觉库&#xff0c;它提供了大量的算法和函数&#xff0c;用于图像处理、计算机视觉和机器学习等领域。 1. OpenCV 简介 1.1 OpenCV 的起源和发展 OpenCV 项目始于 1999 年&#xff0c;由 In…

【火猫欧洲杯】意甲:孔蒂亲自推动,送走尼日利亚锋霸

本赛季那不勒斯作为卫冕冠军发挥不佳,联赛仅仅排在第10名,休赛期他们率先炒掉了主帅卡尔佐纳,基本上锁定了前国米主帅孔蒂。孔蒂对于执教那不勒斯也非常期待,根据意大利媒体爆料,孔蒂已经开始准备推动转会,将球队的进攻核心奥斯梅恩卖掉,如果可以他想将自己的爱将卢卡库换回来。…

java中中的泛型

文章目录 一、定义二、使用语法三、注意事项四、从泛型类派生子类情况一情况二 五、泛型接口语法接口的使用 一、定义 class 类名<泛型标识1,泛型标识2,…>{private 泛型标识1 变量名; }常用的泛型标识: T&#xff0c;E&#xff0c;K&#xff0c;V 二、使用语法 类名&l…

【数据结构与算法】中序遍历的非递归实现

回忆一下递归实现 /** /*** Definition for a binary tree node.* function TreeNode(val, left, right) {* this.val (valundefined ? 0 : val)* this.left (leftundefined ? null : left)* this.right (rightundefined ? null : right)* }*/ /*** param {T…

服务器环境搭建

服务器的使用。 本地服务器 虚拟机服务器 云服务器。 服务器配置内容 如何实现部署到云服务器&#xff1f; 环境部署是一件费劲的事。 自己一个人坚持慢慢弄&#xff0c;也能行。 但是要是一个组的人&#xff0c;问你怎么弄环境。 可就难了&#xff0c;不同的人部署的环境不同&…

Python面试宝典:Python中与数据可视化相关的面试笔试题(1000加面试笔试题助你轻松捕获大厂Offer)

Python面试宝典:1000加python面试题助你轻松捕获大厂Offer【第二部分:Python高级特性:第十九章:数据处理和分析:第三节:数据可视化】 第十九章:数据处理和分析第三节:数据可视化1. Matplotlib概述特点使用场景优点缺点2. Seaborn概述特点使用场景优点缺点3. Pandas Plo…

Java 22的FFM API,比起Java 21的虚拟线程

哪个对Java未来的发展影响更大&#xff1f;两个 Java 版本中的重要特性&#xff1a;Java 21 的虚拟线程和 Java 22 的 FFM API。我这里有一套编程入门教程&#xff0c;不仅包含了详细的视频讲解&#xff0c;项目实战。如果你渴望学习编程&#xff0c;不妨点个关注&#xff0c;给…

MPB | 林科院袁志林组-​内生镰刀菌基因组染色体级别组装和注释

内生镰刀菌基因组染色体级别组装和注释 Chromosome-Scale Genome Assembly and Annotation Method of Endophyte Fusarium 单晓亮1, 2&#xff0c;袁志林1, 2,* 1中国林业科学研究院林木遗传育种国家重点实验室&#xff0c;北京&#xff1b;2中国林业科学研究院亚热带林业研究…

DeepFace ——用于高级人脸识别算法探索与应用

1. 概述 人脸识别作为人工智能和机器学习中的一个活跃领域&#xff0c;长期以来一直在追求模仿甚至超越人类视觉系统的能力。这项技术在安全、监控、身份验证等多个方面都有着广泛的应用&#xff0c;但同时也伴随着隐私、伦理和准确性等社会和文化方面的考量。 Meta&#xff0…

苹果电脑数据丢失怎么办 苹果电脑数据恢复软件免费版 如何使用EasyRecovery恢复数据

无论是使用苹果电脑还是Windows电脑&#xff0c;丢失文件是一个常见的问题。无论是意外的删除、格式化错误还是系统崩溃&#xff0c;都可能导致重要数据的丢失。此时就需要用到数据恢复工具恢复数据。然而数据恢复工具的选择是十分重要的&#xff0c;踩坑了不仅找不回数据&…

【信号加密】基于傅里叶变换和小波变换对音频水印的嵌入、提取matlab代码

% 读取原始音频文件 audio audioread(‘original_audio.wav’); % 读取水印图像 watermark imread(‘watermark_image.png’); % 将水印图像转换为灰度图像 watermark_gray rgb2gray(watermark); % 调整水印图像尺寸以适应音频 watermark_resized imresize(watermark_gr…

前端面试题日常练-day46 【面试题】

题目 希望这些选择题能够帮助您进行前端面试的准备&#xff0c;答案在文末 1. 在Bootstrap中&#xff0c;以下哪个类用于创建一个具有响应式的按钮组&#xff1f; a) .btn-group b) .responsive-btn c) .button-group d) .btn-responsive 2. 哪个Bootstrap类用于创建一个具…

iOS object-c 常用API汇总

前言 本文为入门iOS开发&#xff0c;object-c语法汇总。用于日常查阅。 苹果开发者平台Objective-C文档中文翻译版 Objective-C教程 Objective-C入门教程 文件类型 扩展名内容类型.h头文件。头文件包含类,类型,函数和常数的声明。.m源代码文件。这是典型的源代码文件扩展名&a…

Chrome DevTools攻略(话题文章)

目录 Chrome DevTools 概览 访问 DevTools DevTools 窗口 审查DOM元素和样式 使用Console 调试 JavaScript 提高网络性能 监听 提高渲染性能 JavaScript & CSS 性能 审查存储

超级SDK版本管理器VMR v0.6.1预览版发布!

项目地址&#xff1a;https://github.com/gvcgo/version-manager/releases/tag/v0.6.1 官方文档&#xff1a;https://gvcgo.github.io/vdocs/ 支持的语言列表&#xff1a; bun, clang, codon, deno, dlang, dotnet, elixir, erlang, flutter, gcc, gleam, go, groovy, jdk, …

ImportError: cannot import name ‘url_quote‘ from ‘werkzeug.urls‘

stackoverflow搬运 执行github上的项目遇到的很多问题&#xff0c;都是python版本非默认最新版 pip install Werkzeug2.2.2安装最新版Werkzeug即可

Pandas练习

一 题目要求 酒类消费数据 给定一个某段时间内各个国家的酒类消费数据表drinks.csv&#xff0c;其中包含6个字段&#xff0c;表8-1 给出了该表中的字段信息。 表8-1酒类消费数据表的字段信息 Country国家beer_servings啤酒消费量spirit_servings烈酒消费量wine_servings红酒消…

C语言编程实现导数运算:深入探索与实战解析

C语言编程实现导数运算&#xff1a;深入探索与实战解析 在数学的广袤领域中&#xff0c;导数运算扮演着至关重要的角色&#xff0c;它描述了函数值随自变量变化的速率。然而&#xff0c;将这一理论应用于实际编程中&#xff0c;尤其是使用C语言&#xff0c;却是一项充满挑战的…

【启程Golang之旅】从结构到接口揭秘Go的“面向对象”面纱

欢迎来到Golang的世界&#xff01;在当今快节奏的软件开发领域&#xff0c;选择一种高效、简洁的编程语言至关重要。而在这方面&#xff0c;Golang&#xff08;又称Go&#xff09;无疑是一个备受瞩目的选择。在本文中&#xff0c;带领您探索Golang的世界&#xff0c;一步步地了…