@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 predefi
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, MultiReduc
Dear all,
I focused on the Flink-accumulator and found that there is not any feature to
count the average of values.
And there is a MultiReducedMetric class in storm that calculates the average.
This class can be used internally to get the latency in storm.
So as the first step, I`d like to add a
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
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?
>
> =
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 ev
