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) Creates an InputReadErrorEvent from less parameters, supposed to be used from tests only.
static InputReadErrorEvent	create(String diagnostics, int index, int version, boolean isLocalFetch, boolean isDiskErrorAtSource, String destinationLocalhostName)
static InputReadErrorEvent	create(String diagnostics, int index, int version, int numFailures, boolean isLocalFetch, boolean isDiskErrorAtSource, String destinationLocalhostName) Create an InputReadErrorEvent.
boolean	equals(Object o)
String	getDestinationLocalhostName()
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)

Creates an InputReadErrorEvent from less parameters, supposed to be used from tests only.

Parameters:

diagnostics -

index -

version -

Returns:

InputReadErrorEvent instance

create

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

create

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

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()

getDestinationLocalhostName

public String getDestinationLocalhostName()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object