iot works

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