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