public class HBaseBinaryInputFormat extends AbstractBinaryInputFormat
hadoopConf, janusgraphConf, mrConf| Constructor and Description |
|---|
HBaseBinaryInputFormat() |
| Modifier and Type | Method and Description |
|---|---|
org.apache.hadoop.mapreduce.RecordReader<StaticBuffer,Iterable<Entry>> |
createRecordReader(org.apache.hadoop.mapreduce.InputSplit inputSplit,
org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext) |
org.apache.hadoop.conf.Configuration |
getConf() |
List<org.apache.hadoop.mapreduce.InputSplit> |
getSplits(org.apache.hadoop.mapreduce.JobContext jobContext) |
void |
setConf(org.apache.hadoop.conf.Configuration config) |
public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext jobContext) throws IOException, InterruptedException
getSplits in class org.apache.hadoop.mapreduce.InputFormat<StaticBuffer,Iterable<Entry>>IOExceptionInterruptedExceptionpublic org.apache.hadoop.mapreduce.RecordReader<StaticBuffer,Iterable<Entry>> createRecordReader(org.apache.hadoop.mapreduce.InputSplit inputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext) throws IOException, InterruptedException
createRecordReader in class org.apache.hadoop.mapreduce.InputFormat<StaticBuffer,Iterable<Entry>>IOExceptionInterruptedExceptionpublic void setConf(org.apache.hadoop.conf.Configuration config)
setConf in interface org.apache.hadoop.conf.ConfigurablesetConf in interface org.apache.tinkerpop.gremlin.hadoop.structure.io.HadoopPoolsConfigurablesetConf in class AbstractBinaryInputFormatpublic org.apache.hadoop.conf.Configuration getConf()
getConf in interface org.apache.hadoop.conf.ConfigurablegetConf in interface org.apache.tinkerpop.gremlin.hadoop.structure.io.HadoopPoolsConfigurablegetConf in class AbstractBinaryInputFormatCopyright © 2012–2020. All rights reserved.