Skip to content

Instantly share code, notes, and snippets.

@arodrime
Created July 17, 2018 18:22
Show Gist options
  • Save arodrime/f9591e4bdd2b1367a496447cdd959006 to your computer and use it in GitHub Desktop.
Save arodrime/f9591e4bdd2b1367a496447cdd959006 to your computer and use it in GitHub Desktop.
alain$ grep -RiI CompactionThroughput .
./test/unit/org/apache/cassandra/cql3/validation/miscellaneous/CrcCheckChanceTest.java: DatabaseDescriptor.setCompactionThroughputMbPerSec(1);
./debian/nodetool-completion: getcompactionthroughput
./debian/nodetool-completion: setcompactionthroughput
./CHANGES.txt: * expose compactionThroughputMbPerSec through JMX (CASSANDRA-3117)
./CHANGES.txt: * fix nodetool setcompactionthroughput (CASSANDRA-2550)
./src/java/org/apache/cassandra/tools/nodetool/SetCompactionThroughput.java:@Command(name = "setcompactionthroughput", description = "Set the MB/s throughput cap for compaction in the system, or 0 to disable throttling")
./src/java/org/apache/cassandra/tools/nodetool/SetCompactionThroughput.java:public class SetCompactionThroughput extends NodeToolCmd
./src/java/org/apache/cassandra/tools/nodetool/SetCompactionThroughput.java: private Integer compactionThroughput = null;
./src/java/org/apache/cassandra/tools/nodetool/SetCompactionThroughput.java: probe.setCompactionThroughput(compactionThroughput);
./src/java/org/apache/cassandra/tools/nodetool/CompactionStats.java: int compactionThroughput = probe.getCompactionThroughput();
./src/java/org/apache/cassandra/tools/nodetool/CompactionStats.java: if (compactionThroughput != 0)
./src/java/org/apache/cassandra/tools/nodetool/CompactionStats.java: long remainingTimeInSecs = remainingBytes / (1024L * 1024L * compactionThroughput);
./src/java/org/apache/cassandra/tools/nodetool/GetCompactionThroughput.java:@Command(name = "getcompactionthroughput", description = "Print the MB/s throughput cap for compaction in the system")
./src/java/org/apache/cassandra/tools/nodetool/GetCompactionThroughput.java:public class GetCompactionThroughput extends NodeToolCmd
./src/java/org/apache/cassandra/tools/nodetool/GetCompactionThroughput.java: System.out.println("Current compaction throughput: " + probe.getCompactionThroughput() + " MB/s");
./src/java/org/apache/cassandra/tools/NodeTool.java: GetCompactionThroughput.class,
./src/java/org/apache/cassandra/tools/NodeTool.java: SetCompactionThroughput.class,
./src/java/org/apache/cassandra/tools/NodeProbe.java: public void setCompactionThroughput(int value)
./src/java/org/apache/cassandra/tools/NodeProbe.java: ssProxy.setCompactionThroughputMbPerSec(value);
./src/java/org/apache/cassandra/tools/NodeProbe.java: public int getCompactionThroughput()
./src/java/org/apache/cassandra/tools/NodeProbe.java: return ssProxy.getCompactionThroughputMbPerSec();
./src/java/org/apache/cassandra/config/DatabaseDescriptor.java: public static int getCompactionThroughputMbPerSec()
./src/java/org/apache/cassandra/config/DatabaseDescriptor.java: public static void setCompactionThroughputMbPerSec(int value)
./src/java/org/apache/cassandra/db/compaction/CompactionManager.java: setRate(DatabaseDescriptor.getCompactionThroughputMbPerSec());
./src/java/org/apache/cassandra/service/StorageServiceMBean.java: public int getCompactionThroughputMbPerSec();
./src/java/org/apache/cassandra/service/StorageServiceMBean.java: public void setCompactionThroughputMbPerSec(int value);
./src/java/org/apache/cassandra/service/StorageService.java: public int getCompactionThroughputMbPerSec()
./src/java/org/apache/cassandra/service/StorageService.java: return DatabaseDescriptor.getCompactionThroughputMbPerSec();
./src/java/org/apache/cassandra/service/StorageService.java: public void setCompactionThroughputMbPerSec(int value)
./src/java/org/apache/cassandra/service/StorageService.java: DatabaseDescriptor.setCompactionThroughputMbPerSec(value);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment