ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

A better way to read column value if you are sure the column exists in every row.

Browse source
This commit is contained in:
Rohit Rai 2013-06-03 12:48:35 +05:30
parent 6d8423fd1b
commit 56c64c4033
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
examples/src/main/scala/spark/examples/CassandraTest.scala
View file

@ -10,6 +10,8 @@ import java.util.SortedMap
import org.apache.cassandra.db.IColumn
import org.apache.cassandra.utils.ByteBufferUtil
import scala.collection.JavaConversions._
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/*
@ -60,9 +62,9 @@ object CassandraTest {
classOf[SortedMap[ByteBuffer, IColumn]])
// Let us first get all the paragraphs from the retrieved rows
val paraRdd = casRdd.flatMap {
val paraRdd = casRdd.map {
case (key, value) => {
value.filter(v => ByteBufferUtil.string(v._1).compareTo("para") == 0).map(v => ByteBufferUtil.string(v._2.value()))
ByteBufferUtil.string(value.get(ByteBufferUtil.bytes("para")).value())
}
}