incubator-streampark
incubator-streampark copied to clipboard
Added DataSource module
I am willing contribute this module.
I am willing contribute this module.
great !!! 👍👍👍
@wolfboys
I can finish kafka datasource which inlclude : json auto infer and so on.
- The feature may include:
- (promise) flink kafka catalog .
- (promise) json -> flink sql logicalType infer.
- (non promise) user privilege
User privilege depends on StreamGraph to analysis which need some trick which will change the sql commit way.(Difference with streamxpark done .)
- Detail
Catalog
- Meta center control physic column define.
- Create / hints to support : (Schema# All schema type) . Such as : primary key define, watermark ,timestamp define and logical column.
Json infer
- Auto infer json type to Flink sql logicalType.
Expired proposal