функция карты не вызывается в Apache Spark - PullRequest
0 голосов
/ 28 декабря 2018

Я написал map функцию, которая не выполняется.

Ниже приведен мой код, синтаксически правильный, но не выполняется.

Dataset<TransactionPritmAndSummarySparkVO> currencyConvertedDS =
    filteredExOutputDS.map(vo -> dummyMap(vo), txnPritmAndSummaryOutputEncoder);

currencyConvertedDS.show();

private static TransactionPritmAndSummarySparkVO dummyMap(TransactionPritmAndSummarySparkVO vo) {
    System.out.println("SUMMARY_ID is " + vo.getSUMMARY_ID());
    return vo;
}

Ожидаемый результат - показать результат набора данных currencyConvertedDS с 6 строками в журналах.

Фактический результат: Одна строка отображается без значений.

Это простая операция с картой, я не уверен, почему она не может ее выполнить?

Используемая версия Spark: 2.3.0

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...