292.3.5. 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];
}
};
};
}