import backtype.storm.topology.IComponent; //导入依赖的package包/类
static void addCreateTimestampAttributeToSchemas(IComponent spoutOrBolt, OutputFieldsDeclarer declarer) {
	TransparentFieldsDeclarer transparentDeclarer = new TransparentFieldsDeclarer();
	spoutOrBolt.declareOutputFields(transparentDeclarer);
	
	for(Entry<String, List<String>> declaredStream : transparentDeclarer.declaredStreams.entrySet()) {
		String streamId = declaredStream.getKey();
		boolean direct = transparentDeclarer.directStreams.contains(streamId);
		ArrayList<String> fieldsWithID = new ArrayList<String>(declaredStream.getValue());
		
		if(!streamId.startsWith("aeolus::")) {
			fieldsWithID.add(CREATE_TS_FIELD_NAME);
		}
		
		declarer.declareStream(streamId, direct, new Fields(fieldsWithID));
	}
}
 

import backtype.storm.topology.IComponent; //导入依赖的package包/类
public static Fields getSingleOutputStreamFields(IComponent component) {
    OutputFieldsGetter getter = new OutputFieldsGetter();
    component.declareOutputFields(getter);
    Map<String, StreamInfo> declaration = getter.getFieldsDeclaration();
    if(declaration.size()!=1) {
        throw new RuntimeException("Trident only supports components that emit a single stream");
    }
    StreamInfo si = declaration.values().iterator().next();
    if(si.is_direct()) {
        throw new RuntimeException("Trident does not support direct streams");
    }
    return new Fields(si.get_output_fields());        
}
 

import backtype.storm.topology.IComponent; //导入依赖的package包/类
public static Fields getSingleOutputStreamFields(IComponent component) {
    OutputFieldsGetter getter = new OutputFieldsGetter();
    component.declareOutputFields(getter);
    Map<String, StreamInfo> declaration = getter.getFieldsDeclaration();
    if(declaration.size()!=1) {
        throw new RuntimeException("Trident only supports components that emit a single stream");
    }
    StreamInfo si = declaration.values().iterator().next();
    if(si.is_direct()) {
        throw new RuntimeException("Trident does not support direct streams");
    }
    return new Fields(si.get_output_fields());
}
 

import backtype.storm.topology.IComponent; //导入依赖的package包/类
@Override
public IComponent getSpout() {
	return s;
}
 

import backtype.storm.topology.IComponent; //导入依赖的package包/类
IComponent getSpout(); 

import backtype.storm.topology.IComponent; //导入依赖的package包/类
protected abstract IComponent setBolt(TopologyBuilder builder, String upStreamId);