org.apache.hive.hcatalog.mapreduce

Class TaskCommitContextRegistry

java.lang.Object

org.apache.hive.hcatalog.mapreduce.TaskCommitContextRegistry

public class TaskCommitContextRegistry
extends Object

Singleton Registry to track the commit of TaskAttempts. Used to manage commits for Tasks that create dynamic-partitions.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	TaskCommitContextRegistry.TaskCommitterProxy Implement this interface to register call-backs for committing TaskAttempts.

Method Summary

Modifier and Type	Method and Description
void	abortTask(org.apache.hadoop.mapreduce.TaskAttemptContext context) Trigger abort for TaskAttempt, as specified by the TaskAttemptContext argument.
void	commitTask(org.apache.hadoop.mapreduce.TaskAttemptContext context) Trigger commit for TaskAttempt, as specified by the TaskAttemptContext argument.
void	discardCleanupFor(org.apache.hadoop.mapreduce.TaskAttemptContext context) Method to discard the committer call-backs for a specified TaskAttemptID.
static TaskCommitContextRegistry	getInstance() Singleton instance getter.
void	register(org.apache.hadoop.mapreduce.TaskAttemptContext context, TaskCommitContextRegistry.TaskCommitterProxy committer) Method to register call-backs to control commits and aborts of TaskAttempts.

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static TaskCommitContextRegistry getInstance()

Singleton instance getter.

commitTask

public void commitTask(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                throws IOException

Trigger commit for TaskAttempt, as specified by the TaskAttemptContext argument.

Throws:

IOException

abortTask

public void abortTask(org.apache.hadoop.mapreduce.TaskAttemptContext context)
               throws IOException

Trigger abort for TaskAttempt, as specified by the TaskAttemptContext argument.

Throws:

IOException

register

public void register(org.apache.hadoop.mapreduce.TaskAttemptContext context,
                     TaskCommitContextRegistry.TaskCommitterProxy committer)
              throws IOException

Method to register call-backs to control commits and aborts of TaskAttempts.

Parameters:

context - The TaskAttemptContext instance for the task-attempt, identifying the output.

committer - Instance of TaskCommitterProxy, to commit/abort a TaskAttempt.

Throws:

IOException - On failure.

discardCleanupFor

public void discardCleanupFor(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                       throws IOException

Method to discard the committer call-backs for a specified TaskAttemptID.

Parameters:

context - The TaskAttemptContext instance for the task-attempt, identifying the output.

Throws:

IOException - On failure.