org.apache.beam.sdk.extensions.ordered

Class OrderedProcessingStatus

java.lang.Object

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

@DefaultSchema(value=AutoValueSchema.class)
public abstract class OrderedProcessingStatus
extends java.lang.Object

Indicates the status of ordered processing for a particular key.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OrderedProcessingStatus.Builder

Constructor Summary

Constructors

Constructor and Description
OrderedProcessingStatus()

Method Summary

Modifier and Type	Method and Description
static OrderedProcessingStatus	create(java.lang.Long lastProcessedSequence, long numberOfBufferedEvents, java.lang.Long earliestBufferedSequence, java.lang.Long latestBufferedSequence, long numberOfReceivedEvents, long resultCount, long duplicateCount, boolean lastEventReceived)
boolean	equals(java.lang.Object obj)
abstract long	getDuplicateCount()
abstract java.lang.Long	getEarliestBufferedSequence()
abstract java.lang.Long	getLastProcessedSequence()
abstract java.lang.Long	getLatestBufferedSequence()
abstract long	getNumberOfBufferedEvents()
abstract long	getNumberOfReceivedEvents()
abstract long	getResultCount()
abstract Instant	getStatusDate()
int	hashCode()
abstract boolean	isLastEventReceived()

Methods inherited from class java.lang.Object

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

Constructor Detail

OrderedProcessingStatus

public OrderedProcessingStatus()

Method Detail

create

public static OrderedProcessingStatus create(@Nullable
                                             java.lang.Long lastProcessedSequence,
                                             long numberOfBufferedEvents,
                                             @Nullable
                                             java.lang.Long earliestBufferedSequence,
                                             @Nullable
                                             java.lang.Long latestBufferedSequence,
                                             long numberOfReceivedEvents,
                                             long resultCount,
                                             long duplicateCount,
                                             boolean lastEventReceived)

getLastProcessedSequence

@Nullable
public abstract java.lang.Long getLastProcessedSequence()

Returns:

Last sequence processed. If null is returned - no elements for the given key and window have been processed yet.

getNumberOfBufferedEvents

public abstract long getNumberOfBufferedEvents()

Returns:

Number of events received out of sequence and buffered.

getEarliestBufferedSequence

@Nullable
public abstract java.lang.Long getEarliestBufferedSequence()

Returns:

Earliest buffered sequence. If null is returned - there are no buffered events.

getLatestBufferedSequence

@Nullable
public abstract java.lang.Long getLatestBufferedSequence()

Returns:

Latest buffered sequence. If null is returned - there are no buffered events.

getNumberOfReceivedEvents

public abstract long getNumberOfReceivedEvents()

Returns:

Total number of events received for the given key and window.

getDuplicateCount

public abstract long getDuplicateCount()

Returns:

Number of duplicate events which were output in OrderedEventProcessorResult.unprocessedEvents() PCollection

getResultCount

public abstract long getResultCount()

Returns:

Number of output results produced.

isLastEventReceived

public abstract boolean isLastEventReceived()

Returns:

Indicator that the last event for the given key and window has been received. It doesn't necessarily mean that all the events for the given key and window have been processed. Use getNumberOfBufferedEvents() == 0 and this indicator as the sign that the processing is complete.

getStatusDate

public abstract Instant getStatusDate()

Returns:

Timestamp of when the status was produced. It is not related to the event's timestamp.

equals

public final boolean equals(@Nullable
                            java.lang.Object obj)

Overrides:

equals in class java.lang.Object

hashCode

public final int hashCode()

Overrides:

hashCode in class java.lang.Object