eevans

import java.util.UUID;
import com.opennms.lucidity.annotations.*;
 
@Entity
public class User {
    @Id
    UUID userId;
 
    @Column
    String emailAddress;

eevans

package org.apache.cassandra.tools;

import java.io.IOException;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

import javax.management.JMX;
import javax.management.MBeanServerConnection;
import javax.management.MalformedObjectNameException;

eevans

PREFIX ?= /usr/local

all:

install:
	install -m 755 color-junit $(PREFIX)/bin

uninstall:

eevans

"""
Derived from the uuid module in standard lib.
"""

from uuid import UUID, getnode
import time, random

def uuid1(timestamp=None):
    """
    Generate a type 1 UUID from a timestamp, (or the current time).

eevans

log4j.rootLogger=DEBUG,stdout

log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%5p %d{HH:mm:ss,SSS} %m%n

log4j.appender.R=org.apache.log4j.RollingFileAppender
log4j.appender.file.maxFileSize=20MB
log4j.appender.file.maxBackupIndex=50
log4j.appender.R.layout=org.apache.log4j.PatternLayout

eevans

[...]

DEBUG 18:14:39,837 Resetting pool for /10.1.9.31
DEBUG 18:14:39,838 Node /10.1.9.31 state normal, token 130422514498655458579966251475616909160
DEBUG 18:14:39,838 clearing cached endpoints
 INFO 18:14:39,838 Node /10.1.9.30 is now part of the cluster
DEBUG 18:14:39,839 Resetting pool for /10.1.9.30
DEBUG 18:14:39,839 Node /10.1.9.30 state normal, token 88558006740455176880390025766200390905
DEBUG 18:14:39,840 clearing cached endpoints
DEBUG 18:14:39,858 attempting to connect to /10.1.9.33

eevans

 INFO 17:43:01,763 Loading settings from file:/etc/cassandra/cassandra.yaml
DEBUG 17:43:01,958 Syncing log with a period of 10000
 INFO 17:43:01,958 DiskAccessMode 'auto' determined to be mmap, indexAccessMode is mmap
DEBUG 17:43:02,041 setting auto_bootstrap to false
 INFO 17:43:02,109 Starting up client gossip
DEBUG 17:43:02,197 attempting to connect to /10.1.9.32
 INFO 17:43:02,207 Node /10.1.9.32 is now part of the cluster
DEBUG 17:43:02,207 Resetting pool for /10.1.9.32
DEBUG 17:43:02,210 Node /10.1.9.32 state normal, token 76426229089211633986606168715786092138
DEBUG 17:43:02,210 clearing cached endpoints

eevans

java -jar build/flewton-1.0.jar 9995 com.rackspace.flewton.backend.LoggingBackend,com.rackspace.flewton.backend.NullBackend
 INFO 14:04:50,490 Adding backend: com.rackspace.flewton.backend.LoggingBackend
 INFO 14:04:50,491 Adding backend: com.rackspace.flewton.backend.NullBackend
 INFO 14:04:50,534 Binding to UDP 0.0.0.0:9995
 INFO 14:05:05,029 source=localhost:8888, dest=127.0.0.2:80, bytes=100
 INFO 14:05:10,034 source=localhost:8888, dest=127.0.0.2:80, bytes=100

eevans

from cassandra import Cassandra
from cassandra.atypes import *

client = Cassandra.Client()
client.set_keyspace(keyspace='Keyspace1')
client.insert(key='keyAAA',
              column_parent=ColumnParent(column_family='Standard2'),
              column=Column(name='colAAA',
                            value='valAAA',
                            clock=Clock(timestamp=1),

eevans

class MissingFieldException(Exception):
    pass

class ColumnPath(dict):
    def __init__(self, **kwargs):
        if not kwargs.has_key('column_family'):
            raise MissingFieldException('column_family')
        self['column_family'] = kwargs.get('column_family', None)

        self['super_column'] = kwargs.get('super_column', None)