Bagaimana cara menyesuaikan nama tugas di dasbor Apache flink?

Saya ingin menyesuaikan nama tugas di dasbor Apache flink.

Misalnya, ketika kita memiliki peta tugas di dashboard namanya MAP, bagaimana cara mengubahnya untuk menambahkan nama tertentu?

Terima kasih banyak.


apache-flink flink-streaming
person FlinkNoob    schedule 01.12.2017    source sumber

Jawaban (1)


arrow_upward
2
arrow_downward

Operator dapat diberi nama menggunakan metode name() seperti yang ditunjukkan pada contoh berikut:

DataStream<X> stream2 = stream
  .map(new MyMapper()).name("MyMapFunction")
  .map(new MyMapper2()).name("MyOtherMapper");
person Fabian Hueske    schedule 01.12.2017
comment
Terima kasih banyak @Fabian - person FlinkNoob; 01.12.2017