8000 GitHub - virtualsafety/flinkdemo
[go: up one dir, main page]
More Web Proxy on the site http://driver.im/
Skip to content

virtualsafety/flinkdemo

Repository files navigation

resultFuture.complete 
resultFuture.completeExceptionally
 
 https://www.jianshu.com/p/f1521cb56ac2
 https://blog.csdn.net/cwg_1992/article/details/116615712
 
 
 
import org.apache.flink.streaming.api.functions.async.{AsyncFunction, ResultFuture}
import scala.concurrent.{ExecutionContext, Future}
import scala.util.{Failure, Success}


ExecutionContext



https://www.cnblogs.com/Springmoon-venn/p/11604786.html
https://zhuanlan.zhihu.com/p/93820061
https://codeleading.com/article/18304988227/
https://blog.csdn.net/zuochang_liu/article/details/106462093


https://www.cnblogs.com/Springmoon-venn/p/11103558.html
https://github.com/perkinls/flink-local-train/blob/c8b4efe33620352aea0100adef4fae2a068a3b65/src/main/scala/com/lp/test/asyncio/AsyncIOSideTableJoinMysql.scala


https://hackernoon.com/how-i-ported-10k-lines-of-scala-to-kotlin-in-one-week-c645732d3c1

https://alvinalexander.com/scala/scala-jdbc-connection-mysql-sql-select-example/
https://alvinalexander.com/source-code/scala-jdbc-sql-select-insert-statement-resultset-preparedstatement-example/


https://liurio.github.io/2020/03/28/Flink%E6%B5%81%E4%B8%8E%E7%BB%B4%E8%A1%A8%E7%9A%84%E5%85%B3%E8%81%94/


https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/serialization/types_serialization/

TypeInformation.of(new TypeHint[JSONObject]{})
https://alxe1.github.io/chapters/chapter2_5_1.html

https://tracholar.github.io/wiki/tools/flink.html


add field to json
https://nosqlnocry.wordpress.com/2015/04/16/working-with-json-in-scala-using-the-json4s-library-part-one/

About

No description, website, or topics provided.

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published
0