flink 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确实确实需要两个不同属性的两个设置器，因为uid永不更改，而名称可能会随着拓扑的发展而更改。]