Skip to content

Commit

Permalink
Add additional logging
Browse files Browse the repository at this point in the history
  • Loading branch information
Rithika committed Jul 21, 2023
1 parent 022c03a commit 9195f53
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -104,7 +104,7 @@ public AccumulatorImpl(MetricRegistry metricRegistry, MetricAggregationPolicyPro
@Override
public void add(DataPoint m)
{

log.info("Start adding data points");
add(m, System.currentTimeMillis());

}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,7 @@ static AggregateFunction create( String key, MetricAggregationMethod method)
case AVG:
return new AvgAggregateFunction();
case SUM:
log.info("calling the sum function");
return new SumAggregateFunction();
case CUSTOM1:
return custom1( key );
Expand Down Expand Up @@ -67,6 +68,8 @@ static class SumAggregateFunction
public synchronized AggregateFunction add( DataPoint dataPoint, int now )
{
sum += dataPoint.val;
log.info("Calculating the sum for aggreggate function");
log.info("Print the datapoint name: " + dataPoint.name);
return this;
}

Expand Down

0 comments on commit 9195f53

Please sign in to comment.