是否可以使用扩展点在 DataFrame API/SQL 中添加/替换现有列表达式。
例如:假设我们注入解析规则,该规则可以检查计划中的项目节点,并在检查“名称”列时,将其替换为 upper(name)。
使用扩展点可以实现这样的事情吗?我发现的例子大多很简单,它们没有按照我需要的方式操作输入表达式。
请告诉我这是否可能。
apache-spark apache-spark-sql
apache-spark ×1
apache-spark-sql ×1