spark-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "萝卜丝炒饭" <1427357...@qq.com>
Subject the uniqueSource in StreamExecution, where is it be changed please?
Date Sat, 05 Aug 2017 05:00:00 GMT
Hi all,


These days I am learning the code about the StreamExecution.
In the method constructNextBatch(about line 365), I found the value of latestOffsets changed
but I can not find where the s.getOffset of uniqueSource is  changed.
here is the code link:


https://github.com/apache/spark/blob/master/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala



Would you like help understand it please?


Thanks.
Robin
Mime
View raw message