OfflineSink doesn't support reading
OfflineSink doesn't support reading
in will completely cover these batches Return a new FlowToPipe with the write as a side effect
in will completely cover these batches Return a new FlowToPipe with the write as a side effect
Instances may choose to write out materialized streams by implementing this.
Instances may choose to write out materialized streams by implementing this. This is what readStream returns.
Wrapped for the new scalding sink API in terms of the above