При определении декодера, который должен быть предоставлен классам DatumReader, существует возможность повторного использования декодера, как вы можете видеть ниже. Как упоминалось в документе, класс
В настоящее время я создаю задание Google Cloud Dataflow, которое анализирует XML-файлы и сохраняет записи с помощью Google Datastore, разные библиотеки Java, похоже, очень запутанны. Сначала я нашел
На сегодняшний день я получаю разрыв сборки для существующего кода, который использовался для правильной компиляции, из-за ошибки определения многих классов ключей в SDK Dataflow для Java. Например: [