Spark Streaming - Custom ReceiverInputDStream ( Custom Source) In java

[Nagu Kothapalli]

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