gdusbabek

# output messages into a rolling log file as well as stdout
log4j.rootLogger=TRACE,stdout

# stdout
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.Threshold=DEBUG
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%5p %d{HH:mm:ss,SSS} [%t] %l %m%n

# rolling log file

gdusbabek

@version("1")
record MessageTypeA {
    string a;
    string b;
    int c;
    boolean d;
}

@version("2")
record MessageTypeA {

gdusbabek

#!/usr/bin/env python

import re, sys

STATUS_RE = re.compile(
    '\s+\[junit\] Tests run: [\d]+, Failures: ([\d]+), Errors: ([\d]+)')
EXCEPT_RE = re.compile(
    '\s+\[junit\] (Exception in |\tat \w+|Caused by: )')

RED = "\033[1;31m%s\033[0m"

gdusbabek

var async = require('async');

function doSimpleConnect(callback) {
  
  var Connection = require('cassandra-client').Connection;
  
  // these are the connection parameters you need to connecto to Cassandra.
  var connectionOptions = {
    host: '127.0.0.1',
    port: 19170,

gdusbabek

<dependency>
  <groupId>com.rackspacecloud</groupId>
  <artifactId>service-registry-client</artifactId>
  <version>2.0.1-SNAPSHOT</version>
</dependency>
<dependency>
  <groupId>com.rackspacecloud</groupId>
  <artifactId>service-registry-curator</artifactId>
  <version>2.0.1-SNAPSHOT</version>
</dependency>

gdusbabek

Blueflood Improvment Ideas

These are in no particular order. I add them as I think of them.

1. Local ingestion durability.
2. Use the Cassandra Fat Client for ingestion, rollup and/or query
3. l2met integration (http://r.32k.io/l2met-introduction)
4. Fluentd integration (http://fluentd.org)
5. A distributed test suite
6. Internode coordination (obviate manual shard assignment)

gdusbabek

## Graphite local_settings.py
# Edit this file to customize the default Graphite webapp settings
#
# Additional customizations to Django settings can be added to this file as well

# import the other settings here.
from graphite.settings import *

#####################################
# General Configuration #

gdusbabek

import com.codahale.metrics.JmxReporter;
import com.codahale.metrics.MetricRegistry;
import com.codahale.metrics.Timer;

import java.util.Random;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class RunAndCompare {

gdusbabek

import sys

import numpy as np
import matplotlib
import matplotlib.pyplot as plt
import csv
import datetime


matplotlib.rcParams.update({'font.size': 4})

gdusbabek

-1
! liederbuch
!!!
!!!metal!!!
!artist albums; !pop
!compilations
!compilations; !pop
!compilations; !pop; rock
!compilations; dance
!compilations; r'n'b