Skip to content

Latest commit

 

History

History
28 lines (14 loc) · 538 Bytes

File metadata and controls

28 lines (14 loc) · 538 Bytes

Spark-Streaming-Test

spark streamingのチュートリアルプログラム

Description

echo-serverを建ててspark-streamingが動作していることを確認することが可能

Requirement

Python2系が必要

Usage

echo_sercer.pyを起動

$ python echo_server.py

spark-streaming-sample直下に移動

$sbt

$run

echo_serverに接続すると、echo_serverがクライアントへ1秒毎に英文を流す。 sparkは送られてきた英文の中からbutを含む英文を5秒毎に出力する。