import storm.trident.planner.processor.TridentContext; //导入依赖的package包/类
@Override
public void prepare(Map conf, TopologyContext context, TridentContext tridentContext) {
    this.conf = conf;
    this.topologyContext = context;
    List<TridentTuple.Factory> parents = tridentContext.getParentTupleFactories();
    if (parents.size() != 1) {
        throw new RuntimeException("Aggregation related operation can only have one parent");
    }

    Long maxTuplesCacheSize = getWindowTuplesCacheSize(conf);

    this.tridentContext = tridentContext;
    collector = new FreshCollector(tridentContext);
    projection = new TridentTupleView.ProjectionFactory(parents.get(0), inputFields);

    windowStore = windowStoreFactory.create();
    windowTaskId = windowId + WindowsStore.KEY_SEPARATOR + topologyContext.getThisTaskId() + WindowsStore.KEY_SEPARATOR;
    windowTriggerInprocessId = getWindowTriggerInprocessIdPrefix(windowTaskId);

    tridentWindowManager = storeTuplesInStore ?
            new StoreBasedTridentWindowManager(windowConfig, windowTaskId, windowStore, aggregator, tridentContext.getDelegateCollector(), maxTuplesCacheSize, inputFields)
            : new InMemoryTridentWindowManager(windowConfig, windowTaskId, windowStore, aggregator, tridentContext.getDelegateCollector());

    tridentWindowManager.prepare();
}
 

import storm.trident.planner.processor.TridentContext; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
void prepare(Map conf, TopologyContext context, TridentContext tridentContext);
 

import storm.trident.planner.processor.TridentContext; //导入依赖的package包/类
void prepare(Map conf, TopologyContext context, TridentContext tridentContext);