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