org.apache.spark.streaming.api.java
Class JavaInputDStream<T>

Object
  extended by org.apache.spark.streaming.api.java.JavaDStream<T>
      extended by org.apache.spark.streaming.api.java.JavaInputDStream<T>
All Implemented Interfaces:
java.io.Serializable, JavaDStreamLike<T,JavaDStream<T>,JavaRDD<T>>
Direct Known Subclasses:
JavaReceiverInputDStream

public class JavaInputDStream<T>
extends JavaDStream<T>

A Java-friendly interface to InputDStream.

See Also:
Serialized Form

Constructor Summary
JavaInputDStream(InputDStream<T> inputDStream, scala.reflect.ClassTag<T> classTag)
           
 
Method Summary
 scala.reflect.ClassTag<T> classTag()
           
static
<T> JavaInputDStream<T>
fromInputDStream(InputDStream<T> inputDStream, scala.reflect.ClassTag<T> evidence$1)
          Convert a scala InputDStream to a Java-friendly JavaInputDStream.
 InputDStream<T> inputDStream()
           
 
Methods inherited from class org.apache.spark.streaming.api.java.JavaDStream
cache, compute, dstream, filter, fromDStream, persist, persist, repartition, union, window, window, wrapRDD
 
Methods inherited from class Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.spark.streaming.api.java.JavaDStreamLike
checkpoint, context, count, countByValue, countByValue, countByValueAndWindow, countByValueAndWindow, countByWindow, flatMap, flatMapToPair, foreach, foreach, foreachRDD, foreachRDD, glom, map, mapPartitions, mapPartitionsToPair, mapToPair, print, print, reduce, reduceByWindow, reduceByWindow, reduceByWindow, scalaIntToJavaLong, slice, transform, transform, transformToPair, transformToPair, transformWith, transformWith, transformWithToPair, transformWithToPair
 

Constructor Detail

JavaInputDStream

public JavaInputDStream(InputDStream<T> inputDStream,
                        scala.reflect.ClassTag<T> classTag)
Method Detail

fromInputDStream

public static <T> JavaInputDStream<T> fromInputDStream(InputDStream<T> inputDStream,
                                                       scala.reflect.ClassTag<T> evidence$1)
Convert a scala InputDStream to a Java-friendly JavaInputDStream.

Parameters:
inputDStream - (undocumented)
evidence$1 - (undocumented)
Returns:
(undocumented)

inputDStream

public InputDStream<T> inputDStream()

classTag

public scala.reflect.ClassTag<T> classTag()
Specified by:
classTag in interface JavaDStreamLike<T,JavaDStream<T>,JavaRDD<T>>
Overrides:
classTag in class JavaDStream<T>