You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by GitBox <gi...@apache.org> on 2018/12/03 15:00:46 UTC

[GitHub] jgrier commented on issue #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster

jgrier commented on issue #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster
URL: https://github.com/apache/flink/pull/7099#issuecomment-443739811
 
 
   Sorry I haven't responded to this.  We had a baby boy this week so that has kept me pretty busy ;)
   
   Okay, so I'm on board with generifying this further.  @StephanEwen if we're to do a generic transient aggregator do you mean to allow the client to provide the aggregation function?  In this case the API would look something like this:
   
   `CompletableFuture<R> updateAggregate(
         String aggregateName,
         T aggregand,
         BiFunction<T, R, R> aggregationFunction);`
   
   Is this what you had in mind?
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services