闪烁uid。我们真的需要它吗？它不是用了耳聋的吗？

Question

我们真的对操作符使用uid方法吗？

如果是这样的话..

你能不能建议一种更优雅的方式来设置它(就像c#中的扩展方法)，而不是同时为name和uid传递2次字符串？

例如，而不是：

    streamExecutionEnvironment
    .addSource(new KafkaConsumer(kafkaConsumerOptions))
    .name("Kafka topic reader").uid("Kafka topic reader")

我真的想要这样的东西：

     streamExecutionEnvironment
    .addSource(new KafkaConsumer(kafkaConsumerOptions))
    .nameUid("Kafka topic reader")

(其中nameUid设置了这两个属性)

你能帮忙吗？

Answer 1

名称是要在Flink UI上显示的值，而uid是唯一的值，用于在拓扑中可能发生的更改时维护操作员状态。对于这两个不同的属性，API确实需要两个不同的setter，因为uid永远不应该改变，而名称可能会随着拓扑的演变而改变。