I
- vertexId type parameterM
- message type parameter@NotThreadSafe public abstract class ByteStructVertexIdMessageBytesIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> extends ByteStructVertexIdDataIterator<I,M> implements VertexIdMessageBytesIterator<I,M>
Modifier and Type | Field and Description |
---|---|
protected int |
messageBytes
Number of bytes in the last message
|
protected int |
messageOffset
Last message offset
|
dataSize, vertexIdData
extendedDataInput, vertexId
Constructor and Description |
---|
ByteStructVertexIdMessageBytesIterator(AbstractVertexIdData<I,M> vertexIdData)
Constructor with vertexIdData
|
Modifier and Type | Method and Description |
---|---|
void |
next()
Moves to the next element in the iteration.
|
getCurrentData, getCurrentDataSize, releaseCurrentData
getCurrentVertexId, hasNext, releaseCurrentVertexId
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
writeCurrentMessageBytes
getCurrentData, getCurrentDataSize, releaseCurrentData
getCurrentVertexId, hasNext, releaseCurrentVertexId
protected int messageOffset
protected int messageBytes
public ByteStructVertexIdMessageBytesIterator(AbstractVertexIdData<I,M> vertexIdData)
vertexIdData
- vertexIdDatapublic void next()
next
in interface VertexIdIterator<I extends org.apache.hadoop.io.WritableComparable>
next
in class ByteStructVertexIdDataIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.