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

Constructors

Constructor and Description
JavaInputDStream(InputDStream<T> inputDStream, scala.reflect.ClassTag<T> classTag)

Method Summary

Modifier and Type	Method and Description
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, foreachRDD, foreachRDD, glom, map, mapPartitions, mapPartitionsToPair, mapToPair, print, print, reduce, 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>