org.apache.giraph.utils

Class VerboseByteStructMessageWrite

java.lang.Object

org.apache.giraph.utils.VerboseByteStructMessageWrite

public class VerboseByteStructMessageWrite
extends Object

Verbose Error mesage for ByteArray based messages

Method Summary

Modifier and Type	Method and Description
static <I extends org.apache.hadoop.io.WritableComparable> void	handleNegativeArraySize(I vertexId) message to present on NegativeArraySizeException
static <I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> void	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> void	verboseWriteCurrentMessage(VertexIdMessageIterator<I,M> iterator, DataOutput out) verboseWriteCurrentMessage de-serialize, then write messages

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

verboseWriteCurrentMessage

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

verboseWriteCurrentMessage de-serialize, then write messages

Type Parameters:

I - vertexId

M - message

Parameters:

iterator - iterator

out - DataOutput

Throws:

IOException

RuntimeException

verboseWriteCurrentMessage

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

verboseWriteCurrentMessage de-serialize, then write messages

Type Parameters:

I - vertexId

M - message

Parameters:

vertexId - vertexId

message - message

out - DataOutput

Throws:

IOException

RuntimeException

handleNegativeArraySize

public static <I extends org.apache.hadoop.io.WritableComparable> void handleNegativeArraySize(I vertexId)

message to present on NegativeArraySizeException

Type Parameters:

I - vertexId type

Parameters:

vertexId - vertexId