Как извлечь значения из B, хранящиеся в виде набора данных> без создания новой функции - PullRequest
Новая
       8

Как извлечь значения из B, хранящиеся в виде набора данных> без создания новой функции

0 голосов
/ 24 декабря 2018

У меня есть 2 набора данных, и я выполняю на них операцию joinWith, которая возвращает Dataset<Tuple2<A, B>>
Я хочу сохранить результат в виде Dataset<C>, где C построено с использованием значений, извлеченных из B.

Я пытаюсь использовать map, чтобы выполнить операцию на B и сгенерировать C для каждой строки результирующего набора данных.
Проблема в том, что яне может выделить B, чтобы иметь возможность выполнять операции с ним. 

Dataset<C> newData = dataset1
       .joinWith(dataset2, condition)
       .map(tuple -> {
           B input = (B)tuple._2;
           C output = C.builder()
                       .value(input.getValue())
                       .build();
           return C;
       });

Предположим, Dataset<A> dataset1 и Dataset<B> dataset2.

...