org.apache.tez.runtime.api.events

Class InputReadErrorEvent

java.lang.Object

org.apache.tez.runtime.api.Event

org.apache.tez.runtime.api.events.InputReadErrorEvent

@InterfaceAudience.Public
public final class InputReadErrorEvent
extends Event

Event generated by an Input to indicate error when trying to retrieve data. This is not necessarily a fatal event - it's an indication to the AM to retry source data generation.

Method Summary

Modifier and Type	Method and Description
static InputReadErrorEvent	create(String diagnostics, int index, int version)
static InputReadErrorEvent	create(String diagnostics, int index, int version, boolean isLocalFetch, boolean isDiskErrorAtSource)
static InputReadErrorEvent	create(String diagnostics, int index, int version, int numFailures, boolean isLocalFetch, boolean isDiskErrorAtSource) Create an InputReadErrorEvent.
boolean	equals(Object o)
String	getDiagnostics()
int	getIndex()
int	getNumFailures()
int	getVersion()
int	hashCode()
boolean	isDiskErrorAtSource()
boolean	isLocalFetch()

Methods inherited from class java.lang.Object

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

Method Detail

create

public static InputReadErrorEvent create(String diagnostics,
                                         int index,
                                         int version,
                                         boolean isLocalFetch,
                                         boolean isDiskErrorAtSource)

create

public static InputReadErrorEvent create(String diagnostics,
                                         int index,
                                         int version)

create

public static InputReadErrorEvent create(String diagnostics,
                                         int index,
                                         int version,
                                         int numFailures,
                                         boolean isLocalFetch,
                                         boolean isDiskErrorAtSource)

Create an InputReadErrorEvent.

getDiagnostics

public String getDiagnostics()

getIndex

public int getIndex()

getVersion

public int getVersion()

getNumFailures

public int getNumFailures()

Returns:

number of failures

isLocalFetch

public boolean isLocalFetch()

isDiskErrorAtSource

public boolean isDiskErrorAtSource()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object