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.
---