Spark Streaming has StreamingContext.socketStream() http://spark.apache.org/docs/1.2.1/api/java/org/apache/spark/streaming/StreamingContext.html#socketStream(java.lang.String, int, scala.Function1, org.apache.spark.storage.StorageLevel, scala.reflect.ClassTag)
TD On Mon, Mar 9, 2015 at 11:37 AM, Cui Lin <cui....@hds.com> wrote: > Dear all, > > Could you send me a list for input data source that spark streaming > could support? > My list is HDFS, Kafka, textfile?… > > I am wondering if spark streaming could directly read data from certain > port (443 e.g.) that my devices directly send to? > > > > Best regards, > > Cui Lin >
