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>>
IOException
InterruptedException
public 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>>
IOException
InterruptedException
public void setConf(org.apache.hadoop.conf.Configuration config)
setConf
in interface org.apache.hadoop.conf.Configurable
setConf
in interface org.apache.tinkerpop.gremlin.hadoop.structure.io.HadoopPoolsConfigurable
setConf
in class AbstractBinaryInputFormat
public org.apache.hadoop.conf.Configuration getConf()
getConf
in interface org.apache.hadoop.conf.Configurable
getConf
in interface org.apache.tinkerpop.gremlin.hadoop.structure.io.HadoopPoolsConfigurable
getConf
in class AbstractBinaryInputFormat
Copyright © 2012–2020. All rights reserved.