storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Junguk Cho <jman...@gmail.com>
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 (
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

Mime
View raw message