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 and Description
Builder()

Method Summary

Modifier and Type	Method and Description
abstract OrderedProcessingStatus	build()
abstract OrderedProcessingStatus.Builder	setDuplicateCount(long value)
abstract OrderedProcessingStatus.Builder	setEarliestBufferedSequence(java.lang.Long 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(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(java.lang.Long value)

setNumberOfBufferedEvents

public abstract OrderedProcessingStatus.Builder setNumberOfBufferedEvents(long value)

setEarliestBufferedSequence

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

setLatestBufferedSequence

public abstract OrderedProcessingStatus.Builder setLatestBufferedSequence(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(Instant value)

build

public abstract OrderedProcessingStatus build()