240 发简信
IP属地:青海
  • Flink CDC实战之Oracle同步Mysql

    简介 最近有个项目要对接ZF的数据,数据库为Oracle,由于采用OGG的方式同步费用很高,于是想到采用FlinkCDC的方式进行同步。 Install Oracle 本例采...

  • 240
    PyFlink集群部署

    前言 前面讲到flink实时计算用户画像的功能,flink需要调用python写的算法库,之前的两种方案都存在各种各样的问题,最后决定采用pyflink来开发。 一门新技术的...

  • Cpython简单介绍

    前言 上一篇介绍了Java采用Jython调用python程序的方式,但是问题是目前只支持python2.x,如果需要调用python3.x目前是无法做到的,所以想到另外一种...

  • Jython简单介绍

    前言 Jython(原 JPython),是一个用 Java 语言写的 Python 解释器。由于python语法简洁,写起来快,而且目前有很多现成的算法库,所以别的语言也想...

  • 240
    Flink CDC实战之Mysql同步Hudi

    简介 在业务开发过程中,mysql应该是最常用的数据库了。不同业务部门会有自己的mysql集群,为了解决数据孤岛问题,我们必须对数据进行同步整合,为了提高数据同步的时效性,我...

  • 240
    基于混合云构建调度平台

    简介 很多业务场景对数据的安全性要求很高,所以会采用私有云部署应用,但是开发和运营需要在公有云操作,所以很多企业都采用公有云+私有云的架构模式,本例对这种混合云的调度问题进行...

  • 240
    DataX扩展hudiwriter组件

    前言 最近公司启动了一个规划2年的项目,是做一个数据平台。主要包括数据同步(实时/离线)、mapping(实时/离线)、数仓(实时/离线)、源数据管理、数据血缘、调度、BI等...