public class SparkFileInputStream extends org.apache.spark.streaming.api.java.JavaInputDStream<MRData>
Modifier and Type | Class and Description |
---|---|
static class |
SparkFileInputStream.MRDataInputStream |
Constructor and Description |
---|
SparkFileInputStream(org.apache.spark.streaming.api.java.JavaStreamingContext stream_context,
String directory,
boolean is_binary) |
classTag, fromInputDStream, inputDStream
cache, checkpoint, compute, context, count, countByValue, countByValue, countByValueAndWindow, countByValueAndWindow, countByWindow, dstream, filter, flatMap, flatMapToPair, foreach, foreach, foreachRDD, foreachRDD, fromDStream, glom, map, mapPartitions, mapPartitionsToPair, mapToPair, persist, persist, print, reduce, reduceByWindow, reduceByWindow, repartition, scalaIntToJavaLong, slice, transform, transform, transformToPair, transformToPair, transformWith, transformWith, transformWithToPair, transformWithToPair, union, window, window, wrapRDD
SparkFileInputStream(org.apache.spark.streaming.api.java.JavaStreamingContext stream_context, String directory, boolean is_binary)
Copyright © 2013-2015 The Apache Software Foundation. All Rights Reserved.