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

Object
  org.apache.spark.streaming.api.java.JavaDStream<T>
      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>