Реализация каскадирования (буфера)

Question

Мне нужно создать буфер в каскадном хауопе.

Пусть я есть поля:

member_id, AmountPaid, diadnosis_id, diagnosis_description, superGrouper_id, superGrouper_descriptiion, grouperId, grouperDescription

Мне нужно

1. группы полей из member_id и superGrouper_id
2. Отправить эти данные, используя каждую трубу в буфер
3. выходного буфера должны быть: member_id, высокооплачиваемой сортировка из superGrouper, высокооплачиваемой сортировки из grouperId, высокооплачиваемого из diagnosis_id, вместе с их описанием ...

Пожалуйста помогите мне создать буфер. Заранее спасибо

Answer 1

Вам не нужен специальный буфер. Используйте встроенный агрегатор Max из Cascading. Cascading Docs

Вам тогда просто нужно запустить Max после GroupBy.

pipe = new GroupBy(pipe, new Fields("member_id", "superGrouper_id"); 
pipe = new Every(pipe, new Fields("amountpaid"), new Max(new Fields("max_paid")); 

Answer 2

вы можете сделать следующее:

pipe = new GroupBy(pipe, new Fields("member_id", "superGrouper_id"), new Fields("superGrouper", "grouperId", "")); 
pipe = new Every(pipe, FirstNBuffer(int n)); 

Я извиняюсь, если я не прав. Ваш вопрос не совсем ясен.