Skip to content

F
ffm-baseline
Commit b73c6bc9 authored by 张彦钊's avatar 张彦钊
Browse files
Options

change

parent fcbbd898
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 0 deletions
ctr.py
View file @ b73c6bc9
...@@ -196,6 +196,7 @@ def m_decoder(s): ...@@ -196,6 +196,7 @@ def m_decoder(s):
if __name__ == '__main__': if __name__ == '__main__':
# Spark-Streaming-Kafka # Spark-Streaming-Kafka
write_to_kafka()
sc = SparkContext(conf=SparkConf().setMaster("spark://nvwa01:7077").setAppName("kafka_test").set("spark.io.compression.codec", "lzf")) sc = SparkContext(conf=SparkConf().setMaster("spark://nvwa01:7077").setAppName("kafka_test").set("spark.io.compression.codec", "lzf"))
ssc = SQLContext(sc) ssc = SQLContext(sc)
ssc = StreamingContext(sc, 10) ssc = StreamingContext(sc, 10)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment