CoolplaySpark
CoolplaySpark copied to clipboard
[SS]《2.1 Structured Streaming 之 Source 解析》讨论区
如需要贴代码,请复制以下内容并修改:
public static final thisIsJavaCode;
val thisIsScalaCode
谢谢!
KafkaSourceProvider extends DataSourceRegister with StreamSourceProvider with StreamSinkProvider with RelationProvider with CreatableRelationProvider with SimpleTableProvider 这其中的RelationProvider,CreatableRelationProvider,SimpleTableProvider几个接口的用处一直没搞懂。 大佬有没有写过这方面的源码解析呀?求学习