public class LongDoubleFloatTextInputFormat.LongDoubleFloatVertexReader extends TextVertexInputFormat.TextVertexReader
LongDoubleDoubleTextInputFormat
.Constructor and Description |
---|
LongDoubleFloatVertexReader() |
Modifier and Type | Method and Description |
---|---|
Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> |
getCurrentVertex()
Get the current vertex.
|
boolean |
nextVertex() |
close, createLineRecordReader, getContext, getProgress, getRecordReader, initialize
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage
getConf, setConf
public Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> getCurrentVertex() throws IOException, InterruptedException
VertexReader
getCurrentVertex
in class VertexReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>
IOException
InterruptedException
public boolean nextVertex() throws IOException, InterruptedException
nextVertex
in class VertexReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>
IOException
InterruptedException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.