OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
headerSize = readBuffer.length - decoder.inputStream().available()headerSize = countStream.getBytesRead() - preHeaderCountreadBuffer.length - decoder.inputStream().available()countStream.getBytesRead() - preHeaderCountbeam32a6cde4e43726849713a7183c66aa28f43b0868org.apache.beam.sdk.io.AvroSource.AvroReader
_1518
_2513
_1headerSize
_2headerSize
xyzreadBuffer.length - decoder.inputStream().available()
xyzcountStream.getBytesRead() - preHeaderCount
AssignedToFalse