311.3.4. void RDD 回调
如果您的 RDD 回调不会将任何值返回至 Camel 管道,您可以返回 null 值或使用 VoidRddCallback 基础类:
spark RDD 定义
@Bean
RddCallback<Void> rddCallback() {
return new VoidRddCallback() {
@Override
public void doOnRdd(JavaRDDLike rdd, Object... payloads) {
rdd.saveAsTextFile(output.getAbsolutePath());
}
};
}