thanks, i see the api doc, it seems good for me
2016-12-29 1:00 GMT+08:00 Lukasz Cwik :
> There is this tracking issue (https://issues.apache.org/
> jira/browse/BEAM-147) for the work and also a doc
> http://s.apache.org/beam-metrics-api that describes some additional
> details. Feel free to comm
There is this tracking issue (https://issues.apache.org/jira/browse/BEAM-147)
for the work and also a doc http://s.apache.org/beam-metrics-api that
describes some additional details. Feel free to comment on the issue / doc
with questions.
On Tue, Dec 27, 2016 at 10:55 PM, 陈竞 wrote:
> is there an
The source controls the watermark, since your using KafkaIO you can call
KafkaIO.read().withWatermarkFn(myWatermarkFn) as seen here:
https://github.com/apache/beam/blob/master/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java#L118
On Tue, Dec 27, 2016 at 5:13 PM, Xu, Min
