public final class GiraphVertexReader
extends VertexReader
| Constructor and Description |
|---|
GiraphVertexReader() |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
Vertex |
getCurrentVertex() |
float |
getProgress() |
void |
initialize(InputSplit inputSplit,
TaskAttemptContext context) |
boolean |
nextVertex() |
public void initialize(InputSplit inputSplit,
TaskAttemptContext context)
throws IOException,
InterruptedException
IOExceptionInterruptedExceptionpublic boolean nextVertex()
throws IOException,
InterruptedException
IOExceptionInterruptedExceptionpublic Vertex getCurrentVertex()
throws IOException,
InterruptedException
IOExceptionInterruptedExceptionpublic void close()
throws IOException
IOExceptionpublic float getProgress()
throws IOException,
InterruptedException
IOExceptionInterruptedExceptionCopyright © 2013–2016 Apache Software Foundation. All rights reserved.