storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Junguk Cho <>
Subject Basic questions about Strom
Date Fri, 10 Jun 2016 18:27:49 GMT
Hi, I have some basic questions.

1. About Tuple.
We declare tuple in declareOutputFields.
For example, declarer.declare(new Fields("word", "count"));

Are "word" and "count" forwarded to next node with actual data?
What are the roles of "word" and "count" here internally?

2. About rebalancing (

In storm, there is rebalancing capability.
What happened on-going tuples while storm rebalances topology?
Does it drop and replay?

3. Serialization.
In storm, as far as I know for inter-thread communication, serialization
does not happen. For inter-process and inter-node communication,
serialization is required.
Is it right?


View raw message