Flink自定义的具有null值的元组

Question

我有一个自定义的元组，用于在运算符之间传递数据。

public class A extends Tuple2<String, Message> {
public String topic;
public A() {
super();
}
public A(String topic, String key, Message message) {
super(key, message);
this.topic = topic;
}
public String getTopic() {
return topic;
}
public String getCellId() {
return this.f0;
}
public Message getMessage() {
return this.f1;
}
}

但是当我试图在下游操作符中获取getTopic()时，它返回null。如有任何帮助，我们将不胜感激。

Answer 1

您正在将主题字段分配给它自己：

public A(String topic, String key, Message message) {
super(key, message);
this.topic = topic; //<-bug
}

我认为您需要实现Tuple3<T0、T1、T2>