313.4.2. 转换 RDD 回调

如果您知道哪些输入数据被发送到 RDD 回调，您可以使用 ConvertingRddCallback，并让 Camel 自动转换传入的信息，然后再将它们插入到回调中：

spark RDD 定义

@Bean
RddCallback<Long> rddCallback(CamelContext context) {
  return new ConvertingRddCallback<Long>(context, int.class, int.class) {
            @Override
            public Long doOnRdd(JavaRDDLike rdd, Object... payloads) {
                return rdd.count() * (int) payloads[0] * (int) payloads[1];
            }
        };
    };
}