add Split stream along with some tests
ignore nil from mapper emitted data
add bufferSize option
Merge pull request #1 from virgo-agent-toolkit/songgao/init

add Split stream along with some tests