创建一个带有可选字段的元组（Flink Java）

Question

我想存储一个与 Tuple2<String, String> 键关联的可选值。

为此，我尝试创建一个 class MyKey extends Tuple3<String, String, String>，其中第三个字段是可选的。它可以为 null，并且在检查是否相等时不使用。

然后我覆盖了 equals() 和 hashCode() 方法：

class MyKey extends Tuple3<String, String, String> {
    @Override
    public boolean equals(Object o) {
        if (this == o) {
            return true;
        }
        if (!(o instanceof myKey)) {
            return false;
        }

        MyKey tuple = (MyKey) o;

        if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) {
            return false;
        }
        if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) {
            return false;
        }
        return true;

    }

    @Override
    public int hashCode() {
        int result = f0 != null ? f0.hashCode() : 0;
        result = 31 * result + (f1 != null ? f1.hashCode() : 0);
        return result;
    }
}

使用此方法有什么我应该注意的问题吗？
还有其他我可以考虑的解决方案吗？

Answer 1

您应该知道，Flink 与 RocksDB 状态后端一起使用的元组序列化程序无法序列化具有空字段的记录。我会说这是个问题。

创建一个带有可选字段的元组（Flink Java）

Create a tuple with an optional field (Flink Java)

java

tuples

apache-flink

flink-streaming