org.apache.tez.runtime.api.events

Class InputFailedEvent

java.lang.Object

org.apache.tez.runtime.api.Event

org.apache.tez.runtime.api.events.InputFailedEvent

@InterfaceAudience.Private
public class InputFailedEvent
extends Event

Event sent from the AM to an Input to indicate that one of it's sources has failed - effectively the input is no longer available from the particular source. Users are not expected to send this event.

Constructor Summary

Constructors

Constructor and Description
InputFailedEvent()

Method Summary

Methods

Modifier and Type	Method and Description
static InputFailedEvent	create(int targetIndex, int version)
int	getTargetIndex()
int	getVersion()
InputFailedEvent	makeCopy(int targetIndex) Create a copy of the InputFailedEvent by adding a target input index The index of the physical input to which this event should be routed
void	setTargetIndex(int targetIndex)
void	setVersion(int version)

Methods inherited from class java.lang.Object

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

Constructor Detail

InputFailedEvent

@InterfaceAudience.Private
public InputFailedEvent()

Method Detail

create

@InterfaceAudience.Private
public static InputFailedEvent create(int targetIndex,
                                                int version)

makeCopy

@InterfaceAudience.Private
public InputFailedEvent makeCopy(int targetIndex)

Create a copy of the InputFailedEvent by adding a target input index The index of the physical input to which this event should be routed

Parameters:

targetIndex - The index of the physical input to which this InputFailedEvent should be routed

Returns:

copy of the InputFailedEvent with the target input index added

getTargetIndex

public int getTargetIndex()

setTargetIndex

@InterfaceAudience.Private
public void setTargetIndex(int targetIndex)

getVersion

public int getVersion()

setVersion

@InterfaceAudience.Private
public void setVersion(int version)