Github user nickwallen commented on a diff in the pull request:

    https://github.com/apache/metron/pull/1146#discussion_r208304859
  
    --- Diff: 
metron-analytics/metron-profiler-common/src/main/java/org/apache/metron/profiler/DefaultMessageRouter.java
 ---
    @@ -53,10 +56,16 @@
        */
       private StellarStatefulExecutor executor;
     
    +  /**
    +   * Responsible for creating the {@link Clock}.
    +   */
    +  private ClockFactory clockFactory;
    --- End diff --
    
    The `ClockFactory` helps with the timestamp logic.  This used to live in 
the `ProfileSplitterBolt` as that is where the timestamp extract logic lived.  
Now the `MessageRouter` does this for all Profiler ports.


---

Reply via email to