Skip to content

Instantly share code, notes, and snippets.

View vickumar1981's full-sized avatar

Vic Kumar vickumar1981

View GitHub Profile
private def toJSData = newAnonymousJsFunction(
"""
|function(riakObject) {
| var d = riakObject.values[0].data;
| return [d];
|}
""".stripMargin)
def findByIndex (indexName: String, indexValue: String): List[T] = {
val mr = new IndexMapReduce.Builder()
def setupRiakClient(config: Config): RiakClient = {
val maxConnections = config.getInt(RiakMaxConnections)
val port = config.getInt(RiakPort)
val hosts = config.getStringList(RiakHosts)
val builder = new RiakNode.Builder()
.withMaxConnections(maxConnections)
.withRemotePort(port)
var addresses: java.util.List[String] = new java.util.ArrayList[String]()