Search code examples
javaapache-storm

Pass output fields through a bolt of Apache Storm


In the function declareOutputFields of my Bolt (which extends BaseBasicBolt), is there a simple way to declare the same fields that I received from the previous Bolt or Spout ?


Solution

  • No. This is not possible.

    Spouts and Bolt are basically completely decoupled and only connected when assembling a topology. Thus, each Spout/Bolt must independently from its input, define the output schema.