У меня есть класс, унаследованный от DoFn.Класс принимает в качестве входных данных String [] и выводит измененную String [].Это работает как заклинание для любого бегуна (DirectRunner), но в моих модульных тестах я вижу кучу предупреждений, таких как:
Mar 02, 2019 8:27:49 AM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.SerializableCoder has a #structuralValue method which does not return true when the encoding of the elements is equal. Element [foo0, bar0]
Mar 02, 2019 8:27:49 AM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector verifyUnmodifiedThrowingCheckedExceptions
Итак, вопросы: - я должен написать кодер для String []сам - или такой кодер уже существует - или я что-то не так сделал?
Спасибо /