Merge branch 'dev'
fixing... if pred job has multiple instance, only one worker is selected as a input target. not fixed yet...
small fix
Merge branch 'parallel' of github.com:laysakura/shellstreaming into dev
Merge branch 'master' of github.com:laysakura/shellstreaming
Merge branch 'dev' of github.com:laysakura/shellstreaming into dev

removes some noisy log

Signed-off-by: Sho Nakatani <lay.sakura@gmail.com>

Conflicts:
	example/02_FilterSplit.py
	shellstreaming/ostream/io_stream.py
	shellstreaming/scheduler/worker_sched_single_thread.py
	shellstreaming/worker/worker_server_service.py
adds operator.ShellCmd
adds example
adds example/06
changes output file name
adds istream.RandSentence
adds wordcount application
example/50 with NUM_RECORDS=1890 works, but 1891 does not work...
minor fix
istream makes batches not by timespan but by record count
removes log output
removes log output
test works correctly
minor fix
adds RotateSentence