>>>>
>>>>> val rawStream = KinesisUtils.createStream(ssc, "erich-test",
>>>>> "kinesis.us-east-1.amazonaws.com", Duration(1000),
>>>>> InitialPositionInStream.TRIM_HORIZON, StorageLevel.MEM
>>> "kinesis.us-east-1.amazonaws.com", Duration(1000),
>>>> InitialPositionInStream.TRIM_HORIZON, StorageLevel.MEMORY_ONLY)
>>>> rawStream.map(msg => new String(msg)).print
>>>>
>>>> val loaderStream
;>> rawStream.map(msg => new String(msg)).print
>>>
>>> val loaderStream = KinesisUtils.createStream(
>>> ssc,
>>> "dev-loader",
>>> "kinesis.us-east-1.amazonaws.com",
>>> Duration(1000),
>>> Ini
;dev-loader",
>> "kinesis.us-east-1.amazonaws.com",
>> Duration(1000),
>> InitialPositionInStream.TRIM_HORIZON,
>> StorageLevel.MEMORY_ONLY)
>>
>> val loader = loaderStream.map(msg => new String(msg)).print
sis.us-east-1.amazonaws.com",
> Duration(1000),
> InitialPositionInStream.TRIM_HORIZON,
> StorageLevel.MEMORY_ONLY)
>
> val loader = loaderStream.map(msg => new String(msg)).print
>
> ssc.start()
>
> Thanks,
> -Erich
>
>
>
> --
> View this
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Multiple-Kinesis-Streams-in-a-single-Streaming-job-tp22889.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
-
To uns
