yangzhe1991

package main
import (
	"runtime"
	"log"
	"os"
	"strconv"
	"time"
	"net"
	"fmt"
	"sync/atomic"

yangzhe1991

2014-12-11 13:13:42
Full thread dump Java HotSpot(TM) 64-Bit Server VM (24.51-b03 mixed mode):

"MemtablePostFlush:13" daemon prio=10 tid=0x00000000122f5800 nid=0x6311 waiting on condition [0x00000000467d7000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000645922050> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
	at java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)

yangzhe1991

Session session = getSession();
 
//update
Statement exampleQuery = QueryBuilder.update("keyspace","table").with(QueryBuilder.set("height", 180))
        .and(QueryBuilder.set("width", 300)).where(QueryBuilder.eq("id", 5145924587302797538L));
session.execute(exampleQuery);
 
//insert
exampleQuery= QueryBuilder.insertInto("keyspace","table").value("id",12245L)
        .value("data",ByteBuffer.wrap(new byte[]{0x11})).ifNotExists();