class diagram

类图设计：通过实现了Istream接口的DataStreamAdapter类来统一封装数据源，任何实现了Istream接口的类注册到DataStreamAdapter的streamMap即可，storm程序调用DataStreamAdapter的getMsg来poll数据。特别是如果直接集成DataStreamAdapter并调用super(this)将会自动注册，不需要额外手工注册。