public class NoSQLInputFormat extends org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.Text,RecordInfo>
RecordInfo
respectivelyConstructor and Description |
---|
NoSQLInputFormat() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,RecordInfo> |
createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) |
protected NoSQLConfiguration |
getKVConfiguration(org.apache.hadoop.conf.Configuration conf) |
protected java.util.List<org.apache.hadoop.mapreduce.InputSplit> |
getSplits(org.apache.hadoop.conf.Configuration conf) |
java.util.List<org.apache.hadoop.mapreduce.InputSplit> |
getSplits(org.apache.hadoop.mapreduce.JobContext context) |
public org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,RecordInfo> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws java.io.IOException, java.lang.InterruptedException
createRecordReader
in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.Text,RecordInfo>
java.io.IOException
java.lang.InterruptedException
public java.util.List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context) throws java.io.IOException, java.lang.InterruptedException
getSplits
in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.Text,RecordInfo>
java.io.IOException
java.lang.InterruptedException
protected java.util.List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.conf.Configuration conf)
protected NoSQLConfiguration getKVConfiguration(org.apache.hadoop.conf.Configuration conf)
Copyright © 2016 Oracle and/or its affiliates. All Rights Reserved.