Skip to content

Instantly share code, notes, and snippets.

View rstrickland's full-sized avatar

Robbie Strickland rstrickland

  • MeteoGroup
  • Utrecht, Netherlands
View GitHub Profile
@rstrickland
rstrickland / mo_example.java
Created September 21, 2012 20:33
MultipleOutputs Example
import java.io.IOException;
import java.nio.ByteBuffer;
import java.util.*;
import org.apache.cassandra.db.IColumn;
import org.apache.cassandra.thrift.*;
import org.apache.cassandra.hadoop.*;
import org.apache.cassandra.utils.ByteBufferUtil;
import org.apache.hadoop.conf.*;
import org.apache.hadoop.io.*;
import org.apache.hadoop.mapreduce.*;
@rstrickland
rstrickland / LocalNodeFirstLoadBalancingPolicy.scala
Created November 4, 2015 13:48
LocalNodeFirstLoadBalancingPolicy
package com.datastax.spark.connector.cql
import java.nio.ByteBuffer
import java.util.{Iterator => JIterator, Collection => JCollection}
import com.datastax.driver.core.policies.LoadBalancingPolicy
import com.datastax.driver.core._
import java.net.{InetAddress, NetworkInterface}
import scala.collection.JavaConversions._