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 <[email protected]> wrote: > Hi > > Anyone have any idea on *ClassTag<Text> in spark context..* > > On Fri, Jan 22, 2016 at 12:42 PM, Nagu Kothapalli < > [email protected]> 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 >> > >
