Как я могу определить DoFn в apache crunch с типом данных void?
По сути, мне не нужен вывод из DoFn, я просто хочу обновить некоторые mysql db для каждой записи, которую я получаю в DoFn. Итак, как я могу определить DoFn, имеющий тип данных void? По сути, я не хочу излучать что-либо из DoFn.
1 ответ
Это невозможно. После того, как Crunch сгенерирует график для выполнения, он определяет, есть ли вывод для записи или данные для материализации (очень похоже на действие). Даже чтобы выполнить то, что вы хотите, вам нужно будет сделать обходной путь, как создать DoFn<T,String> код для записи или материализации результата PCollection из вашего DoFn, даже если вы уже знаете, что не будет никаких выходных данных.