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 java.lang.Object

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	UnprocessedEvent.Reason

Constructor Summary

Constructors

Constructor and Description
UnprocessedEvent()

Method Summary

Modifier and Type	Method and Description
static <EventT> UnprocessedEvent<EventT>	create(EventT event, java.lang.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 java.lang.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 Detail

UnprocessedEvent

public UnprocessedEvent()

Method Detail

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,
                                                       java.lang.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 java.lang.String getExplanation()