org.apache.beam.sdk.transforms.splittabledofn

Class Backlogs

java.lang.Object

org.apache.beam.sdk.transforms.splittabledofn.Backlogs

public final class Backlogs
extends java.lang.Object

Definitions and convenience methods for reporting/consuming/updating backlogs.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Backlogs.HasBacklog RestrictionTrackers which can provide a backlog should implement this interface.
static interface	Backlogs.HasPartitionedBacklog RestrictionTrackers which can provide a backlog that is from a shared resource such as a message queue should implement this interface to provide the partition identifier.

Constructor Summary

Constructors

Constructor and Description
Backlogs()

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

Backlogs

public Backlogs()