import storm.trident.planner.TupleReceiver; //导入依赖的package包/类
@Override
public void execute(ProcessorContext processorContext, String streamId, TridentTuple tuple) {
    TridentTuple toEmit = _factory.create(tuple);
    for(TupleReceiver r: _context.getReceivers()) {
        r.execute(processorContext, _context.getOutStreamId(), toEmit);
    }
}
 

import storm.trident.planner.TupleReceiver; //导入依赖的package包/类
@Override
public void emit(List<Object> values) {
    TridentTuple toEmit = _factory.create(values);
    for(TupleReceiver r: _triContext.getReceivers()) {
        r.execute(context, _triContext.getOutStreamId(), toEmit);
    }            
}
 

import storm.trident.planner.TupleReceiver; //导入依赖的package包/类
public TridentContext(Fields selfFields, List<Factory> parentFactories,
        List<String> parentStreams, List<TupleReceiver> receivers, 
        String outStreamId, int stateIndex, BatchOutputCollector collector) {
    this.selfFields = selfFields;
    this.parentFactories = parentFactories;
    this.parentStreams = parentStreams;
    this.receivers = receivers;
    this.outStreamId = outStreamId;
    this.stateIndex = stateIndex;
    this.collector = collector;        
}
 

import storm.trident.planner.TupleReceiver; //导入依赖的package包/类
@Override
public void emit(List<Object> values) {
    TridentTuple toEmit = _factory.create((TridentTupleView) tuple, values);
    for(TupleReceiver r: _triContext.getReceivers()) {
        r.execute(context, _triContext.getOutStreamId(), toEmit);
    }
}
 

import storm.trident.planner.TupleReceiver; //导入依赖的package包/类
@Override
public void execute(ProcessorContext processorContext, String streamId, TridentTuple tuple) {
    TridentTuple toEmit = _factory.create(tuple);
    for (TupleReceiver r : _context.getReceivers()) {
        r.execute(processorContext, _context.getOutStreamId(), toEmit);
    }
}
 

import storm.trident.planner.TupleReceiver; //导入依赖的package包/类
@Override
public void emit(List<Object> values) {
    TridentTuple toEmit = _factory.create(values);
    for (TupleReceiver r : _triContext.getReceivers()) {
        r.execute(context, _triContext.getOutStreamId(), toEmit);
    }
}
 

import storm.trident.planner.TupleReceiver; //导入依赖的package包/类
public TridentContext(Fields selfFields, List<Factory> parentFactories, List<String> parentStreams, List<TupleReceiver> receivers, String outStreamId,
        int stateIndex, BatchOutputCollector collector) {
    this.selfFields = selfFields;
    this.parentFactories = parentFactories;
    this.parentStreams = parentStreams;
    this.receivers = receivers;
    this.outStreamId = outStreamId;
    this.stateIndex = stateIndex;
    this.collector = collector;
}
 

import storm.trident.planner.TupleReceiver; //导入依赖的package包/类
@Override
public void emit(List<Object> values) {
    TridentTuple toEmit = _factory.create((TridentTupleView) tuple, values);
    for (TupleReceiver r : _triContext.getReceivers()) {
        r.execute(context, _triContext.getOutStreamId(), toEmit);
    }
}
 

import storm.trident.planner.TupleReceiver; //导入依赖的package包/类
public TridentContext(Fields selfFields, List<Factory> parentFactories,
        List<String> parentStreams, List<TupleReceiver> receivers, 
        String outStreamId, int stateIndex, BatchOutputCollector collector) {
    this.selfFields = selfFields;
    this.parentFactories = parentFactories;
    this.parentStreams = parentStreams;
    this.receivers = receivers;
    this.outStreamId = outStreamId;
    this.stateIndex = stateIndex;
    this.collector = collector;
}
 

import storm.trident.planner.TupleReceiver; //导入依赖的package包/类
public List<TupleReceiver> getReceivers() {
    return receivers;
}