pub fn create_dstream<'a>() -> DStream<'a>