flink 1.3 metric / operator naming: Group multiple operations under one name

Viewed 276

I am trying to combine multiple map operations on my dataStream into one group so that in the metrics / flink dashboard visualization my operator chain (map -> map -> map) shows up as (foo). Calling #name on the last map leaves me with (map -> map -> foo) rather than (foo).

Can this be done? I like grouping my logic into map/filter/flatMap blocks and want to avoid rewriting it to fit into a single flatMap just to clean up the metric names.

(flink 1.3)

0 Answers
Related