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

    https://github.com/apache/incubator-gearpump/pull/226#discussion_r141615634
  
    --- Diff: 
streaming/src/main/scala/org/apache/gearpump/streaming/dsl/window/impl/WindowRunner.scala
 ---
    @@ -73,6 +73,25 @@ case class AndThen[IN, MIDDLE, OUT](left: 
WindowRunner[IN, MIDDLE],
       }
     }
     
    +class DirectWindowRunner[IN, OUT](fnRunner: FunctionRunner[IN, OUT])
    --- End diff --
    
    @huafengw I'm a bit stuck for the name here. This is actually not a window 
runner. Any suggestions ?


---

Reply via email to