Package org.apache.beam.sdk.extensions.ordered

Class OrderedProcessingStatus.Builder

java.lang.Object

org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus.Builder

Enclosing class:

OrderedProcessingStatus

public abstract static class OrderedProcessingStatus.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
abstract OrderedProcessingStatus	build()
abstract OrderedProcessingStatus.Builder	setDuplicateCount(long value)
abstract OrderedProcessingStatus.Builder	setEarliestBufferedSequence(Long value)
abstract OrderedProcessingStatus.Builder	setLastContiguousSequenceRange(ContiguousSequenceRange value)
abstract OrderedProcessingStatus.Builder	setLastEventReceived(boolean value)
abstract OrderedProcessingStatus.Builder	setLastProcessedSequence(Long value)
abstract OrderedProcessingStatus.Builder	setLatestBufferedSequence(Long value)
abstract OrderedProcessingStatus.Builder	setNumberOfBufferedEvents(long value)
abstract OrderedProcessingStatus.Builder	setNumberOfReceivedEvents(long value)
abstract OrderedProcessingStatus.Builder	setResultCount(long value)
abstract OrderedProcessingStatus.Builder	setStatusDate(Instant value)

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

setLastProcessedSequence

public abstract OrderedProcessingStatus.Builder setLastProcessedSequence(@Nullable
 Long value)

setNumberOfBufferedEvents

public abstract OrderedProcessingStatus.Builder setNumberOfBufferedEvents(long value)

setEarliestBufferedSequence

public abstract OrderedProcessingStatus.Builder setEarliestBufferedSequence(@Nullable
 Long value)

setLatestBufferedSequence

public abstract OrderedProcessingStatus.Builder setLatestBufferedSequence(@Nullable
 Long value)

setNumberOfReceivedEvents

public abstract OrderedProcessingStatus.Builder setNumberOfReceivedEvents(long value)

setDuplicateCount

public abstract OrderedProcessingStatus.Builder setDuplicateCount(long value)

setResultCount

public abstract OrderedProcessingStatus.Builder setResultCount(long value)

setLastEventReceived

public abstract OrderedProcessingStatus.Builder setLastEventReceived(boolean value)

setStatusDate

public abstract OrderedProcessingStatus.Builder setStatusDate(Instant value)

setLastContiguousSequenceRange

public abstract OrderedProcessingStatus.Builder setLastContiguousSequenceRange(@Nullable
 ContiguousSequenceRange value)

build

public abstract OrderedProcessingStatus build()