小编use*_*897的帖子

使用 Spark Catalyst 逻辑计划修改查询

是否可以使用扩展点在 DataFrame API/SQL 中添加/替换现有列表达式。

例如:假设我们注入解析规则,该规则可以检查计划中的项目节点,并在检查“名称”列时,将其替换为 upper(name)。

使用扩展点可以实现这样的事情吗?我发现的例子大多很简单,它们没有按照我需要的方式操作输入表达式。

请告诉我这是否可能。

apache-spark apache-spark-sql

1
推荐指数
1
解决办法
1571
查看次数

标签 统计

apache-spark ×1

apache-spark-sql ×1