I
- vertexId typeM
- message typepublic class OneMessageToManyIdsIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> extends Object implements VertexIdMessageIterator<I,M>
ByteArrayOneMessageToManyIds
Constructor and Description |
---|
OneMessageToManyIdsIterator(ByteArrayOneMessageToManyIds<I,M> vertexIdMessages)
Constructor
|
Modifier and Type | Method and Description |
---|---|
M |
getCurrentData()
Get the current data.
|
int |
getCurrentDataSize()
Get serialized size of current data
|
M |
getCurrentMessage()
Get the current message.
|
int |
getCurrentMessageSize()
Get the serialized size of current message
|
I |
getCurrentVertexId()
Get the current vertex id.
|
boolean |
hasNext()
Returns true if the iteration has more elements.
|
boolean |
isNewMessage()
Return true of current message is new
|
void |
next()
Moves to the next element in the iteration.
|
M |
releaseCurrentData()
Release the current data object.
|
I |
releaseCurrentVertexId()
The backing store of the current vertex id is now released.
|
public OneMessageToManyIdsIterator(ByteArrayOneMessageToManyIds<I,M> vertexIdMessages)
vertexIdMessages
- vertexId messages object to iterate overpublic I getCurrentVertexId()
VertexIdIterator
getCurrentVertexId
in interface VertexIdIterator<I extends org.apache.hadoop.io.WritableComparable>
public M getCurrentMessage()
VertexIdMessageIterator
getCurrentMessage
in interface VertexIdMessageIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
public M getCurrentData()
VertexIdDataIterator
getCurrentData
in interface VertexIdDataIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
public M releaseCurrentData()
VertexIdDataIterator
releaseCurrentData
in interface VertexIdDataIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
public I releaseCurrentVertexId()
VertexIdIterator
releaseCurrentVertexId
in interface VertexIdIterator<I extends org.apache.hadoop.io.WritableComparable>
public boolean hasNext()
VertexIdIterator
hasNext
in interface VertexIdIterator<I extends org.apache.hadoop.io.WritableComparable>
public void next()
VertexIdIterator
next
in interface VertexIdIterator<I extends org.apache.hadoop.io.WritableComparable>
public int getCurrentMessageSize()
VertexIdMessageIterator
getCurrentMessageSize
in interface VertexIdMessageIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
public int getCurrentDataSize()
VertexIdDataIterator
getCurrentDataSize
in interface VertexIdDataIterator<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.