Кодер для String[]
У меня есть класс, унаследованный от 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[] - или такой кодер уже существует - или я сделал что-то не так?
Спасибо/