<gh_stars>0
from pyspark import SparkContext
from pyspark.streaming import StreamingContext

sc = SparkContext("local[2]", "Contagem")
ssc = StreamingContext(sc,10)

pesquisa = ssc.textFileStream("file:///home/cloudera/spark/")

contagem = pesquisa.flatMap(lambda palavra: palavra.split(" "))
contagem = pesquisa.map(lambda pal: (pal,1))
contagem = contagem.reduceByKey(lambda a,b: a + b)

contagem.pprint()

ssc.start()
ssc.awaitTermination()  

from pyspark import SparkContext
from pyspark.streaming import StreamingContext

sc = SparkContext("local[2]", "Contagem")
ssc = StreamingContext(sc,10)

pesquisa = ssc.textFileStream("file:///home/cloudera/spark/")

contagem = pesquisa.flatMap(lambda palavra: palavra.split(" "))
contagem = pesquisa.map(lambda pal: (pal,1))
contagem = contagem.reduceByKey(lambda a,b: a + b)

contagem.pprint()

ssc.start()
ssc.awaitTermination()