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
IOException
InterruptedException
public boolean nextVertex() throws IOException, InterruptedException
IOException
InterruptedException
public Vertex getCurrentVertex() throws IOException, InterruptedException
IOException
InterruptedException
public void close() throws IOException
IOException
public float getProgress() throws IOException, InterruptedException
IOException
InterruptedException
Copyright © 2013–2020 Apache Software Foundation. All rights reserved.