Updated Branches: refs/heads/trunk 7a6e5f043 -> 5a3ffc090
who forgets to add files? I do. Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/5a3ffc09 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/5a3ffc09 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/5a3ffc09 Branch: refs/heads/trunk Commit: 5a3ffc0904e75152eb3e8fafd0b84ae499a94c77 Parents: 7a6e5f0 Author: Brandon Williams <[email protected]> Authored: Tue Feb 11 11:30:02 2014 -0600 Committer: Brandon Williams <[email protected]> Committed: Tue Feb 11 11:32:02 2014 -0600 ---------------------------------------------------------------------- .../cassandra/hadoop/ReporterWrapper.java | 57 ++++++++++++++++++++ 1 file changed, 57 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/5a3ffc09/src/java/org/apache/cassandra/hadoop/ReporterWrapper.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/hadoop/ReporterWrapper.java b/src/java/org/apache/cassandra/hadoop/ReporterWrapper.java new file mode 100644 index 0000000..9940ba4 --- /dev/null +++ b/src/java/org/apache/cassandra/hadoop/ReporterWrapper.java @@ -0,0 +1,57 @@ +package org.apache.cassandra.hadoop; + +import org.apache.hadoop.mapred.Counters; +import org.apache.hadoop.mapred.InputSplit; +import org.apache.hadoop.mapred.Reporter; +import org.apache.hadoop.mapreduce.StatusReporter; + +/** + * A reporter that works with both mapred and mapreduce APIs. + */ +public class ReporterWrapper extends StatusReporter implements Reporter { + private Reporter wrappedReporter; + + public ReporterWrapper(Reporter reporter) { + wrappedReporter = reporter; + } + + @Override + public Counters.Counter getCounter(Enum<?> anEnum) { + return wrappedReporter.getCounter(anEnum); + } + + @Override + public Counters.Counter getCounter(String s, String s1) { + return wrappedReporter.getCounter(s, s1); + } + + @Override + public void incrCounter(Enum<?> anEnum, long l) { + wrappedReporter.incrCounter(anEnum, l); + } + + @Override + public void incrCounter(String s, String s1, long l) { + wrappedReporter.incrCounter(s, s1, l); + } + + @Override + public InputSplit getInputSplit() throws UnsupportedOperationException { + return wrappedReporter.getInputSplit(); + } + + @Override + public void progress() { + wrappedReporter.progress(); + } + + // @Override + public float getProgress() { + throw new UnsupportedOperationException(); + } + + @Override + public void setStatus(String s) { + wrappedReporter.setStatus(s); + } +} \ No newline at end of file
