Package | Description |
---|---|
org.apache.tez.dag.api | |
org.apache.tez.runtime.api.events |
Modifier and Type | Method and Description |
---|---|
int |
EdgeManagerPluginOnDemand.routeInputErrorEventToSource(InputReadErrorEvent event,
int destinationTaskIndex,
int destinationFailedInputIndex)
Return the source task index to which to send the input error event
|
abstract int |
EdgeManagerPlugin.routeInputErrorEventToSource(InputReadErrorEvent event,
int destinationTaskIndex,
int destinationFailedInputIndex)
Return the source task index to which to send the input error event
|
Modifier and Type | Method and Description |
---|---|
static InputReadErrorEvent |
InputReadErrorEvent.create(String diagnostics,
int index,
int version)
Creates an InputReadErrorEvent from less parameters, supposed to be used from tests only.
|
static InputReadErrorEvent |
InputReadErrorEvent.create(String diagnostics,
int index,
int version,
boolean isLocalFetch,
boolean isDiskErrorAtSource,
String destinationLocalhostName) |
static InputReadErrorEvent |
InputReadErrorEvent.create(String diagnostics,
int index,
int version,
int numFailures,
boolean isLocalFetch,
boolean isDiskErrorAtSource,
String destinationLocalhostName)
Create an InputReadErrorEvent.
|
Copyright © 2024 Apache Software Foundation. All rights reserved.