headerSize = readBuffer.length - decoder.inputStream().available() | headerSize = countStream.getBytesRead() - preHeaderCount | readBuffer.length - decoder.inputStream().available() | countStream.getBytesRead() - preHeaderCount | beam | 32a6cde4e43726849713a7183c66aa28f43b0868 | org.apache.beam.sdk.io.AvroSource.AvroReader | | | xyz | readBuffer.length - decoder.inputStream().available() |
---|
| | xyz | countStream.getBytesRead() - preHeaderCount |
---|
| AssignedTo | False |