Package org.apache.iceberg.mr.hive
Class TezUtil
- java.lang.Object
-
- org.apache.iceberg.mr.hive.TezUtil
-
public class TezUtil extends java.lang.Object
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static org.apache.hadoop.mapred.TaskAttemptContext
enrichContextWithAttemptWrapper(org.apache.hadoop.mapred.TaskAttemptContext taskAttemptContext)
Creates a new taskAttemptContext by replacing the taskAttemptID with a wrapped object.static org.apache.hadoop.mapred.JobContext
enrichContextWithVertexId(org.apache.hadoop.mapred.JobContext jobContext)
If the Tez vertex id is present in config, creates a new jobContext by appending the Tez vertex id to the jobID.static org.apache.hadoop.mapred.TaskAttemptID
taskAttemptWrapper(org.apache.hadoop.mapred.JobConf jc)
static org.apache.hadoop.mapred.TaskAttemptID
taskAttemptWrapper(org.apache.hadoop.mapred.TaskAttemptID attemptID)
-
-
-
Method Detail
-
enrichContextWithVertexId
public static org.apache.hadoop.mapred.JobContext enrichContextWithVertexId(org.apache.hadoop.mapred.JobContext jobContext)
If the Tez vertex id is present in config, creates a new jobContext by appending the Tez vertex id to the jobID. For the rationale behind this enrichment, please refer to point #1 in the docs ofTezUtil.TaskAttemptWrapper
.- Parameters:
jobContext
- original jobContext to be enriched- Returns:
- enriched jobContext
-
enrichContextWithAttemptWrapper
public static org.apache.hadoop.mapred.TaskAttemptContext enrichContextWithAttemptWrapper(org.apache.hadoop.mapred.TaskAttemptContext taskAttemptContext)
Creates a new taskAttemptContext by replacing the taskAttemptID with a wrapped object. For the rationale behind this enrichment, please refer to point #2 in the docs ofTezUtil.TaskAttemptWrapper
.- Parameters:
taskAttemptContext
- original taskAttemptContext to be enriched- Returns:
- enriched taskAttemptContext
-
taskAttemptWrapper
public static org.apache.hadoop.mapred.TaskAttemptID taskAttemptWrapper(org.apache.hadoop.mapred.TaskAttemptID attemptID)
-
taskAttemptWrapper
public static org.apache.hadoop.mapred.TaskAttemptID taskAttemptWrapper(org.apache.hadoop.mapred.JobConf jc)
-
-