@Matthias
Thanks for advice :-)
==
I personally never used Metrics in Storm. It would be best, if you design an
own example.
I guess you are familiar with
https://storm.apache.org/documentation/Metrics.html
As a first step, I would try to include the
Sounds great. It is easy to create an AverageAccumulator by implementing
the org.apache.flink.api.common.accumulators.Accumulator interface,
accumulating the sum and the count internally, and dividing in the end.
This would be something useful also outside of Storm compatibility.
Then,
Flink accumulators are documented here:
https://ci.apache.org/projects/flink/flink-docs-master/apis/programming_guide.html#accumulators--counters
I think Aljoscha's idea is to implement Storm metrics on top of those.
Huangwei, perhaps you can look whether the interfaces match (basically if
Flink
Hi,
I think I can take a simple design for it.
Do you have any idea?
Maybe. I did not put any thoughts into this...
On 08/31/2015 12:25 PM, Aljoscha Krettek wrote:
> Hi,
> could the metrics not be implemented on top of Flink accumulators?
> They would
I did not look into it and I am not super familiar with Flink's
accumulators... Can not provide much help right now. Sorry :(
-Matthias
On 08/31/2015 01:01 PM, huangwei (G) wrote:
> Hi,
> I think I can take a simple design for it.
> Do you have any idea?
>
>
