Skip to content

Instantly share code, notes, and snippets.

View bsbodden's full-sized avatar

Brian Sam-Bodden bsbodden

129 followers · 60 following
View GitHub Profile
@bsbodden
bsbodden / linux_cassandra_prep_dirs
Created November 24, 2014 17:30
Create and give Cassandra permission to use the right folders on your system
sudo mkdir /var/lib/cassandra
sudo mkdir /var/log/cassandra
sudo chown -R $USER:$GROUP /var/lib/cassandra
sudo chown -R $USER:$GROUP /var/log/cassandra
@bsbodden
bsbodden / linux_cassandra_variables
Created November 24, 2014 17:41
Set up Cassandra HOME and added it to the execution path
export CASSANDRA_HOME=~/cassandra
export PATH=$PATH:$CASSANDRA_HOME/bin
@bsbodden
bsbodden / gist:8ff6067f9f63c409ce13
Created December 3, 2014 04:20
HelloCassandra.java
package org.integrallis.cassandra.oink;
import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Host;
import com.datastax.driver.core.Metadata;
import com.datastax.driver.core.Row;
import com.datastax.driver.core.Session;
import com.datastax.driver.core.exceptions.NoHostAvailableException;
public class HelloCassandra {
@bsbodden
bsbodden / gist:6e2d157b0d8b8a4ba0d5
Created December 3, 2014 04:22
HelloCassandra.java: Package and Imports
package org.integrallis.cassandra.oink;
import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Host;
import com.datastax.driver.core.Metadata;
import com.datastax.driver.core.Row;
import com.datastax.driver.core.Session;
import com.datastax.driver.core.exceptions.NoHostAvailableException;
@bsbodden
bsbodden / gist:27309f7b698deb898e3e
Created December 3, 2014 04:27
HelloCassandra.java: Main Method
public static void main(String[] args) {
Cluster cluster = null;
Session session = null;
try {
cluster = Cluster.builder().addContactPoints("localhost").build();
Metadata metadata = cluster.getMetadata();
System.out.printf("Connected to cluster: %s\n", metadata.getClusterName());
for ( Host host : metadata.getAllHosts() ) {
System.out.printf("Datacenter: %s; Host: %s; Rack: %s\n", host.getDatacenter(), host.getAddress(), host.getRack());
@bsbodden
bsbodden / gist:a9f543097ca4c85c6715
Created December 3, 2014 04:29
HelloCassandra.java: Query1
session = cluster.connect("oink");
for (Row row : session.execute("SELECT oink_id, dateOf(oink_id), user_id, body FROM oinks")) {
System.out.println("========================================================");
System.out.println("OINK_ID: " + row.getUUID("oink_id"));
System.out.println("TIMESTAMP: " + row.getDate("dateOf(oink_id)"));
System.out.println("USER_ID: " + row.getString("user_id"));
System.out.println("BODY: " + row.getString("body"));
}
System.out.println("========================================================");
@bsbodden
bsbodden / gist:fe142e3773a53bcff5d4
Created April 3, 2015 13:49
package io.integrallis.atmosphere
import io.dropwizard.lifecycle.Managed
import java.io.BufferedReader
import java.io.InputStreamReader
import java.net.InetAddress
import java.util.List
import java.util.Set
import org.jgroups.JChannel
@bsbodden
bsbodden / gist:6319cc4f48f5d79579d2
Created April 12, 2015 00:40
<config xmlns="urn:org:jgroups"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:org:jgroups http://www.jgroups.org/schema/JGroups-3.2.xsd">
<TCP
bind_port="7800"
loopback="false"
recv_buf_size="${tcp.recv_buf_size:20M}"
send_buf_size="${tcp.send_buf_size:640K}"
max_bundle_size="64K"
max_bundle_timeout="30"
@bsbodden
bsbodden / BaseDroolsTestCase.java
Created August 9, 2015 20:05
Base Drools JUnit Test Case
package org.integrallis.drools.junit;
import org.kie.api.KieServices;
import org.kie.api.runtime.KieContainer;
import org.kie.api.runtime.KieSession;
import org.junit.After;
import org.junit.Before;
public abstract class BaseDroolsTestCase {
@bsbodden
bsbodden / acme_fico_rule
Created August 10, 2015 03:36
ACME-Fico DSLR Rule
rule "ACME-Fico"
when
the lender is "ACME Mortgage"
and there is an application
- with a FICO score below 680
then
reject the application because "a FICO score of at least 680 is required"
end