New: sparkdatastreaming