You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@spark.apache.org by Nagu Kothapalli <na...@gmail.com> on 2016/01/22 08:12:37 UTC

Spark Streaming - Custom ReceiverInputDStream ( Custom Source) In java

Hi All

Facing an Issuee With CustomInputDStream object in java



*public CustomInputDStream(StreamingContext ssc_, ClassTag<Text> classTag)*
* {*
* super(ssc_, classTag);*
* }*
Can you help me to create the Instance in above class with *ClassTag* In
java

Re: Spark Streaming - Custom ReceiverInputDStream ( Custom Source) In java

Posted by Tathagata Das <td...@databricks.com>.

See how other Java wrapper classes use JavaSparkContext.fakeClassTag

example;
https://github.com/apache/spark/blob/master/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaMapWithStateDStream.scala

On Fri, Jan 22, 2016 at 2:00 AM, Nagu Kothapalli <na...@gmail.com>
wrote:

> Hi
>
> Anyone have any idea on *ClassTag<Text> in spark context..*
>
> On Fri, Jan 22, 2016 at 12:42 PM, Nagu Kothapalli <
> nagukothapalli9@gmail.com> wrote:
>
>> Hi All
>>
>> Facing an Issuee With CustomInputDStream object in java
>>
>>
>>
>> *public CustomInputDStream(StreamingContext ssc_, ClassTag<Text>
>> classTag)*
>> * {*
>> * super(ssc_, classTag);*
>> * }*
>> Can you help me to create the Instance in above class with *ClassTag* In
>> java
>>
>
>

Re: Spark Streaming - Custom ReceiverInputDStream ( Custom Source) In java

Posted by Nagu Kothapalli <na...@gmail.com>.

Hi

Anyone have any idea on *ClassTag<Text> in spark context..*

On Fri, Jan 22, 2016 at 12:42 PM, Nagu Kothapalli <nagukothapalli9@gmail.com
> wrote:

> Hi All
>
> Facing an Issuee With CustomInputDStream object in java
>
>
>
> *public CustomInputDStream(StreamingContext ssc_, ClassTag<Text> classTag)*
> * {*
> * super(ssc_, classTag);*
> * }*
> Can you help me to create the Instance in above class with *ClassTag* In
> java
>