protected abstract class HCatalogVertexValueInputFormat.HCatalogVertexValueReader extends VertexValueReader<I,V>
Modifier | Constructor and Description |
---|---|
protected |
HCatalogVertexValueReader() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected org.apache.hadoop.mapreduce.TaskAttemptContext |
getContext()
Get the context.
|
float |
getProgress() |
protected org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.WritableComparable,org.apache.hcatalog.data.HCatRecord> |
getRecordReader()
Get the record reader.
|
void |
initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
boolean |
nextVertex() |
getCurrentVertex
getCurrentVertexId, getCurrentVertexValue
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage
getConf, setConf
public final void initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
initialize
in class VertexValueReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable>
IOException
InterruptedException
public boolean nextVertex() throws IOException, InterruptedException
nextVertex
in class VertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>
IOException
InterruptedException
public final void close() throws IOException
close
in class VertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>
IOException
public final float getProgress() throws IOException, InterruptedException
getProgress
in class VertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>
IOException
InterruptedException
protected final org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.WritableComparable,org.apache.hcatalog.data.HCatRecord> getRecordReader()
protected final org.apache.hadoop.mapreduce.TaskAttemptContext getContext()
Copyright © 2011-2019 The Apache Software Foundation. All Rights Reserved.