[streaming] Streaming jobgraph and vertex refactor to match recent runtime changes