Я написал 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