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

Class UnprocessedEvent<EventT>

java.lang.Object

org.apache.beam.sdk.extensions.ordered.UnprocessedEvent<EventT>

Type Parameters:

EventT -

public abstract class UnprocessedEvent<EventT>
extends Object

Combines the source event which failed to process with the failure reason.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	UnprocessedEvent.Reason

Constructor Summary

Constructors

Constructor	Description
UnprocessedEvent()

Method Summary

Modifier and Type	Method	Description
static <EventT> UnprocessedEvent<EventT>	create(EventT event, Exception exception)	Create new unprocessed event which failed due to an exception thrown.
static <EventT> UnprocessedEvent<EventT>	create(EventT event, UnprocessedEvent.Reason reason)	Create new unprocessed event.
abstract EventT	getEvent()
abstract String	getExplanation()
abstract UnprocessedEvent.Reason	getReason()

Methods inherited from class java.lang.Object

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

Constructor Details

UnprocessedEvent

public UnprocessedEvent()

Method Details

create

public static <EventT> UnprocessedEvent<EventT> create(EventT event,
 UnprocessedEvent.Reason reason)

Create new unprocessed event.

Type Parameters:

EventT - type of the event

Parameters:

event - failed event

reason - for failure

Returns:

create

public static <EventT> UnprocessedEvent<EventT> create(EventT event,
 Exception exception)

Create new unprocessed event which failed due to an exception thrown.

Type Parameters:

EventT - type of the event

Parameters:

event - which failed

exception - which caused the failure

Returns:

getEvent

public abstract EventT getEvent()

getReason

public abstract UnprocessedEvent.Reason getReason()

getExplanation

@Nullable
public abstract String getExplanation()