Package org.apache.hadoop.hbase.snapshot
Class ExportSnapshot.ExportSnapshotInputFormat
java.lang.Object
org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.NullWritable>
org.apache.hadoop.hbase.snapshot.ExportSnapshot.ExportSnapshotInputFormat
- Enclosing class:
- ExportSnapshot
static class ExportSnapshot.ExportSnapshotInputFormat
extends org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.NullWritable>
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static class
private static class
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.BytesWritable,
org.apache.hadoop.io.NullWritable> createRecordReader
(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext tac) List<org.apache.hadoop.mapreduce.InputSplit>
getSplits
(org.apache.hadoop.mapreduce.JobContext context) (package private) Collection<List<Pair<org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotFileInfo,
Long>>> groupFilesForSplits
(org.apache.hadoop.conf.Configuration conf, List<Pair<org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotFileInfo, Long>> snapshotFiles)
-
Constructor Details
-
ExportSnapshotInputFormat
-
-
Method Details
-
createRecordReader
public org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.NullWritable> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext tac) throws IOException, InterruptedException - Specified by:
createRecordReader
in classorg.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.BytesWritable,
org.apache.hadoop.io.NullWritable> - Throws:
IOException
InterruptedException
-
getSplits
public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context) throws IOException, InterruptedException - Specified by:
getSplits
in classorg.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.BytesWritable,
org.apache.hadoop.io.NullWritable> - Throws:
IOException
InterruptedException
-
groupFilesForSplits
Collection<List<Pair<org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotFileInfo,Long>>> groupFilesForSplits(org.apache.hadoop.conf.Configuration conf, List<Pair<org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotFileInfo, Long>> snapshotFiles)
-