org.apache.tez.runtime.library.common

Class InputAttemptIdentifier

java.lang.Object

org.apache.tez.runtime.library.common.InputAttemptIdentifier

@InterfaceAudience.Private
public class InputAttemptIdentifier
extends Object

Container for a task number and an attempt number for the task.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	InputAttemptIdentifier.SPILL_INFO

Field Summary

Fields

Modifier and Type	Field and Description
static String	PATH_PREFIX

Constructor Summary

Constructors

Constructor and Description
InputAttemptIdentifier(int inputIndex, int attemptNumber)
InputAttemptIdentifier(int inputIdentifier, int attemptNumber, String pathComponent)
InputAttemptIdentifier(int inputIdentifier, int attemptNumber, String pathComponent, boolean shared)
InputAttemptIdentifier(int inputIdentifier, int attemptNumber, String pathComponent, boolean shared, InputAttemptIdentifier.SPILL_INFO fetchTypeInfo, int spillEventId)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	canRetrieveInputInChunks()
boolean	equals(Object obj)
int	getAttemptNumber()
InputAttemptIdentifier.SPILL_INFO	getFetchTypeInfo()
int	getInputIdentifier()
String	getPathComponent()
int	getSpillEventId()
int	hashCode()
boolean	isShared()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

PATH_PREFIX

public static final String PATH_PREFIX

See Also:

Constant Field Values

Constructor Detail

InputAttemptIdentifier

public InputAttemptIdentifier(int inputIndex,
                      int attemptNumber)

InputAttemptIdentifier

public InputAttemptIdentifier(int inputIdentifier,
                      int attemptNumber,
                      String pathComponent)

InputAttemptIdentifier

public InputAttemptIdentifier(int inputIdentifier,
                      int attemptNumber,
                      String pathComponent,
                      boolean shared)

InputAttemptIdentifier

public InputAttemptIdentifier(int inputIdentifier,
                      int attemptNumber,
                      String pathComponent,
                      boolean shared,
                      InputAttemptIdentifier.SPILL_INFO fetchTypeInfo,
                      int spillEventId)

Method Detail

getInputIdentifier

public int getInputIdentifier()

getAttemptNumber

public int getAttemptNumber()

getPathComponent

public String getPathComponent()

isShared

public boolean isShared()

getFetchTypeInfo

public InputAttemptIdentifier.SPILL_INFO getFetchTypeInfo()

getSpillEventId

public int getSpillEventId()

canRetrieveInputInChunks

public boolean canRetrieveInputInChunks()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object