|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
Object org.apache.spark.streaming.api.java.JavaDStream<T> org.apache.spark.streaming.api.java.JavaInputDStream<T>
public class JavaInputDStream<T>
A Java-friendly interface to InputDStream
.
Constructor Summary | |
---|---|
JavaInputDStream(InputDStream<T> inputDStream,
scala.reflect.ClassTag<T> classTag)
|
Method Summary | ||
---|---|---|
scala.reflect.ClassTag<T> |
classTag()
|
|
static
|
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 |
---|
public JavaInputDStream(InputDStream<T> inputDStream, scala.reflect.ClassTag<T> classTag)
Method Detail |
---|
public static <T> JavaInputDStream<T> fromInputDStream(InputDStream<T> inputDStream, scala.reflect.ClassTag<T> evidence$1)
InputDStream
to a Java-friendly
JavaInputDStream
.
inputDStream
- (undocumented)evidence$1
- (undocumented)
public InputDStream<T> inputDStream()
public scala.reflect.ClassTag<T> classTag()
classTag
in interface JavaDStreamLike<T,JavaDStream<T>,JavaRDD<T>>
classTag
in class JavaDStream<T>
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |