incubator-hama-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Edward J. Yoon" <edwardy...@apache.org>
Subject Re: Hama receive queue
Date Thu, 17 May 2012 00:34:29 GMT
Hi,

To send or receive multiple Message types, I think you can use
GenericWritable. You can also implement your own GenericMessage and
contribute it to our project!

Hope this helps you.

On Thu, May 17, 2012 at 7:48 AM, Aditya Sarawgi
<sarawgi.aditya@gmail.com> wrote:
> Hi Guys,
>
> I am wondering how do the receive queues in hama work. Consider this case
> that I want to sent a different type of BSPMessage in 2 consecutive
> superstep.
> In this first superstep I am sending IntMessage and in the next one I am
> sending a ArrayMessage ( custom message class).
>
> Now in the second super step when I do a
>  while ((arrayMessage = (ArrayMessage) peer.getCurrentMessage()) != null) {
>
> it is throwing a java.lang.ClassCastException, which is obvious since its
> trying to cast IntMessage to ArrayMessage.
> I thought the message is dropped from the queue after it is read, is this
> not the case ?
> And if it is not, how can this be handled elegantly ?
>
> --
> Cheers,
> Aditya Sarawgi



-- 
Best Regards, Edward J. Yoon
@eddieyoon

Mime
View raw message