apache-flink - 将 flink uid 命名为 operator 的最佳实践

Question

是否有命名 UID 的最佳实践？对于运营商？
可以是简单的东西吗

stream.flatMap(new FlatMapFunc).uid("1")
    .assignTimestampsAndWatermarks(new TimestampExtractor).uid("2")
    .keyBy(r => r.key )
    .timeWindow(Time.minutes(10))
    .allowedLateness(Time.minutes(30))
    .process(new ProcessFunc).uid("3")

或者有一些命名 uid 的规则/建议？

Answer 1

UID 没有命名约定，但在我们的团队中，我们使用与 operator.name() 中相同的值。 name 值用于在 Flink UI 中渲染算子框

这样我们就有了这样的代码，对我们来说是语义和简单的:

        streamExecutionEnvironment
        .addSource(new KafkaConsumer(kafkaConsumerOptions))
        .name("Kafka topic reader").uid("Kafka topic reader")
        .filter(new CreatedBy("my uncle"))
        .name("Created by my uncle filter").uid("Created by my uncle filter")
        .map(new ToInvoice())
        .name("To invoice mapper").uid("To invoice mapper")