public class VerboseByteStructMessageWrite extends Object
Modifier and Type | Method and Description |
---|---|
static <I extends org.apache.hadoop.io.WritableComparable> |
handleNegativeArraySize(I vertexId)
message to present on NegativeArraySizeException
|
static <I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> |
verboseWriteCurrentMessage(I vertexId,
M message,
DataOutput out)
verboseWriteCurrentMessage
de-serialize, then write messages
|
static <I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> |
verboseWriteCurrentMessage(VertexIdMessageIterator<I,M> iterator,
DataOutput out)
verboseWriteCurrentMessage
de-serialize, then write messages
|
public static <I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> void verboseWriteCurrentMessage(VertexIdMessageIterator<I,M> iterator, DataOutput out) throws IOException
I
- vertexIdM
- messageiterator
- iteratorout
- DataOutputIOException
RuntimeException
public static <I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> void verboseWriteCurrentMessage(I vertexId, M message, DataOutput out) throws IOException
I
- vertexIdM
- messagevertexId
- vertexIdmessage
- messageout
- DataOutputIOException
RuntimeException
public static <I extends org.apache.hadoop.io.WritableComparable> void handleNegativeArraySize(I vertexId)
I
- vertexId typevertexId
- vertexIdCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.