是怎么解析JSON后提交任务到flink的？说下大致逻辑 #1162
Unanswered
wangzhen-wudangshan
asked this question in
Q&A
Replies: 1 comment
-
|
ChunJun是通过工具类，将json中的参数配置转换成内部的配置类，然后解析，通过SourceFactory、SinkFactory 构建flink 对应的PackagedProgram。 |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
是怎么解析JSON后提交任务到flink的？说下大致逻辑
Beta Was this translation helpful? Give feedback.
All reactions