Skip to content

Commit

Permalink
Update README.md
Browse files Browse the repository at this point in the history
  • Loading branch information
imarios authored Jan 6, 2017
1 parent 8c27714 commit f66c505
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -146,13 +146,13 @@ Connect to the Spark VM
vagrant ssh spark1
```

Start Spark shell with the proper kafka dependecies. The shell we pre-load the commands from [streaming.scala](scripts/streaming.scala).
Start Spark shell with the proper kafka dependecies. On start-up the shell pre-loads the commands from [streaming.scala](scripts/streaming.scala).

```bash
/vagrant/scripts/run_spark_streaming.sh t1
```

When the shell stops loading, go ahead and implement the most basic consumer (count events in each 10 second interval)
When the shell stops loading, go ahead and implement the most basic consumer that counts events in each 10 seconds interval.

```
Welcome to
Expand Down

0 comments on commit f66c505

Please sign in to comment.