I
- vertexId type parameterM
- message type parameterpublic class ByteStructVertexIdMessageIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> extends ByteStructVertexIdDataIterator<I,M> implements VertexIdMessageIterator<I,M>
dataSize, vertexIdData
extendedDataInput, vertexId
Constructor and Description |
---|
ByteStructVertexIdMessageIterator(AbstractVertexIdData<I,M> vertexIdData)
Constructor with vertexIdData
|
Modifier and Type | Method and Description |
---|---|
M |
getCurrentMessage()
Get the current message.
|
int |
getCurrentMessageSize()
Get the serialized size of current message
|
boolean |
isNewMessage()
Return true of current message is new
|
getCurrentData, getCurrentDataSize, next, releaseCurrentData
getCurrentVertexId, hasNext, releaseCurrentVertexId
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getCurrentData, getCurrentDataSize, releaseCurrentData
getCurrentVertexId, hasNext, next, releaseCurrentVertexId
public ByteStructVertexIdMessageIterator(AbstractVertexIdData<I,M> vertexIdData)
vertexIdData
- vertexIdDatapublic M getCurrentMessage()
VertexIdMessageIterator
getCurrentMessage
in interface VertexIdMessageIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
public int getCurrentMessageSize()
VertexIdMessageIterator
getCurrentMessageSize
in interface VertexIdMessageIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
public boolean isNewMessage()
VertexIdMessageIterator
isNewMessage
in interface VertexIdMessageIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.