моргатьмы действительно нуждаемся в этом? разве он не использует глухой?

Question

действительно ли мы используем метод uid для операторов?

, если это так.

Можете ли вы предложить более элегантный способ его установки (например, метод расширения в c #) вместопередавая 2 раза строку для имени & uid?

, например, вместо:

    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, в то время как uid - это уникальное значение, используемое для поддержания состояния оператора во время возможного изменения топологии. API действительно нужны два разных установщика для двух разных свойств, так как uid никогда не должен изменяться, в то время как имя может меняться по мере развития топологии.