Skip to content

Instantly share code, notes, and snippets.

@reikje
reikje / cassandra_heap.sh
Last active December 10, 2015 20:28
Cassandra Heap Memory Evaluation
cd /tmp
wget http://downloads.sourceforge.net/cyclops-group/jmxterm-1.0-alpha-4-uber.jar
java -jar jmxterm-1.0-alpha-4-uber.jar
>open localhost:7199
>bean org.apache.cassandra.db:type=Caches
>info
>get KeyCacheSize
>get RowCacheSize
>get KeyCacheCapacityInMB
>get RowCacheCapacityInMB
if [ -f ${HOME}/.ssh-agent ]; then
. ${HOME}/.ssh-agent > /dev/null
fi
if [ -z "$SSH_AGENT_PID" -o -z "`/usr/bin/ps -a|/usr/bin/egrep \"^[ ]+$SSH_AGENT_PID\"`" ]; then
/usr/bin/ssh-agent > ${HOME}/.ssh-agent
. ${HOME}/.ssh-agent > /dev/null
fi
ssh-add ~/.ssh/id_rsa
nodetool cfstats | grep 'Memtable Data Size' | awk '{sum+=$4}END{print sum}'
@reikje
reikje / embedded_cassandra.py
Last active December 11, 2015 17:58
EmbeddedCassandra
#coding: UTF-8
import shutil
import socket
import subprocess
from time import sleep
import uuid
import os, tempfile
from logging import getLogger
CASSANDRA_DIR = os.path.abspath(os.path.join(os.path.dirname(__file__), '../../resources/cassandra')) # change me
@reikje
reikje / embedded_cassandra_test.py
Created January 25, 2013 22:14
EmbeddedCassandraTestCase
#coding: UTF-8
import logging
import unittest
import sys
from javasplitter.embedded_cassandra import EmbeddedCassandra
class EmbeddedCassandraTestCase(unittest.TestCase):
def __init__(self, methodName='runTest', port=None):
super(EmbeddedCassandraTestCase, self).__init__(methodName)
@reikje
reikje / random_word_test.py
Created January 25, 2013 22:14
RandomWordTest
#coding: UTF-8
import random
import string
from pycassa import ConnectionPool, SystemManager, ColumnFamily, SIMPLE_STRATEGY, UTF8_TYPE, INT_TYPE
from javasplitter.embedded_cassandra_test import EmbeddedCassandraTestCase
class RandomWordTest(EmbeddedCassandraTestCase):
def setUp(self):
@reikje
reikje / mvn_clean_package.xml
Created January 25, 2013 22:23
mvn clean package
mvn clean package
object ExampleRestApp {
class RestController(statsReceiver: StatsReceiver = NullStatsReceiver) extends Controller(statsReceiver) {
get("/user/:userId") { request =>
val userId: Long = request.routeParams.getOrElse("userId", "0").toLong
val user = someService.lookupUser(userId)
if (user == null) {
render.notFound.plain("").toFuture
} else {
render.body(user).header("Content-Type", "application/json").toFuture
object ExampleRestApp {
@Api(value = "/", description = "Docs for our example controller")
@Path("/")
class RestController(statsReceiver: StatsReceiver = NullStatsReceiver) extends Controller(statsReceiver) {
get_user_id()
@ApiOperation(value = "Returns a user in json format.", notes = "Will only return a subset of the attributes.", responseClass = "java.lang.String", httpMethod = "GET")
@Path("user/{userId}")
@ApiErrors(Array(new ApiError(code = 404, reason = "No such user")))
def get_user_id(@ApiParam(name = "UserId", value = "A valid user id", required = true) env: Long = 0L) {
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<dependencies>
// not all shown