Kafka Support new topic subscriptions without requiring restart of the streaming context

2016-08-07 Thread r7raul1...@163.com
How to add new topic to kafka without requiring restart of the streaming 
context?



r7raul1...@163.com


How to create a Row from a List or Array in Spark using Scala

2015-02-28 Thread r7raul1...@163.com
import org.apache.spark.sql.catalyst.expressions._

val values: JavaArrayList[Any] = new JavaArrayList()
computedValues = Row(values.get(0),values.get(1)) //It is not good by use 
get(index).  How to create a Row from a List or Array in Spark using Scala .



r7raul1...@163.com