Source

Typically, its getBatch will construct new DataSource.

Inside of runBatch of StreamExecution, runBatch is invoked to construct the new DataSource though source.getBatch. Later on, StreamingExecutionRelation of the logicalPlan in StreamExecution is replaced by the newly constructed DataSource, resulting in withNewSources.