public static class ParquetIO.ReadFiles.BlockTracker extends OffsetRangeTracker
RestrictionTracker.HasProgress, RestrictionTracker.IsBounded, RestrictionTracker.Progress, RestrictionTracker.TruncateResult<RestrictionT>
lastAttemptedOffset, lastClaimedOffset, range
|Constructor and Description|
|Modifier and Type||Method and Description|
A representation for the amount of known completed and known remaining work.
checkDone, currentRestriction, isBounded, toString, tryClaim, trySplit
public BlockTracker(OffsetRange range, long totalByteSize, long recordCount)
public void makeProgress() throws java.io.IOException
public RestrictionTracker.Progress getProgress()
It is up to each restriction tracker to convert between their natural representation of
completed and remaining work and the
double representation. For example:
message bytesthat have processed and the number of messages or number of
message bytesthat are outstanding.
The work completed and work remaining must be of the same scale whether that be number of messages or number of bytes and should never represent two distinct unit types.