Внутренний тип данных Flink обрабатывается как общий тип ⇐ JAVA

[Anonymous]

У меня есть проект, которому потребуется гибкий тип данных в Flink для прохождения через операторы, которые могут использовать некоторую пользовательскую схему и выполнять на ней общие вычисления. Я склоняюсь к типу данных Row, поскольку он является внутренним для Flink, с ним может быть проще работать. с. Однако я получил ошибку при попытке создать тип данных строки в API Datastream, в частности

Код: Выделить всё

11:52:43,362 INFO  org.apache.flink.api.java.typeutils.TypeExtractor            [] - Field Row#fieldByName will be processed as GenericType. Please read the Flink documentation on "Data Types & Serialization" for details of the effect on performance and schema evolution.
11:52:43,363 INFO  org.apache.flink.api.java.typeutils.TypeExtractor            [] - class java.util.LinkedHashMap does not contain a getter for field accessOrder
11:52:43,363 INFO  org.apache.flink.api.java.typeutils.TypeExtractor            [] - class java.util.LinkedHashMap does not contain a setter for field accessOrder
11:52:43,363 INFO  org.apache.flink.api.java.typeutils.TypeExtractor            [] - Class class java.util.LinkedHashMap cannot be used as a POJO type because not all fields are valid POJO fields, and must be processed as GenericType. Please read the Flink documentation on "Data Types & Serialization" for details of the effect on performance and schema evolution.
11:52:43,363 INFO  org.apache.flink.api.java.typeutils.TypeExtractor            [] - Field Row#positionByName will be processed as GenericType. Please read the Flink documentation on "Data Types & Serialization" for details of the effect on performance and schema evolution.
11:52:43,363 INFO  org.apache.flink.api.java.typeutils.TypeExtractor            [] - class org.apache.flink.types.Row is missing a default constructor so it cannot be used as a POJO type and must be processed as GenericType. Please read the Flink documentation on "Data Types & Serialization" for details of the effect on performance and schema evolution.

Я вижу, что для типа Row отсутствует конструктор по умолчанию, но не имеет смысла, что Row может быть сериализован только с помощью Kryo, я не уверен, чего мне здесь не хватает< /п>

Подробнее здесь: https://stackoverflow.com/questions/792 ... neric-type