thanks a lot Terry
2016-07-26 12:03 GMT+08:00 Terry Hoo :
> Kevin,
>
> Try to create the StreamingContext as following:
>
> val ssc = new StreamingContext(spark.sparkContext, Seconds(2))
>
>
>
> On Tue, Jul 26, 2016 at 11:25 AM, kevin wrote:
>
>> hi,all:
>> I want to read data from kafka and reg
Kevin,
Try to create the StreamingContext as following:
val ssc = new StreamingContext(spark.sparkContext, Seconds(2))
On Tue, Jul 26, 2016 at 11:25 AM, kevin wrote:
> hi,all:
> I want to read data from kafka and regist as a table then join a jdbc
> table.
> My sample like this :
>
> val spa
hi,all:
I want to read data from kafka and regist as a table then join a jdbc table.
My sample like this :
val spark = SparkSession
.builder
.config(sparkConf)
.getOrCreate()
val jdbcDF = spark.read.format("jdbc").options(Map("url" ->
"jdbc:mysql://master1:3306/demo", "drive
