iot works
2017-05-13 10:09:21 0 举报
a
作者其他创作
大纲/内容
RcWrapper extends Seriazable
extends
AbstractSourceWrapper
String sourceTypeJSONArray schema
constructorregisterInput(RcContext)
StreamActuatorBuilder
Actuator build(...SteamExecutionEnvironment)
AbstractProcessorWrapper
KafkaSourceWrapper
Logger loggerRcTimeAttr timeAttrString brokersList<String> topicsString groupId
KafkaSourceWrapper(Builder)registerInput(RcContext) StreamExecutionEnvironment.addSource()
SqlprocessorWrapper
implements
AbstractWrapper
jobIdtenantIdnodeIdnideNameparallelism
constructor
0 条评论
回复 删除
下一页
