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 java.lang.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(java.lang.Long value)
abstract OrderedProcessingStatus.Builder	setLastContiguousSequenceRange(ContiguousSequenceRange value)
abstract OrderedProcessingStatus.Builder	setLastEventReceived(boolean value)
abstract OrderedProcessingStatus.Builder	setLastProcessedSequence(java.lang.Long value)
abstract OrderedProcessingStatus.Builder	setLatestBufferedSequence(java.lang.Long value)
abstract OrderedProcessingStatus.Builder	setNumberOfBufferedEvents(long value)
abstract OrderedProcessingStatus.Builder	setNumberOfReceivedEvents(long value)
abstract OrderedProcessingStatus.Builder	setResultCount(long value)
abstract OrderedProcessingStatus.Builder	setStatusDate(org.joda.time.Instant value)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

setLastProcessedSequence

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

setNumberOfBufferedEvents

public abstract OrderedProcessingStatus.Builder setNumberOfBufferedEvents(long value)

setEarliestBufferedSequence

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

setLatestBufferedSequence

public abstract OrderedProcessingStatus.Builder setLatestBufferedSequence(@Nullable
                                                                          java.lang.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(org.joda.time.Instant value)

setLastContiguousSequenceRange

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

build

public abstract OrderedProcessingStatus build()