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 (
http://storm.apache.org/releases/1.0.1/Understanding-the-parallelism-of-a-Storm-topology.html
)
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?
Thanks,
Junguk