Add alignToSchema option on datastream

[sksamuel]

Given a datastream it would be useful if we could apply a schema to it to return a new datastream which then is aligned with the the given schema. Any missing fields would result in an error.