Package 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:

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	Description
JavaInputDStream(InputDStream<T> inputDStream, scala.reflect.ClassTag<T> classTag)

Method Summary

Modifier and Type	Method	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 java.lang.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 Details

JavaInputDStream

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

Method Details

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>