Package org.apache.cassandra.hadoop.cql3
Class CqlBulkOutputFormat.NullOutputCommitter
- java.lang.Object
-
- org.apache.hadoop.mapreduce.OutputCommitter
-
- org.apache.cassandra.hadoop.cql3.CqlBulkOutputFormat.NullOutputCommitter
-
- Enclosing class:
- CqlBulkOutputFormat
public static class CqlBulkOutputFormat.NullOutputCommitter extends org.apache.hadoop.mapreduce.OutputCommitter
-
-
Constructor Summary
Constructors Constructor Description NullOutputCommitter()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
abortTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
void
cleanupJob(org.apache.hadoop.mapreduce.JobContext jobContext)
void
commitTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
boolean
needsTaskCommit(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
void
setupJob(org.apache.hadoop.mapreduce.JobContext jobContext)
void
setupTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
-
-
-
Method Detail
-
abortTask
public void abortTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
- Specified by:
abortTask
in classorg.apache.hadoop.mapreduce.OutputCommitter
-
cleanupJob
public void cleanupJob(org.apache.hadoop.mapreduce.JobContext jobContext)
- Overrides:
cleanupJob
in classorg.apache.hadoop.mapreduce.OutputCommitter
-
commitTask
public void commitTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
- Specified by:
commitTask
in classorg.apache.hadoop.mapreduce.OutputCommitter
-
needsTaskCommit
public boolean needsTaskCommit(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
- Specified by:
needsTaskCommit
in classorg.apache.hadoop.mapreduce.OutputCommitter
-
setupJob
public void setupJob(org.apache.hadoop.mapreduce.JobContext jobContext)
- Specified by:
setupJob
in classorg.apache.hadoop.mapreduce.OutputCommitter
-
setupTask
public void setupTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
- Specified by:
setupTask
in classorg.apache.hadoop.mapreduce.OutputCommitter
-
-