code: void prepare(Map stormConf, TopologyContext context, OutputCollector collector,
                   KeyValueState<TaskStream, WindowState> windowState) {
          init(stormConf, context, collector, windowState);
          super.prepare(stormConf, context, collector);
      }
docs: package access for unit tests