import backtype.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout; //导入依赖的package包/类
public TransactionalTopologyBuilder(String id, String spoutId,
		IOpaquePartitionedTransactionalSpout spout, Number spoutParallelism) {
	this(id, spoutId,
			new OpaquePartitionedTransactionalSpoutExecutor(spout),
			spoutParallelism);
}
 

import backtype.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout; //导入依赖的package包/类
@Override
public IOpaquePartitionedTransactionalSpout.Emitter<MemoryTransactionalSpoutMeta> getEmitter(
		Map conf, TopologyContext context) {
	return new Emitter(conf);
}
 

import backtype.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout; //导入依赖的package包/类
@Override
public IOpaquePartitionedTransactionalSpout.Coordinator getCoordinator(
		Map conf, TopologyContext context) {
	return new Coordinator();
}
 

import backtype.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout; //导入依赖的package包/类
public TransactionalTopologyBuilder(String id, String spoutId, IOpaquePartitionedTransactionalSpout spout, Number spoutParallelism) {
    this(id, spoutId, new OpaquePartitionedTransactionalSpoutExecutor(spout), spoutParallelism);
}
 

import backtype.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout; //导入依赖的package包/类
@Override
public IOpaquePartitionedTransactionalSpout.Emitter<MemoryTransactionalSpoutMeta> getEmitter(Map conf, TopologyContext context) {
    return new Emitter(conf);
}
 

import backtype.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout; //导入依赖的package包/类
@Override
public IOpaquePartitionedTransactionalSpout.Coordinator getCoordinator(Map conf, TopologyContext context) {
    return new Coordinator();
}
 

import backtype.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout; //导入依赖的package包/类
public IOpaquePartitionedTransactionalSpout.Emitter<BatchMeta> getEmitter(Map conf, TopologyContext context) {
    return new Emitter();
}