@Internal
public class DetectNewPartitionsTracker
extends org.apache.beam.sdk.transforms.splittabledofn.GrowableOffsetRangeTracker
org.apache.beam.sdk.transforms.splittabledofn.GrowableOffsetRangeTracker.RangeEndEstimator
org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker.HasProgress, org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker.IsBounded, org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker.Progress, org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker.TruncateResult<RestrictionT>
Constructor and Description |
---|
DetectNewPartitionsTracker(long start) |
Modifier and Type | Method and Description |
---|---|
@Nullable org.apache.beam.sdk.transforms.splittabledofn.SplitResult<org.apache.beam.sdk.io.range.OffsetRange> |
trySplit(double fractionOfRemainder) |
getProgress, isBounded