Migrating 0.9.2 → 1.0.0-beta-3 1.0.0-beta-3 How to try 1.0.0-beta-2 How to try DevelopmentEngine to EngineMain 1.0.0-beta-1 How to try 1.0.0-alpha-1 New coroutines 0.9.5 N...
DataStream Connectors Predefined Sources and Sinks Flink Project Connectors Connectors in Apache Bahir Other Ways to Connect to Flink Data Enrichment via Async I/O DataStre...
Transport API Transport API Transport API 的核心是 Channel 接口,用于所有的出站操作,见下图 如上图所示,每个 Channel 都会分配一个 ChannelPipeline 和ChannelConfig。ChannelConfig 负责设置并存储 Channel 的配置,并允许在运行期间更新它们...
Looking into the Received Data 查看收到的数据 Looking into the Received Data 查看收到的数据 现在我们已经编写出我们第一个服务端,我们需要测试一下他是否真的可以运行。最简单的测试方法是用 telnet 命令。例如,你可以在命令行上输入telnet localhost 8080 或者其他类型参...
How Ktor works note Entry points Start-up Common embeddedServer EngineMain TestApplicationEngine Monitor events Pipelines ApplicationCallPipeline Features Routing What...
Streaming Connectors Predefined Sources and Sinks Bundled Connectors Connectors in Apache Bahir Other Ways to Connect to Flink Data Enrichment via Async I/O Queryable State ...