Skip to content

Instantly share code, notes, and snippets.

View arodrime's full-sized avatar

Alain Rodriguez arodrime

15 followers · 3 following
View GitHub Profile
@arodrime
arodrime / Looking in C* code for the MBean
Created July 17, 2018 18:22
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.j
@arodrime
arodrime / gist:f2c4376052bc0eb49d5366747c62febf
Last active March 30, 2016 17:08
[root@cass04 ~]# du -sh /mnt/cassandra/data/Telesto/DeviceImpressions-53cf1590475911e5bad7894bc771451d/* | sort -h | tail -6
26G /mnt/cassandra/data/Telesto/DeviceImpressions-53cf1590475911e5bad7894bc771451d/Telesto-DeviceImpressions-ka-9310-Data.db
99G /mnt/cassandra/data/Telesto/DeviceImpressions-53cf1590475911e5bad7894bc771451d/Telesto-DeviceImpressions-ka-8374-Data.db
113G /mnt/cassandra/data/Telesto/DeviceImpressions-53cf1590475911e5bad7894bc771451d/Telesto-DeviceImpressions-ka-8714-Data.db
170G /mnt/cassandra/data/Telesto/DeviceImpressions-53cf1590475911e5bad7894bc771451d/Telesto-DeviceImpressions-ka-9063-Data.db
201G /mnt/cassandra/data/Telesto/DeviceImpressions-53cf1590475911e5bad7894bc771451d/Telesto-DeviceImpressions-ka-8146-Data.db
271G /mnt/cassandra/data/Telesto/DeviceImpressions-53cf1590475911e5bad7894bc771451d/Telesto-DeviceImpressions-ka-8084-Data.db
[root@cass04 ~]# du -sh /mnt/cassandra/data/Telesto*/* | sort -h | tail -6 | awk '{print $2}' | xargs /usr/local/apache-cassandra/tools/bin/sstab
@arodrime
arodrime / system.peer
Created August 12, 2014 12:46
echo "SELECT rpc_address, release_version, schema_version FROM peers;" | cqlsh -ksystem
rpc_address | release_version | schema_version
-------------+-----------------+--------------------------------------
null | 1.2.2 | 0443507f-7a35-370c-bcb1-2de90fa26c30
0.0.0.0 | 1.2.11 | e6f8cc28-9ea6-31f9-b9b0-45b228206c9d
0.0.0.0 | 1.2.11 | e6f8cc28-9ea6-31f9-b9b0-45b228206c9d
0.0.0.0 | 1.2.11 | e6f8cc28-9ea6-31f9-b9b0-45b228206c9d
0.0.0.0 | 1.2.11 | e6f8cc28-9ea6-31f9-b9b0-45b228206c9d
null | 1.2.2 | 0443507f-7a35-370c-bcb1-2de90fa26c30
@arodrime
arodrime / LogsCassandra
Last active August 29, 2015 14:02
INFO 11:41:35,589 Logging initialized
INFO 11:41:35,606 JVM vendor/version: Java HotSpot(TM) 64-Bit Server VM/1.6.0_38
INFO 11:41:35,612 Heap size: 8422162432/8422162432
INFO 11:41:35,612 Classpath: /usr/share/cassandra/lib/antlr-3.2.jar:/usr/share/cassandra/lib/avro-1.4.0-fixes.jar:/usr/share/cassandra/lib/avro-1.4.0-sources-fixes.jar:/usr/share/cassandra/lib/commons-cli-1.1.jar:/usr/share/cassandra/lib/commons-codec-1.2.jar:/usr/share/cassandra/lib/commons-lang-2.6.jar:/usr/share/cassandra/lib/compress-lzf-0.8.4.jar:/usr/share/cassandra/lib/concurrentlinkedhashmap-lru-1.3.jar:/usr/share/cassandra/lib/graphite-reporter-agent-1.0-SNAPSHOT.jar:/usr/share/cassandra/lib/guava-13.0.1.jar:/usr/share/cassandra/lib/high-scale-lib-1.1.2.jar:/usr/share/cassandra/lib/jackson-core-asl-1.9.2.jar:/usr/share/cassandra/lib/jackson-mapper-asl-1.9.2.jar:/usr/share/cassandra/lib/jamm-0.2.5.jar:/usr/share/cassandra/lib/jbcrypt-0.3m.jar:/usr/share/cassandra/lib/jline-1.0.jar:/usr/share/cassandra/lib/json-simple-1.1.jar:/usr/
@arodrime
arodrime / gist:10019138
Created April 7, 2014 12:12
[...]
def forked_call(pagination_counts, pagination_standard, keys, timeout, num_nodes):
#Connection to Cassandra
connection = cassandraHelpers.ConnectAndOpenSession(timeout=timeout, executor_threads=num_nodes)
session = connection['session']
print(len(keys))
def go_threads(workers, keys, pagination_counts, pagination_standard, timeout, num_nodes):
@arodrime
arodrime / Output
Created April 7, 2014 12:09
383305
383305
383305
383305
383305
383305
ERROR: Unknown error connecting the server
Traceback (most recent call last):
File "/Users/alain/Teads/projects/admin-script-crons/lib/cassandraHelpers/cassandraHelpers.py", line 74, in ConnectAndOpenSession
session = cluster.connect(keyspace)
@arodrime
arodrime / gist:9510920
Created March 12, 2014 16:39
DROP TABLE stats_teads;
CREATE TABLE stats_teads (
dim text,
dimId text,
level text,
event text,
date text,
value int,
PRIMARY KEY ((dim, dimId, level, event), date)
@arodrime
arodrime / pool - datastax python driver output
Created March 11, 2014 10:25
2014-03-11 11:12:45,428 [INFO] cassandra.cluster: New Cassandra host 127.0.0.3 added
2014-03-11 11:12:45,440 [INFO] cassandra.cluster: New Cassandra host 127.0.0.2 added
2014-03-11 11:12:45,748 [INFO] root: dropping existing keyspace...
2014-03-11 11:12:47,348 [INFO] root: creating keyspace...
2014-03-11 11:12:48,417 [INFO] root: setting keyspace...
2014-03-11 11:12:48,422 [INFO] root: creating table...
2014-03-11 11:12:50,103 [INFO] root: Insering row 0
2014-03-11 11:12:54,919 [INFO] root: Insering row 1000
2014-03-11 11:12:57,423 [INFO] root: Insering row 2000
2014-03-11 11:12:59,734 [INFO] root: Insering row 3000
@arodrime
arodrime / Datastax Python priver with multiprocessing.Pool
Created March 11, 2014 10:15
#!/usr/bin/env python
import logging
log = logging.getLogger()
log.setLevel('INFO')
handler = logging.StreamHandler()
handler.setFormatter(logging.Formatter("%(asctime)s [%(levelname)s] %(name)s: %(message)s"))
log.addHandler(handler)