我对spark环境还不熟悉。我在我的项目中使用sparksql。我想在sparksql临时表中创建自动递增字段。我创建了自定义项,但它没有正常工作。我在网上试过各种各样的例子。这是我的java pojo类:
public class AutoIcrementId {
int lastValue;
public int evaluate() {
lastValue++;
return lastValue;
}
}
我对spark环境还不熟悉。我在我的项目中使用sparksql。我想在sparksql临时表中创建自动递增字段。我创建了自定义项,但它没有正常工作。我在网上试过各种各样的例子。这是我的java pojo类:
public class AutoIcrementId {
int lastValue;
public int evaluate() {
lastValue++;
return lastValue;
}
}
1条答案
按热度按时间dz6r00yl1#
我们可以使用配置单元有状态的自定义项来自动增加值。代码是这样的。
注册自定义项:
用法:
这里回答了类似的问题(如何在sparksql中实现自动增量)