Hi,
I've heard there has been work towards porting Scio Dataflow Scala API to
Beam.
I was wondering at what stage this is in, where is this happening (Saw no
branch in BEAM repository, and one in Scio repository that is dependent on
beam 0.2.0-INCUBATING) and if there is a way to contribute?
UnboundedReader exposes method getTotalBacklogBytes() which promises:
* Returns the size of the backlog of unread data in the underlying data
source represented by split of this source.
But there are no implementations of this method in any source, I'm assuming
that this is because splits are
