org.apache.beam.sdk.transforms.splittabledofn

Interface Backlogs.HasBacklog

All Known Subinterfaces:

Backlogs.HasPartitionedBacklog

All Known Implementing Classes:

ByteKeyRangeTracker, OffsetRangeTracker

Enclosing class:

Backlogs

public static interface Backlogs.HasBacklog

RestrictionTrackers which can provide a backlog should implement this interface. Implementations that do not implement this interface will be assumed to have an unknown backlog.

By default, the backlog partition identifier is represented as the encoded element and restriction pair. See Backlogs.HasPartitionedBacklog for RestrictionTrackers that report backlogs over a shared resource.

Method Summary

Modifier and Type	Method and Description
Backlog	getBacklog()

Method Detail

getBacklog

Backlog getBacklog()