import backtype.storm.hooks.info.EmitInfo; //导入依赖的package包/类
@Override
public void emit(EmitInfo info) {
    super.emit(info);
    if (null != info && null != info.values && providers.size() > 0) {
        for (int v = 0; v < info.values.size(); v++) {
            aggregate(info.values.get(v));
        }
    }
}
 

import backtype.storm.hooks.info.EmitInfo; //导入依赖的package包/类
@Override
public void emit(EmitInfo info) {
    if (null != info && null != info.values && info.taskId == taskId) {
        String stream = info.stream;
        if (null != stream && !isInternalStream(stream)) { // ignore the internal streams
            itemsSend.addAndGet(info.values.size());
            if (null != memGatherer) {
                itemsVolume.addAndGet(memGatherer.getObjectSize(info.values));
            }
            MonitoringPluginRegistry.emitted(info);
        }
    }
}
 

import backtype.storm.hooks.info.EmitInfo; //导入依赖的package包/类
@Override
public void emit(EmitInfo info) {
  GlobalMetrics.incr("hook_emit");
  ++emitted;
  if (emitted % N == 0) {
    System.out.println("emit() is invoked in hook");
    System.out.println(info.values);
    System.out.println(info.taskId);
    System.out.println(info.stream);
    System.out.println(info.outTasks);
  }
}
 

import backtype.storm.hooks.info.EmitInfo; //导入依赖的package包/类
@Override
public void emit(EmitInfo info) {
}
 

import backtype.storm.hooks.info.EmitInfo; //导入依赖的package包/类
/**
 * Notifies about emitting tuples.
 * 
 * @param info information about the last emit
 */
public static void emitted(EmitInfo info) {
    for (int p = 0, n = PLUGINS.size(); p < n; p++) {
        PLUGINS.get(p).emitted(info);
    }
}
 

import backtype.storm.hooks.info.EmitInfo; //导入依赖的package包/类
@Override
public void emit(EmitInfo info) {
	send("EMIT", info.taskId, info.stream, info.outTasks.toString());
}
 

import backtype.storm.hooks.info.EmitInfo; //导入依赖的package包/类
/**
 * Notifies about emitting a tuples.
 * 
 * @param info information about the last emit
 */
public void emitted(EmitInfo info);
 

import backtype.storm.hooks.info.EmitInfo; //导入依赖的package包/类
void emit(EmitInfo info);