Apache Flink 提供了 DataStream API 来实现稳定可靠的、有状态的流处理应用程序。 Flink 支持对状态和时间的细粒度控制，以此来实现复杂的事件驱动数据处理系统。 这个入门指导手册讲述了如何通过 Flink DataStream API 来实现一个有状态流处理程序。 你要搭建一个什么系统 在当今数字时代，信用卡欺诈行为越来越被重视。 罪犯可以通过诈骗或者入侵安全...

Apache Flink offers a Table API as a unified, relational API for batch and stream processing, i.e., queries are executed with the same semantics on unbounded, real-time streams or bounded, batch da...

Apache Flink 可以以多种方式在不同的环境中部署，抛开这种多样性而言，Flink 集群的基本构建方式和操作原则仍然是相同的。 在这篇文章里，你将会学习如何管理和运行 Flink 任务，了解如何部署和监控应用程序、Flink 如何从失败作业中进行恢复，同时你还会学习如何执行一些日常操作任务，如升级和扩容。 场景说明 这篇文章中的所有操作都是基于如下两个集群进行的： Flink ...

该练习的重点是充分全面地了解 DataStream API，以便于编写流式应用入门。 什么能被转化成流？ Flink 的 Java 和 Scala DataStream API 可以将任何可序列化的对象转化为流。Flink 自带的序列化器有 基本类型，即 String、Long、Integer、Boolean、Array 复合类型：Tuples、POJOs 和 Scala c...

金融股票 https://github.com/microsoft/qlib Qlib是一个面向AI的量化投资平台，旨在实现潜力，增强研究能力并创造AI技术在量化投资中的价值。包括多个模型。 https://github.com/QUANTAXIS/QUANTAXIS 量化金融策略框架 https://github.com/ricequant/rqalpha 从数据获取、算法交易、回测...

安装Connector 下载链接 ```plain text http://client.hub.confluent.io/confluent-hub-client-latest.tar.gz?_ga=2.215682399.93673590.1629776859-1065619546.1629776859 1 解压 ```plain text tar confluent-hub-...

Flink MySQL 大数据 流式计算 前言 之前其实在 《从0到1学习Flink》—— 如何自定义 Data Sink ？ 文章中其实已经写了点将数据写入到 MySQL，但是一些配置化的东西当时是写死的，不能够通用，最近知识星球里有朋友叫我: 写个从 kafka 中读取数据，经过 Flink 做个预聚合，然后创建数据库连接池将数据批量写入到 mysql 的例子。 ...

Rust 程序设计 rust-lang/rust rust使每个人都能构建可靠、高效的软件。Rust 的主要源代码存储库。它包含编译器、标准库和文档。 servo/servo 用 Rust 语言编写的原型 Web 浏览器引擎。 rust-unofficial/awesome-rust Rust 代码和资源的精选列表。 ...

蛋白质结构 deepmind/alphafold 此包提供了 AlphaFold v2.0 的推理流线的实现。AlphaFold是Google旗下DeepMind开发的一款人工智能程序，它使用深度学习算法通过蛋白质序列来预测蛋白质结构。蛋白质通过卷曲折叠会构成三维结构，蛋白质的功能正由其结构决定。了解蛋白质结构有助于开发治疗疾病的药物。 RosettaC...

我打小是一个不善言辞的人，喜欢使用文字表达，到如今也是如此，但凡能用写，我基本很少会通过说，这也导致了我在口语表达上缺乏练习，所以到了关键时刻，必须要用口语表达时候，如果没有提前做好充分的准备，我经常会掉链子——不能清晰完整地将我脑子里的想法传达给听者。 在需要进行工作汇报或是商务洽谈的时候，就非要要命。深刻记得前一任Boss用了一个比喻形容我：“你脑子里装有东西，但你仿佛有四张嘴，每一张...