brianmhess

import java.util.*;
import java.lang.*;
import java.math.BigInteger;

import com.datastax.driver.core.*;
import com.datastax.driver.core.policies.*;

class CassReadMT {
    class ThreadExecute extends Thread {
        private Cluster cluster;

brianmhess

package org.apache.cassandra.triggers;

import java.nio.ByteBuffer;
import java.util.Collection;
import org.apache.cassandra.db.ColumnFamily;
import org.apache.cassandra.db.Mutation;
import org.apache.cassandra.db.Cell;

public class FWWTrigger implements ITrigger {
    public Collection<Mutation> augment(ByteBuffer partitionKey, ColumnFamily update) {

brianmhess

#include <assert.h>
#include <string.h>
#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>

#include "cassandra.h"

#define NUM_CONCURRENT_REQUESTS 5000