Java等效于PREGEL API上的火花代码

Question

我在格式的图表上写下pregel Graph<Row,Row>，该图在

(_,a,b) => a+b

我正在尝试将其转换为Java功能，该功能的签名为

Function3<Object, VD, A, VD> arg4

我知道VD将是行类型，A是汇总消息，但是Java中的返回类型是什么，因为在特定顶点处收集计算？

new Function3<Row, Double, Row, Row>() {
        private static final long serialVersionUID = 1L;
        public Row call(Row arg0, Double arg1, Row arg2) throws Exception {
            // TODO Auto-generated method stub
        }

是正确的吗？

Answer 1

是的，您是对的，因此根据此签名 - (_,a,b) => a+b使用function3，您必须忽略第一个参数并添加最后两个参数，但是您的签名public Row call(Row arg0, Double arg1, Row arg2)是错误的，arg2必须具有Double类型，更改为：

new Function3<Row, Double, Double, Row>()

在这里，您忽略了第一个参数行，然后添加第二和第三个参数行，然后将其包装为返回类型行。