Ошибка информации о типе Apache Flink для POJO, содержащего список кортежейJAVA

Программисты JAVA общаются здесь
Ответить
Anonymous
 Ошибка информации о типе Apache Flink для POJO, содержащего список кортежей

Сообщение Anonymous »

[Редактирование 1: на этот раз добавлен правильный журнал ошибок]
[Редактирование 2: уменьшено количество полей из класса и TypeInfoFactory]
Я Я не могу создать класс типа POJO, содержащий тип данных, представляющий собой список кортежей. Возможно, я неправильно предоставляю информацию о типе?
[Отредактировано] Вот класс и TypeInfo:
@TypeInfo(NodeTestSerializer.class)
public class NodeTest implements Serializable {
public List msgDestinationList = new ArrayList();

public NodeTest() {
msgDestinationList.add(Tuple3.of(1,2,"abc"));
};
}

и я определил информацию о его типе следующим образом:
public class NodeTestSerializer extends TypeInfoFactory {
@Override
public TypeInformation createTypeInfo(Type t, Map

Подробнее здесь: https://stackoverflow.com/questions/791 ... -of-tuples
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «JAVA»