| /* |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| package org.apache.cassandra.tools.nodetool.stats; |
| |
| import java.io.PrintStream; |
| import java.util.List; |
| |
| import org.json.simple.JSONObject; |
| import org.yaml.snakeyaml.Yaml; |
| |
| public enum TableStatsPrinter |
| { |
| DEFAULT(new DefaultPrinter()), |
| JSON(new JsonPrinter()), |
| YAML(new YamlPrinter()),; |
| |
| private final StatsPrinter<StatsHolder> printer; |
| |
| TableStatsPrinter(StatsPrinter<StatsHolder> printer) |
| { |
| this.printer = printer; |
| } |
| |
| public void print(StatsHolder stats, PrintStream out) |
| { |
| printer.printFormat(stats, out); |
| } |
| |
| public static TableStatsPrinter from(String format) |
| { |
| switch (format) |
| { |
| case "json": |
| return JSON; |
| case "yaml": |
| return YAML; |
| default: |
| return DEFAULT; |
| } |
| } |
| |
| private static class DefaultPrinter implements StatsPrinter<StatsHolder> |
| { |
| @Override |
| public void printFormat(StatsHolder data, PrintStream out) |
| { |
| List<StatsKeyspace> keyspaces = data.keyspaces; |
| for (StatsKeyspace keyspace : keyspaces) |
| { |
| // print each keyspace's information |
| out.println("Keyspace : " + keyspace.name); |
| out.println("\tRead Count: " + keyspace.readCount); |
| out.println("\tRead Latency: " + keyspace.readLatency() + " ms."); |
| out.println("\tWrite Count: " + keyspace.writeCount); |
| out.println("\tWrite Latency: " + keyspace.writeLatency() + " ms."); |
| out.println("\tPending Flushes: " + keyspace.pendingFlushes); |
| |
| // print each table's information |
| List<StatsTable> tables = keyspace.tables; |
| for (StatsTable table : tables) |
| { |
| out.println("\t\tTable" + (table.isIndex ? " (index): " + table.name : ": ") + table.name); |
| if (table.isLeveledSstable) |
| out.println("\t\tSSTables in each level: [" + String.join(", ", |
| table.sstablesInEachLevel) + "]"); |
| |
| out.println("\t\tSpace used (live): " + table.spaceUsedLive); |
| out.println("\t\tSpace used (total): " + table.spaceUsedTotal); |
| out.println("\t\tSpace used by snapshots (total): " + table.spaceUsedBySnapshotsTotal); |
| |
| if (table.offHeapUsed) |
| out.println("\t\tOff heap memory used (total): " + table.offHeapMemoryUsedTotal); |
| out.println("\t\tSSTable Compression Ratio: " + table.sstableCompressionRatio); |
| out.println("\t\tNumber of keys (estimate): " + table.numberOfKeysEstimate); |
| out.println("\t\tMemtable cell count: " + table.memtableCellCount); |
| out.println("\t\tMemtable data size: " + table.memtableDataSize); |
| |
| if (table.memtableOffHeapUsed) |
| out.println("\t\tMemtable off heap memory used: " + table.memtableOffHeapMemoryUsed); |
| out.println("\t\tMemtable switch count: " + table.memtableSwitchCount); |
| out.println("\t\tLocal read count: " + table.localReadCount); |
| out.printf("\t\tLocal read latency: %01.3f ms%n", table.localReadLatencyMs); |
| out.println("\t\tLocal write count: " + table.localWriteCount); |
| out.printf("\t\tLocal write latency: %01.3f ms%n", table.localWriteLatencyMs); |
| out.println("\t\tPending flushes: " + table.pendingFlushes); |
| out.println("\t\tPercent repaired: " + table.percentRepaired); |
| |
| out.println("\t\tBloom filter false positives: " + table.bloomFilterFalsePositives); |
| out.printf("\t\tBloom filter false ratio: %01.5f%n", table.bloomFilterFalseRatio); |
| out.println("\t\tBloom filter space used: " + table.bloomFilterSpaceUsed); |
| |
| if (table.bloomFilterOffHeapUsed) |
| out.println("\t\tBloom filter off heap memory used: " + table.bloomFilterOffHeapMemoryUsed); |
| if (table.indexSummaryOffHeapUsed) |
| out.println("\t\tIndex summary off heap memory used: " + table.indexSummaryOffHeapMemoryUsed); |
| if (table.compressionMetadataOffHeapUsed) |
| out.println("\t\tCompression metadata off heap memory used: " + table.compressionMetadataOffHeapMemoryUsed); |
| |
| out.println("\t\tCompacted partition minimum bytes: " + table.compactedPartitionMinimumBytes); |
| out.println("\t\tCompacted partition maximum bytes: " + table.compactedPartitionMaximumBytes); |
| out.println("\t\tCompacted partition mean bytes: " + table.compactedPartitionMeanBytes); |
| out.println("\t\tAverage live cells per slice (last five minutes): " + table.averageLiveCellsPerSliceLastFiveMinutes); |
| out.println("\t\tMaximum live cells per slice (last five minutes): " + table.maximumLiveCellsPerSliceLastFiveMinutes); |
| out.println("\t\tAverage tombstones per slice (last five minutes): " + table.averageTombstonesPerSliceLastFiveMinutes); |
| out.println("\t\tMaximum tombstones per slice (last five minutes): " + table.maximumTombstonesPerSliceLastFiveMinutes); |
| out.println("\t\tDropped Mutations: " + table.droppedMutations); |
| out.println(""); |
| } |
| out.println("----------------"); |
| } |
| } |
| } |
| |
| private static class JsonPrinter implements StatsPrinter<StatsHolder> |
| { |
| @Override |
| public void printFormat(StatsHolder data, PrintStream out) |
| { |
| JSONObject json = new JSONObject(); |
| json.putAll(data.convert2Map()); |
| out.println(json.toString()); |
| } |
| } |
| |
| private static class YamlPrinter implements StatsPrinter<StatsHolder> |
| { |
| @Override |
| public void printFormat(StatsHolder data, PrintStream out) |
| { |
| Yaml yaml = new Yaml(); |
| out.println(yaml.dump(data.convert2Map())); |
| } |
| } |
| |
| } |