flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljoscha <...@git.apache.org>
Subject [GitHub] flink issue #4616: [FLINK-7552] [FLINK-7553] Enhance SinkInterface / Use in ...
Date Tue, 19 Sep 2017 14:01:47 GMT
Github user aljoscha commented on the issue:

    @pnowojski and @EronWright I changed the name of the `Context`, I added a test in `StreamSinkOperatorTest`,
I added methods or querying current processing time/watermark to the context. I changed the
`timestamp()` method to return a primitive `long` and I added a method `hasTimestamp()`. Also,
`timestamp()` now throws an exception if no timestamp is available.
    What do you think?


View raw message