class diagram

2014-10-14 11:42:42   14  举报





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

storm

ProcessOn

作者其他创作

大纲/内容

implements

DBStream

KafkaStream

DataStreamAdapter

+ DataStreamAdapter():+ DataStreamAdapter(IStream):+ setStreamType(StreamType):void+ getMsg():String+ getStreamType():StreamType+ regist(IStream):void- autoRegist():void- getStream():IStream

SocketStream

or extends

IStream

+ setStreamType(StreamType):void+ getMsg():String+ getStreamType():StreamType

StreamType:Enum

FileStream

OtherStream