Flink DataSet MongoDB Парсинг

Question

В настоящее время я создаю рекомендательный движок, используя flink. Я использую MongoDB в качестве источника для DataSets, используя HadoopInputFormat, Я получил это работает, и Flink теперь может получить данные из MongoDB и поместить их в DataSet с BSONWritable тип данных.

Но как я могу преобразовать его в родные типы данных, такие как String или же Int? Я буду использовать его для машинного обучения, в частности, алгоритм ALS.