flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Deepak Jha <dkjhan...@gmail.com>
Subject Unique ID of an operator
Date Fri, 08 Apr 2016 21:46:12 GMT
I have a use case where I need to get UniqueId of an operator inside a
stream. DataStream's getId() returns the ID of the stream but I have
operator partitioned (say partitionByHash) inside the datastream. So I
would like to get unique ID for each operator working in parallel. Is there
a way in which I can get it ?
Also, does DataStream's getId generates different ID in case i have
parallelism > 1 ?


  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message