()
| 2941 | super.initMetrics(); |
| 2942 | metrics_.addGauge(NUM_PARTITIONS_METRIC, new Gauge<Integer>() { |
| 2943 | @Override |
| 2944 | public Integer getValue() { return partitionMap_.values().size(); } |
| 2945 | }); |
| 2946 | metrics_.addGauge(NUM_FILES_METRIC, new Gauge<Long>() { |
| 2947 | @Override |