apache-flink - jar 中两个路径中的 SimpleStringSchema 是否相同？

Question

在 intellij 中，SimpleStringSchema可以从两个地方导入。

import org.apache.flink.streaming.util.serialization.SimpleStringSchema;

import org.apache.flink.api.common.serialization.SimpleStringSchema;

对于我们的项目，它们总是一样吗？

谢谢你的帮助

标签： apache-flink

Answer 1

它们的行为应该是相同的，因为 inorg.apache.flink.streaming.util.serialization扩展了 in org.apache.flink.api.common.serialization。我不确定为什么要创建两个类。

值得一提的是，你应该只使用org.apache.flink.api.common.serialization.SimpleStringSchema另一个已被弃用的。