private static void updateMetrics()

in spark-job/src/main/java/org/apache/cassandra/diff/Differ.java [316:336]

• 18 lines of code
• 2 McCabe index (conditional complexity)

    private static void updateMetrics(String prefix, Map<KeyspaceTablePair, RangeStats> statsMap)
    {
        for (Map.Entry<KeyspaceTablePair, RangeStats> entry : statsMap.entrySet())
        {
            KeyspaceTablePair keyspaceTablePair = entry.getKey();
            String qualifier = String.format("%s.%s.%s", prefix, keyspaceTablePair.keyspace, keyspaceTablePair.table);
            RangeStats stats = entry.getValue();

            metrics.meter(qualifier + ".partitions_read").mark(stats.getMatchedPartitions() + stats.getOnlyInSource() + stats.getOnlyInTarget() + stats.getMismatchedPartitions());
            metrics.counter(qualifier + ".matched_partitions").inc(stats.getMatchedPartitions());
            metrics.counter(qualifier + ".mismatched_partitions").inc(stats.getMismatchedPartitions());

            metrics.counter(qualifier + ".partitions_only_in_source").inc(stats.getOnlyInSource());
            metrics.counter(qualifier + ".partitions_only_in_target").inc(stats.getOnlyInTarget());
            metrics.counter(qualifier + ".skipped_partitions").inc(stats.getSkippedPartitions());

            metrics.counter(qualifier + ".matched_rows").inc(stats.getMatchedRows());
            metrics.counter(qualifier + ".matched_values").inc(stats.getMatchedValues());
            metrics.counter(qualifier + ".mismatched_values").inc(stats.getMismatchedValues());
        }
    }