refactor
refactor of queueStream()
rafactor of foreachRDD()
move check of window into Python
add more docs, add first(), take()