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