ceocoder

/**
 * Copyright 2009 T Jake Luciani
 * 
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at

ceocoder

5 [run-main] INFO scromium.Cassandra$ - config file cassandra.json does not exist
java.lang.ClassNotFoundException: CommonsConnectionPool
	at java.net.URLClassLoader$1.run(URLClassLoader.java:202)
	at java.security.AccessController.doPrivileged(Native Method)
	at java.net.URLClassLoader.findClass(URLClassLoader.java:190)
	at java.lang.ClassLoader.loadClass(ClassLoader.java:307)
	at java.lang.ClassLoader.loadClass(ClassLoader.java:248)
	at java.lang.Class.forName0(Native Method)
	at java.lang.Class.forName(Class.java:247)
	at scromium.reflect.Reflect$.string2Class(Reflect.scala:13)

ceocoder

        val conf = Map("connectionPool" -> "scromium.thrift.ThriftClientPool",
            "host" -> "127.0.0.1",
            "port" -> 9160,
            "maxIdle" -> 10,
            "initCapacity" -> 10,
            "clientProvider" -> "scromium.thrift.ThriftClientProvider")

java.lang.ClassNotFoundException: scromium.thrift.ThriftClientPool
	at java.net.URLClassLoader$1.run(URLClassLoader.java:202)
	at java.security.AccessController.doPrivileged(Native Method)

ceocoder

        val conf = Map("connectionPool" -> "scromium.connection.CommonsConnectionPool",
            "host" -> "127.0.0.1",
            "port" -> 9160,
            "maxIdle" -> 10,
            "initCapacity" -> 10,
            "clientProvider" -> "scromium.thrift.ThriftClientProvider")

        val cassandra = Cassandra.start(conf)

java.lang.reflect.InvocationTargetException

ceocoder

java.lang.ExceptionInInitializerError
	at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34)
	at scala.collection.mutable.ArrayOps.foreach(ArrayOps.scala:34)
	at scala.actors.Actor$class.receive(Actor.scala:524)
	at scala.actors.Reactor$class.seq(Reactor.scala:280)
	at scala.actors.Reactor$$anon$3.andThen(Reactor.scala:258)
	at scala.actors.Combinators$class.loop(Combinators.scala:26)
	at scala.actors.Reactor$$anonfun$dostart$1.apply(Reactor.scala:222)
	at scala.actors.Reactor$$anonfun$dostart$1.apply(Reactor.scala:222)
	at scala.actors.ReactorTask.run(ReactorTask.scala:36)

ceocoder

Code,

object EnterTheDragon {

    def main(args: Array[String]) {

        val conf = Map(
            "seedHost" -> "127.0.0.1",
            "seedPort" -> 9160,
            "maxIdle" -> 10,

ceocoder

class SuperSliceSelector(
    rows: List[Array[Byte]],
    slice: Slice) extends SuperReadable with Deletable {

    def toRead(cf: String) =
        new Read(rows, cf, slice = Some(slice))

    def toDelete(cf: String, clock: Clock) =
        new Delete(rows, cf, slice = Some(slice), clock = clock)

ceocoder

HTTP ERROR 500

Problem accessing /solandra/emailreal.user-new-3062/select. Reason:

    Field cache data missing

java.io.IOException: Field cache data missing
	at org.apache.lucene.search.LucandraFieldCache.getFieldCacheEntries(LucandraFieldCache.java:852)
	at org.apache.lucene.search.LucandraFieldCache.access$000(LucandraFieldCache.java:36)
	at org.apache.lucene.search.LucandraFieldCache$LongCache.createValue(LucandraFieldCache.java:625)

ceocoder

#Set to true if you want solandra to compress fields + meta data
#This will size on disk at the cost of indexing speed
solandra.compression = false

#The consistency level of solandra reads and writes
solandra.consistency = ONE

#The number of milliseconds solandra will wait before
#checking to see if it's cache needs to be invalidated

ceocoder

    private final ConcurrentMap<String, ShardInfo>                   indexShards     = new MapMaker().makeMap();                             

    private static final Logger                                      logger          = Logger.getLogger(CassandraIndexManager.class);

    private class ShardInfo
    {
        public final String                                   indexName;
        public final long                                     ttl    = System.currentTimeMillis()
                                                                             + (expirationTime * 1000) - 1000;
        public final ConcurrentSkipListMap<Integer, NodeInfo> shards = new ConcurrentSkipListMap<Integer, NodeInfo>();