Package cz.o2.proxima.beam.core.direct.io

Class OffsetRestrictionTracker

java.lang.Object

org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker<OffsetRestrictionTracker.OffsetRange,Offset>

cz.o2.proxima.beam.core.direct.io.OffsetRestrictionTracker

public class OffsetRestrictionTracker
extends org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker<OffsetRestrictionTracker.OffsetRange,Offset>

A RestrictionTracker for Offsets read from CommitLogReader

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	OffsetRestrictionTracker.OffsetRange

Nested classes/interfaces inherited from class org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker

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 extends java.lang.Object>

Method Summary

Modifier and Type	Method	Description
void	checkDone()
OffsetRestrictionTracker.OffsetRange	currentRestriction()
org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker.Progress	getProgress()
org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker.IsBounded	isBounded()
boolean	tryClaim(Offset position)
org.apache.beam.sdk.transforms.splittabledofn.SplitResult<OffsetRestrictionTracker.OffsetRange>	trySplit(double fractionOfRemainder)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

tryClaim

public boolean tryClaim(Offset position)

Specified by:

tryClaim in class org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker<OffsetRestrictionTracker.OffsetRange,Offset>

currentRestriction

public OffsetRestrictionTracker.OffsetRange currentRestriction()

Specified by:

currentRestriction in class org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker<OffsetRestrictionTracker.OffsetRange,Offset>

trySplit

@Nullable
public org.apache.beam.sdk.transforms.splittabledofn.SplitResult<OffsetRestrictionTracker.OffsetRange> trySplit(double fractionOfRemainder)

Specified by:

trySplit in class org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker<OffsetRestrictionTracker.OffsetRange,Offset>

checkDone

public void checkDone()
               throws java.lang.IllegalStateException

Specified by:

checkDone in class org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker<OffsetRestrictionTracker.OffsetRange,Offset>

Throws:

java.lang.IllegalStateException

isBounded

public org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker.IsBounded isBounded()

Specified by:

isBounded in class org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker<OffsetRestrictionTracker.OffsetRange,Offset>

getProgress

public org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker.Progress getProgress()